Struct PubSubInputConfig 

pub struct PubSubInputConfig {
    pub emulator: Option<String>,
    pub credentials: Option<String>,
    pub endpoint: Option<String>,
    pub pool_size: Option<u32>,
    pub timeout_seconds: Option<u32>,
    pub connect_timeout_seconds: Option<u32>,
    pub project_id: Option<String>,
    pub subscription: String,
    pub snapshot: Option<String>,
    pub timestamp: Option<String>,
}

Google Pub/Sub input connector configuration.

Fields

emulator: Option<String>

Set in order to use a Pub/Sub emulator instead of the production service, e.g., ‘localhost:8681’.

credentials: Option<String>

The content of a Google Cloud credentials JSON file.

When this option is specified, the connector will use the provided credentials for authentication. Otherwise, it will use Application Default Credentials (ADC) configured in the environment where the Feldera service is running. See Google Cloud documentation for information on configuring application default credentials.

When running Feldera in an environment where ADC are not configured, e.g., a Docker container, use this option to ship Google Cloud credentials from another environment. For example, if you use the gcloud auth application-default login command for authentication in your local development environment, ADC are stored in the .config/gcloud/application_default_credentials.json file in your home directory.

endpoint: Option<String>

Override the default service endpoint ‘pubsub.googleapis.com’

pool_size: Option<u32>

gRPC channel pool size.

timeout_seconds: Option<u32>

gRPC request timeout.

connect_timeout_seconds: Option<u32>

gRPC connection timeout.

project_id: Option<String>

Google Cloud project_id.

When not specified, the connector will use the project id associated with the authenticated account.

subscription: String

Subscription name.

snapshot: Option<String>

Reset subscription’s backlog to a given snapshot on startup, using the Pub/Sub Seek API.

This option is mutually exclusive with the timestamp option.

timestamp: Option<String>

Reset subscription’s backlog to a given timestamp on startup, using the Pub/Sub Seek API.

The value of this option is an ISO 8601-encoded UTC time, e.g., “2024-08-17T16:39:57-08:00”.

This option is mutually exclusive with the snapshot option.

Trait Implementations

impl Clone for PubSubInputConfig

fn clone(&self) -> PubSubInputConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PubSubInputConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PubSubInputConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for PubSubInputConfig

impl PartialEq for PubSubInputConfig

fn eq(&self, other: &PubSubInputConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for PubSubInputConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for PubSubInputConfig

impl<'__s> ToSchema<'__s> for PubSubInputConfig

fn schema() -> (&'__s str, RefOr<Schema>)

Return a tuple of name and schema or reference to a schema that can be referenced by the name or inlined directly to responses, request bodies or parameters.

fn aliases() -> Vec<(&'__s str, Schema)>

Optional set of alias schemas for the ToSchema::schema.