Struct dsf_client::client::Client

pub struct Client { /* fields omitted */ }

Implementations

impl Client

pub fn new(options: &Options) -> Result<Self, Error>

Create a new client

pub async fn request<'_>(
    &'_ mut self,
    rk: RequestKind
) -> Result<ResponseKind, Error>

Issue a request to the daemon using a client instance, returning a response

pub async fn status<'_>(&'_ mut self) -> Result<StatusInfo, Error>

Fetch daemon status information

pub async fn connect<'_>(
    &'_ mut self,
    options: ConnectOptions
) -> Result<ConnectInfo, Error>

Connect to another DSF instance

pub async fn find<'_>(
    &'_ mut self,
    options: SearchOptions
) -> Result<PeerInfo, Error>

Search for a peer using the database

pub async fn list<'_>(
    &'_ mut self,
    options: ListOptions
) -> Result<Vec<ServiceInfo>, Error>

List known services

pub async fn info<'_>(
    &'_ mut self,
    options: InfoOptions
) -> Result<(ServiceHandle, ServiceInfo), Error>

Fetch information for a given service

pub async fn create<'_>(
    &'_ mut self,
    options: CreateOptions
) -> Result<ServiceHandle, Error>

Create a new service with the provided options This MUST be stored locally for reuse

pub async fn register<'_>(
    &'_ mut self,
    options: RegisterOptions
) -> Result<RegisterInfo, Error>

Register a service instance in the distributed database

pub async fn locate<'_>(
    &'_ mut self,
    options: LocateOptions
) -> Result<(ServiceHandle, LocateInfo), Error>

Locate a service instance in the distributed database This returns a future that will resolve to the desired service or an error

pub async fn publish<'_>(
    &'_ mut self,
    options: PublishOptions
) -> Result<PublishInfo, Error>

Publish data using an existing service

pub async fn subscribe<'_>(
    &'_ mut self,
    options: SubscribeOptions
) -> Result<impl Stream<Item = ResponseKind>, Error>

Subscribe to data from a given service

pub async fn data<'_>(
    &'_ mut self,
    options: ListOptions
) -> Result<Vec<DataInfo>, Error>

Fetch data from a given service

Trait Implementations

impl Debug for Client

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

Formats the value using the given formatter.