Struct FluvioConfig 

pub struct FluvioConfig {
    pub endpoint: String,
    pub topic_prefix: String,
    pub retention: Duration,
    pub replicas: i32,
    pub crypto: TransportCrypto,
    pub replay_cursor: ReplayCursor,
    pub sync_ack: bool,
    pub max_inflight: u32,
    pub topic_shards: u32,
}

Resolved Fluvio adapter settings (no env lookups at append time).

Fields

endpoint: String

Fluvio Streaming Controller endpoint.

topic_prefix: String

Topic prefix for Photon events.

retention: Duration

Topic retention / replay window.

replicas: i32

Topic replication factor.

crypto: TransportCrypto

Payload envelope crypto.

replay_cursor: ReplayCursor

Replay and checkpoint semantics.

sync_ack: bool

Await produce ack per message.

max_inflight: u32

Max concurrent in-flight publishes.

topic_shards: u32

Independent Fluvio topics for ingress sharding (1 = legacy single layout).

Implementations

impl FluvioConfig

pub const fn effective_replicas(&self) -> i32

Effective replication factor when creating shard topics.

pub const fn is_sharded(&self) -> bool

Whether publishes route across multiple topic shards.

pub fn checkpoint_topic(&self) -> String

Compact checkpoint topic name.

Trait Implementations

impl Clone for FluvioConfig

fn clone(&self) -> FluvioConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.