feldera-adapterlib 0.291.0

Connector support for the Feldera streaming engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

use bytemuck::NoUninit;
pub use dbsp::DetailedError as DbspDetailedError;
use num_derive::FromPrimitive;
use serde::Serialize;

pub mod catalog;
mod connector_metadata;
pub mod errors;
pub mod format;
pub mod metrics;
pub mod preprocess;
pub mod transport;
pub mod utils;

pub use connector_metadata::ConnectorMetadata;

#[doc(hidden)]
#[derive(Copy, Clone, Debug, Default, PartialEq, Eq, FromPrimitive, Serialize, NoUninit)]
#[repr(u8)]
pub enum PipelineState {
    /// All input endpoints are paused (or are in the process of being paused).
    #[default]
    Paused,

    /// Controller is running.
    Running,

    /// Controller is being terminated.
    Terminated,
}