Struct reool::instrumentation::StateCountersInstrumentation

pub struct StateCountersInstrumentation { /* fields omitted */ }

Trait Implementations

impl Instrumentation for StateCountersInstrumentation

fn pool_added(&self, pool: PoolId)

fn pool_removed(&self, pool: PoolId)

fn checked_out_connection(
    &self,
    _idle_for: Duration,
    _time_since_checkout_request: Duration,
    pool: PoolId
)

A connection was checked out

fn checked_in_returned_connection(&self, _flight_time: Duration, pool: PoolId)

A connection that was previously checked out was checked in again

fn checked_in_new_connection(&self, pool: PoolId)

A newly created connection was checked in

fn connection_dropped(
    &self,
    _flight_time: Option<Duration>,
    _lifetime: Duration,
    pool: PoolId
)

A connection was dropped because it was marked as defect

fn connection_created(
    &self,
    _connected_after: Duration,
    _total_time: Duration,
    _pool: PoolId
)

A new connection was created

fn idle_inc(&self, pool: PoolId)

The number of idle connections increased by 1

fn idle_dec(&self, pool: PoolId)

The number of idle connections decreased by 1

fn in_flight_inc(&self, pool: PoolId)

The number of in flight connections increased by 1

fn in_flight_dec(&self, pool: PoolId)

The number of in flight connections decreased by 1

fn reservation_added(&self, pool: PoolId)

A reservation has been enqueued

fn reservation_fulfilled(
    &self,
    _reservation_time: Duration,
    _checkout_request_time: Duration,
    pool: PoolId
)

A reservation was fulfilled. A connection was available in time.

fn reservation_not_fulfilled(
    &self,
    _reservation_time: Duration,
    _checkout_request_time: Duration,
    pool: PoolId
)

A reservation was not fulfilled. A connection was mostly not available in time.

fn reservation_limit_reached(&self, pool: PoolId)

The reservation queue has a limit and that limit was just reached. This means a checkout has instantaneously failed.

fn connection_factory_failed(&self, pool: PoolId)

The connection factory was asked to create a new connection but it failed to do so.

fn internal_message_received(&self, _latency: Duration, _pool: PoolId)

A pool internal message was received

fn checkout_message_received(&self, _latency: Duration, _pool: PoolId)

fn relevant_message_processed(&self, _processing_time: Duration, _pool: PoolId)