gproxy-protocol 4.1.2

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
50
51
52
53
54
55
56
57
58
59
60

//! Incremental generation invocation over explicitly injected capabilities.

mod binding;
pub mod bridge;
pub mod event;
pub mod fanout;
mod history;
mod invoke;
mod next;
mod output;
mod prepare;
pub mod reader;
mod resource_map;
pub mod synthesize;
pub mod websocket;

pub use history::ResponsesHistoryCache;
pub use history::response_output_as_input;
pub use invoke::{StreamChunk, StreamInvocation, StreamSettings, StreamStart, StreamTarget};
pub use prepare::{
    ChatViaGeminiStreamFacts, ClaudeViaGeminiStreamFacts, GeminiViaClaudeStreamFacts,
    ResponsesViaClaudeStreamFacts, ResponsesViaGeminiStreamFacts,
};

fn invalid(message: impl Into<String>) -> crate::transform::TransformError {
    crate::transform::TransformError::invalid_result("generation.stream", message)
}

fn conflict(message: impl Into<String>) -> crate::transform::TransformError {
    crate::transform::TransformError::new(
        crate::transform::TransformErrorKind::Conflict,
        "generation.stream",
        message,
    )
}

fn missing(message: impl Into<String>) -> crate::transform::TransformError {
    crate::transform::TransformError::new(
        crate::transform::TransformErrorKind::MissingState,
        "generation.stream",
        message,
    )
}

fn limit(message: impl Into<String>) -> crate::transform::TransformError {
    crate::transform::TransformError::new(
        crate::transform::TransformErrorKind::Limit,
        "generation.stream",
        message,
    )
}

fn codec_error(e: crate::codec::CodecError) -> crate::transform::TransformError {
    let kind = match e.kind() {
        crate::codec::CodecErrorKind::Limit => crate::transform::TransformErrorKind::Limit,
        crate::codec::CodecErrorKind::Transport => crate::transform::TransformErrorKind::Host,
        _ => crate::transform::TransformErrorKind::InvalidResult,
    };
    crate::transform::TransformError::with_source(kind, "generation.stream.codec", e.to_string(), e)
}