Trait tk_pool::metrics::Collect [−] [src]

pub trait Collect: Clone + Send + Sync {
    fn connection_attempt(&self) { ... }

    fn connection_error(&self) { ... }

    fn connection_abort(&self) { ... }

    fn connection(&self) { ... }

    fn disconnect(&self) { ... }

    fn blacklist_add(&self) { ... }

    fn blacklist_remove(&self) { ... }

    fn request_queued(&self) { ... }

    fn request_forwarded(&self) { ... }

    fn pool_closed(&self) { ... }
}

An object implementing trait may collect metrics of a connection pool

Provided Methods

We started establishing connection

This pairs either with connection on success or connection_abort and connection_error on error

Error establishing connection

Aborted connection attempt (name changed, and doesn't include address)

Connection established successfully

Connection closed (usully means name changed)

Host address added to a blacklist (i.e. connection error)

Host address removed from a blacklist

Note this callback is only called when we're searching for a new connection and all others are busy. I.e. unlisting a host from a blacklist may be delayed arbitrarily when not under backpressure. This may be fixed in future.

Request queued in the internal queue

Request unqueued from the internal queue and forwarded to a sink

Note: this might not mean that request is already sent as we can't control the underlying sinks used.

Connection pool is closed

Implementors