Enum raftstore::store::msg::Callback

[−] Show declaration

pub enum Callback<S: Snapshot> {
    None,
    Read(ReadCallback<S>),
    Write {
        cb: WriteCallback,
        proposed_cb: Option<ExtCallback>,
        committed_cb: Option<ExtCallback>,
    },
}

[−] Expand description

Variants of callbacks for Msg.

• Read: a callback for read only requests including StatusRequest, GetRequest and SnapRequest
• Write: a callback for write only requests including AdminRequest PutRequest, DeleteRequest and DeleteRangeRequest.

Variants

None

[−] Expand description

No callback.

Read(ReadCallback<S>)

[−] Expand description

Read callback.

Write

[−] Expand description

Write callback.

[−] Show fields

Fields of Write

cb: WriteCallbackproposed_cb: Option<ExtCallback>

proposed_cb is called after a request is proposed to the raft group successfully. It’s used to notify the caller to move on early because it’s very likely the request will be applied to the raftstore.

committed_cb: Option<ExtCallback>

committed_cb is called after a request is committed and before it’s being applied, and it’s guaranteed that the request will be successfully applied soon.

Implementations

impl<S> Callback<S> where
    S: Snapshot, [−]

pub fn write(cb: WriteCallback) -> Self

pub fn write_ext(
    cb: WriteCallback,
    proposed_cb: Option<ExtCallback>,
    committed_cb: Option<ExtCallback>
) -> Self

pub fn invoke_with_response(self, resp: RaftCmdResponse)

pub fn invoke_proposed(&mut self)

pub fn invoke_committed(&mut self)

pub fn invoke_read(self, args: ReadResponse<S>)

pub fn is_none(&self) -> bool

Trait Implementations

impl<S> Debug for Callback<S> where
    S: Snapshot, [+]

[+] Show hidden undocumented items

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

Formats the value using the given formatter.