Struct EnableStreamingRequest 

pub struct EnableStreamingRequest {
    pub buffer_size: Option<usize>,
    pub batch_size: Option<usize>,
    pub flush_interval_ms: Option<u64>,
}

Request body for the enable-streaming endpoint.

All fields are optional; omitted fields fall back to the engine defaults (buffer_size = 10000, batch_size = 128, flush_interval_ms = 50).

Fields

buffer_size: Option<usize>

Capacity of the bounded ingestion channel (backpressure threshold).

batch_size: Option<usize>

Number of points that trigger an immediate micro-batch flush.

flush_interval_ms: Option<u64>

Maximum time (ms) before a partial batch is flushed.

Implementations

impl EnableStreamingRequest

pub fn to_config(&self) -> StreamingConfig

Builds a StreamingConfig, falling back to the engine default for every omitted field.

Trait Implementations

impl Debug for EnableStreamingRequest

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

Formats the value using the given formatter.

impl Default for EnableStreamingRequest

fn default() -> EnableStreamingRequest

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for EnableStreamingRequest

fn deserialize<__D>( __deserializer: __D, ) -> Result<EnableStreamingRequest, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl ToSchema for EnableStreamingRequest

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

Return name of the schema.

fn schemas(schemas: &mut Vec<(String, RefOr<Schema>)>)

Implement reference utoipa::openapi::schema::Schemas for this type.