Enum Operation

pub enum Operation {
    Get {
        key: TracedBytes,
        epoch: Option<u64>,
        read_options: TracedReadOptions,
    },
    Insert {
        key: TracedBytes,
        new_val: TracedBytes,
        old_val: Option<TracedBytes>,
    },
    Delete {
        key: TracedBytes,
        old_val: TracedBytes,
    },
    Iter {
        key_range: TracedIterRange,
        epoch: Option<u64>,
        read_options: TracedReadOptions,
    },
    IterNext(RecordId),
    Sync(Vec<(u64, Vec<u32>)>),
    MetaMessage(Box<TracedSubResp>),
    Result(OperationResult),
    NewLocalStorage(TracedNewLocalOptions, LocalStorageId),
    DropLocalStorage,
    LocalStorageInit(TracedInitOptions),
    TryWaitEpoch(TracedHummockReadEpoch, TracedTryWaitEpochOptions),
    SealCurrentEpoch {
        epoch: u64,
        opts: TracedSealCurrentEpochOptions,
    },
    LocalStorageEpoch,
    LocalStorageIsDirty,
    TryFlush,
    Flush,
    Finish,
}

Operations represents Hummock operations

Variants

Get

Get operation of Hummock.

Fields

key: TracedBytes

Key to retrieve.

epoch: Option<u64>

Optional epoch value.

read_options: TracedReadOptions

Read options for the operation.

Insert

Insert operation of Hummock.

Fields

key: TracedBytes

Key to insert.

new_val: TracedBytes

New value to insert.

old_val: Option<TracedBytes>

Optional old value to replace.

Delete

Delete operation of Hummock.

Fields

key: TracedBytes

Key to delete.

old_val: TracedBytes

Value to match for deletion.

Iter

Iter operation of Hummock.

Fields

key_range: TracedIterRange

Key range for iteration.

epoch: Option<u64>

Optional epoch value.

read_options: TracedReadOptions

Read options for the operation.

IterNext(RecordId)

Iter.next operation of Hummock.

Sync(Vec<(u64, Vec<u32>)>)

Sync operation of Hummock.

MetaMessage(Box<TracedSubResp>)

MetaMessage operation of Hummock.

Result(OperationResult)

Result operation of Hummock.

NewLocalStorage(TracedNewLocalOptions, LocalStorageId)

NewLocalStorage operation of Hummock.

DropLocalStorage

DropLocalStorage operation of Hummock.

LocalStorageInit(TracedInitOptions)

Init of a local storage

TryWaitEpoch(TracedHummockReadEpoch, TracedTryWaitEpochOptions)

Try wait epoch

SealCurrentEpoch

Seal current epoch

Fields

epoch: u64

opts: TracedSealCurrentEpochOptions

LocalStorageEpoch

LocalStorageIsDirty

TryFlush

Flush

Finish

Finish operation of Hummock.

Implementations

impl Operation

pub fn get( key: Bytes, epoch: Option<u64>, read_options: TracedReadOptions, ) -> Operation

pub fn insert(key: Bytes, new_val: Bytes, old_val: Option<Bytes>) -> Operation

Trait Implementations

impl<'__de> BorrowDecode<'__de> for Operation

fn borrow_decode<__D: BorrowDecoder<'__de>>( decoder: &mut __D, ) -> Result<Self, DecodeError>

Attempt to decode this type with the given BorrowDecode.

impl Clone for Operation

fn clone(&self) -> Operation

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Operation

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

Formats the value using the given formatter.

impl Decode for Operation

fn decode<__D: Decoder>(decoder: &mut __D) -> Result<Self, DecodeError>

Attempt to decode this type with the given Decode.

impl Encode for Operation

fn encode<__E: Encoder>(&self, encoder: &mut __E) -> Result<(), EncodeError>

Encode a given type.

impl PartialEq for Operation

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Operation