Skip to main content

feldera_adapterlib/
lib.rs

1use bytemuck::NoUninit;
2pub use dbsp::DetailedError as DbspDetailedError;
3use num_derive::FromPrimitive;
4use serde::Serialize;
5
6pub mod catalog;
7mod connector_metadata;
8pub mod errors;
9pub mod format;
10pub mod metrics;
11pub mod preprocess;
12pub mod transport;
13pub mod utils;
14
15pub use connector_metadata::ConnectorMetadata;
16
17#[doc(hidden)]
18#[derive(Copy, Clone, Debug, Default, PartialEq, Eq, FromPrimitive, Serialize, NoUninit)]
19#[repr(u8)]
20pub enum PipelineState {
21    /// All input endpoints are paused (or are in the process of being paused).
22    #[default]
23    Paused,
24
25    /// Controller is running.
26    Running,
27
28    /// Controller is being terminated.
29    Terminated,
30}