Struct PulsarSubscription 

pub struct PulsarSubscription { /* private fields */ }

A subscription descriptor for one Pulsar subscription over one or more topics.

Where the subscription starts reading is not a descriptor option: it is the framework’s start_at(..) clause over PulsarPosition, which the Seekable capability backs.

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

use std::time::Duration;
use ruststream_pulsar::{DeadLetter, PulsarSubscription, SubscriptionType};

let source = PulsarSubscription::new("orders", "workers")
    .subscription_type(SubscriptionType::Shared)
    .dead_letter(DeadLetter::new("orders-dlq").max_deliveries(5))
    .ack_timeout(Duration::from_secs(30));

Implementations

impl PulsarSubscription

pub fn new(topic: impl Into<String>, subscription: impl Into<String>) -> Self

Subscribes subscription to topic (a bare name, a tenant/namespace/topic triple, or a fully qualified name).

pub fn topics<I, S>(topics: I, subscription: impl Into<String>) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Subscribes to every topic in the list.

pub fn pattern( pattern: impl Into<String>, subscription: impl Into<String>, ) -> Self

Subscribes to every topic in the lookup namespace whose name matches pattern (a regular expression, validated on subscribe).

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

Sets the subscription type. Defaults to SubscriptionType::Shared.

pub fn dead_letter(self, dead_letter: DeadLetter) -> Self

Sets the consumer-side dead-letter policy.

pub fn ack_timeout(self, timeout: Duration) -> Self

Redelivers messages that stay unacknowledged longer than timeout.

pub fn subscription(&self) -> &str

The subscription name.

Trait Implementations

impl Clone for PulsarSubscription

fn clone(&self) -> PulsarSubscription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PulsarSubscription

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

Formats the value using the given formatter.

impl Eq for PulsarSubscription

impl PartialEq for PulsarSubscription

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for PulsarSubscription

impl SubscriptionSource<ConnectedPulsarBroker> for PulsarSubscription

type Subscriber = PulsarSubscriber

The subscriber type this source opens.

fn name(&self) -> &str

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

async fn subscribe( self, connected: &ConnectedPulsarBroker, ) -> Result<PulsarSubscriber, PulsarError>

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