Struct LocalPublisher 

pub struct LocalPublisher { /* private fields */ }

In-memory publisher backed by a ManifestRegistry.

Implementations

impl LocalPublisher

pub fn new( server_version: impl Into<String>, default_endpoint: Endpoint, ) -> Self

pub fn registry(&self) -> &ManifestRegistry

pub fn registry_mut(&mut self) -> &mut ManifestRegistry

pub fn default_endpoint(&self) -> &Endpoint

Default endpoint advertised on successful subscriptions. The negotiated transport’s tag is paired with this endpoint’s address to form the SubscribeAck::endpoint.

pub fn register( &mut self, descriptor: FeedDescriptor, ) -> Result<(), ValidationError>

pub fn handle_subscribe( &self, req: &SubscriptionDescriptor, ) -> SubscribeResponse

Validate a subscription request and produce the matching SubscribeResponse. Unknown feeds and capability violations produce Err variants with descriptive codes; successful negotiations produce an Ack pointing at the publisher’s default endpoint with the negotiated transport.

Trait Implementations

impl Clone for LocalPublisher

fn clone(&self) -> LocalPublisher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LocalPublisher

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

Formats the value using the given formatter.