Module cernan::sink[−][src]

A 'sink' is a final destination for telemetry and log lines. That is, a 'sink' is that which is at the end of a source -> filter -> filter -> ... -> sink chain. The sink has no obligations with regard to the telemetry and log lines it receives, other than to receive them. Individual sinks make different choices.

Re-exports

pub use self::elasticsearch::Elasticsearch;

pub use self::elasticsearch::ElasticsearchConfig;

pub use self::influxdb::InfluxDB;

pub use self::influxdb::InfluxDBConfig;

pub use self::kafka::Kafka;

pub use self::kafka::KafkaConfig;

pub use self::prometheus::Prometheus;

pub use self::prometheus::PrometheusConfig;

pub use self::wavefront::Wavefront;

pub use self::wavefront::WavefrontConfig;

Modules

elasticsearch	`ElasticSearch` is a documentation indexing engine.
influxdb	`InfluxDB` is a telemetry database.
kafka	Kafka sink for Raw events.
prometheus	Prometheus is a pull-based aggregation server
wavefront	Wavefront is a proprietary aggregation and alerting product

Structs

Console	The 'console' sink exists for development convenience. The sink will aggregate according to buckets method and print each `flush-interval` to stdout.
ConsoleConfig	The configuration struct for Console. There's not a whole lot to configure here, independent of other sinks, but Console does do aggregations and that requires knowing what the user wants for `bin_width`.
Native	The native sink
NativeConfig	Configuration for the native sink
Null	Null sink
NullConfig	Configuration for the `Null` sink
RunnableSink	Generic interface used to capture global sink configuration parameters as well as sink specific parameters.

Traits

Sink	A 'sink' is a sink for metrics.