Type Alias LogsArchiveReader

pub type LogsArchiveReader = ArchiveReader<Logs>;

Alias for ArchiveReader. Used for reading logs.

Aliased Type

struct LogsArchiveReader { /* private fields */ }

Implementations

impl ArchiveReader<Logs>

pub fn logs() -> Self

Creates an ArchiveReader for reading logs

pub async fn snapshot(&self) -> Result<Vec<Data<Logs>>, Error>

Connects to the ArchiveAccessor and returns data matching provided selectors.

pub fn snapshot_then_subscribe(&self) -> Result<Subscription, Error>

Connects to the ArchiveAccessor and returns a stream of data containing a snapshot of the current buffer in the Archivist as well as new data that arrives.

impl<T: DiagnosticsDataType> ArchiveReader<T>

pub fn with_archive(&mut self, archive: ArchiveAccessorProxy) -> &mut Self

Initializes the ArchiveReader with a custom connection to an ArchiveAccessor. By default, the connection will be initialized by connecting to fuchsia.diagnostics.ArchiveAccessor

pub fn with_minimum_schema_count( &mut self, minimum_schema_count: usize, ) -> &mut Self

Sets the minimum number of schemas expected in a result in order for the result to be considered a success.

pub fn retry(&mut self, config: RetryConfig) -> &mut Self

Sets a custom retry configuration. By default we always retry.

pub fn with_timeout(&mut self, duration: MonotonicDuration) -> &mut Self

Sets the maximum time to wait for a response from the Archive. Do not use in tests unless timeout is the expected behavior.

pub fn select_all_for_component( &mut self, component: impl ToComponentSelectorArguments, ) -> &mut Self

Filters logs for a specific component or component selector. If string input, the string may be either a component selector string or a moniker, or a ComponentSelector may be passed directly.