Struct cernan::config::Args

pub struct Args {
    pub max_hopper_in_memory_bytes: usize,
    pub max_hopper_queue_files: usize,
    pub max_hopper_queue_bytes: usize,
    pub data_directory: PathBuf,
    pub scripts_directory: PathBuf,
    pub flush_interval: u64,
    pub version: String,
    pub programmable_filters: Option<HashMap<String, ProgrammableFilterConfig>>,
    pub delay_filters: Option<HashMap<String, DelayFilterConfig>>,
    pub json_encode_filters: Option<HashMap<String, JSONEncodeFilterConfig>>,
    pub flush_boundary_filters: Option<HashMap<String, FlushBoundaryFilterConfig>>,
    pub console: Option<ConsoleConfig>,
    pub null: Option<NullConfig>,
    pub wavefront: Option<WavefrontConfig>,
    pub influxdb: Option<InfluxDBConfig>,
    pub native_sink_config: Option<NativeConfig>,
    pub prometheus: Option<PrometheusConfig>,
    pub elasticsearch: Option<ElasticsearchConfig>,
    pub kafkas: Option<Vec<KafkaConfig>>,
    pub files: Option<Vec<FileServerConfig>>,
    pub internal: InternalConfig,
    pub graphites: Option<HashMap<String, GraphiteConfig>>,
    pub avros: Option<HashMap<String, TCPConfig>>,
    pub native_server_config: Option<HashMap<String, NativeServerConfig>>,
    pub statsds: Option<HashMap<String, StatsdConfig>>,
}

Big configuration struct for cernan executable

This struct is what we construct from parsing the cernan configuration. It is not intended to be created by external clients. Please see documentation on parse_args in this module for more details.

Fields

max_hopper_in_memory_bytes: usize

The maximum size -- in bytes -- that a hopper queue may hold in memory before flushing to disk.

max_hopper_queue_files: usize

The maximum number of queue files that hopper may hold on disk. The maximum disk consumption of a single hopper queue will be max_hopper_queue_files * max_hopper_queue_bytes.

max_hopper_queue_bytes: usize

The maximum size -- in bytes -- that a hopper queue may grow to before being cycled.

data_directory: PathBuf

The location on-disk where cernan will store its private files. This directory MUST be solely owned by cernan.

scripts_directory: PathBuf

The location on-disk where cernan will search for programmable filter scripts.

flush_interval: u64

The global flush interval. This value is inherited by all sinks which do not specify their own.

version: String

Cernan version string. This is set automatically.

programmable_filters: Option<HashMap<String, ProgrammableFilterConfig>>

The programmable filters to use in this cernan run. See filters::ProgrammableFilter for more.

delay_filters: Option<HashMap<String, DelayFilterConfig>>

The delay filters to use in this cernan run. See filters::DelayFilter for more.

json_encode_filters: Option<HashMap<String, JSONEncodeFilterConfig>>

The json_encode filters to use in this cernan run. See filters::JSONEncodeFilter for more.

flush_boundary_filters: Option<HashMap<String, FlushBoundaryFilterConfig>>

The flush boundaryfilters to use in this cernan run. See filters::FlushBoundaryFilter for more.

console: Option<ConsoleConfig>

See sinks::Console for more.

null: Option<NullConfig>

See sinks::Null for more.

wavefront: Option<WavefrontConfig>

See sinks::Wavefront for more.

influxdb: Option<InfluxDBConfig>

See sinks::InfluxDB for more.

native_sink_config: Option<NativeConfig>

See sinks::Native for more.

prometheus: Option<PrometheusConfig>

See sinks::Prometheus for more.

elasticsearch: Option<ElasticsearchConfig>

See sinks::Elasticsearch for more.

kafkas: Option<Vec<KafkaConfig>>

See sinks::Kafka for more.

files: Option<Vec<FileServerConfig>>

See sources::FileServer for more.

internal: InternalConfig

See sources::Internal for more.

graphites: Option<HashMap<String, GraphiteConfig>>

See sources::Graphite for more.

avros: Option<HashMap<String, TCPConfig>>

See sources::Avro for more.

native_server_config: Option<HashMap<String, NativeServerConfig>>

See sources::Native for more.

statsds: Option<HashMap<String, StatsdConfig>>

See sources::Statsd for more.

Trait Implementations

impl Debug for Args

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Default for Args

fn default() -> Self

Returns the "default value" for a type.