Module extractor

Structs

• Component
• Config
• MessageHeader
  Metadata associated with a message.
• ShardId
  Identifies a shard. Aka. partition.
• SharedMessage
  It uses an Arc to hold the bytes, so is cheap to clone.
• StreamKey
  Identifies a stream. Aka. topic.
• Timestamp
  A PrimitiveDateTime with a UtcOffset.

Enums

• SeaMessage
  sea-streamer-socket concrete type of Message.

Traits

• FromMsg
• Message
  Common interface of messages, to be implemented by all backends.

Type Aliases

• SeqNo
  The tuple (StreamKey, ShardId, SeqNo) uniquely identifies a message. Aka. offset.