Struct GrpcConfig 

pub struct GrpcConfig {
    pub url: String,
    pub topic: Option<String>,
    pub timeout_ms: Option<u64>,
    pub tls: TlsConfig,
    pub server_mode: bool,
    pub initial_stream_window_size: Option<u32>,
    pub initial_connection_window_size: Option<u32>,
    pub concurrency_limit_per_connection: Option<usize>,
    pub http2_keepalive_interval_ms: Option<u64>,
    pub http2_keepalive_timeout_ms: Option<u64>,
    pub max_decoding_message_size: Option<usize>,
}

Fields

url: String

The gRPC server URL (e.g., “http://localhost:50051” for client or “0.0.0.0:50051” for server mode).

topic: Option<String>

Topic / subject used for both subscribe and publish paths.

timeout_ms: Option<u64>

Timeout in milliseconds.

• Client mode: used as the connection timeout and per-request deadline.
• Server mode: applied as the per-request deadline on the embedded server.

tls: TlsConfig

TLS configuration.

server_mode: bool

If true, start an embedded tonic gRPC server that accepts incoming Publish / PublishBatch RPCs. If false (the default), connect to a remote server as a client.

initial_stream_window_size: Option<u32>

HTTP/2 stream-level initial window size in bytes. Server-mode only.

initial_connection_window_size: Option<u32>

HTTP/2 connection-level initial window size in bytes. Server-mode only.

concurrency_limit_per_connection: Option<usize>

Maximum number of concurrent requests handled per connection. Server-mode only.

http2_keepalive_interval_ms: Option<u64>

HTTP/2 keepalive ping interval in milliseconds. Server-mode only. Default disabled

http2_keepalive_timeout_ms: Option<u64>

Timeout for a keepalive ping acknowledgement in milliseconds. Server-mode only.

max_decoding_message_size: Option<usize>

Maximum size of a decoded incoming message in bytes. Server-mode only. Default 4 MiB.

Implementations

impl GrpcConfig

pub fn new(url: impl Into<String>) -> Self

Creates a new gRPC configuration with the specified server URL.

pub fn with_topic(self, topic: impl Into<String>) -> Self

pub fn with_server_mode(self, server_mode: bool) -> Self

Enable or disable server mode for this gRPC endpoint.

Trait Implementations

impl Clone for GrpcConfig

fn clone(&self) -> GrpcConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GrpcConfig

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

Formats the value using the given formatter.

impl Default for GrpcConfig

fn default() -> GrpcConfig

Returns the “default value” for a type.

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

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl SecretExtractor for GrpcConfig

fn extract_secrets( &mut self, prefix: &str, secrets: &mut HashMap<String, String>, )

Extracts secrets into the provided map using the given prefix, and clears them from self.

impl Serialize for GrpcConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.