Struct EventsClient

pub struct EventsClient<T> { /* private fields */ }

Implementations

impl EventsClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>

where D: TryInto<Endpoint>, D::Error: Into<StdError>,

Attempt to create a new client by connecting to a given endpoint.

impl<T> EventsClient<T>

where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> EventsClient<InterceptedService<T, F>>

where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

pub async fn publish( &mut self, request: impl IntoRequest<PublishRequest>, ) -> Result<Response<()>, Status>

Publish an event to a topic.

The event will be packed into a timestamp envelope with the namespace introspected from the context. The envelope will then be dispatched.

pub async fn forward( &mut self, request: impl IntoRequest<ForwardRequest>, ) -> Result<Response<()>, Status>

Forward sends an event that has already been packaged into an envelope with a timestamp and namespace.

This is useful if earlier timestamping is required or when forwarding on behalf of another component, namespace or publisher.

pub async fn subscribe( &mut self, request: impl IntoRequest<SubscribeRequest>, ) -> Result<Response<Streaming<Envelope>>, Status>

Subscribe to a stream of events, possibly returning only that match any of the provided filters.

Unlike many other methods in containerd, subscribers will get messages from all namespaces unless otherwise specified. If this is not desired, a filter can be provided in the format ‘namespace==’ to restrict the received events.

Trait Implementations

impl<T: Clone> Clone for EventsClient<T>

fn clone(&self) -> EventsClient<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for EventsClient<T>

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

Formats the value using the given formatter.