Struct PubSubSubscription 

pub struct PubSubSubscription { /* private fields */ }

A subscription descriptor for one Pub/Sub subscription.

Implements SubscriptionSource, so it can sit inline in the #[subscriber(..)] decorator:

use std::time::Duration;
use ruststream_gcp_pubsub::PubSubSubscription;

let source = PubSubSubscription::new("orders-workers")
    .max_outstanding(1_000)
    .ack_extension(Duration::from_secs(60));

Implementations

impl PubSubSubscription

pub fn new(name: impl Into<String>) -> Self

Names an existing subscription (short name or full projects/{p}/subscriptions/{s} resource name).

pub fn create_with_topic(self, topic: impl Into<String>) -> Self

Creates the subscription bound to topic on subscribe when it does not exist yet (the topic is created too). Meant for local development and tests against the emulator; production subscriptions are usually managed as infrastructure.

pub fn max_outstanding(self, messages: i64) -> Self

Flow control: how many received messages may be outstanding (unacked) at once. Defaults to the client’s 1000.

pub fn ack_extension(self, extension: Duration) -> Self

How far each background ack-deadline extension reaches while a handler runs. The client clamps it to the protocol’s 10s..=600s range; defaults to 60s.

pub fn subscription(&self) -> &str

The subscription name this descriptor resolves.

Trait Implementations

impl Clone for PubSubSubscription

fn clone(&self) -> PubSubSubscription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PubSubSubscription

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

Formats the value using the given formatter.

impl Eq for PubSubSubscription

impl PartialEq for PubSubSubscription

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for PubSubSubscription

impl SubscriptionSource<ConnectedPubSubBroker> for PubSubSubscription

type Subscriber = PubSubSubscriber

The subscriber type this source opens.

fn name(&self) -> &str

The name (subject / channel) this subscription binds to.

async fn subscribe( self, connected: &ConnectedPubSubBroker, ) -> Result<PubSubSubscriber, PubSubError>

Opens the subscription against the connected broker. Called once at startup.