Struct wick_invocation_server::InvocationServer

pub struct InvocationServer {
    pub collection: SharedComponent,
    /* private fields */
}

A GRPC server for implementers of flow_component::Component.

Fields

collection: SharedComponent

The component that will handle incoming requests.

Implementations

impl InvocationServer

pub fn new(collection: SharedComponent) -> Self

Constructor.

Trait Implementations

impl Debug for InvocationServer

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

Formats the value using the given formatter.

impl InvocationService for InvocationServer

type InvokeStream = ReceiverStream<Result<Packet, Status>>

Server streaming response type for the Invoke method.

fn invoke<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<InvocationRequest>> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::InvokeStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn list<'life0, 'async_trait>( &'life0 self, _request: Request<ListRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<ListResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn stats<'life0, 'async_trait>( &'life0 self, _request: Request<StatsRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<StatsResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,