Struct GrpcConfig 

pub struct GrpcConfig {
    pub listen: Option<String>,
    pub endpoint: Option<String>,
    pub recv_buffer_size: usize,
    pub recv_timeout_ms: u64,
    pub max_message_size: usize,
    pub compression: bool,
    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).

max_message_size: usize

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

compression: bool

Enable gzip compression for gRPC messages.

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 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.