Struct ChannelConfig 

pub struct ChannelConfig {
    pub blob_storage: Option<BlobStorageConfig>,
    pub kafka: Option<KafkaConfig>,
    pub nats: Option<NatsConfig>,
    pub minid_time: u64,
    pub capacity: usize,
    pub queue_codec: Option<String>,
    pub batch_concurrency: Option<usize>,
    pub compression_threshold: Option<usize>,
    pub nack_max_retries: Option<u32>,
    pub nack_backoff_ms: Option<u64>,
}

Channel (Queue) Configuration

Fields

blob_storage: Option<BlobStorageConfig>

Blob storage configuration

kafka: Option<KafkaConfig>

Kafka configuration for queue

nats: Option<NatsConfig>

NATS (JetStream) configuration for queue

minid_time: u64

Minimum ID time (snowflake/uuid related)

capacity: usize

Channel capacity

queue_codec: Option<String>

Queue codec: json | msgpack

batch_concurrency: Option<usize>

Concurrency limit for batch flushing (default: 10)

compression_threshold: Option<usize>

Compression threshold in bytes (payloads larger than this will be compressed)

nack_max_retries: Option<u32>

Max retries for NACK before sending to DLQ (default: 0)

nack_backoff_ms: Option<u64>

Backoff in milliseconds before retrying NACK (default: 0)

Trait Implementations

impl Clone for ChannelConfig

fn clone(&self) -> ChannelConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChannelConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ChannelConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ChannelConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.