Struct Node 

pub struct Node { /* private fields */ }

All the functionality is implemented in the Node structure. To interact with the other services of the Sabaton system, a node structure must be created. The NodeBuilder structure provides a builder pattern to create the node. A node is cloneable.

Implementations

impl Node

pub fn advertise_with_listener<T: TopicType>( &self, options: &PublishOptions, listener: PublisherListener, ) -> Result<Writer<T>, MiddlewareError>

pub fn advertise<T>( &self, options: &PublishOptions, ) -> Result<Writer<T>, MiddlewareError>

where T: TopicType,

Advertise a Type to the rest of the system. This call returns a Writer which you can use to publish samples to the topic. The topic name is create from the type of T and the combination of the group and instance.

pub fn subscribe_with_listener<T>( &self, options: &SubscribeOptions, listener: SubscriberListener, ) -> Result<Reader<T>, MiddlewareError>

where T: TopicType,

pub fn subscribe<T>( &self, options: &SubscribeOptions, ) -> Result<Reader<T>, MiddlewareError>

where T: TopicType,

Subscribe to a topic. This call returns a Reader. You can read samples from the reader.

pub fn subscribe_async<T>( &self, options: &SubscribeOptions, ) -> Result<Reader<T>, MiddlewareError>

where T: TopicType,

Subscribe to a topic. This call returns a Reader. You can read samples from the reader. The reader that is returned supports asynchronous reads.

pub fn create_proxy<T: 'static + Proxy + ProxyConstruct + ServiceIdentifier + ServiceVersion + Clone>( &self, ) -> Result<T, MiddlewareError>

create a proxy for a service

pub fn serve<T: CreateServerRequestHandler<Item = T>>( &self, server_impl: Arc<T>, ) -> Result<(), MiddlewareError>

Hosting a service

pub fn spin<F>(&self, main_function: F) -> Result<(), MiddlewareError>

where F: 'static + Send + FnOnce(),

The main processing loop of the node. This function will block waiting for events and pumping the necessary callbacks.

pub fn terminate(&self)

Terminate the processing of the node. The spin function hangs around waiting for a SIGINT.

Trait Implementations

impl Clone for Node

fn clone(&self) -> Node

Returns a duplicate of the value.

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

Performs copy-assignment from source.