Struct LogSink 

pub struct LogSink { /* private fields */ }

Reads a daemon’s output on stdin and writes it to the log store

Spawned by the supervisor as a sibling of the daemon, holding the read end of the daemon’s output pipe. Keeping the reader in its own process is what makes logging survive a supervisor crash: the pipe still has a reader, so the daemon is neither killed by SIGPIPE nor blocked, and no output is lost. Exits when the pipe reaches end of file, which happens once the daemon and every descendant holding the write end have gone.

Implementations

impl LogSink

pub async fn run(&self) -> Result<()>

Trait Implementations

impl CommandArgs for LogSink

const COMMAND: &'static Command<'static>

The parse tables for this command.

const META: &'static CommandMeta<'static>

The metadata for this command.

type Partial = Partial

Values collected so far. Partly-filled by construction, since a parse can stop early.

fn start() -> Self::Partial

A partial with any declared defaults already in place.

fn apply(partial: &mut Self::Partial, event: &Event<'_, '_, '_>) -> bool

Take one event, and say whether it belonged to this command.

fn apply_mirrored_global( partial: &mut Self::Partial, event: &Event<'_, '_, '_>, ) -> bool

Mirror a redeclared child flag’s value into this command’s matching global field.

fn deprecations(partial: &Self::Partial, out: &mut Vec<Warning<'static>>)

The deprecated declarations this command line actually used.

fn check<'t, 'v>(partial: &mut Self::Partial) -> Result<(), Error<'t, 'v>>

Everything this command decides after the last token: required-ness, choices, and how many values a variadic got.

fn check_with_args_override_self<'t, 'v>( partial: &mut Self::Partial, args_override_self: bool, ) -> Result<(), Error<'t, 'v>>

Run checks under the repeat policy of the command that composed these args.

fn check_with_args_override_self_for_view<'t, 'v>( partial: &mut Self::Partial, args_override_self: bool, view: Option<&'static ViewMeta<'static>>, ) -> Result<(), Error<'t, 'v>>

Run checks under a parent command’s repeat policy and executable projection.

fn check_update<'t, 'v>( partial: &mut Self::Partial, standing: &Self, ) -> Result<(), Error<'t, 'v>>

CommandArgs::check against the union of this argv and what the caller had.

fn check_update_with_args_override_self<'t, 'v>( partial: &mut Self::Partial, args_override_self: bool, standing: &Self, ) -> Result<(), Error<'t, 'v>>

CommandArgs::check_with_args_override_self against the same union.

fn any_given(partial: &Self::Partial) -> Option<&'static str>

One declaration in this command that ended up being given, if any.

fn exclusive_given(partial: &Self::Partial) -> Option<&'static str>

One exclusive flag in this command that was given, if any.

fn argument_state( partial: &Self::Partial, selector: &str, ) -> Option<ArgumentState>

Find an argument by any selector it accepts.

fn canonical_selector(selector: &str) -> Option<&'static str>

The portable spelling for a selector accepted by this typed command.

fn argument_matches( partial: &Self::Partial, selector: &str, value: &[u8], ) -> Option<bool>

Whether a selected argument has an explicitly supplied value.

fn standing_state(standing: &Self, selector: &str) -> Option<ArgumentState>

Find an argument by selector in a value the caller already holds.

fn standing_matches( standing: &Self, selector: &str, value: &[u8], ) -> Option<bool>

Whether an argument in a value the caller already holds matches value.

fn displace(partial: &mut Self::Partial, selector: &str) -> bool

Reset the flag named by selector after an overriding token wins.

fn event_matches(event: &Event<'_, '_, '_>, selector: &str) -> bool

Whether this event binds the flag named by selector.

fn any_standing(__usage_s: &Self) -> Option<&'static str>

One declaration in this command whose value the caller already had.

fn apply_defaults(partial: &mut Self::Partial)

Fill fields in this command from their declared defaults.

fn apply_defaults_for_view( partial: &mut Self::Partial, __usage_view: Option<&'static ViewMeta<'static>>, )

Fill defaults for fields visible through an executable view.

fn apply_defaults_update(partial: &mut Self::Partial, standing: &Self)

CommandArgs::apply_defaults, filling only what the caller does not already have.

fn apply_env(partial: &mut Self::Partial)

Fill fields in this command from their declared environment variables.

fn apply_env_for_view( partial: &mut Self::Partial, __usage_view: Option<&'static ViewMeta<'static>>, )

Fill environment fallbacks for fields visible through an executable view.

fn apply_env_update(partial: &mut Self::Partial, standing: &Self)

CommandArgs::apply_env, filling only what the caller does not already have.

fn omit_own_for_view(partial: &mut Self::Partial)

Mark this command’s own fields as outside an injected executable-view path.

fn build<'t, 'v>(partial: Self::Partial) -> Result<Self, Error<'t, 'v>>

Build the struct from what was collected.

fn merge<'t, 'v>( partial: Self::Partial, standing: &mut Self, ) -> Result<(), Error<'t, 'v>>

Overwrite the fields this argv gave, and leave the rest of standing alone.

const SETTINGS_BINDINGS: &'static [(&'static str, &'static str)] = _

Every flag this command reads into a setting, and the setting it sets.

fn settings_given(partial: &Self::Partial) -> Vec<(&'static str, SettingGiven)>

The settings this command line gave values for.

fn deprecations_for_view_path( partial: &Self::Partial, remaining_descendants: usize, out: &mut Vec<Warning<'static>>, )

Report deprecations while traversing the injected parents of a view.

fn apply_env_for_view_path( partial: &mut Self::Partial, remaining_descendants: usize, )

Fill environment fallbacks while traversing the injected parents of a view.

fn check_for_view_path<'t, 'v>( partial: &mut Self::Partial, remaining_descendants: usize, ) -> Result<(), Error<'t, 'v>>

Check a command while traversing the injected parents of a view.

impl Debug for LogSink

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

Formats the value using the given formatter.

impl<__UsageOmitter> ViewCommandArgs<__UsageOmitter> for LogSink

where __UsageOmitter: Omitted<String> + Omitted<Option<String>> + Omitted<u64> + Omitted<bool>,

fn build_for_view<'t, 'v>(partial: Self::Partial) -> Result<Self, Error<'t, 'v>>