pub trait TunnelServiceHandle<Ctx> {
// Required methods
fn start(&mut self, _ctx: &TunnelServiceCtx);
fn on_agent_conn<S: AsyncRead + AsyncWrite + Send + Sync + Unpin + 'static>(
&mut self,
_ctx: &TunnelServiceCtx,
_agent_id: AgentId,
ctx: Ctx,
_stream: S,
);
fn on_cluster_event(
&mut self,
_ctx: &TunnelServiceCtx,
_event: P2pServiceEvent,
);
}Expand description
This service take care how we process a incoming request from agent
Required Methods§
fn start(&mut self, _ctx: &TunnelServiceCtx)
fn on_agent_conn<S: AsyncRead + AsyncWrite + Send + Sync + Unpin + 'static>( &mut self, _ctx: &TunnelServiceCtx, _agent_id: AgentId, ctx: Ctx, _stream: S, )
fn on_cluster_event(&mut self, _ctx: &TunnelServiceCtx, _event: P2pServiceEvent)
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.