Struct LogsArtifactsContainer 

pub struct LogsArtifactsContainer {
    pub identity: Arc<ComponentIdentity>,
    pub stats: Arc<LogStreamStats>,
    /* private fields */
}

Fields

identity: Arc<ComponentIdentity>

The source of logs in this container.

stats: Arc<LogStreamStats>

Inspect instrumentation.

Implementations

impl LogsArtifactsContainer

pub fn new<'a>( identity: Arc<ComponentIdentity>, interest_selectors: impl Iterator<Item = &'a LogInterestSelector>, initial_interest: Option<FidlSeverity>, stats: Arc<LogStreamStats>, buffer: ContainerBuffer, on_inactive: Option<OnInactive>, ) -> Self

pub fn handle_log_sink( self: &Arc<Self>, stream: LogSinkRequestStream, scope: ScopeHandle, )

Handle LogSink protocol on stream. Each socket received from the LogSink client is drained by a Task which is sent on sender. The Tasks do not complete until their sockets have been closed.

pub fn ingest_message(&self, message: StoredMessage)

Updates log stats in inspect and push the message onto the container’s buffer.

pub fn update_interest<'a>( &self, interest_selectors: impl Iterator<Item = &'a LogInterestSelector>, previous_selectors: &[LogInterestSelector], )

Set the Interest for this component, notifying all active LogSink/WaitForInterestChange hanging gets with the new interset if it is a change from the previous interest. For any match that is also contained in previous_selectors, the previous values will be removed from the set of interests.

pub fn reset_interest(&self, interest_selectors: &[LogInterestSelector])

Resets the Interest for this component, notifying all active LogSink/WaitForInterestChange hanging gets with the lowest interest found in the set of requested interests for all control handles.

pub fn is_active(&self) -> bool

Returns true if this container corresponds to a running component, or still has pending objects to drain.

pub fn terminate(&self)

Stop accepting new messages, ensuring that pending Cursors return Poll::Ready(None) after consuming any messages received before this call.

pub fn buffer(&self) -> &ContainerBuffer

Trait Implementations

impl Debug for LogsArtifactsContainer

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

Formats the value using the given formatter.