Struct PostgresIngress 

pub struct PostgresIngress { /* private fields */ }

Minimal blocking PostgreSQL ingress adapter.

The adapter executes the configured query whenever its internal queue is empty. Query authors should provide incremental or tailing SQL if they want exactly-once style progression.

Implementations

impl PostgresIngress

pub fn new( name: impl Into<String>, dsn: &str, query: &str, poll_interval: Duration, max_row_bytes: usize, row_format: Option<&str>, ) -> Result<Self, AdapterError>

Create a blocking PostgreSQL ingress adapter.

Trait Implementations

impl Adapter for PostgresIngress

fn name(&self) -> &str

Stable adapter name for logs/obs.

fn transport_kind(&self) -> &str

Adapter transport family label.

fn status_fields(&self) -> Map<String, Value>

Transport-specific runtime fields that can be attached to operator snapshots.

fn connection_state(&self) -> &str

Best-effort connection/runtime state for operator visibility.

fn lag(&self) -> Option<u64>

Best-effort queue/stream lag, when the adapter can observe it.

impl IngressAdapter for PostgresIngress

fn read_next(&mut self, out: &mut [u8]) -> Result<Option<usize>, AdapterError>

Read the next message.