Enum AnalyticsStreamSink 

pub enum AnalyticsStreamSink {
    Webhook(AnalyticsStreamWebhook),
    Kafka(AnalyticsStreamKafka),
}

The access-record stream’s sink (DW-121, gateway.analytics_stream.sink). Closed set, internally tagged (type: webhook or type: kafka): webhook ships today; kafka (SCALE-08, #187) produces NDJSON batches to a Kafka topic via a Kafka REST Proxy (HTTP-based, no native client dependency). The variant payloads carry their own deny_unknown_fields, so a misspelled knob inside a sink is still a rejected config.

Variants

Webhook(AnalyticsStreamWebhook)

POST each flushed batch as one NDJSON body (one JSON object per line, one line per record) to the configured URL, reusing the DW-044 webhook delivery engine’s retry/budget shape — one delivery (with its retries) per batch.

Kafka(AnalyticsStreamKafka)

Produce each flushed batch as NDJSON messages to a Kafka topic via a Kafka REST Proxy (SCALE-08, #187). The REST Proxy endpoint receives the batch as an HTTP POST with the Content-Type: application/vnd.kafka.binary.v2+json media type; each NDJSON line becomes a Kafka message value (base64 encoded per the REST Proxy spec). TLS is via https://; SASL auth is via headers. This avoids the native rdkafka dependency while providing a production-usable Kafka integration.

Trait Implementations

impl Clone for AnalyticsStreamSink

fn clone(&self) -> AnalyticsStreamSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AnalyticsStreamSink

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AnalyticsStreamSink

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for AnalyticsStreamSink

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 AnalyticsStreamSink

fn eq(&self, other: &AnalyticsStreamSink) -> 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 AnalyticsStreamSink

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 AnalyticsStreamSink