Struct goodmetrics::downstream::GoodmetricsDownstream

pub struct GoodmetricsDownstream<TChannel> { /* private fields */ }

A downstream that sends metrics to a goodmetricsd or other goodmetrics grpc server.

Implementations

impl<TChannel> GoodmetricsDownstream<TChannel>

where TChannel: GrpcService<BoxBody>, TChannel::Error: Into<Box<dyn Error + Send + Sync + 'static>>, TChannel::ResponseBody: Body<Data = Bytes> + Send + 'static, <TChannel::ResponseBody as Body>::Error: Into<Box<dyn Error + Send + Sync + 'static>> + Send,

pub fn new( channel: TChannel, shared_dimensions: impl IntoIterator<Item = (impl Into<String>, impl Into<Dimension>)>, ) -> Self

Create a new goodmetrics sender from a grpc channel

pub async fn send_batches_forever(self, receiver: Receiver<Vec<Datum>>)

Spawn this on a tokio runtime to send your metrics to your downstream receiver