Struct proxy_sdk::GrpcStreamBuilder

pub struct GrpcStreamBuilder<'a> { /* private fields */ }

Builder for GrpcStream.

Implementations

impl<'a> GrpcStreamBuilder<'a>

pub fn cluster<VALUE: Into<Upstream<'a>>>(self, value: VALUE) -> Self

Upstream cluster to send the request to.

pub fn service<VALUE: Into<&'a str>>(self, value: VALUE) -> Self

The GRPC service to call.

pub fn method<VALUE: Into<&'a str>>(self, value: VALUE) -> Self

The GRPC service method to call.

pub fn initial_metadata<VALUE: Into<Vec<(&'a str, &'a [u8])>>>( self, value: VALUE ) -> Self

Initial GRPC metadata to send with the request.

pub fn metadata<VALUE>(self, item: VALUE) -> Self

where Vec<(&'a str, &'a [u8])>: Default + Extend<VALUE>,

Initial GRPC metadata to send with the request.

pub fn build(self) -> Result<GrpcStream<'a>, GrpcStreamBuilderError>

Builds a new GrpcStream.

Errors

If a required field has not been initialized.

impl<'a> GrpcStreamBuilder<'a>

pub fn on_message<R: RootContext + 'static>( self, callback: impl FnMut(&mut R, GrpcStreamHandle, &GrpcStreamMessage) + 'static ) -> Self

Set a stream message callback

pub fn on_close<R: RootContext + 'static>( self, callback: impl FnOnce(&mut R, &GrpcStreamClose) + 'static ) -> Self

Set a stream close callback

Trait Implementations

impl<'a> Default for GrpcStreamBuilder<'a>

fn default() -> Self

Returns the “default value” for a type.