Struct test_pd::server::PdMock[−][src]

struct PdMock<C: PdMocker> {
    default_handler: Arc<Service>,
    case: Option<Arc<C>>,
}

Fields

default_handler: Arc<Service>case: Option<Arc<C>>

Trait Implementations

`impl<C: PdMocker> Clone for PdMock<C>`[src]

`fn clone(&self) -> Self`[src]

`pub fn clone_from(&mut self, source: &Self)`1.0.0 [src]

`impl<C: Debug + PdMocker> Debug for PdMock<C>`[src]

`fn fmt(&self, f: &mut Formatter<'_>) -> Result`[src]

`impl<C: PdMocker + Send + Sync + 'static> Pd for PdMock<C>`[src]

`fn get_members( &mut self, ctx: RpcContext<'_>, req: GetMembersRequest, sink: UnarySink<GetMembersResponse> )`[src]

`fn tso( &mut self, ctx: RpcContext<'_>, req: RequestStream<TsoRequest>, resp: DuplexSink<TsoResponse> )`[src]

`fn bootstrap( &mut self, ctx: RpcContext<'_>, req: BootstrapRequest, sink: UnarySink<BootstrapResponse> )`[src]

`fn is_bootstrapped( &mut self, ctx: RpcContext<'_>, req: IsBootstrappedRequest, sink: UnarySink<IsBootstrappedResponse> )`[src]

`fn alloc_id( &mut self, ctx: RpcContext<'_>, req: AllocIdRequest, sink: UnarySink<AllocIdResponse> )`[src]

`fn get_store( &mut self, ctx: RpcContext<'_>, req: GetStoreRequest, sink: UnarySink<GetStoreResponse> )`[src]

`fn put_store( &mut self, ctx: RpcContext<'_>, req: PutStoreRequest, sink: UnarySink<PutStoreResponse> )`[src]

`fn get_all_stores( &mut self, ctx: RpcContext<'_>, req: GetAllStoresRequest, sink: UnarySink<GetAllStoresResponse> )`[src]

`fn store_heartbeat( &mut self, ctx: RpcContext<'_>, req: StoreHeartbeatRequest, sink: UnarySink<StoreHeartbeatResponse> )`[src]

`fn region_heartbeat( &mut self, ctx: RpcContext<'_>, stream: RequestStream<RegionHeartbeatRequest>, sink: DuplexSink<RegionHeartbeatResponse> )`[src]

`fn get_region( &mut self, ctx: RpcContext<'_>, req: GetRegionRequest, sink: UnarySink<GetRegionResponse> )`[src]

`fn get_region_by_id( &mut self, ctx: RpcContext<'_>, req: GetRegionByIdRequest, sink: UnarySink<GetRegionResponse> )`[src]

`fn ask_split( &mut self, ctx: RpcContext<'_>, req: AskSplitRequest, sink: UnarySink<AskSplitResponse> )`[src]

`fn report_split( &mut self, _: RpcContext<'_>, _: ReportSplitRequest, _: UnarySink<ReportSplitResponse> )`[src]

`fn ask_batch_split( &mut self, ctx: RpcContext<'_>, req: AskBatchSplitRequest, sink: UnarySink<AskBatchSplitResponse> )`[src]

`fn report_batch_split( &mut self, ctx: RpcContext<'_>, req: ReportBatchSplitRequest, sink: UnarySink<ReportBatchSplitResponse> )`[src]

`fn get_cluster_config( &mut self, ctx: RpcContext<'_>, req: GetClusterConfigRequest, sink: UnarySink<GetClusterConfigResponse> )`[src]

`fn put_cluster_config( &mut self, ctx: RpcContext<'_>, req: PutClusterConfigRequest, sink: UnarySink<PutClusterConfigResponse> )`[src]

`fn scatter_region( &mut self, ctx: RpcContext<'_>, req: ScatterRegionRequest, sink: UnarySink<ScatterRegionResponse> )`[src]

