Struct TypeConfig 

pub struct TypeConfig {}

Trait Implementations

impl Clone for TypeConfig

fn clone(&self) -> TypeConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for TypeConfig

impl Debug for TypeConfig

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

Formats the value using the given formatter.

impl Default for TypeConfig

fn default() -> TypeConfig

Returns the “default value” for a type.

impl Eq for TypeConfig

impl Ord for TypeConfig

fn cmp(&self, other: &TypeConfig) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl PartialEq for TypeConfig

fn eq(&self, other: &TypeConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl PartialOrd for TypeConfig

fn partial_cmp(&self, other: &TypeConfig) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl RaftLogReader<TypeConfig> for LogStore

async fn try_get_log_entries<RB: RangeBounds<u64> + Clone + Debug + OptionalSend>( &mut self, range: RB, ) -> Result<Vec<Entry<TypeConfig>>, StorageError<NodeId>>

Get a series of log entries from storage.

fn limited_get_log_entries( &mut self, start: u64, end: u64, ) -> impl Future<Output = Result<Vec<<C as RaftTypeConfig>::Entry>, StorageError<<C as RaftTypeConfig>::NodeId>>> + Send

Returns log entries within range [start, end), end is exclusive, potentially limited by implementation-defined constraints.

impl RaftLogStorage<TypeConfig> for LogStore

type LogReader = LogStore

Log reader type.

async fn get_log_state( &mut self, ) -> Result<LogState<TypeConfig>, StorageError<NodeId>>

Returns the last deleted log id and the last log id.

async fn get_log_reader(&mut self) -> Self::LogReader

Get the log reader.

async fn save_vote( &mut self, vote: &Vote<NodeId>, ) -> Result<(), StorageError<NodeId>>

Save vote to storage.

async fn read_vote( &mut self, ) -> Result<Option<Vote<NodeId>>, StorageError<NodeId>>

Return the last saved vote by Self::save_vote.

async fn append<I>( &mut self, entries: I, callback: LogFlushed<TypeConfig>, ) -> Result<(), StorageError<NodeId>>

where I: IntoIterator<Item = Entry<TypeConfig>> + OptionalSend,

Append log entries and call the callback once logs are persisted on disk.

async fn truncate( &mut self, log_id: LogId<NodeId>, ) -> Result<(), StorageError<NodeId>>

Truncate logs since log_id, inclusive

async fn purge( &mut self, log_id: LogId<NodeId>, ) -> Result<(), StorageError<NodeId>>

Purge logs upto log_id, inclusive

fn save_committed( &mut self, _committed: Option<LogId<<C as RaftTypeConfig>::NodeId>>, ) -> impl Future<Output = Result<(), StorageError<<C as RaftTypeConfig>::NodeId>>> + Send

Saves the last committed log id to storage.

fn read_committed( &mut self, ) -> impl Future<Output = Result<Option<LogId<<C as RaftTypeConfig>::NodeId>>, StorageError<<C as RaftTypeConfig>::NodeId>>> + Send

Return the last saved committed log id by Self::save_committed.

impl RaftNetwork<TypeConfig> for RaftHttpConnection

async fn append_entries( &mut self, rpc: AppendEntriesRequest<TypeConfig>, _option: RPCOption, ) -> Result<AppendEntriesResponse<NodeId>, RPCError<NodeId, BasicNode, RaftError<NodeId>>>

Send an AppendEntries RPC to the target.

async fn install_snapshot( &mut self, rpc: InstallSnapshotRequest<TypeConfig>, _option: RPCOption, ) -> Result<InstallSnapshotResponse<NodeId>, RPCError<NodeId, BasicNode, RaftError<NodeId, InstallSnapshotError>>>

Send an InstallSnapshot RPC to the target.

async fn vote( &mut self, rpc: VoteRequest<NodeId>, _option: RPCOption, ) -> Result<VoteResponse<NodeId>, RPCError<NodeId, BasicNode, RaftError<NodeId>>>

Send a RequestVote RPC to the target.

fn full_snapshot( &mut self, vote: Vote<<C as RaftTypeConfig>::NodeId>, snapshot: Snapshot<C>, cancel: impl Future<Output = ReplicationClosed> + OptionalSend + 'static, option: RPCOption, ) -> impl Future<Output = Result<SnapshotResponse<<C as RaftTypeConfig>::NodeId>, StreamingError<C, Fatal<<C as RaftTypeConfig>::NodeId>>>> + Send

Send a complete Snapshot to the target.

fn backoff(&self) -> Backoff

Build a backoff instance if the target node is temporarily(or permanently) unreachable.

impl RaftNetworkFactory<TypeConfig> for RaftHttpNetwork

type Network = RaftHttpConnection

Actual type of the network handling a single connection.

async fn new_client( &mut self, target: NodeId, node: &BasicNode, ) -> Self::Network

Create a new network instance sending RPCs to the target node.

impl RaftSnapshotBuilder<TypeConfig> for StateMachine

async fn build_snapshot( &mut self, ) -> Result<Snapshot<TypeConfig>, StorageError<NodeId>>

Build snapshot

impl RaftStateMachine<TypeConfig> for StateMachine

type SnapshotBuilder = StateMachine

Snapshot builder type.

async fn applied_state( &mut self, ) -> Result<(Option<LogId<NodeId>>, StoredMembership<NodeId, BasicNode>), StorageError<NodeId>>

Returns the last applied log id which is recorded in state machine, and the last applied membership config.

async fn apply<I>( &mut self, entries: I, ) -> Result<Vec<ClusterResponse>, StorageError<NodeId>>

where I: IntoIterator<Item = Entry<TypeConfig>> + OptionalSend,

Apply the given payload of entries to the state machine.

async fn get_snapshot_builder(&mut self) -> Self::SnapshotBuilder

Get the snapshot builder for the state machine.

async fn begin_receiving_snapshot( &mut self, ) -> Result<Box<Cursor<Vec<u8>>>, StorageError<NodeId>>

Create a new blank snapshot, returning a writable handle to the snapshot object.

async fn install_snapshot( &mut self, meta: &SnapshotMeta<NodeId, BasicNode>, snapshot: Box<Cursor<Vec<u8>>>, ) -> Result<(), StorageError<NodeId>>

Install a snapshot which has finished streaming from the leader.

async fn get_current_snapshot( &mut self, ) -> Result<Option<Snapshot<TypeConfig>>, StorageError<NodeId>>

Get a readable handle to the current snapshot.

impl RaftTypeConfig for TypeConfig

type D = ClusterCommand

Application-specific request data passed to the state machine.

type R = ClusterResponse

Application-specific response data returned by the state machine.

type Node = BasicNode

Raft application level node data

type NodeId = u64

A Raft node’s ID.

type Entry = Entry<TypeConfig>

Raft log entry, which can be built from an AppData.

type SnapshotData = Cursor<Vec<u8>>

Snapshot data for exposing a snapshot for reading & writing.

type Responder = OneshotResponder<TypeConfig>

Send the response or error of a client write request(WriteResult).

type AsyncRuntime = TokioRuntime

Asynchronous runtime type.

impl StructuralPartialEq for TypeConfig