Skip to main content

Event

Enum Event 

Source
#[non_exhaustive]
pub enum Event<'a> {
Show 23 variants Connect { host: &'a str, port: u16, }, Authenticated { user: &'a str, }, Disconnect { reason: DisconnectReason, }, PrepareStart { name: &'a str, sql: &'a str, }, PrepareFinish { name: &'a str, param_oids: &'a [u32], col_count: u16, duration: Duration, cache_hit: bool, }, ExecuteStart { stmt: StmtRef<'a>, param_count: usize, }, ExecuteFinish { stmt: StmtRef<'a>, rows: u64, duration: Duration, outcome: Outcome<'a>, }, PipelineStart { batch_len: usize, }, PipelineFlush { batch_len: usize, total_duration: Duration, }, TxBegin { isolation: Option<IsolationLevel>, }, TxCommit { duration: Duration, }, TxRollback { duration: Duration, reason: RollbackReason<'a>, }, PoolAcquireStart { pending: usize, }, PoolAcquireFinish { wait: Duration, outcome: AcquireOutcome, }, PoolRelease, Notice { severity: &'a str, code: &'a str, message: &'a str, }, Notification { channel: &'a str, payload: &'a str, pid: i32, }, QueryMacro { macro_name: &'a str, query_id: &'a str, sql: &'a str, }, ReducerBegin { name: &'a str, }, ReducerCommit { name: &'a str, duration: Duration, }, ReducerRollback { name: &'a str, error: &'a str, }, MigrationApply { version: &'a str, duration: Duration, checksum: &'a str, }, MigrationDrift { version: &'a str, recorded: &'a str, current: &'a str, },
}

Variants (Non-exhaustive)§

This enum is marked as non-exhaustive
Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.
§

Connect

Fields

§host: &'a str
§port: u16
§

Authenticated

Fields

§user: &'a str
§

Disconnect

Fields

§

PrepareStart

Fields

§name: &'a str
§sql: &'a str
§

PrepareFinish

Fields

§name: &'a str
§param_oids: &'a [u32]
§col_count: u16
§duration: Duration
§cache_hit: bool
§

ExecuteStart

Fields

§stmt: StmtRef<'a>
§param_count: usize
§

ExecuteFinish

Fields

§stmt: StmtRef<'a>
§rows: u64
§duration: Duration
§outcome: Outcome<'a>
§

PipelineStart

Fields

§batch_len: usize
§

PipelineFlush

Fields

§batch_len: usize
§total_duration: Duration
§

TxBegin

Fields

§

TxCommit

Fields

§duration: Duration
§

TxRollback

Fields

§duration: Duration
§reason: RollbackReason<'a>
§

PoolAcquireStart

Fields

§pending: usize
§

PoolAcquireFinish

Fields

§

PoolRelease

§

Notice

Fields

§severity: &'a str
§code: &'a str
§message: &'a str
§

Notification

Fields

§channel: &'a str
§payload: &'a str
§pid: i32
§

QueryMacro

Fields

§macro_name: &'a str
§query_id: &'a str
§sql: &'a str
§

ReducerBegin

Fields

§name: &'a str
§

ReducerCommit

Fields

§name: &'a str
§duration: Duration
§

ReducerRollback

Fields

§name: &'a str
§error: &'a str
§

MigrationApply

Fields

§version: &'a str
§duration: Duration
§checksum: &'a str
§

MigrationDrift

Fields

§version: &'a str
§recorded: &'a str
§current: &'a str

Auto Trait Implementations§

§

impl<'a> Freeze for Event<'a>

§

impl<'a> !RefUnwindSafe for Event<'a>

§

impl<'a> Send for Event<'a>

§

impl<'a> Sync for Event<'a>

§

impl<'a> Unpin for Event<'a>

§

impl<'a> UnsafeUnpin for Event<'a>

§

impl<'a> !UnwindSafe for Event<'a>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more