Struct SubscriberConfig 

pub struct SubscriberConfig {
    pub project_id: String,
    pub subscription_name: String,
    pub subscription_type: SubscriptionType,
    pub ack_deadline_seconds: i64,
    pub flow_control: FlowControlSettings,
    pub handler_concurrency: usize,
    pub enable_ordering: bool,
    pub dead_letter_config: Option<DeadLetterConfig>,
    pub endpoint: Option<String>,
    pub auto_extend_deadline: bool,
}

Configuration for the subscriber.

Fields

project_id: String

Project ID.

subscription_name: String

Subscription name.

subscription_type: SubscriptionType

Subscription type.

ack_deadline_seconds: i64

Acknowledgment deadline in seconds.

flow_control: FlowControlSettings

Flow control settings.

handler_concurrency: usize

Message handler concurrency.

enable_ordering: bool

Enable message ordering.

dead_letter_config: Option<DeadLetterConfig>

Dead letter queue configuration.

endpoint: Option<String>

Custom endpoint (for testing).

auto_extend_deadline: bool

Automatically extend acknowledgment deadlines.

Implementations

impl SubscriberConfig

pub fn new( project_id: impl Into<String>, subscription_name: impl Into<String>, ) -> Self

Creates a new subscriber configuration.

pub fn with_type(self, subscription_type: SubscriptionType) -> Self

Sets the subscription type.

pub fn with_ack_deadline(self, seconds: i64) -> Self

Sets the acknowledgment deadline.

pub fn with_flow_control(self, settings: FlowControlSettings) -> Self

Sets the flow control settings.

pub fn with_handler_concurrency(self, concurrency: usize) -> Self

Sets the handler concurrency.

pub fn with_ordering(self, enable: bool) -> Self

Enables message ordering.

pub fn with_dead_letter(self, config: DeadLetterConfig) -> Self

Sets the dead letter queue configuration.

pub fn with_endpoint(self, endpoint: impl Into<String>) -> Self

Sets a custom endpoint.

Trait Implementations

impl Clone for SubscriberConfig

fn clone(&self) -> SubscriberConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriberConfig

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

Formats the value using the given formatter.

impl Default for SubscriberConfig

fn default() -> Self

Returns the “default value” for a type.