gproxy-protocol 4.1.4

GPROXY v4 connection modelling, operation declarations, vendor wire types and pairwise conversion
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

//! Bounded native Responses SSE lifecycle, collection and synthesis.

mod collector;
mod emit;
mod events;
mod items;
mod lifecycle;
mod parts;
mod snapshots;
mod status;
mod synthesize;
use crate::transform::TransformError;
use crate::wire::openai::responses::{input as i, response as r, stream as s};
pub use collector::{ResponsesStreamCollector, ResponsesStreamLimits};
pub use synthesize::synthesize_responses_stream;

fn invalid(message: &'static str) -> TransformError {
    TransformError::invalid_result("responses.stream", message)
}

fn limit() -> TransformError {
    TransformError::new(
        crate::transform::TransformErrorKind::Limit,
        "responses.stream",
        "Responses stream limit exceeded",
    )
}

fn bounded<T: serde::Serialize>(value: &T, cap: usize) -> Result<usize, TransformError> {
    crate::codec::encode_json(
        value,
        crate::codec::CodecLimits {
            max_body_bytes: cap as u64,
            max_value_bytes: cap as u64,
            max_buffer_bytes: cap as u64,
            max_line_bytes: cap as u64,
            max_part_bytes: cap as u64,
            max_parts: 0,
        },
    )
    .map(|v| v.len())
    .map_err(|e| {
        if e.kind() == crate::codec::CodecErrorKind::Limit {
            limit()
        } else {
            invalid("cannot encode declared stream value")
        }
    })
}