`fn get_prev_region( &mut self, _: RpcContext<'_>, _: GetRegionRequest, _: UnarySink<GetRegionResponse> )`[src]

`fn get_gc_safe_point( &mut self, ctx: RpcContext<'_>, req: GetGcSafePointRequest, sink: UnarySink<GetGcSafePointResponse> )`[src]

`fn update_gc_safe_point( &mut self, ctx: RpcContext<'_>, req: UpdateGcSafePointRequest, sink: UnarySink<UpdateGcSafePointResponse> )`[src]

`fn sync_regions( &mut self, _ctx: RpcContext<'_>, _stream: RequestStream<SyncRegionRequest>, _sink: DuplexSink<SyncRegionResponse> )`[src]

`fn get_operator( &mut self, ctx: RpcContext<'_>, req: GetOperatorRequest, sink: UnarySink<GetOperatorResponse> )`[src]

`fn scan_regions( &mut self, _ctx: RpcContext<'_>, _req: ScanRegionsRequest, _sink: UnarySink<ScanRegionsResponse> )`[src]

`fn update_service_gc_safe_point( &mut self, _ctx: RpcContext<'_>, _req: UpdateServiceGcSafePointRequest, _sink: UnarySink<UpdateServiceGcSafePointResponse> )`[src]

`fn sync_max_ts( &mut self, _ctx: RpcContext<'_>, _req: SyncMaxTsRequest, _sink: UnarySink<SyncMaxTsResponse> )`[src]

`fn split_regions( &mut self, _: RpcContext<'_>, _: SplitRegionsRequest, _: UnarySink<SplitRegionsResponse> )`[src]

`fn get_dc_location_info( &mut self, _: RpcContext<'_>, _: GetDcLocationInfoRequest, _: UnarySink<GetDcLocationInfoResponse> )`[src]

Auto Trait Implementations

`impl<C> RefUnwindSafe for PdMock<C> where C: RefUnwindSafe,`

`impl<C> Send for PdMock<C> where C: Send + Sync,`

`impl<C> Sync for PdMock<C> where C: Send + Sync,`

`impl<C> Unpin for PdMock<C>`

`impl<C> UnwindSafe for PdMock<C> where C: RefUnwindSafe,`

