gproxy-protocol 4.1.5

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

//! Direct incremental Chat ↔ Gemini streams, with native source validation.

mod chat_to_gemini;
mod common;
mod gemini_to_chat;
mod tools;

use crate::{
    transform::{
        Converted, Report, TransformError, TransformErrorKind,
        identity::{IdentityFlow, IdentityRole, SourceIdentity, TargetIdPolicy},
    },
    wire::{
        DeclaredFields, gemini as g,
        openai::chat::{self as c, stream as s},
    },
};
use std::collections::BTreeMap;

pub use chat_to_gemini::ChatToGeminiStream;
pub use common::{StreamEnd, StreamLimits};
pub use gemini_to_chat::{GeminiToChatContext, GeminiToChatStream};

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

fn limit() -> TransformError {
    TransformError::new(
        TransformErrorKind::Limit,
        "chat_gemini.stream",
        "stream limit exceeded",
    )
}