morpheus.messages.message_meta#

Classes

AppShieldMessageMeta(**kwargs)

This class extends MessageMeta to also hold source corresponding to batched metadata.

MessageMeta(**kwargs)

This is a container class to hold batch deserialized messages metadata.

MutableTableCtxMgr(meta)

Context manager for editing the DataFrame held by a MessageMeta, ensures an editing lock aqcuired and released.

UserMessageMeta(**kwargs)

This class extends MessageMeta to also hold userid corresponding to batched metadata.