gproxy-protocol 4.1.9

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
61

use super::*;

pub(super) fn sequence(event: &s::StreamEvent) -> Option<i64> {
    Some(match event {
        s::StreamEvent::Keepalive | s::StreamEvent::Unknown => return None,
        s::StreamEvent::Metadata(v) => return v.sequence_number,
        s::StreamEvent::Created(v) => v.sequence_number,
        s::StreamEvent::Queued(v) => v.sequence_number,
        s::StreamEvent::InProgress(v) => v.sequence_number,
        s::StreamEvent::Completed(v) => v.sequence_number,
        s::StreamEvent::Failed(v) => v.sequence_number,
        s::StreamEvent::Incomplete(v) => v.sequence_number,
        s::StreamEvent::OutputItemAdded(v) => v.sequence_number,
        s::StreamEvent::OutputItemDone(v) => v.sequence_number,
        s::StreamEvent::ContentPartAdded(v) => v.sequence_number,
        s::StreamEvent::ContentPartDone(v) => v.sequence_number,
        s::StreamEvent::OutputTextDelta(v) => v.sequence_number,
        s::StreamEvent::OutputTextDone(v) => v.sequence_number,
        s::StreamEvent::OutputTextAnnotationAdded(v) => v.sequence_number,
        s::StreamEvent::RefusalDelta(v) => v.sequence_number,
        s::StreamEvent::RefusalDone(v) => v.sequence_number,
        s::StreamEvent::ReasoningTextDelta(v) => v.sequence_number,
        s::StreamEvent::ReasoningTextDone(v) => v.sequence_number,
        s::StreamEvent::ReasoningSummaryPartAdded(v) => v.sequence_number,
        s::StreamEvent::ReasoningSummaryPartDone(v) => v.sequence_number,
        s::StreamEvent::ReasoningSummaryTextDelta(v) => v.sequence_number,
        s::StreamEvent::ReasoningSummaryTextDone(v) => v.sequence_number,
        s::StreamEvent::FunctionCallArgumentsDelta(v) => v.sequence_number,
        s::StreamEvent::FunctionCallArgumentsDone(v) => v.sequence_number,
        s::StreamEvent::CustomToolInputDelta(v) => v.sequence_number,
        s::StreamEvent::CustomToolInputDone(v) => v.sequence_number,
        s::StreamEvent::CodeInterpreterCodeDelta(v) => v.sequence_number,
        s::StreamEvent::CodeInterpreterCodeDone(v) => v.sequence_number,
        s::StreamEvent::AudioDelta(v) => v.sequence_number,
        s::StreamEvent::AudioDone(v) => v.sequence_number,
        s::StreamEvent::AudioTranscriptDelta(v) => v.sequence_number,
        s::StreamEvent::AudioTranscriptDone(v) => v.sequence_number,
        s::StreamEvent::ImagePartial(v) => v.sequence_number,
        s::StreamEvent::ImageCall(v) => v.sequence_number,
        s::StreamEvent::ImageGenerating(v) => v.sequence_number,
        s::StreamEvent::ImageCompleted(v) => v.sequence_number,
        s::StreamEvent::CodeInterpreterInProgress(v) => v.sequence_number,
        s::StreamEvent::CodeInterpreterInterpreting(v) => v.sequence_number,
        s::StreamEvent::CodeInterpreterCompleted(v) => v.sequence_number,
        s::StreamEvent::FileSearchInProgress(v) => v.sequence_number,
        s::StreamEvent::FileSearchSearching(v) => v.sequence_number,
        s::StreamEvent::FileSearchCompleted(v) => v.sequence_number,
        s::StreamEvent::WebSearchInProgress(v) => v.sequence_number,
        s::StreamEvent::WebSearchSearching(v) => v.sequence_number,
        s::StreamEvent::WebSearchCompleted(v) => v.sequence_number,
        s::StreamEvent::McpArgumentsDelta(v) => v.sequence_number,
        s::StreamEvent::McpArgumentsDone(v) => v.sequence_number,
        s::StreamEvent::McpInProgress(v) => v.sequence_number,
        s::StreamEvent::McpCompleted(v) => v.sequence_number,
        s::StreamEvent::McpFailed(v) => v.sequence_number,
        s::StreamEvent::McpListToolsInProgress(v) => v.sequence_number,
        s::StreamEvent::McpListToolsCompleted(v) => v.sequence_number,
        s::StreamEvent::McpListToolsFailed(v) => v.sequence_number,
        s::StreamEvent::Error(v) => v.sequence_number(),
    })
}