Struct Handle 

pub struct Handle { /* private fields */ }

Implementations

impl Handle

pub fn events(&self) -> Events

Subscribe to events stream.

impl Handle

pub fn new( home: Home, controller: Controller<Control, PopolWaker>, emitter: Emitter<Event>, ) -> Self

pub fn worker_result(&mut self, result: TaskResult) -> Result<(), Error>

pub fn flush(&mut self, remote: NodeId, stream: StreamId) -> Result<(), Error>

Trait Implementations

impl Clone for Handle

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Handle

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

Formats the value using the given formatter.

impl Handle for Handle

type Sessions = Vec<Session>

The peer sessions type.

type Events = Events

type Event = Event

type Error = Error

The error returned by all methods.

fn nid(&self) -> Result<NodeId, Self::Error>

Get the local Node ID.

fn is_running(&self) -> bool

Check if the node is running.

fn connect( &mut self, node: NodeId, addr: Address, opts: ConnectOptions, ) -> Result<ConnectResult, Error>

Connect to a peer.

fn disconnect(&mut self, node: NodeId) -> Result<(), Self::Error>

Disconnect from a peer.

fn seeds(&mut self, id: RepoId) -> Result<Seeds, Self::Error>

Lookup the seeds of a given repository in the routing table.

fn config(&self) -> Result<Config, Self::Error>

Get the current node configuration.

fn listen_addrs(&self) -> Result<Vec<SocketAddr>, Self::Error>

Get the node’s bound listen addresses.

fn fetch( &mut self, id: RepoId, from: NodeId, timeout: Duration, ) -> Result<FetchResult, Error>

Fetch a repository from the network.

fn follow(&mut self, id: NodeId, alias: Option<Alias>) -> Result<bool, Error>

Start following the given peer.

fn unfollow(&mut self, id: NodeId) -> Result<bool, Error>

Unfollow the given peer.

fn seed(&mut self, id: RepoId, scope: Scope) -> Result<bool, Error>

Start seeding the given repo. May update the scope. Does nothing if the repo is already seeded.

fn unseed(&mut self, id: RepoId) -> Result<bool, Error>

Un-seed the given repo and delete it from storage.

fn announce_refs(&mut self, id: RepoId) -> Result<RefsAt, Error>

Notify the service that a project has been updated, and announce local refs.

fn announce_inventory(&mut self) -> Result<(), Error>

Announce local inventory.

fn add_inventory(&mut self, rid: RepoId) -> Result<bool, Error>

Notify the service that our inventory was updated with the given repository.

fn subscribe(&self, _timeout: Duration) -> Result<Self::Events, Self::Error>

Subscribe to node events.

fn sessions(&self) -> Result<Self::Sessions, Error>

Query the peer session state.

fn session(&self, nid: NodeId) -> Result<Option<Session>, Self::Error>

Query the state of a peer session. Returns None if no session was found.

fn shutdown(self) -> Result<(), Error>

Ask the service to shutdown.

fn debug(&self) -> Result<Value, Self::Error>

Return debug information as a JSON value.