Struct GrpcConfig

Source

pub struct GrpcConfig {Show 17 fields
    pub proto_file: Option<String>,
    pub service: Option<String>,
    pub method: Option<String>,
    pub reflection: bool,
    pub transport_intent: TransportIntent,
    pub client_transport: ClientTransport,
    pub server_transport: ServerTransport,
    pub max_receive_message_length: usize,
    pub deadline_ms: Option<u64>,
    pub metadata: Option<String>,
    pub connect_timeout_ms: u64,
    pub default_deadline_ms: u64,
    pub auth: AuthConfig,
    pub interceptors: InterceptorConfig,
    pub consumer_strategy: ConsumerStrategy,
    pub producer_strategy: ProducerStrategy,
    pub retry: NetworkRetryPolicy,
}

Fields§

§proto_file: Option<String>§service: Option<String>§method: Option<String>§reflection: bool§transport_intent: TransportIntent§client_transport: ClientTransport§server_transport: ServerTransport§max_receive_message_length: usize§deadline_ms: Option<u64>§metadata: Option<String>§connect_timeout_ms: u64§default_deadline_ms: u64§auth: AuthConfig§interceptors: InterceptorConfig§consumer_strategy: ConsumerStrategy§producer_strategy: ProducerStrategy§retry: NetworkRetryPolicy

Transient error retry policy for gRPC producer RPC calls.

Controls how the producer retries Unavailable, DeadlineExceeded, ResourceExhausted, Aborted, and transport-level errors. Permanent codes (InvalidArgument, NotFound, PermissionDenied, etc.) are never retried.

GrpcConfig

Struct GrpcConfig Copy item path

Fields§

Trait Implementations§

impl Clone for GrpcConfig

fn clone(&self) -> GrpcConfig

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

impl Debug for GrpcConfig

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

impl<'de> Deserialize<'de> for GrpcConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

Auto Trait Implementations§

impl !RefUnwindSafe for GrpcConfig

impl !UnwindSafe for GrpcConfig

impl Freeze for GrpcConfig

impl Send for GrpcConfig

impl Sync for GrpcConfig

impl Unpin for GrpcConfig

impl UnsafeUnpin for GrpcConfig

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> DeserializeOwned for Twhere T: for<'de> Deserialize<'de>,

impl<T> DynClone for Twhere T: Clone,

fn __clone_box(&self, _: Private) -> *mut ()

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ

fn with_current_context(self) -> WithContext<Self> ⓘ

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = !

fn try_from(value: U) -> Result<T, !>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Struct GrpcConfig

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

impl<T> DynClone for T
where T: Clone,

impl<T> FromRef<T> for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,