Blanket Implementations

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`pub fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`pub fn borrow(&self) -> &T`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`pub fn borrow_mut(&mut self) -> &mut T`[src]

`impl<T> From<T> for T`[src]

`pub fn from(t: T) -> T`[src]

`impl<T> Instrument for T`[src]

`pub fn instrument(self, span: Span) -> Instrumented<Self>`[src]

`pub fn in_current_span(self) -> Instrumented<Self>`[src]

`impl<T, U> Into for T where U: From<T>,` [src]

`pub fn into(self) -> U`[src]

`impl<T> Pointable for T`[src]

`pub const ALIGN: usize`[src]

`type Init = T`

The type for initializers.

`pub unsafe fn init(init: <T as Pointable>::Init) -> usize`[src]

`pub unsafe fn deref<'a>(ptr: usize) -> &'a T`[src]

`pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T`[src]

`pub unsafe fn drop(ptr: usize)`[src]

`impl<T> Same<T> for T`[src]

`type Output = T`

Should always be Self

`impl<T> Sealed<T> for T where T: ?Sized,` [src]

`impl<T> SendSyncUnwindSafe for T where T: Send + Sync + UnwindSafe + ?Sized,` [src]

`impl<T> ToOwned for T where T: Clone,` [src]

`type Owned = T`

The resulting type after obtaining ownership.

`pub fn to_owned(&self) -> T`[src]

`pub fn clone_into(&self, target: &mut T)`[src]

`impl<T, U> TryFrom for T where U: Into<T>,` [src]

`type Error = Infallible`

The type returned in the event of a conversion error.

`pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>`[src]

`impl<T, U> TryInto for T where U: TryFrom<T>,` [src]

`type Error = >::Error`

The type returned in the event of a conversion error.

`pub fn try_into(self) -> Result<U, >::Error>`[src]

`impl<V, T> VZip<V> for T where V: MultiLane<T>,` [src]

`pub fn vzip(self) -> V`[src]

Struct test_pd::server::PdMock⎘[−][src]

Fields

Trait Implementations

impl<C: PdMocker> Clone for PdMock<C>[src]

fn clone(&self) -> Self[src]

pub fn clone_from(&mut self, source: &Self)1.0.0[src]

impl<C: Debug + PdMocker> Debug for PdMock<C>[src]

fn fmt(&self, f: &mut Formatter<'_>) -> Result[src]

impl<C: PdMocker + Send + Sync + 'static> Pd for PdMock<C>[src]

fn get_members( &mut self, ctx: RpcContext<'_>, req: GetMembersRequest, sink: UnarySink<GetMembersResponse>)[src]

fn tso( &mut self, ctx: RpcContext<'_>, req: RequestStream<TsoRequest>, resp: DuplexSink<TsoResponse>)[src]

fn bootstrap( &mut self, ctx: RpcContext<'_>, req: BootstrapRequest, sink: UnarySink<BootstrapResponse>)[src]

fn is_bootstrapped( &mut self, ctx: RpcContext<'_>, req: IsBootstrappedRequest, sink: UnarySink<IsBootstrappedResponse>)[src]

fn alloc_id( &mut self, ctx: RpcContext<'_>, req: AllocIdRequest, sink: UnarySink<AllocIdResponse>)[src]

fn get_store( &mut self, ctx: RpcContext<'_>, req: GetStoreRequest, sink: UnarySink<GetStoreResponse>)[src]

fn put_store( &mut self, ctx: RpcContext<'_>, req: PutStoreRequest, sink: UnarySink<PutStoreResponse>)[src]

fn get_all_stores( &mut self, ctx: RpcContext<'_>, req: GetAllStoresRequest, sink: UnarySink<GetAllStoresResponse>)[src]

fn store_heartbeat( &mut self, ctx: RpcContext<'_>, req: StoreHeartbeatRequest, sink: UnarySink<StoreHeartbeatResponse>)[src]

fn region_heartbeat( &mut self, ctx: RpcContext<'_>, stream: RequestStream<RegionHeartbeatRequest>, sink: DuplexSink<RegionHeartbeatResponse>)[src]

fn get_region( &mut self, ctx: RpcContext<'_>, req: GetRegionRequest, sink: UnarySink<GetRegionResponse>)[src]

fn get_region_by_id( &mut self, ctx: RpcContext<'_>, req: GetRegionByIdRequest, sink: UnarySink<GetRegionResponse>)[src]

fn ask_split( &mut self, ctx: RpcContext<'_>, req: AskSplitRequest, sink: UnarySink<AskSplitResponse>)[src]

fn report_split( &mut self, _: RpcContext<'_>, _: ReportSplitRequest, _: UnarySink<ReportSplitResponse>)[src]

fn ask_batch_split( &mut self, ctx: RpcContext<'_>, req: AskBatchSplitRequest, sink: UnarySink<AskBatchSplitResponse>)[src]

fn report_batch_split( &mut self, ctx: RpcContext<'_>, req: ReportBatchSplitRequest, sink: UnarySink<ReportBatchSplitResponse>)[src]

fn get_cluster_config( &mut self, ctx: RpcContext<'_>, req: GetClusterConfigRequest, sink: UnarySink<GetClusterConfigResponse>)[src]

fn put_cluster_config( &mut self, ctx: RpcContext<'_>, req: PutClusterConfigRequest, sink: UnarySink<PutClusterConfigResponse>)[src]

fn scatter_region( &mut self, ctx: RpcContext<'_>, req: ScatterRegionRequest, sink: UnarySink<ScatterRegionResponse>)[src]

fn get_prev_region( &mut self, _: RpcContext<'_>, _: GetRegionRequest, _: UnarySink<GetRegionResponse>)[src]

fn get_gc_safe_point( &mut self, ctx: RpcContext<'_>, req: GetGcSafePointRequest, sink: UnarySink<GetGcSafePointResponse>)[src]

fn update_gc_safe_point( &mut self, ctx: RpcContext<'_>, req: UpdateGcSafePointRequest, sink: UnarySink<UpdateGcSafePointResponse>)[src]

fn sync_regions( &mut self, _ctx: RpcContext<'_>, _stream: RequestStream<SyncRegionRequest>, _sink: DuplexSink<SyncRegionResponse>)[src]

fn get_operator( &mut self, ctx: RpcContext<'_>, req: GetOperatorRequest, sink: UnarySink<GetOperatorResponse>)[src]

fn scan_regions( &mut self, _ctx: RpcContext<'_>, _req: ScanRegionsRequest, _sink: UnarySink<ScanRegionsResponse>)[src]

fn update_service_gc_safe_point( &mut self, _ctx: RpcContext<'_>, _req: UpdateServiceGcSafePointRequest, _sink: UnarySink<UpdateServiceGcSafePointResponse>)[src]

fn sync_max_ts( &mut self, _ctx: RpcContext<'_>, _req: SyncMaxTsRequest, _sink: UnarySink<SyncMaxTsResponse>)[src]

fn split_regions( &mut self, _: RpcContext<'_>, _: SplitRegionsRequest, _: UnarySink<SplitRegionsResponse>)[src]

fn get_dc_location_info( &mut self, _: RpcContext<'_>, _: GetDcLocationInfoRequest, _: UnarySink<GetDcLocationInfoResponse>)[src]

Auto Trait Implementations

impl<C> RefUnwindSafe for PdMock<C> where C: RefUnwindSafe,

impl<C> Send for PdMock<C> where C: Send + Sync,

impl<C> Sync for PdMock<C> where C: Send + Sync,

impl<C> Unpin for PdMock<C>

impl<C> UnwindSafe for PdMock<C> where C: RefUnwindSafe,

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized, [src]

pub fn type_id(&self) -> TypeId[src]

impl<T> Borrow<T> for T where T: ?Sized, [src]

pub fn borrow(&self) -> &T[src]

impl<T> BorrowMut<T> for T where T: ?Sized, [src]

pub fn borrow_mut(&mut self) -> &mut T[src]

impl<T> From<T> for T[src]

pub fn from(t: T) -> T[src]

impl<T> Instrument for T[src]

pub fn instrument(self, span: Span) -> Instrumented<Self>[src]

pub fn in_current_span(self) -> Instrumented<Self>[src]

impl<T, U> Into<U> for T where U: From<T>, [src]

pub fn into(self) -> U[src]

impl<T> Pointable for T[src]

pub const ALIGN: usize[src]

type Init = T

pub unsafe fn init(init: <T as Pointable>::Init) -> usize[src]

pub unsafe fn deref<'a>(ptr: usize) -> &'a T[src]

pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T[src]

pub unsafe fn drop(ptr: usize)[src]

impl<T> Same<T> for T[src]

type Output = T

impl<T> Sealed<T> for T where T: ?Sized, [src]

impl<T> SendSyncUnwindSafe for T where T: Send + Sync + UnwindSafe + ?Sized, [src]

impl<T> ToOwned for T where T: Clone, [src]

type Owned = T

pub fn to_owned(&self) -> T[src]

pub fn clone_into(&self, target: &mut T)[src]

impl<T, U> TryFrom<U> for T where U: Into<T>, [src]

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]

impl<T, U> TryInto<U> for T where U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]

impl<V, T> VZip<V> for T where V: MultiLane<T>, [src]