List of all items

Structs

• ack::AckToken
• error::ArrowSnafu
• error::LengthMismatchSnafu
• error::XidAppendSnafu
• event::EventBatch
• metadata::ComponentId
• metadata::EventMetadata
• metadata::OutputId
• shutdown::ShutdownCoordinator
• shutdown::ShutdownSignal
• state::StateStore

Enums

• encode::Error
• error::Error
• shutdown::ShutdownReason

Traits

• ack::BatchNotifier
• encode::Decoder
• encode::DecoderConfig
• encode::Encoder
• encode::EncoderConfig
• healthcheck::Healthcheck
• serverless::BatchWriterConfig
• serverless::EmitterConfig
• serverless::ProcessorConfig
• serverless::ReceiverConfig

Functions

• error_payload::create_error_batch
• xid_util::batch_xids
• xid_util::ensure_xid_column

Type Aliases

• encode::Result
• error::Result
• metadata::ArcEventMetadata