Skip to main content

kinetic_core/
lib.rs

1//! Core abstractions and structures for the Kinetic analytics pipeline.
2
3pub mod ack;
4pub mod encode;
5pub mod error;
6pub mod error_payload;
7pub mod event;
8pub mod healthcheck;
9pub mod metadata;
10pub mod serverless;
11pub mod shutdown;
12pub mod state;
13pub mod xid_util;
14
15// Re-export core types for convenience
16pub use ack::{AckToken, BatchNotifier};
17pub use error::{Error, Result};
18pub use error_payload::create_error_batch;
19pub use event::EventBatch;
20pub use healthcheck::Healthcheck;
21pub use metadata::{ArcEventMetadata, ComponentId, EventMetadata, OutputId};
22pub use serverless::{BatchWriterConfig, EmitterConfig, ReceiverConfig};
23pub use shutdown::{ShutdownCoordinator, ShutdownReason, ShutdownSignal};
24pub use xid_util::ensure_xid_column;