Enum raftstore::store::msg::Callback[−][src]

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

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

No callback.

Read(ReadCallback<S>)

Read callback.

Write

Write callback.

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,` [src]

`pub fn write(cb: WriteCallback) -> Self`[src]

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

`pub fn invoke_with_response(self, resp: RaftCmdResponse)`[src]

`pub fn invoke_proposed(&mut self)`[src]

`pub fn invoke_committed(&mut self)`[src]

`pub fn invoke_read(self, args: ReadResponse<S>)`[src]

`pub fn is_none(&self) -> bool`[src]

Trait Implementations

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

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

Auto Trait Implementations

`impl<S> !RefUnwindSafe for Callback<S>`

`impl<S> Send for Callback<S>`

`impl<S> !Sync for Callback<S>`

`impl<S> Unpin for Callback<S>`

`impl<S> !UnwindSafe for Callback<S>`

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<V, W> ConvertFrom<W> for V where W: ConvertTo<V>,` [src]

`pub fn convert_from(ctx: &mut EvalContext, from: W) -> Result<V, Error>`[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> 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, 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.

Enum raftstore::store::msg::Callback⎘[−][src]

Variants

Fields of Write

Implementations

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

pub fn write(cb: WriteCallback) -> Self[src]

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

pub fn invoke_with_response(self, resp: RaftCmdResponse)[src]

pub fn invoke_proposed(&mut self)[src]

pub fn invoke_committed(&mut self)[src]

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

pub fn is_none(&self) -> bool[src]

Trait Implementations

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

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

Auto Trait Implementations

impl<S> !RefUnwindSafe for Callback<S>

impl<S> Send for Callback<S>

impl<S> !Sync for Callback<S>

impl<S> Unpin for Callback<S>

impl<S> !UnwindSafe for Callback<S>

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<V, W> ConvertFrom<W> for V where W: ConvertTo<V>, [src]

pub fn convert_from(ctx: &mut EvalContext, from: W) -> Result<V, Error>[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> 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, 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]

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

Enum raftstore::store::msg::Callback[−][src]

`impl<S> Callback<S> where S: Snapshot,` [src]

`pub fn write(cb: WriteCallback) -> Self`[src]

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

`pub fn invoke_with_response(self, resp: RaftCmdResponse)`[src]

`pub fn invoke_proposed(&mut self)`[src]

`pub fn invoke_committed(&mut self)`[src]

`pub fn invoke_read(self, args: ReadResponse<S>)`[src]

`pub fn is_none(&self) -> bool`[src]

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

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

`impl<S> !RefUnwindSafe for Callback<S>`

`impl<S> Send for Callback<S>`

`impl<S> !Sync for Callback<S>`

`impl<S> Unpin for Callback<S>`

`impl<S> !UnwindSafe for Callback<S>`

`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<V, W> ConvertFrom<W> for V where W: ConvertTo<V>,` [src]

`pub fn convert_from(ctx: &mut EvalContext, from: W) -> Result<V, Error>`[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> 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, 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]

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