Struct scylla::history::HistoryCollector

pub struct HistoryCollector { /* private fields */ }

HistoryCollector can be used as HistoryListener to collect all the query history events. Each event is marked with an UTC timestamp.

Implementations

impl HistoryCollector

pub fn new() -> HistoryCollector

Creates a new HistoryCollector with empty data.

pub fn clone_collected(&self) -> HistoryCollectorData

Clones the data collected by the collector.

pub fn take_collected(&self) -> HistoryCollectorData

Takes the data out of the collector. The collected events are cleared.
It’s possible that after finishing a query and taking out the events new ones will still come - from queries that haven’t been cancelled yet.

pub fn clone_structured_history(&self) -> StructuredHistory

Clone the collected events and convert them to StructuredHistory.

pub fn take_structured_history(&self) -> StructuredHistory

Take the collected events out, just like in take_collected and convert them to StructuredHistory.

Trait Implementations

impl Debug for HistoryCollector

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

Formats the value using the given formatter.

impl Default for HistoryCollector

fn default() -> HistoryCollector

Returns the “default value” for a type.

impl HistoryListener for HistoryCollector

fn log_query_start(&self) -> QueryId

Log that a query has started on query start - right after the call to Session::{query,execute}_*/batch.

fn log_query_success(&self, query_id: QueryId)

Log that query was successful - called right before returning the result from Session::query_, execute_, etc.

fn log_query_error(&self, query_id: QueryId, error: &QueryError)

Log that query ended with an error - called right before returning the error from Session::query_, execute_, etc.

fn log_new_speculative_fiber(&self, query_id: QueryId) -> SpeculativeId

Log that a new speculative fiber has started.

fn log_attempt_start( &self, query_id: QueryId, speculative_id: Option<SpeculativeId>, node_addr: SocketAddr, ) -> AttemptId

Log that an attempt has started - request has been sent on some Connection, now awaiting for an answer.

fn log_attempt_success(&self, attempt_id: AttemptId)

Log that an attempt succeeded.

fn log_attempt_error( &self, attempt_id: AttemptId, error: &QueryError, retry_decision: &RetryDecision, )

Log that an attempt ended with an error. The error and decision whether to retry the attempt are also included in the log.