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.