Struct Node 

pub struct Node { /* private fields */ }

Node controller.

Implementations

impl Node

pub fn new<P>(path: P) -> Node

where P: AsRef<Path>,

Connect to the node, via the socket at the given path.

pub fn call<T>( &self, cmd: Command, timeout: Duration, ) -> Result<LineIter<T>, Error>

where T: DeserializeOwned + Send + 'static,

Call a command on the node.

pub fn announce( &mut self, rid: RepoId, namespaces: impl IntoIterator<Item = PublicKey>, timeout: Duration, announcer: Announcer, report: impl FnMut(&PublicKey, Progress), ) -> Result<AnnouncerResult, Error>

Announce refs of the given rid to the given seeds. Waits for the seeds to acknowledge the refs or times out if no acknowledgments are received within the given time.

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.

impl Debug for Node

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

Formats the value using the given formatter.

impl Handle for Node

type Sessions = Vec<Session>

The peer sessions type.

type Events = LineIter<Event>

type Event = Result<Event, Error>

type Error = Error

The error returned by all methods.

fn nid(&self) -> Result<PublicKey, Error>

Get the local Node ID.

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

Get the node’s bound listen addresses.

fn is_running(&self) -> bool

Check if the node is running.

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

Get the current node configuration.

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

Connect to a peer.

fn disconnect(&mut self, nid: PublicKey) -> Result<(), <Node as Handle>::Error>

Disconnect from a peer.

fn seeds_for( &mut self, rid: RepoId, namespaces: impl IntoIterator<Item = PublicKey>, ) -> Result<Seeds, Error>

Look up the seeds of a given repository in the routing table and report sync status for namespaces.

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

Fetch a repository from the network.

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

Start following the given peer.

fn block(&mut self, nid: PublicKey) -> Result<bool, Error>

Set the following policy to block for the given peer.

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

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

fn unfollow(&mut self, nid: PublicKey) -> Result<bool, Error>

Unfollow the given peer.

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

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

fn announce_refs_for( &mut self, rid: RepoId, namespaces: impl IntoIterator<Item = PublicKey>, ) -> Result<RefsAt, Error>

Notify the service that a repository has been updated, and references for the given namespaces should be announced over the network.

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<LineIter<Event>, Error>

Subscribe to node events.

fn sessions(&self) -> Result<<Node as Handle>::Sessions, Error>

Query the peer session state.

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

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

fn debug(&self) -> Result<Value, <Node as Handle>::Error>

Return debug information as a JSON value.

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

Ask the service to shutdown.

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

👎Deprecated: use seeds_for instead

Look up the seeds of a given repository in the routing table.

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

👎Deprecated: use announce_refs_for instead

Notify the service that a repository has been updated, and references should be announced over the network.