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 postprocess;
12pub mod preprocess;
13pub mod transport;
14pub mod utils;
15
16pub use connector_metadata::ConnectorMetadata;
17
18#[doc(hidden)]
19#[derive(Copy, Clone, Debug, Default, PartialEq, Eq, FromPrimitive, Serialize, NoUninit)]
20#[repr(u8)]
21pub enum PipelineState {
22    /// All input endpoints are paused (or are in the process of being paused).
23    #[default]
24    Paused,
25
26    /// Controller is running.
27    Running,
28
29    /// Controller is being terminated.
30    Terminated,
31}