risingwave_common_metrics::monitor::connection

Trait EndpointExt

source
pub trait EndpointExt {
    // Required methods
    async fn monitored_connect(
        self,
        _: impl Into<String>,
        _: TcpConfig,
    ) -> Result<Channel, Error>;
    fn monitored_connect_lazy(
        self,
        _: impl Into<String>,
        _: TcpConfig,
    ) -> Channel;
}

Required Methods§

Object Safety§

This trait is not object safe.

Implementations on Foreign Types§

source§

impl EndpointExt for Endpoint

source§

async fn monitored_connect( self, connection_type: impl Into<String>, config: TcpConfig, ) -> Result<Channel, Error>

source§

fn monitored_connect_lazy( self, connection_type: impl Into<String>, config: TcpConfig, ) -> Channel

Implementors§