Struct GrpcStream

pub struct GrpcStream<'a> {
    pub cluster: Upstream<'a>,
    pub service: &'a str,
    pub method: &'a str,
    pub initial_metadata: Vec<(&'a str, &'a [u8])>,
    pub on_message: Option<Box<dyn FnMut(&mut DowncastBox<dyn RootContext>, GrpcStreamHandle, &GrpcStreamMessage)>>,
    pub on_close: Option<Box<dyn FnOnce(&mut DowncastBox<dyn RootContext>, &GrpcStreamClose)>>,
}

Outbound GRPC stream (bidirectional)

Fields

cluster: Upstream<'a>

Upstream cluster to send the request to.

service: &'a str

The GRPC service to call.

method: &'a str

The GRPC service method to call.

initial_metadata: Vec<(&'a str, &'a [u8])>

Initial GRPC metadata to send with the request.

on_message: Option<Box<dyn FnMut(&mut DowncastBox<dyn RootContext>, GrpcStreamHandle, &GrpcStreamMessage)>>

Callback to call when the server sends a stream message.

on_close: Option<Box<dyn FnOnce(&mut DowncastBox<dyn RootContext>, &GrpcStreamClose)>>

Callback to call when the stream closes.

Implementations

impl<'a> GrpcStream<'a>

pub fn open(self) -> Result<GrpcStreamHandle, Status>

Open a new outbound GRPC stream.