Struct tempest::topology::TopologyOptions

pub struct TopologyOptions {
    pub name: String,
    pub metric_flush_interval: Option<u64>,
    pub metric_targets: Vec<MetricTarget>,
    pub graceful_shutdown: Option<u64>,
    // some fields omitted
}

Topology configuration options

Fields

name: String

Name of the topology

metric_flush_interval: Option<u64>

Metric flush interval in milliseconds This value is overridden by Topology.toml configuration.

metric_targets: Vec<MetricTarget>

Define a list of metric targets for sending metrics too. This value is overridden by Topology.toml configuration.

graceful_shutdown: Option<u64>

Graceful shutdown period

Methods

impl TopologyOptions

pub fn name(&mut self, name: &'static str)

The topology name

pub fn failure_policy(&mut self, policy: TopologyFailurePolicy)

Topology failure policy

pub fn msg_timeout(&mut self, ms: usize)

Topology message time out value. This is the maximum amount of time to wait before a source message goes into an error state.

pub fn host_port(&mut self, host_port: String)

This is the host and port value host:port (example: 127.0.0.1:5678)

pub fn agent_host_port(&mut self, host_port: String)

This is the agent host and port value host:port (example: 127.0.0.1:6789)

pub fn graceful_shutdown(&mut self, ms: u64)

The maximum amount of time to wait before a hard shutdown occurs

pub fn metric_flush_interval(&mut self, ms: u64)

The maximum amount of time to wait before a flushing accumulated metrics

pub fn metric_target(&mut self, target: MetricTarget)

Push a metric target onto the vector metric targets

Trait Implementations

impl Default for TopologyOptions

fn default() -> TopologyOptions

Returns the "default value" for a type.

impl Clone for TopologyOptions

fn clone(&self) -> TopologyOptions

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl PartialEq<TopologyOptions> for TopologyOptions

fn eq(&self, other: &TopologyOptions) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &TopologyOptions) -> bool

This method tests for !=.

impl Debug for TopologyOptions

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

Formats the value using the given formatter.