Struct SubscribeOptions 

pub struct SubscribeOptions {
    pub priority: Priority,
    pub admission_class: AdmissionClass,
    pub event_buffer: usize,
    pub route_retry: RetryBackoff,
    pub route_retry_deadline: Duration,
    pub route_open_timeout: Duration,
    pub consumer_identity: Option<ConsumerIdentity>,
    pub consumer_capabilities: Option<Vec<String>>,
}

Options for SubcConsumer::subscribe.

Fields

priority: Priority

admission_class: AdmissionClass

Admission behavior stamped into the subscription request. Defaults to NORMAL.

event_buffer: usize

Maximum number of events buffered for the caller before the subscription is dropped. The reader task never awaits a slow event consumer; if this bounded channel fills, closed() resolves with CallError::SubscriptionBackpressure.

route_retry: RetryBackoff

route_retry_deadline: Duration

Maximum real-time limit for retrying route.open attempts when the target is temporarily absent.

route_open_timeout: Duration

Deadline for opening the managed route and queuing the held-open request. The subscription itself has no response timeout once the request is sent.

consumer_identity: Option<ConsumerIdentity>

Explicit consumer identity for route.open; when absent, non-empty SUBC_MODULE_ID and SUBC_LAUNCH_NONCE environment variables are used.

consumer_capabilities: Option<Vec<String>>

Consumer-declared reverse-request capabilities for route.open. This is a declaration, not a verified privilege; providers treat an absent field as no reverse-request capability. Known MCP method-family values today are “elicitation”, “sampling”, and “roots”.

Trait Implementations

impl Clone for SubscribeOptions

fn clone(&self) -> SubscribeOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscribeOptions

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

Formats the value using the given formatter.

impl Default for SubscribeOptions

fn default() -> Self

Returns the “default value” for a type.

impl Eq for SubscribeOptions

impl PartialEq for SubscribeOptions

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SubscribeOptions