Struct Client 

pub struct Client { /* private fields */ }

Implementations

impl Client

pub fn fire_event<'a>( &'a self, name: &str, payload: &[u8], coalesce: bool, ) -> RPCRequest<'a, ()>

Fire an event

impl Client

pub fn force_leave<'a>(&'a self, node: &str) -> RPCRequest<'a, ()>

Force a node to leave

impl Client

pub fn join<'a>( &'a self, existing: &[&str], replay: bool, ) -> RPCRequest<'a, JoinResponse>

Join a serf cluster, given existing ip addresses. replay controls whether to replay old user events

impl Client

pub fn members<'a>(&'a self) -> RPCRequest<'a, MembersResponse>

Returns a list of all known members

impl Client

pub fn members_filtered<'a>( &'a self, status: Option<&str>, name: Option<&str>, tags: Option<&HashMap<String, String>>, ) -> RPCRequest<'a, MembersResponse>

Returns a filtered list of all known members

impl Client

pub fn tags<'a>( &'a self, add_tags: &[&str], delete_tags: &[&str], ) -> RPCRequest<'a, MembersResponse>

Modifies the tags of the current node

impl Client

pub fn leave<'a>(&'a self) -> RPCRequest<'a, ()>

Gracefully leave

impl Client

pub fn query_respond<'a>( &'a self, id: u64, payload: &[u8], ) -> RPCRequest<'a, ()>

Response to a query

impl Client

pub fn get_coordinate<'a>( &'a self, node: &str, ) -> RPCRequest<'a, CoordinateResponse>

Get a node’s coordinate

impl Client

pub fn stats<'a>(&'a self) -> RPCRequest<'a, AgentStats>

Get information about the Serf agent.

impl Client

pub fn stream(self: &Arc<Self>, ty: &str) -> RPCStream<StreamMessage>

impl Client

pub async fn connect( rpc_addr: SocketAddr, auth_key: Option<&str>, ) -> Result<Self, String>

Connect to hub.

Waits for handshake, and optionally for authentication if an auth key is provided.

pub async fn current_node_name(&self) -> Result<String, String>

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.