Struct AnalyticsStreamConfig 

pub struct AnalyticsStreamConfig {
    pub sink: AnalyticsStreamSink,
    pub buffer: Option<u64>,
    pub flush_ms: Option<u64>,
    pub batch_max: Option<u64>,
}

Real-time access-record stream (DW-121, gateway.analytics_stream).

Every completed request’s access record is copied onto a bounded channel at request completion (drop-and-count on full — the stream can never slow the dataplane), and a background flusher turns the queue into ordered batches delivered to the configured sink: one delivery per flushed BATCH, not per record. The channel capacity is fixed at boot; the sink set, flush cadence, and batch bound are read live from the current generation, so a reload can retarget or disable the stream without a restart.

Fields

sink: AnalyticsStreamSink

Where flushed batches go. One sink in v1 (type: webhook); the set is closed so a second implementation (a Kafka producer is the documented slot) is an additive config change, not a silent behavior change.

buffer: Option<u64>

Capacity of the bounded record channel (default 8192; validated to [64, 65536]). The queue’s entire memory story: every queued record is an owned copy, and a full queue DROPS (and counts) rather than blocking the request path. Startup wiring: the capacity is fixed when the gateway boots (a live reload changes the sink and the cadence, not this).

flush_ms: Option<u64>

Maximum batch latency in milliseconds (default 1000; validated to [100, 60000]): a batch is flushed when it holds batch_max records, reaches the batch byte cap, or this much time has passed since its first record — whichever comes first. Read live per flush cycle.

batch_max: Option<u64>

Maximum records per flushed batch (default 512; validated to [1, 4096]). With the batch byte cap, whichever comes first. One batch is one delivery, so this is also the largest single delivery’s record count.

Trait Implementations

impl Clone for AnalyticsStreamConfig

fn clone(&self) -> AnalyticsStreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AnalyticsStreamConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AnalyticsStreamConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for AnalyticsStreamConfig

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl PartialEq for AnalyticsStreamConfig

fn eq(&self, other: &AnalyticsStreamConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for AnalyticsStreamConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for AnalyticsStreamConfig