Struct moleculer::ServiceBroker

pub struct ServiceBroker { /* fields omitted */ }

The struct used to interact with moleculer. Use emit(), broadcast() and call() functions.

// emit an event
broker.emit("printHi", json!{{}});

// broadcast an event
broker.broadcast("printHi", json!{{}});

// call an action
let result = broker.call("math.add", json!{"a": 1, "b": c}).await?;

Implementations

impl ServiceBroker

pub fn new(config: Config) -> ServiceBroker

Create new service broker, takes Config struct.

pub fn add_service(self, service: Service) -> Self

Add a service to the service broker.

pub fn add_services(self, services: Vec<Service>) -> Self

Add all the services to the service broker at once. Takes a vector of services and replaces any services the broker already had.

pub async fn start(self)

Starts the service, this will run forever until your application exits.

pub async fn call<S: Into<String>>(
    self,
    action: S,
    params: Value
) -> Result<Value, Error>

Request/Response style call Call an action directly with params serialized into serde_json::Value and await on the result

pub fn emit<S: Into<String>>(&self, event: S, params: Value)

Emits a balanced event to one of the nodes.

pub fn broadcast<S: Into<String>>(&self, event: S, params: Value)

Emits an event to all the nodes that can handle the event.

Trait Implementations

impl Clone for ServiceBroker

fn clone(&self) -> ServiceBroker

Returns a copy of the value.

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

Performs copy-assignment from source.