Initial version of a RabbitMQ/AMQP sink

This commit is contained in:
Thomas Roehl
2024-04-19 17:59:43 +02:00
parent 16c796a2b8
commit 157bd6f0cc
3 changed files with 387 additions and 0 deletions

View File

@@ -21,6 +21,8 @@ var AvailableSinks = map[string]func(name string, config json.RawMessage) (Sink,
"influxdb": NewInfluxSink,
"influxasync": NewInfluxAsyncSink,
"http": NewHttpSink,
"amqp": NewAmqpSink,
"rabbitmq": NewAmqpSink,
}
// Metric collector manager data structure