Struct DcpClient 

pub struct DcpClient { /* private fields */ }

Implementations

impl DcpClient

pub async fn connect_tcp(addr: SocketAddr, hello: Hello) -> DcpResult<Self>

pub async fn connect_quic( addr: SocketAddr, server_name: &str, client_config: ClientConfig, hello: Hello, ) -> DcpResult<Self>

pub async fn hello(&self, hello: Hello) -> DcpResult<()>

pub async fn request(&self, request: Request) -> DcpResult<Response>

pub async fn list_jobs(&self) -> DcpResult<Vec<WireJobStatus>>

pub async fn list_cluster_jobs( &self, timeout_ms: u64, ) -> DcpResult<ClusterJobList>

pub async fn cluster_node_info( &self, timeout_ms: u64, ) -> DcpResult<ClusterNodeList>

pub async fn start_job( &self, factory_name: impl Into<String>, instance_name: impl Into<String>, params: HashMap<String, String>, ) -> DcpResult<WireJobStatus>

pub async fn submit_cluster_job( &self, factory_name: impl Into<String>, instance_name: impl Into<String>, params: HashMap<String, String>, placement: PlacementSpec, timeout_ms: u64, ) -> DcpResult<WireJobStatus>

pub async fn drain_job( &self, name: impl Into<String>, ) -> DcpResult<WireJobStatus>

pub async fn drain_cluster_job( &self, name: impl Into<String>, timeout_ms: u64, ) -> DcpResult<WireJobStatus>

pub async fn stop_job( &self, name: impl Into<String>, ) -> DcpResult<WireJobStatus>

pub async fn stop_cluster_job( &self, name: impl Into<String>, timeout_ms: u64, ) -> DcpResult<WireJobStatus>

pub async fn restart_job( &self, name: impl Into<String>, ) -> DcpResult<WireJobStatus>

pub async fn job_status( &self, name: impl Into<String>, ) -> DcpResult<WireJobStatus>

pub async fn cluster_job_status( &self, name: impl Into<String>, timeout_ms: u64, ) -> DcpResult<WireJobStatus>

pub async fn allocate_shard( &self, type_name: impl Into<String>, shard_id: impl Into<String>, timeout_ms: u64, ) -> DcpResult<ShardAllocation>

pub async fn remember_shard_allocations( &self, table: ShardAllocationTable, ) -> DcpResult<()>

pub async fn get_shard_allocations( &self, type_name: impl Into<String>, timeout_ms: u64, ) -> DcpResult<ShardAllocationTable>

pub async fn forward_shard_envelopes( &self, batch: ForwardShardEnvelopes, timeout_ms: u64, ) -> DcpResult<ShardEnvelopeBatchResult>

pub async fn complete_sharding_ask( &self, reply: CompleteShardingAsk, ) -> DcpResult<()>

pub async fn subscribe_events(&self) -> DcpResult<EventSubscription>

pub async fn subscribe_metrics( &self, interval_ms: u64, ) -> DcpResult<MetricSubscription>

pub async fn get_config(&self, key: impl Into<String>) -> DcpResult<ConfigValue>

pub async fn put_config( &self, key: impl Into<String>, value: impl Into<String>, ) -> DcpResult<ConfigValue>

Trait Implementations

impl Clone for DcpClient

fn clone(&self) -> DcpClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.