Struct MetricEventLoggerQuerierProxy

pub struct MetricEventLoggerQuerierProxy { /* private fields */ }

Implementations

impl MetricEventLoggerQuerierProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for fuchsia.metrics.test/MetricEventLoggerQuerier.

pub fn take_event_stream(&self) -> MetricEventLoggerQuerierEventStream

Get a Stream of events from the remote end of the protocol.

Panics

Panics if the event stream was already taken.

pub fn watch_logs( &self, project_id: u32, method: LogMethod, ) -> QueryResponseFut<(Vec<MetricEvent>, bool), DefaultFuchsiaResourceDialect>

Returns the first N events that were logged for the logger with the given project_id and a more flag indicating whether there were more than N events logged. There is no way to retrieve events logged after the first N events.

Will hang until at least one metrics metric is recorded for the given project_id and method.

Repeated calls to WatchLogs for a given LogMethod will block until new events are logged with that method, enabling tests to synchronize without sleeps or timeouts.

pub fn reset_logger( &self, project_id: u32, method: LogMethod, ) -> Result<(), Error>

Clear all logged events by logging method for the logger with the given project_id.

This is a no-op if a logger for the given project_id does not exist. Notably, it does not create a new logger with project_id if one does not already exist.

Trait Implementations

impl Clone for MetricEventLoggerQuerierProxy

fn clone(&self) -> MetricEventLoggerQuerierProxy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MetricEventLoggerQuerierProxy

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

Formats the value using the given formatter.

impl MetricEventLoggerQuerierProxyInterface for MetricEventLoggerQuerierProxy

type WatchLogsResponseFut = QueryResponseFut<(Vec<MetricEvent>, bool)>

fn watch_logs( &self, project_id: u32, method: LogMethod, ) -> Self::WatchLogsResponseFut

fn reset_logger(&self, project_id: u32, method: LogMethod) -> Result<(), Error>

impl Proxy for MetricEventLoggerQuerierProxy

type Protocol = MetricEventLoggerQuerierMarker

The protocol which this Proxy controls.

fn from_channel(inner: AsyncChannel) -> Self

Create a proxy over the given channel.

fn into_channel(self) -> Result<AsyncChannel, Self>

Attempt to convert the proxy back into a channel.

fn as_channel(&self) -> &AsyncChannel

Get a reference to the proxy’s underlying channel.

fn into_client_end(self) -> Result<ClientEnd<Self::Protocol>, Self>

Attempt to convert the proxy back into a client end.

fn is_closed(&self) -> bool

Returns true if the proxy has received the PEER_CLOSED signal.

fn on_closed(&self) -> OnSignals<'_, Unowned<'_, Handle>>

Returns a future that completes when the proxy receives the PEER_CLOSED signal.