Module cernan::source

Staging ground for all sources

In cernan a Source is a place where all metric::Event come from, feeding down into the source's forwards for further processing. Statsd is a source that creates Telemetry, FileServer is a source that creates LogLines.

Structs

FileServer	FileServer is a Source which cooperatively schedules reads over files, converting the lines of said files into LogLine structures. As FileServer is intended to be useful across multiple operating systems with POSIX filesystem semantics FileServer must poll for changes. That is, no event notification is used by FileServer.
FileServerConfig	The configuration struct for FileServer.
FlushTimer	The source of all flush pulses.
FlushTimerConfig	Nil config for FlushTimer.
GraphiteConfig	Configured for the metric::Telemetry source.
Internal	'Internal' is a Source which is meant to allow cernan to self-telemeter. This is an improvement over past methods as an explicit Source gives operators the ability to define a filter topology for such telemetry and makes it easier for modules to report on themeselves.
InternalConfig	The configuration struct for 'Internal'
NativeServerConfig	The native source
RunnableSource	Generic interface used to capture global source configuration parameters as well as source specific parameters.
Statsd	The statsd source
StatsdConfig	Configuration for the statsd source.
StatsdParseConfig	Configuration for the statsd parser
TCP	State for a TCP backed source.
TCPConfig	Configured for the metric::Telemetry source.

Traits

Source	cernan Source, the originator of all metric::Event.
TCPStreamHandler	Simple single threaded TCP Stream handler.

Functions

report_full_telemetry

Push telemetry into the Internal queue

Type Definitions

Avro	Source for Avro events.
Graphite	Graphite protocol source
NativeServer	Source for Cernan's native protocol.