Struct StreamSubscription 

pub struct StreamSubscription {
    pub id: String,
    pub source: String,
    pub transform: Option<String>,
    pub interval: Option<Duration>,
    pub active: bool,
    pub last_seq: u64,
    pub error_count: u32,
}

Subscription to a data source.

Fields

id: String

Unique subscription ID

source: String

Data source path

transform: Option<String>

Transform expression to apply

interval: Option<Duration>

Refresh interval

active: bool

Whether this subscription is active

last_seq: u64

Last received sequence number

error_count: u32

Error count for backoff

Implementations

impl StreamSubscription

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

Create a new subscription.

pub fn with_id(id: impl Into<String>, source: impl Into<String>) -> Self

Create with explicit ID.

pub fn with_interval(self, ms: u64) -> Self

Set refresh interval in milliseconds.

pub fn with_transform(self, transform: impl Into<String>) -> Self

Set transform expression.

pub fn to_message(&self) -> StreamMessage

Convert to subscribe message.

Trait Implementations

impl Clone for StreamSubscription

fn clone(&self) -> StreamSubscription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamSubscription

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

Formats the value using the given formatter.