gproxy-protocol 4.1.14

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

use super::*;
use crate::transform::generate::{
    chat_responses::stream as hr, claude_chat::stream as ch, claude_gemini::stream as cg,
    gemini_responses::stream as gr,
};

mod sealed {
    pub trait Edge {}
}

/// The four single-result upstream edges that can serve a multi-candidate client.
pub trait FanoutBridge: StreamBridge + sealed::Edge {
    fn reserve(&mut self, role: IdentityRole, ids: &BTreeSet<String>)
    -> Result<(), TransformError>;
}

macro_rules! edge {
    ($ty:ty) => {
        impl sealed::Edge for $ty {}
        impl FanoutBridge for $ty {
            fn reserve(
                &mut self,
                role: IdentityRole,
                ids: &BTreeSet<String>,
            ) -> Result<(), TransformError> {
                self.reserve_external_ids(role, ids)
            }
        }
    };
}
edge!(ch::ClaudeToChatStream);
edge!(cg::ClaudeToGeminiStream);
edge!(hr::ResponsesToChatStream);

impl sealed::Edge for gr::ResponsesToGeminiStream {}
impl FanoutBridge for gr::ResponsesToGeminiStream {
    fn reserve(
        &mut self,
        role: IdentityRole,
        ids: &BTreeSet<String>,
    ) -> Result<(), TransformError> {
        self.reserve_external_ids(role, ids)
    }
}