Struct google_cloud_pubsub::subscriber::SubscriberConfig
source · pub struct SubscriberConfig {
pub ping_interval: Duration,
pub retry_setting: Option<RetrySetting>,
pub stream_ack_deadline_seconds: i32,
pub max_outstanding_messages: i64,
pub max_outstanding_bytes: i64,
}Fields§
§ping_interval: Durationping interval for Bi Directional Streaming
retry_setting: Option<RetrySetting>§stream_ack_deadline_seconds: i32§max_outstanding_messages: i64§max_outstanding_bytes: i64Trait Implementations§
source§impl Clone for SubscriberConfig
impl Clone for SubscriberConfig
source§fn clone(&self) -> SubscriberConfig
fn clone(&self) -> SubscriberConfig
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl RefUnwindSafe for SubscriberConfig
impl Send for SubscriberConfig
impl Sync for SubscriberConfig
impl Unpin for SubscriberConfig
impl UnwindSafe for SubscriberConfig
Blanket Implementations§
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request