Struct MockRpcService 

pub struct MockRpcService {
    pub server_port: Option<u16>,
    pub expected_vote_response: Option<Result<VoteResponse, Status>>,
    pub expected_append_entries_response: Option<Result<AppendEntriesResponse, Status>>,
    pub expected_update_cluster_conf_response: Option<Result<ClusterConfUpdateResponse, Status>>,
    pub expected_client_propose_response: Option<Result<ClientResponse, Status>>,
    pub expected_client_read_response: Option<Result<ClientResponse, Status>>,
    pub expected_metadata_response: Option<Arc<dyn Fn(u16) -> Result<ClusterMembership, Status> + Send + Sync>>,
    pub expected_snapshot_response: Option<Result<SnapshotResponse, Status>>,
    pub expected_stream_snapshot_response: Option<Result<SnapshotChunk, Status>>,
    pub expected_purge_log_response: Option<Result<PurgeLogResponse, Status>>,
    pub expected_join_cluster_response: Option<Result<JoinResponse, Status>>,
    pub expected_discover_leader_response: Option<Result<LeaderDiscoveryResponse, Status>>,
}

Fields

server_port: Option<u16>

expected_vote_response: Option<Result<VoteResponse, Status>>

expected_append_entries_response: Option<Result<AppendEntriesResponse, Status>>

expected_update_cluster_conf_response: Option<Result<ClusterConfUpdateResponse, Status>>

expected_client_propose_response: Option<Result<ClientResponse, Status>>

expected_client_read_response: Option<Result<ClientResponse, Status>>

expected_metadata_response: Option<Arc<dyn Fn(u16) -> Result<ClusterMembership, Status> + Send + Sync>>

expected_snapshot_response: Option<Result<SnapshotResponse, Status>>

expected_stream_snapshot_response: Option<Result<SnapshotChunk, Status>>

expected_purge_log_response: Option<Result<PurgeLogResponse, Status>>

expected_join_cluster_response: Option<Result<JoinResponse, Status>>

expected_discover_leader_response: Option<Result<LeaderDiscoveryResponse, Status>>

Implementations

impl MockRpcService

pub fn with_metadata_response( self, f: impl Fn(u16) -> Result<ClusterMembership, Status> + Send + Sync + 'static, ) -> Self

pub fn set_port(&mut self, port: u16)

Trait Implementations

impl Clone for MockRpcService

fn clone(&self) -> MockRpcService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ClusterManagementService for MockRpcService

fn update_cluster_conf<'life0, 'async_trait>( &'life0 self, _request: Request<ClusterConfChangeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ClusterConfUpdateResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_cluster_metadata<'life0, 'async_trait>( &'life0 self, _request: Request<MetadataRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ClusterMembership>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn join_cluster<'life0, 'async_trait>( &'life0 self, _request: Request<JoinRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<JoinResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Request to join the cluster as a new learner node

fn discover_leader<'life0, 'async_trait>( &'life0 self, _request: Request<LeaderDiscoveryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<LeaderDiscoveryResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

New RPC for leader discovery

impl Default for MockRpcService

fn default() -> MockRpcService

Returns the “default value” for a type.

impl RaftClientService for MockRpcService

type WatchStream = ReceiverStream<Result<WatchResponse, Status>>

Server streaming response type for the Watch method.

fn handle_client_write<'life0, 'async_trait>( &'life0 self, _request: Request<ClientWriteRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ClientResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn handle_client_read<'life0, 'async_trait>( &'life0 self, _request: Request<ClientReadRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ClientResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn watch<'life0, 'async_trait>( &'life0 self, _request: Request<WatchRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::WatchStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Watch for changes on a specific key

impl RaftElectionService for MockRpcService

fn request_vote<'life0, 'async_trait>( &'life0 self, _request: Request<VoteRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<VoteResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl RaftReplicationService for MockRpcService

fn append_entries<'life0, 'async_trait>( &'life0 self, _request: Request<AppendEntriesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AppendEntriesResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl SnapshotService for MockRpcService

type StreamSnapshotStream = Streaming<SnapshotChunk>

Server streaming response type for the StreamSnapshot method.

fn stream_snapshot<'life0, 'async_trait>( &'life0 self, _request: Request<Streaming<SnapshotAck>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamSnapshotStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Learner-driven snapshot streaming

fn install_snapshot<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<SnapshotChunk>>, ) -> Pin<Box<dyn Future<Output = Result<Response<SnapshotResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Leader-driven snapshot streaming

fn purge_log<'life0, 'async_trait>( &'life0 self, _request: Request<PurgeLogRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PurgeLogResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Log compaction request