Struct GrpcConfig 

pub struct GrpcConfig {

    pub listen: Option<String>,
    pub endpoint: Option<String>,
    pub recv_buffer_size: usize,
    pub recv_timeout_ms: u64,
    pub send_timeout_ms: u64,
    pub max_message_size: usize,
    pub compression: bool,
    pub tls_enabled: bool,
    pub tls_ca_path: Option<String>,
    pub tls_domain: Option<String>,
    pub tls_client_cert_path: Option<String>,
    pub tls_client_key_path: Option<String>,
    pub filters_in: Vec<FilterRule>,
    pub filters_out: Vec<FilterRule>,
}

Available on crate features transport-grpc and transport only.

gRPC transport configuration.

Supports client mode (sending), server mode (receiving), or both.

Client mode

Set endpoint to connect to a remote DFE gRPC server.

Server mode

Set listen to accept incoming Push RPCs.

Both

Set both for bidirectional communication (e.g., a relay node).

Fields

listen: Option<String>

Server listen address (e.g., “0.0.0.0:6000”). When set, the transport accepts incoming Push RPCs.

endpoint: Option<String>

Client endpoint URI (e.g., “http://dfe-loader:6000”). When set, the transport can send messages to a remote server.

recv_buffer_size: usize

Receive buffer size (messages buffered from incoming RPCs).

recv_timeout_ms: u64

Receive timeout in milliseconds (0 = non-blocking).

send_timeout_ms: u64

Per-RPC send deadline in milliseconds (0 = no deadline).

Bounds a single push call so a hung or black-holing server cannot block a sender task forever. Applied as the gRPC request deadline (grpc-timeout header) on every outbound RPC. Default 30s.

max_message_size: usize

Maximum message size in bytes (both send and receive).

compression: bool

Enable gzip compression for gRPC messages.

tls_enabled: bool

Enable client TLS for the endpoint connection.

tls_ca_path: Option<String>

Private-CA PEM (maps to TlsTrust.extra_roots). When unset with tls_enabled, falls back to OS native roots.

tls_domain: Option<String>

Domain name for SNI / certificate verification (overrides the URI host).

tls_client_cert_path: Option<String>

Client certificate PEM for mTLS (with tls_client_key_path).

tls_client_key_path: Option<String>

Client key PEM for mTLS (with tls_client_cert_path).

filters_in: Vec<FilterRule>

Inbound message filters (applied on recv before caller sees messages).

filters_out: Vec<FilterRule>

Outbound message filters (applied on send before transport dispatches).

Implementations

impl GrpcConfig

pub fn from_cascade() -> Self

Load from the config cascade under the grpc key.

pub fn server(listen: &str) -> Self

Create a server-only config.

pub fn client(endpoint: &str) -> Self

Create a client-only config.

pub fn with_compression(self) -> Self

Enable gzip compression.

pub fn with_max_message_size(self, size: usize) -> Self

Set max message size.

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() -> Self

Returns the “default value” for a type.

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

where GrpcConfig: Default,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl FromCascade for GrpcConfig

fn from_cascade_key(key: &str) -> Self

Load Self from the config cascade under key, registering the section in the global registry; falls back to Default if the cascade is unavailable or the key is absent/invalid.

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.