Struct mz_orchestrator_tracing::TracingCliArgs

pub struct TracingCliArgs {

    pub log_filter: SerializableTargets,
    pub log_format: LogFormat,
    pub log_prefix: Option<String>,
    pub opentelemetry_enabled: DefaultTrue,
    pub opentelemetry_endpoint: Option<String>,
    pub opentelemetry_header: Vec<KeyValueArg<HeaderName, HeaderValue>>,
    pub opentelemetry_filter: SerializableTargets,
    pub opentelemetry_resource: Vec<KeyValueArg<String, String>>,
    pub tokio_console_listen_addr: Option<SocketAddr>,
    pub tokio_console_publish_interval: Duration,
    pub tokio_console_retention: Duration,
    pub sentry_dsn: Option<String>,
    pub sentry_environment: Option<String>,
}

Command line arguments for application tracing.

These arguments correspond directly to parameters in TracingConfig, and this type can be directly converted into a TracingConfig via the supplied From<TracingCliArgs> implementation.

This logic is separated from mz_ore::tracing because the details of how these command-line arguments are parsed and unparsed is specific to orchestrators and does not belong in a foundational crate like mz_ore.

Fields

log_filter: SerializableTargets

Which tracing events to log to stderr.

This value is a comma-separated list of filter directives. Each filter directive has the following format:

[module::path=]level

A directive indicates that log messages from the specified module that are at least as severe as the specified level should be emitted. If a directive omits the module, then it implicitly applies to all modules. When directives conflict, the last directive wins. If a log message does not match any directive, it is not emitted.

The module path of a log message reflects its location in Materialize’s source code. Choosing module paths for filter directives requires familiarity with Materialize’s codebase and is intended for advanced users. Note that module paths change frequency from release to release.

The valid levels for a log message are, in increasing order of severity: trace, debug, info, warn, and error. The special level “off” may be used in a directive to suppress all log messages, even errors.

The default value for this option is “info”.

log_format: LogFormat

The format to use for stderr log messages.

log_prefix: Option<String>

An optional prefix for each stderr log line.

Only respected when --log-format is text.

opentelemetry_enabled: DefaultTrue

Whether OpenTelemetry tracing is enabled by default.

OpenTelemetry tracing can be dynamically toggled during runtime via the internal HTTP server.

Requires that the --opentelemetry-endpoint option is specified.

opentelemetry_endpoint: Option<String>

Export OpenTelemetry tracing events to the provided endpoint.

The specified endpoint should speak the OTLP/HTTP protocol. If the backend requires authentication, you can pass authentication metadata via the --opentelemetry-header option.

opentelemetry_header: Vec<KeyValueArg<HeaderName, HeaderValue>>

A header to pass with every request to the OpenTelemetry endpoint specified by --opentelemetry-endpoint in the form NAME=VALUE.

Requires that the --opentelemetry-endpoint option is specified. To specify multiple headers, either specify this option multiple times, or specify it once with multiple NAME=VALUE pairs separated by commas.

opentelemetry_filter: SerializableTargets

Which tracing events to export to the OpenTelemetry endpoint specified by --opentelemetry-endpoint.

The syntax of this option is the same as the syntax of the --log-filter option.

Requires that the --opentelemetry-endpoint option is specified.

opentelemetry_resource: Vec<KeyValueArg<String, String>>

Additional key-value pairs to send with all opentelemetry traces.

Requires that the --opentelemetry-endpoint option is specified.

tokio_console_listen_addr: Option<SocketAddr>

The address on which to listen for Tokio console connections.

For details about Tokio console, see: https://github.com/tokio-rs/console

Requires that the --tokio-console option is specified.

tokio_console_publish_interval: Duration

How frequently to publish updates to Tokio console clients.

Requires that the --tokio-console option is specified.

tokio_console_retention: Duration

How long Tokio console data is retained for completed tasks.

Requires that the --tokio-console option is specified.

sentry_dsn: Option<String>

Sentry data source to submit events and exceptions (e.g. panics) to.

sentry_environment: Option<String>

The environment name to report to Sentry.

Ignored unless the --sentry-dsn option is specified.

See: https://docs.sentry.io/platforms/rust/configuration/options/#environment

Implementations

impl TracingCliArgs

pub async fn configure_tracing( &self, __arg1: StaticTracingConfig ) -> Result<(TracingHandle, TracingGuard), Error>

Trait Implementations

impl Args for TracingCliArgs

fn augment_args<'b>(__clap_app: Command<'b>) -> Command<'b>

Append to Command so it can instantiate Self.

fn augment_args_for_update<'b>(__clap_app: Command<'b>) -> Command<'b>

Append to Command so it can update self.

impl Clone for TracingCliArgs

fn clone(&self) -> TracingCliArgs

Returns a copy of the value.

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

Performs copy-assignment from source.

impl CommandFactory for TracingCliArgs

fn into_app<'b>() -> Command<'b>

Deprecated, replaced with CommandFactory::command

fn into_app_for_update<'b>() -> Command<'b>

Deprecated, replaced with CommandFactory::command_for_update

fn command<'help>() -> App<'help>

Build a Command that can instantiate Self.

fn command_for_update<'help>() -> App<'help>

Build a Command that can update self.

impl Debug for TracingCliArgs

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

Formats the value using the given formatter.

impl Default for TracingCliArgs

fn default() -> TracingCliArgs

Returns the “default value” for a type.

impl FromArgMatches for TracingCliArgs

fn from_arg_matches(__clap_arg_matches: &ArgMatches) -> Result<Self, Error>

Instantiate Self from ArgMatches, parsing the arguments as needed.

fn from_arg_matches_mut( __clap_arg_matches: &mut ArgMatches ) -> Result<Self, Error>

Instantiate Self from ArgMatches, parsing the arguments as needed.

fn update_from_arg_matches( &mut self, __clap_arg_matches: &ArgMatches ) -> Result<(), Error>

Assign values from ArgMatches to self.

fn update_from_arg_matches_mut( &mut self, __clap_arg_matches: &mut ArgMatches ) -> Result<(), Error>

Assign values from ArgMatches to self.

impl Parser for TracingCliArgs

fn parse() -> Self

Parse from std::env::args_os(), exit on error

fn try_parse() -> Result<Self, Error>

Parse from std::env::args_os(), return Err on error.

fn parse_from<I, T>(itr: I) -> Selfwhere I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Parse from iterator, exit on error

fn try_parse_from<I, T>(itr: I) -> Result<Self, Error>where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Parse from iterator, return Err on error.

fn update_from<I, T>(&mut self, itr: I)where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Update from iterator, exit on error

fn try_update_from<I, T>(&mut self, itr: I) -> Result<(), Error>where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Update from iterator, return Err on error.