Struct Service

pub struct Service { /* private fields */ }

Available on crate feature service only.

Service instance.

Examples

use async_nats::service::ServiceExt;
use futures::StreamExt;
let client = async_nats::connect("demo.nats.io").await?;
let mut service = client.service_builder().start("generator", "1.0.0").await?;
let mut endpoint = service.endpoint("get").await?;

if let Some(request) = endpoint.next().await {
    request.respond(Ok("hello".into())).await?;
}

Implementations

impl Service

pub async fn stop(self) -> Result<(), Error>

Stops this instance of the Service. If there are more instances of Services with the same name, the Service will be scaled down by one instance. If it was the only running instance, it will effectively remove the service entirely.

pub async fn reset(&mut self)

Resets Stats of the Service instance.

pub async fn stats(&self) -> HashMap<String, Stats>

Returns Stats for this service instance.

pub async fn info(&self) -> Info

Returns Info for this service instance.

pub fn group<S: ToString>(&self, prefix: S) -> Group

Creates a group for endpoints under common prefix.

Examples

use async_nats::service::ServiceExt;
let client = async_nats::connect("demo.nats.io").await?;
let mut service = client.service_builder().start("service", "1.0.0").await?;

let v1 = service.group("v1");
let products = v1.endpoint("products").await?;

pub fn group_with_queue_group<S: ToString, Z: ToString>( &self, prefix: S, queue_group: Z, ) -> Group

Creates a group for endpoints under common prefix with custom queue group.

Examples

use async_nats::service::ServiceExt;
let client = async_nats::connect("demo.nats.io").await?;
let mut service = client.service_builder().start("service", "1.0.0").await?;

let v1 = service.group("v1");
let products = v1.endpoint("products").await?;

pub fn endpoint_builder(&self) -> EndpointBuilder

Builder for customized Endpoint creation.

Examples

use async_nats::service::ServiceExt;
let client = async_nats::connect("demo.nats.io").await?;
let mut service = client.service_builder().start("service", "1.0.0").await?;

let products = service
    .endpoint_builder()
    .name("api")
    .add("products")
    .await?;

pub async fn endpoint<S: ToString>(&self, subject: S) -> Result<Endpoint, Error>

Adds a new endpoint to the Service.

Examples

use async_nats::service::ServiceExt;
let client = async_nats::connect("demo.nats.io").await?;
let mut service = client.service_builder().start("service", "1.0.0").await?;

let products = service.endpoint("products").await?;

Trait Implementations

impl Debug for Service

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

Formats the value using the given formatter.