Struct PandaClient 

pub struct PandaClient { /* private fields */ }

Client for the lores-p2panda-server gRPC API.

Implementations

impl PandaClient

pub async fn connect<D>(dst: D) -> Result<Self, Error>

where D: TryInto<Endpoint>, D::Error: Into<Box<dyn Error + Send + Sync>>,

Connect to a lores-p2panda-server at the given endpoint URI.

Example

let client = lores_p2panda_client::PandaClient::connect("http://[::1]:50051").await.unwrap();

pub fn connect_lazy<D>(dst: D) -> Result<Self, Error>

where D: TryInto<Endpoint>, D::Error: Into<Box<dyn Error + Send + Sync>>,

Create a client with a lazy channel — no connection is made until the first RPC call, so the process starts cleanly even if the gRPC server is not yet available.

pub async fn publish( &mut self, region_id: [u8; 32], app_namespace: impl Into<String>, payload: impl Into<Vec<u8>>, ) -> Result<Response<PublishResponse>, Status>

Publish an operation to a region+namespace topic.

Returns only after the operation has been persisted by the remote p2panda node, guaranteeing eventual propagation to peers.

pub async fn subscribe( &mut self, region_id: [u8; 32], app_namespace: impl Into<String>, ) -> Result<Response<Streaming<OperationEvent>>, Status>

Subscribe to a region+namespace topic and receive a stream of OperationEvents.

HTTP/2 flow control provides natural backpressure.

pub async fn list_regions( &mut self, ) -> Result<Response<ListRegionsResponse>, Status>

List all regions the remote node knows about.