Trait kvproto::deadlock::Deadlock

pub trait Deadlock {
    fn get_wait_for_entries(
        &mut self, 
        ctx: RpcContext<'_>, 
        req: WaitForEntriesRequest, 
        sink: UnarySink<WaitForEntriesResponse>
    );
    fn detect(
        &mut self, 
        ctx: RpcContext<'_>, 
        stream: RequestStream<DeadlockRequest>, 
        sink: DuplexSink<DeadlockResponse>
    );
}

Required methods

fn get_wait_for_entries(
    &mut self,
    ctx: RpcContext<'_>,
    req: WaitForEntriesRequest,
    sink: UnarySink<WaitForEntriesResponse>
)

fn detect(
    &mut self,
    ctx: RpcContext<'_>,
    stream: RequestStream<DeadlockRequest>,
    sink: DuplexSink<DeadlockResponse>
)

Loading content...

Implementors

Loading content...