Crate kinetic_core 

Core abstractions and structures for the Kinetic analytics pipeline.

Re-exports

pub use ack::AckToken;

pub use ack::BatchNotifier;

pub use error::Error;

pub use error::Result;

pub use error_payload::create_error_batch;

pub use event::EventBatch;

pub use healthcheck::Healthcheck;

pub use metadata::ArcEventMetadata;

pub use metadata::ComponentId;

pub use metadata::EventMetadata;

pub use metadata::OutputId;

pub use serverless::BatchWriterConfig;

pub use serverless::EmitterConfig;

pub use serverless::ReceiverConfig;

pub use shutdown::ShutdownCoordinator;

pub use shutdown::ShutdownReason;

pub use shutdown::ShutdownSignal;

pub use xid_util::ensure_xid_column;

Modules

ack

End-to-end acknowledgement tracking for pipeline events.

encode

Encoder and Decoder traits for serializing and deserializing EventBatch.

error

error_payload

event

Core event definitions wrapping Apache Arrow structures.

healthcheck

Healthcheck trait for components.

metadata

Event metadata structures for Kinetic pipelines.

serverless

Traits for Kinetic Serverless components.

shutdown

Graceful shutdown coordination for Kinetic components.

state

Persistent state storage for components.

xid_util