Trait console_api::instrument::instrument_server::Instrument

source · [−]
pub trait Instrument: Send + Sync + 'static {
    type WatchUpdatesStream: Stream<Item = Result<Update, Status>> + Send + 'static;
    type WatchTaskDetailsStream: Stream<Item = Result<TaskDetails, Status>> + Send + 'static;

    fn watch_updates<'life0, 'async_trait>(
        &'life0 self,
        request: Request<InstrumentRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::WatchUpdatesStream>, Status>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn watch_task_details<'life0, 'async_trait>(
        &'life0 self,
        request: Request<TaskDetailsRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::WatchTaskDetailsStream>, Status>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn pause<'life0, 'async_trait>(
        &'life0 self,
        request: Request<PauseRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<PauseResponse>, Status>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn resume<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ResumeRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<ResumeResponse>, Status>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}
Expand description

Generated trait containing gRPC methods that should be implemented for use with InstrumentServer.

Required Associated Types

Server streaming response type for the WatchUpdates method.

Server streaming response type for the WatchTaskDetails method.

Required Methods

Produces a stream of updates representing the behavior of the instrumented async runtime.

Produces a stream of updates describing the activity of a specific task.

Registers that the console observer wants to pause the stream.

Registers that the console observer wants to resume the stream.

Implementors