Struct mz_dataflow_types::client::grpc::GrpcClient

pub struct GrpcClient<Client, PC, PR> { /* private fields */ }

A client to a remote dataflow server using gRPC and protobuf based communication.

The client opens a connection using the proto client stubs that are generated by tonic from the service definition in client.proto. After creation, the client is in disconnected state. To connect it, connect has to be called. Once the client is connected, it will call automatically the only RPC defined in the service description, encapsulated by the BidiProtoClient trait. This trait bound is not on the Client type parameter here, but it IS on the impl blocks. Bidirectional protobuf RPC sets up two streams that persist after the RPC has returned: A Request (Command) stream (for us, backed by a unbounded mpsc queue) going from this instance to the server and a response stream coming back (represented directly as a Streaming instance). The recv and send functions interact with the two mpsc channels or the streaming instance respectively.

Implementations

impl<Client, PC, PR> GrpcClient<Client, PC, PR> where
    Client: BidiProtoClient<ProtoCommand = PC, ProtoResponse = PR>, 

pub async fn connect(&mut self)

Trait Implementations

impl<Client: Debug, PC: Debug, PR: Debug> Debug for GrpcClient<Client, PC, PR>

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

Formats the value using the given formatter.

impl<Client, PC, PR> FromAddr for GrpcClient<Client, PC, PR>

fn from_addr(addr: String) -> Self

impl<Client, C, R, PC, PR> GenericClient<C, R> for GrpcClient<Client, PC, PR> where
    C: RustType<PC> + Send + Sync + 'static,
    R: RustType<PR> + Send + Sync,
    Client: BidiProtoClient<ProtoCommand = PC, ProtoResponse = PR> + Send + Debug,
    PC: Send + Sync + Debug,
    PR: Send + Sync + Debug, 

fn send<'life0, 'async_trait>(
    &'life0 mut self,
    cmd: C
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Sends a command to the dataflow server.

fn recv<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = Result<Option<R>, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Receives the next response from the dataflow server.

fn as_stream<'a>(
    &'a mut self
) -> Pin<Box<dyn Stream<Item = Result<R, Error>> + Send + 'a>> where
    R: Send + 'a, 

Returns an adapter that treats the client as a stream.

impl<Client: BidiProtoClient<ProtoCommand = PC, ProtoResponse = PR> + Send + Sync, PC: Send, PR> Reconnect for GrpcClient<Client, PC, PR>

fn disconnect(&mut self)

fn reconnect<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait,