Enum ColdStoreEvent 

pub enum ColdStoreEvent {
    WriteChunkBegin {
        path: String,
        payload_len: usize,
    },
    WriteChunkComplete {
        path: String,
        object_size: u64,
    },
    DeleteChunkBegin {
        path: String,
    },
    DeleteChunkComplete {
        path: String,
    },
    RemoveAllBegin {
        path: String,
    },
    RemoveAllComplete {
        path: String,
    },
    ReadObjectRangeBegin {
        stream_id: Option<BucketStreamId>,
        path: String,
        read_start_offset: u64,
        len: usize,
        object_start: u64,
        object_end: u64,
        cached: bool,
    },
    ReadObjectRangeComplete {
        stream_id: Option<BucketStreamId>,
        path: String,
        read_start_offset: u64,
        len: usize,
        returned_len: usize,
        cached: bool,
    },
    FaultInjected {
        operation: ColdStoreOperation,
        stream_id: Option<BucketStreamId>,
        path: String,
        message: String,
    },
    DelayInjected {
        operation: ColdStoreOperation,
        stream_id: Option<BucketStreamId>,
        path: String,
        delay_ms: u64,
    },
    TruncateInjected {
        stream_id: Option<BucketStreamId>,
        path: String,
        requested_len: usize,
        returned_len: usize,
    },
}

Variants

WriteChunkBegin

Fields

path: String

payload_len: usize

WriteChunkComplete

Fields

path: String

object_size: u64

DeleteChunkBegin

Fields

path: String

DeleteChunkComplete

Fields

path: String

RemoveAllBegin

Fields

path: String

RemoveAllComplete

Fields

path: String

ReadObjectRangeBegin

Fields

stream_id: Option<BucketStreamId>

path: String

read_start_offset: u64

len: usize

object_start: u64

object_end: u64

cached: bool

ReadObjectRangeComplete

Fields

stream_id: Option<BucketStreamId>

path: String

read_start_offset: u64

len: usize

returned_len: usize

cached: bool

FaultInjected

Fields

operation: ColdStoreOperation

stream_id: Option<BucketStreamId>

path: String

message: String

DelayInjected

Fields

operation: ColdStoreOperation

stream_id: Option<BucketStreamId>

path: String

delay_ms: u64

TruncateInjected

Fields

stream_id: Option<BucketStreamId>

path: String

requested_len: usize

returned_len: usize

Trait Implementations

impl Clone for ColdStoreEvent

fn clone(&self) -> ColdStoreEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ColdStoreEvent

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

Formats the value using the given formatter.

impl Eq for ColdStoreEvent

impl PartialEq for ColdStoreEvent

fn eq(&self, other: &ColdStoreEvent) -> 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 ColdStoreEvent