feldera_types/transport/
postgres.rs

1use serde::{Deserialize, Serialize};
2use utoipa::ToSchema;
3
4/// Postgres input connector configuration.
5#[derive(Debug, Clone, Eq, PartialEq, Deserialize, Serialize, ToSchema)]
6pub struct PostgresReaderConfig {
7    /// Postgres URI.
8    pub uri: String,
9
10    /// Query that specifies what data to fetch from postgres.
11    pub query: String,
12}