Trait reool::instrumentation::Instrumentation[−][src]

pub trait Instrumentation {
    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
    );

    fn checked_in_returned_connection(
        &self, 
        flight_time: Duration, 
        pool: PoolId
    );

    fn checked_in_new_connection(&self, pool: PoolId);

    fn connection_dropped(
        &self, 
        flight_time: Option<Duration>, 
        lifetime: Duration, 
        pool: PoolId
    );

    fn connection_created(
        &self, 
        connected_after: Duration, 
        total_time: Duration, 
        pool: PoolId
    );

    fn idle_inc(&self, pool: PoolId);

    fn idle_dec(&self, pool: PoolId);

    fn in_flight_inc(&self, pool: PoolId);

    fn in_flight_dec(&self, pool: PoolId);

    fn reservation_added(&self, pool: PoolId);

    fn reservation_fulfilled(
        &self, 
        reservation_time: Duration, 
        checkout_request_time: Duration, 
        pool: PoolId
    );

    fn reservation_not_fulfilled(
        &self, 
        reservation_time: Duration, 
        checkout_request_time: Duration, 
        pool: PoolId
    );

    fn reservation_limit_reached(&self, pool: PoolId);

    fn connection_factory_failed(&self, pool: PoolId);

    fn internal_message_received(&self, latency: Duration, pool: PoolId);

    fn checkout_message_received(&self, latency: Duration, pool: PoolId);

    fn relevant_message_processed(
        &self, 
        processing_time: Duration, 
        pool: PoolId
    );
}

A trait with methods that get called by the pool on certain events.

Required methods

fn pool_added(&self, pool: PoolId)[src]

fn pool_removed(&self, pool: PoolId)[src]

fn checked_out_connection(
    &self,
    idle_for: Duration,
    time_since_checkout_request: Duration,
    pool: PoolId
)[src]

A connection was checked out

fn checked_in_returned_connection(&self, flight_time: Duration, pool: PoolId)[src]

A connection that was previously checked out was checked in again

fn checked_in_new_connection(&self, pool: PoolId)[src]

A newly created connection was checked in

fn connection_dropped(
    &self,
    flight_time: Option<Duration>,
    lifetime: Duration,
    pool: PoolId
)[src]

A connection was dropped because it was marked as defect

fn connection_created(
    &self,
    connected_after: Duration,
    total_time: Duration,
    pool: PoolId
)[src]

A new connection was created

fn idle_inc(&self, pool: PoolId)[src]

The number of idle connections increased by 1

fn idle_dec(&self, pool: PoolId)[src]

The number of idle connections decreased by 1

fn in_flight_inc(&self, pool: PoolId)[src]

The number of in flight connections increased by 1

fn in_flight_dec(&self, pool: PoolId)[src]

The number of in flight connections decreased by 1

fn reservation_added(&self, pool: PoolId)[src]

A reservation has been enqueued

fn reservation_fulfilled(
    &self,
    reservation_time: Duration,
    checkout_request_time: Duration,
    pool: PoolId
)[src]

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

fn reservation_not_fulfilled(
    &self,
    reservation_time: Duration,
    checkout_request_time: Duration,
    pool: PoolId
)[src]

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

fn reservation_limit_reached(&self, pool: PoolId)[src]

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)[src]

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)[src]

A pool internal message was received

fn checkout_message_received(&self, latency: Duration, pool: PoolId)[src]

fn relevant_message_processed(&self, processing_time: Duration, pool: PoolId)[src]

Loading content...

Implementors

impl Instrumentation for StateCountersInstrumentation[src]

Loading content...