Struct DcpServer 

pub struct DcpServer { /* private fields */ }

Implementations

impl DcpServer

pub fn new( registry: JobRegistryHandle, instrumentation: StreamInstrumentationRegistry, factories: DcpJobFactories, config: DcpServerConfig, ) -> Self

pub fn from_agent( agent: &AgentHandle, factories: DcpJobFactories, config: DcpServerConfig, ) -> Self

pub fn set_cluster_view(&self, provider: Arc<dyn ClusterViewProvider>)

Install or replace the provider used for cluster-wide read-only DCP requests.

pub fn clear_cluster_view(&self)

Remove the cluster view provider. Cluster DCP requests will fail until a provider is installed again.

pub fn set_sharding_view(&self, provider: Arc<dyn ShardingViewProvider>)

Install or replace the provider used for cluster-sharding DCP requests.

pub fn clear_sharding_view(&self)

Remove the sharding provider. Sharding DCP requests will fail until a provider is installed again.

pub async fn start(&self) -> DcpResult<DcpServerHandle>

Trait Implementations

impl Clone for DcpServer

fn clone(&self) -> DcpServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.