Struct TraceSpan

pub struct TraceSpan {
    tx: UnboundedSender<RecordMsg>,
    id: RecordId,
    storage_type: StorageType,
}

TraceSpan traces hummock operations. It marks the beginning of an operation and the end when the span is dropped. So, please make sure the span live long enough. Underscore binding like let _ = span will drop the span immediately.

Fields

tx: UnboundedSender<RecordMsg>

id: RecordId

storage_type: StorageType

Implementations

impl TraceSpan

pub fn new( tx: Sender<RecordMsg>, id: RecordId, storage_type: StorageType, ) -> Self

pub fn new_global_op(op: Operation, storage_type: StorageType) -> MayTraceSpan

pub fn new_epoch_span(storage_type: StorageType) -> MayTraceSpan

pub fn new_is_dirty_span(storage_type: StorageType) -> MayTraceSpan

pub fn new_seal_current_epoch_span( epoch: u64, opts: TracedSealCurrentEpochOptions, storage_type: StorageType, ) -> MayTraceSpan

pub fn new_try_wait_epoch_span( epoch: HummockReadEpoch, options: TracedTryWaitEpochOptions, ) -> MayTraceSpan

pub fn new_get_span( key: Bytes, epoch: Option<u64>, read_options: TracedReadOptions, storage_type: StorageType, ) -> MayTraceSpan

pub fn new_iter_span( key_range: (Bound<Bytes>, Bound<Bytes>), epoch: Option<u64>, read_options: TracedReadOptions, storage_type: StorageType, ) -> MayTraceSpan

pub fn new_insert_span( key: Bytes, new_val: Bytes, old_val: Option<Bytes>, storage_type: StorageType, ) -> MayTraceSpan

pub fn new_delete_span( key: Bytes, old_val: Bytes, storage_type: StorageType, ) -> MayTraceSpan

pub fn new_sync_span( sync_table_epochs: &Vec<(HummockEpoch, HashSet<TableId>)>, storage_type: StorageType, ) -> MayTraceSpan

pub fn new_local_storage_span( option: TracedNewLocalOptions, storage_type: StorageType, local_storage_id: u64, ) -> MayTraceSpan

pub fn new_drop_storage_span(storage_type: StorageType) -> MayTraceSpan

pub fn new_flush_span(storage_type: StorageType) -> MayTraceSpan

pub fn new_try_flush_span(storage_type: StorageType) -> MayTraceSpan

pub fn new_meta_message_span(resp: SubscribeResponse) -> MayTraceSpan

pub fn new_local_storage_init_span( options: TracedInitOptions, storage_type: StorageType, ) -> MayTraceSpan

pub fn send(&self, op: Operation)

pub fn send_result(&self, res: OperationResult)

pub fn finish(&self)

pub fn id(&self) -> RecordId

fn storage_type(&self) -> &StorageType

pub fn new_to_global(op: Operation, storage_type: StorageType) -> Self

Create a span and send operation to the GLOBAL_COLLECTOR

Trait Implementations

impl Clone for TraceSpan

fn clone(&self) -> TraceSpan

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Drop for TraceSpan

fn drop(&mut self)

Executes the destructor for this type.