Struct svc_agent::Subscription

pub struct Subscription {}

Messages subscription builder.

Implementations

impl Subscription

pub fn broadcast_events<'a, A>( from: &'a A, version: &'a str, uri: &'a str ) -> EventSubscription<'a>where A: Authenticable,

Builds an EventSubscription for broadcast events.

Use it to subscribe to events from some service,

Arguments

• from – anything Addressable to receive events from. For example service AgentId.
• version – API version string of the from agent. Example: v1.
• uri – resource path divided by / to receive events on. Example: room/ROOM_ID/events.

Example

let agent = AgentId::new("instance01", AccountId::new("service_name", "svc.example.org"));
let subscription = Subscription::broadcast_events(&agent, "v1", "rooms/123/events");

pub fn multicast_requests(version: Option<&str>) -> RequestSubscription<'_>

Builds a RequestSubscription for multicast requests from any agent.

Use it to subscribe a stateless service endpoint to its consumers’ requests.

Arguments

• version – API version string of the from agent. Example: v1.

Example

let subscription = Subscription::multicast_requests("v1");

pub fn multicast_requests_from<'a, A>( from: &'a A, version: Option<&'a str> ) -> RequestSubscription<'a>where A: Addressable,

Builds a RequestSubscription for multicast requests from a specific agent.

This is the same as multicast_requests but subscribes only from requests from a specific agent.

Arguments

• from – anything Addressable to receive requests from. For example service AgentId.
• version – API version string of the from agent. Example: v1.

Example

let agent = AgentId::new("instance01", AccountId::new("service_name", "svc.example.org"));
let subscription = Subscription::multicast_requests_from(&agent, "v1");

pub fn unicast_requests<'a>() -> RequestSubscription<'a>

Builds a RequestSubscription for unicast requests from any agent.

Use it to subscribe a stateful service endpoint to its consumers’ requests.

Example

let subscription = Subscription::unicast_requests();

pub fn unicast_requests_from<A>(from: &A) -> RequestSubscription<'_>where A: Authenticable,

Builds a RequestSubscription for unicast requests from a specific agent.

This is the same as unicast_requests but subscribes only from requests from a specific agent.

Arguments

• from – anything Addressable to receive requests from. For example service AgentId.

Example

let agent = AgentId::new("instance01", AccountId::new("service_name", "svc.example.org"));
let subscription = Subscription::unicast_requests(&agent);

pub fn unicast_responses<'a>() -> ResponseSubscription<'a>

Builds a ResponseSubscription for unicast requests from any agent.

Use it to subscribe to responses from all services.

Example

let subscription = Subscription::unicast_responses();

pub fn unicast_responses_from<A>(from: &A) -> ResponseSubscription<'_>where A: Authenticable,

Builds a ResponseSubscription for unicast requests from a specific agent.

This is the same as unicast_responses but subscribes only from requests from a specific agent.

Example

let agent = AgentId::new("instance01", AccountId::new("service_name", "svc.example.org"));
let subscription = Subscription::unicast_responses_from(&agent);