iscp/message/proto/
iscp2.v1.rs

1// This file is @generated by prost-build.
2#[derive(serde::Serialize, serde::Deserialize)]
3#[derive(Clone, PartialEq, ::prost::Message)]
4pub struct StreamChunk {
5    #[prost(uint32, tag = "1")]
6    pub sequence_number: u32,
7    #[prost(message, repeated, tag = "2")]
8    pub data_point_groups: ::prost::alloc::vec::Vec<DataPointGroup>,
9}
10#[derive(serde::Serialize, serde::Deserialize)]
11#[derive(Clone, PartialEq, ::prost::Message)]
12pub struct DataPointGroup {
13    #[prost(message, repeated, tag = "3")]
14    pub data_points: ::prost::alloc::vec::Vec<DataPoint>,
15    #[prost(uint32, repeated, tag = "4")]
16    pub data_filter_ids: ::prost::alloc::vec::Vec<u32>,
17    #[prost(oneof = "data_point_group::DataIdOrAlias", tags = "1, 2")]
18    pub data_id_or_alias: ::core::option::Option<data_point_group::DataIdOrAlias>,
19}
20/// Nested message and enum types in `DataPointGroup`.
21pub mod data_point_group {
22    #[derive(serde::Serialize, serde::Deserialize)]
23    #[derive(Clone, PartialEq, ::prost::Oneof)]
24    #[derive(PartialOrd, Ord, Eq, Hash)]
25    pub enum DataIdOrAlias {
26        #[prost(message, tag = "1")]
27        DataId(super::DataId),
28        #[prost(uint32, tag = "2")]
29        DataIdAlias(u32),
30    }
31}
32#[derive(serde::Serialize, serde::Deserialize)]
33#[derive(Eq)]
34#[derive(Clone, PartialEq, ::prost::Message)]
35pub struct DataPoint {
36    #[prost(sint64, tag = "1")]
37    pub elapsed_time: i64,
38    #[prost(bytes = "bytes", tag = "2")]
39    pub payload: ::prost::bytes::Bytes,
40}
41#[derive(serde::Serialize, serde::Deserialize)]
42#[derive(PartialOrd, Ord, Eq, Hash)]
43#[derive(Clone, PartialEq, ::prost::Message)]
44pub struct DataId {
45    #[prost(string, tag = "1")]
46    pub name: ::prost::alloc::string::String,
47    #[prost(string, tag = "2")]
48    #[serde(rename = "type")]
49    pub type_: ::prost::alloc::string::String,
50}
51#[derive(serde::Serialize, serde::Deserialize)]
52#[derive(PartialOrd, Ord, Eq, Hash)]
53#[derive(Clone, PartialEq, ::prost::Message)]
54pub struct DownstreamFilter {
55    #[prost(string, tag = "1")]
56    pub source_node_id: ::prost::alloc::string::String,
57    #[prost(message, repeated, tag = "2")]
58    pub data_filters: ::prost::alloc::vec::Vec<DataFilter>,
59}
60#[derive(serde::Serialize, serde::Deserialize)]
61#[derive(Clone, Copy, PartialEq, ::prost::Message)]
62pub struct DownstreamFilterReference {
63    #[prost(uint32, tag = "1")]
64    pub downstream_filter_index: u32,
65    #[prost(uint32, tag = "2")]
66    pub data_filter_index: u32,
67}
68#[derive(serde::Serialize, serde::Deserialize)]
69#[derive(Clone, PartialEq, ::prost::Message)]
70pub struct DownstreamFilterReferences {
71    #[prost(message, repeated, tag = "1")]
72    pub references: ::prost::alloc::vec::Vec<DownstreamFilterReference>,
73}
74#[derive(serde::Serialize, serde::Deserialize)]
75#[derive(PartialOrd, Ord, Eq, Hash)]
76#[derive(Clone, PartialEq, ::prost::Message)]
77pub struct DataFilter {
78    #[prost(string, tag = "1")]
79    pub name: ::prost::alloc::string::String,
80    #[prost(string, tag = "2")]
81    #[serde(rename = "type")]
82    pub type_: ::prost::alloc::string::String,
83}
84#[derive(serde::Serialize, serde::Deserialize)]
85#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
86#[repr(i32)]
87pub enum QoS {
88    Unreliable = 0,
89    Reliable = 1,
90    Partial = 2,
91}
92impl QoS {
93    /// String value of the enum field names used in the ProtoBuf definition.
94    ///
95    /// The values are not transformed in any way and thus are considered stable
96    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
97    pub fn as_str_name(&self) -> &'static str {
98        match self {
99            Self::Unreliable => "UNRELIABLE",
100            Self::Reliable => "RELIABLE",
101            Self::Partial => "PARTIAL",
102        }
103    }
104    /// Creates an enum from field names used in the ProtoBuf definition.
105    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
106        match value {
107            "UNRELIABLE" => Some(Self::Unreliable),
108            "RELIABLE" => Some(Self::Reliable),
109            "PARTIAL" => Some(Self::Partial),
110            _ => None,
111        }
112    }
113}
114#[derive(serde::Serialize, serde::Deserialize)]
115#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
116#[repr(i32)]
117pub enum ResultCode {
118    Succeeded = 0,
119    IncompatibleVersion = 1,
120    MaximumDataIdAlias = 2,
121    MaximumUpstreamAlias = 3,
122    UnspecifiedError = 64,
123    NoNodeId = 65,
124    AuthFailed = 66,
125    ConnectTimeout = 67,
126    MalformedMessage = 68,
127    ProtocolError = 69,
128    AckTimeout = 70,
129    InvalidPayload = 71,
130    InvalidDataId = 72,
131    InvalidDataIdAlias = 73,
132    InvalidDataFilter = 74,
133    StreamNotFound = 75,
134    ResumeRequestConflict = 76,
135    ProcessFailed = 77,
136    DesiredQosNotSupported = 78,
137    PingTimeout = 79,
138    TooLargeMessageSize = 80,
139    TooManyDataIdAliases = 81,
140    TooManyStreams = 82,
141    TooLongAckInterval = 83,
142    TooManyDownstreamFilters = 84,
143    TooManyDataFilters = 85,
144    TooLongExpiryInterval = 86,
145    TooLongPingTimeout = 87,
146    TooShortPingInterval = 88,
147    TooShortPingTimeout = 89,
148    RateLimitReached = 90,
149    TooLargeFeedId = 91,
150    TooManyTargetNodes = 92,
151    FeedNotFound = 93,
152    InvalidResumeToken = 94,
153    NodeIdMismatch = 128,
154    SessionNotFound = 129,
155    SessionAlreadyClosed = 130,
156    SessionCannotClosed = 131,
157}
158impl ResultCode {
159    /// String value of the enum field names used in the ProtoBuf definition.
160    ///
161    /// The values are not transformed in any way and thus are considered stable
162    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
163    pub fn as_str_name(&self) -> &'static str {
164        match self {
165            Self::Succeeded => "SUCCEEDED",
166            Self::IncompatibleVersion => "INCOMPATIBLE_VERSION",
167            Self::MaximumDataIdAlias => "MAXIMUM_DATA_ID_ALIAS",
168            Self::MaximumUpstreamAlias => "MAXIMUM_UPSTREAM_ALIAS",
169            Self::UnspecifiedError => "UNSPECIFIED_ERROR",
170            Self::NoNodeId => "NO_NODE_ID",
171            Self::AuthFailed => "AUTH_FAILED",
172            Self::ConnectTimeout => "CONNECT_TIMEOUT",
173            Self::MalformedMessage => "MALFORMED_MESSAGE",
174            Self::ProtocolError => "PROTOCOL_ERROR",
175            Self::AckTimeout => "ACK_TIMEOUT",
176            Self::InvalidPayload => "INVALID_PAYLOAD",
177            Self::InvalidDataId => "INVALID_DATA_ID",
178            Self::InvalidDataIdAlias => "INVALID_DATA_ID_ALIAS",
179            Self::InvalidDataFilter => "INVALID_DATA_FILTER",
180            Self::StreamNotFound => "STREAM_NOT_FOUND",
181            Self::ResumeRequestConflict => "RESUME_REQUEST_CONFLICT",
182            Self::ProcessFailed => "PROCESS_FAILED",
183            Self::DesiredQosNotSupported => "DESIRED_QOS_NOT_SUPPORTED",
184            Self::PingTimeout => "PING_TIMEOUT",
185            Self::TooLargeMessageSize => "TOO_LARGE_MESSAGE_SIZE",
186            Self::TooManyDataIdAliases => "TOO_MANY_DATA_ID_ALIASES",
187            Self::TooManyStreams => "TOO_MANY_STREAMS",
188            Self::TooLongAckInterval => "TOO_LONG_ACK_INTERVAL",
189            Self::TooManyDownstreamFilters => "TOO_MANY_DOWNSTREAM_FILTERS",
190            Self::TooManyDataFilters => "TOO_MANY_DATA_FILTERS",
191            Self::TooLongExpiryInterval => "TOO_LONG_EXPIRY_INTERVAL",
192            Self::TooLongPingTimeout => "TOO_LONG_PING_TIMEOUT",
193            Self::TooShortPingInterval => "TOO_SHORT_PING_INTERVAL",
194            Self::TooShortPingTimeout => "TOO_SHORT_PING_TIMEOUT",
195            Self::RateLimitReached => "RATE_LIMIT_REACHED",
196            Self::TooLargeFeedId => "TOO_LARGE_FEED_ID",
197            Self::TooManyTargetNodes => "TOO_MANY_TARGET_NODES",
198            Self::FeedNotFound => "FEED_NOT_FOUND",
199            Self::InvalidResumeToken => "INVALID_RESUME_TOKEN",
200            Self::NodeIdMismatch => "NODE_ID_MISMATCH",
201            Self::SessionNotFound => "SESSION_NOT_FOUND",
202            Self::SessionAlreadyClosed => "SESSION_ALREADY_CLOSED",
203            Self::SessionCannotClosed => "SESSION_CANNOT_CLOSED",
204        }
205    }
206    /// Creates an enum from field names used in the ProtoBuf definition.
207    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
208        match value {
209            "SUCCEEDED" => Some(Self::Succeeded),
210            "INCOMPATIBLE_VERSION" => Some(Self::IncompatibleVersion),
211            "MAXIMUM_DATA_ID_ALIAS" => Some(Self::MaximumDataIdAlias),
212            "MAXIMUM_UPSTREAM_ALIAS" => Some(Self::MaximumUpstreamAlias),
213            "UNSPECIFIED_ERROR" => Some(Self::UnspecifiedError),
214            "NO_NODE_ID" => Some(Self::NoNodeId),
215            "AUTH_FAILED" => Some(Self::AuthFailed),
216            "CONNECT_TIMEOUT" => Some(Self::ConnectTimeout),
217            "MALFORMED_MESSAGE" => Some(Self::MalformedMessage),
218            "PROTOCOL_ERROR" => Some(Self::ProtocolError),
219            "ACK_TIMEOUT" => Some(Self::AckTimeout),
220            "INVALID_PAYLOAD" => Some(Self::InvalidPayload),
221            "INVALID_DATA_ID" => Some(Self::InvalidDataId),
222            "INVALID_DATA_ID_ALIAS" => Some(Self::InvalidDataIdAlias),
223            "INVALID_DATA_FILTER" => Some(Self::InvalidDataFilter),
224            "STREAM_NOT_FOUND" => Some(Self::StreamNotFound),
225            "RESUME_REQUEST_CONFLICT" => Some(Self::ResumeRequestConflict),
226            "PROCESS_FAILED" => Some(Self::ProcessFailed),
227            "DESIRED_QOS_NOT_SUPPORTED" => Some(Self::DesiredQosNotSupported),
228            "PING_TIMEOUT" => Some(Self::PingTimeout),
229            "TOO_LARGE_MESSAGE_SIZE" => Some(Self::TooLargeMessageSize),
230            "TOO_MANY_DATA_ID_ALIASES" => Some(Self::TooManyDataIdAliases),
231            "TOO_MANY_STREAMS" => Some(Self::TooManyStreams),
232            "TOO_LONG_ACK_INTERVAL" => Some(Self::TooLongAckInterval),
233            "TOO_MANY_DOWNSTREAM_FILTERS" => Some(Self::TooManyDownstreamFilters),
234            "TOO_MANY_DATA_FILTERS" => Some(Self::TooManyDataFilters),
235            "TOO_LONG_EXPIRY_INTERVAL" => Some(Self::TooLongExpiryInterval),
236            "TOO_LONG_PING_TIMEOUT" => Some(Self::TooLongPingTimeout),
237            "TOO_SHORT_PING_INTERVAL" => Some(Self::TooShortPingInterval),
238            "TOO_SHORT_PING_TIMEOUT" => Some(Self::TooShortPingTimeout),
239            "RATE_LIMIT_REACHED" => Some(Self::RateLimitReached),
240            "TOO_LARGE_FEED_ID" => Some(Self::TooLargeFeedId),
241            "TOO_MANY_TARGET_NODES" => Some(Self::TooManyTargetNodes),
242            "FEED_NOT_FOUND" => Some(Self::FeedNotFound),
243            "INVALID_RESUME_TOKEN" => Some(Self::InvalidResumeToken),
244            "NODE_ID_MISMATCH" => Some(Self::NodeIdMismatch),
245            "SESSION_NOT_FOUND" => Some(Self::SessionNotFound),
246            "SESSION_ALREADY_CLOSED" => Some(Self::SessionAlreadyClosed),
247            "SESSION_CANNOT_CLOSED" => Some(Self::SessionCannotClosed),
248            _ => None,
249        }
250    }
251}
252#[derive(serde::Serialize, serde::Deserialize)]
253#[derive(Clone, PartialEq, ::prost::Message)]
254pub struct ConnectRequest {
255    #[prost(uint32, tag = "1")]
256    pub request_id: u32,
257    #[prost(string, tag = "2")]
258    pub protocol_version: ::prost::alloc::string::String,
259    #[prost(string, tag = "3")]
260    pub node_id: ::prost::alloc::string::String,
261    #[prost(uint32, tag = "4")]
262    pub ping_interval: u32,
263    #[prost(uint32, tag = "5")]
264    pub ping_timeout: u32,
265    #[prost(message, optional, tag = "6")]
266    pub extension_fields: ::core::option::Option<
267        extensions::ConnectRequestExtensionFields,
268    >,
269    /// 再接続時に既存接続を指定
270    #[prost(string, tag = "7")]
271    pub connection_id: ::prost::alloc::string::String,
272    /// マルチコネクションで指定する。
273    #[prost(string, tag = "8")]
274    pub connection_group_id: ::prost::alloc::string::String,
275    /// コネクションの有効期限（秒）
276    #[prost(uint32, tag = "9")]
277    pub expiry_interval: u32,
278}
279#[derive(serde::Serialize, serde::Deserialize)]
280#[derive(Clone, PartialEq, ::prost::Message)]
281pub struct ConnectResponse {
282    #[prost(uint32, tag = "1")]
283    pub request_id: u32,
284    #[prost(string, tag = "2")]
285    pub protocol_version: ::prost::alloc::string::String,
286    #[prost(enumeration = "ResultCode", tag = "3")]
287    pub result_code: i32,
288    #[prost(string, tag = "4")]
289    pub result_string: ::prost::alloc::string::String,
290    #[prost(message, optional, tag = "5")]
291    pub extension_fields: ::core::option::Option<
292        extensions::ConnectResponseExtensionFields,
293    >,
294    #[prost(string, tag = "6")]
295    pub connection_id: ::prost::alloc::string::String,
296    #[prost(string, tag = "8")]
297    pub connection_group_id: ::prost::alloc::string::String,
298}
299#[derive(serde::Serialize, serde::Deserialize)]
300#[derive(Clone, PartialEq, ::prost::Message)]
301pub struct Disconnect {
302    #[prost(enumeration = "ResultCode", tag = "1")]
303    pub result_code: i32,
304    #[prost(string, tag = "2")]
305    pub result_string: ::prost::alloc::string::String,
306    #[prost(message, optional, tag = "3")]
307    pub extension_fields: ::core::option::Option<extensions::DisconnectExtensionFields>,
308}
309#[derive(serde::Serialize, serde::Deserialize)]
310#[derive(Clone, PartialEq, ::prost::Message)]
311pub struct BaseTime {
312    #[prost(string, tag = "1")]
313    pub session_id: ::prost::alloc::string::String,
314    #[prost(string, tag = "2")]
315    pub name: ::prost::alloc::string::String,
316    #[prost(uint32, tag = "3")]
317    pub priority: u32,
318    #[prost(uint64, tag = "4")]
319    pub elapsed_time: u64,
320    #[prost(sint64, tag = "5")]
321    pub base_time: i64,
322}
323#[derive(serde::Serialize, serde::Deserialize)]
324#[derive(Clone, PartialEq, ::prost::Message)]
325pub struct UpstreamOpen {
326    #[prost(bytes = "bytes", tag = "1")]
327    pub stream_id: ::prost::bytes::Bytes,
328    #[prost(string, tag = "2")]
329    pub session_id: ::prost::alloc::string::String,
330    #[prost(enumeration = "QoS", tag = "3")]
331    pub qos: i32,
332}
333#[derive(serde::Serialize, serde::Deserialize)]
334#[derive(Clone, PartialEq, ::prost::Message)]
335pub struct UpstreamAbnormalClose {
336    #[prost(bytes = "bytes", tag = "1")]
337    pub stream_id: ::prost::bytes::Bytes,
338    #[prost(string, tag = "2")]
339    pub session_id: ::prost::alloc::string::String,
340}
341#[derive(serde::Serialize, serde::Deserialize)]
342#[derive(Clone, PartialEq, ::prost::Message)]
343pub struct UpstreamResume {
344    #[prost(bytes = "bytes", tag = "1")]
345    pub stream_id: ::prost::bytes::Bytes,
346    #[prost(string, tag = "2")]
347    pub session_id: ::prost::alloc::string::String,
348    #[prost(enumeration = "QoS", tag = "3")]
349    pub qos: i32,
350}
351#[derive(serde::Serialize, serde::Deserialize)]
352#[derive(Clone, PartialEq, ::prost::Message)]
353pub struct UpstreamNormalClose {
354    #[prost(bytes = "bytes", tag = "1")]
355    pub stream_id: ::prost::bytes::Bytes,
356    #[prost(string, tag = "2")]
357    pub session_id: ::prost::alloc::string::String,
358    #[prost(uint64, tag = "3")]
359    pub total_data_points: u64,
360    #[prost(uint32, tag = "4")]
361    pub final_sequence_number: u32,
362}
363#[derive(serde::Serialize, serde::Deserialize)]
364#[derive(Clone, PartialEq, ::prost::Message)]
365pub struct DownstreamOpen {
366    #[prost(bytes = "bytes", tag = "1")]
367    pub stream_id: ::prost::bytes::Bytes,
368    #[prost(message, repeated, tag = "2")]
369    pub downstream_filters: ::prost::alloc::vec::Vec<DownstreamFilter>,
370    #[prost(enumeration = "QoS", tag = "3")]
371    pub qos: i32,
372}
373#[derive(serde::Serialize, serde::Deserialize)]
374#[derive(Clone, PartialEq, ::prost::Message)]
375pub struct DownstreamAbnormalClose {
376    #[prost(bytes = "bytes", tag = "1")]
377    pub stream_id: ::prost::bytes::Bytes,
378}
379#[derive(serde::Serialize, serde::Deserialize)]
380#[derive(Clone, PartialEq, ::prost::Message)]
381pub struct DownstreamResume {
382    #[prost(bytes = "bytes", tag = "1")]
383    pub stream_id: ::prost::bytes::Bytes,
384    #[prost(message, repeated, tag = "2")]
385    pub downstream_filters: ::prost::alloc::vec::Vec<DownstreamFilter>,
386    #[prost(enumeration = "QoS", tag = "3")]
387    pub qos: i32,
388}
389#[derive(serde::Serialize, serde::Deserialize)]
390#[derive(Clone, PartialEq, ::prost::Message)]
391pub struct DownstreamNormalClose {
392    #[prost(bytes = "bytes", tag = "1")]
393    pub stream_id: ::prost::bytes::Bytes,
394}
395#[derive(serde::Serialize, serde::Deserialize)]
396#[derive(Clone, PartialEq, ::prost::Message)]
397pub struct DownstreamOpenRequest {
398    #[prost(uint32, tag = "1")]
399    pub request_id: u32,
400    #[prost(uint32, tag = "2")]
401    pub desired_stream_id_alias: u32,
402    #[prost(message, repeated, tag = "3")]
403    pub downstream_filters: ::prost::alloc::vec::Vec<DownstreamFilter>,
404    #[prost(uint32, tag = "4")]
405    pub expiry_interval: u32,
406    #[prost(map = "uint32, message", tag = "5")]
407    pub data_id_aliases: ::std::collections::HashMap<u32, DataId>,
408    #[prost(enumeration = "QoS", tag = "6")]
409    pub qos: i32,
410    #[prost(message, optional, tag = "7")]
411    pub extension_fields: ::core::option::Option<
412        extensions::DownstreamOpenRequestExtensionFields,
413    >,
414    #[prost(bool, tag = "8")]
415    pub omit_empty_chunk: bool,
416}
417#[derive(serde::Serialize, serde::Deserialize)]
418#[derive(Clone, PartialEq, ::prost::Message)]
419pub struct DownstreamOpenResponse {
420    #[prost(uint32, tag = "1")]
421    pub request_id: u32,
422    #[prost(bytes = "bytes", tag = "2")]
423    pub assigned_stream_id: ::prost::bytes::Bytes,
424    #[prost(sint64, tag = "3")]
425    pub server_time: i64,
426    #[prost(enumeration = "ResultCode", tag = "4")]
427    pub result_code: i32,
428    #[prost(string, tag = "5")]
429    pub result_string: ::prost::alloc::string::String,
430    #[prost(message, optional, tag = "6")]
431    pub extension_fields: ::core::option::Option<
432        extensions::DownstreamOpenResponseExtensionFields,
433    >,
434    #[prost(string, tag = "7")]
435    pub resume_token: ::prost::alloc::string::String,
436}
437#[derive(serde::Serialize, serde::Deserialize)]
438#[derive(Clone, PartialEq, ::prost::Message)]
439pub struct DownstreamResumeRequest {
440    #[prost(uint32, tag = "1")]
441    pub request_id: u32,
442    #[prost(bytes = "bytes", tag = "2")]
443    pub stream_id: ::prost::bytes::Bytes,
444    #[prost(uint32, tag = "3")]
445    pub desired_stream_id_alias: u32,
446    #[prost(message, optional, tag = "4")]
447    pub extension_fields: ::core::option::Option<
448        extensions::DownstreamResumeRequestExtensionFields,
449    >,
450    #[prost(string, tag = "5")]
451    pub resume_token: ::prost::alloc::string::String,
452}
453#[derive(serde::Serialize, serde::Deserialize)]
454#[derive(Clone, PartialEq, ::prost::Message)]
455pub struct DownstreamResumeResponse {
456    #[prost(uint32, tag = "1")]
457    pub request_id: u32,
458    #[prost(enumeration = "ResultCode", tag = "2")]
459    pub result_code: i32,
460    #[prost(string, tag = "3")]
461    pub result_string: ::prost::alloc::string::String,
462    #[prost(message, optional, tag = "4")]
463    pub extension_fields: ::core::option::Option<
464        extensions::DownstreamResumeResponseExtensionFields,
465    >,
466    #[prost(string, tag = "5")]
467    pub resume_token: ::prost::alloc::string::String,
468}
469#[derive(serde::Serialize, serde::Deserialize)]
470#[derive(Clone, PartialEq, ::prost::Message)]
471pub struct DownstreamCloseRequest {
472    #[prost(uint32, tag = "1")]
473    pub request_id: u32,
474    #[prost(bytes = "bytes", tag = "2")]
475    pub stream_id: ::prost::bytes::Bytes,
476    #[prost(message, optional, tag = "3")]
477    pub extension_fields: ::core::option::Option<
478        extensions::DownstreamCloseRequestExtensionFields,
479    >,
480}
481#[derive(serde::Serialize, serde::Deserialize)]
482#[derive(Clone, PartialEq, ::prost::Message)]
483pub struct DownstreamCloseResponse {
484    #[prost(uint32, tag = "1")]
485    pub request_id: u32,
486    #[prost(enumeration = "ResultCode", tag = "2")]
487    pub result_code: i32,
488    #[prost(string, tag = "3")]
489    pub result_string: ::prost::alloc::string::String,
490    #[prost(message, optional, tag = "4")]
491    pub extension_fields: ::core::option::Option<
492        extensions::DownstreamCloseResponseExtensionFields,
493    >,
494}
495#[derive(serde::Serialize, serde::Deserialize)]
496#[derive(Clone, PartialEq, ::prost::Message)]
497pub struct DownstreamChunk {
498    #[prost(uint32, tag = "1")]
499    pub stream_id_alias: u32,
500    #[prost(message, optional, tag = "4")]
501    pub stream_chunk: ::core::option::Option<StreamChunk>,
502    #[prost(message, optional, tag = "5")]
503    pub extension_fields: ::core::option::Option<
504        extensions::DownstreamChunkExtensionFields,
505    >,
506    #[prost(message, repeated, tag = "6")]
507    pub downstream_filter_references: ::prost::alloc::vec::Vec<
508        DownstreamFilterReferences,
509    >,
510    #[prost(oneof = "downstream_chunk::UpstreamOrAlias", tags = "2, 3")]
511    pub upstream_or_alias: ::core::option::Option<downstream_chunk::UpstreamOrAlias>,
512}
513/// Nested message and enum types in `DownstreamChunk`.
514pub mod downstream_chunk {
515    #[derive(serde::Serialize, serde::Deserialize)]
516    #[derive(Clone, PartialEq, ::prost::Oneof)]
517    pub enum UpstreamOrAlias {
518        #[prost(message, tag = "2")]
519        UpstreamInfo(super::UpstreamInfo),
520        #[prost(uint32, tag = "3")]
521        UpstreamAlias(u32),
522    }
523}
524#[derive(serde::Serialize, serde::Deserialize)]
525#[derive(Clone, PartialEq, ::prost::Message)]
526pub struct DownstreamChunkAck {
527    #[prost(uint32, tag = "1")]
528    pub stream_id_alias: u32,
529    #[prost(uint32, tag = "2")]
530    pub ack_id: u32,
531    #[prost(message, repeated, tag = "3")]
532    pub results: ::prost::alloc::vec::Vec<DownstreamChunkResult>,
533    #[prost(map = "uint32, message", tag = "4")]
534    pub upstream_aliases: ::std::collections::HashMap<u32, UpstreamInfo>,
535    #[prost(map = "uint32, message", tag = "5")]
536    pub data_id_aliases: ::std::collections::HashMap<u32, DataId>,
537    #[prost(message, optional, tag = "6")]
538    pub extension_fields: ::core::option::Option<
539        extensions::DownstreamChunkAckExtensionFields,
540    >,
541}
542#[derive(serde::Serialize, serde::Deserialize)]
543#[derive(Clone, PartialEq, ::prost::Message)]
544pub struct DownstreamChunkAckComplete {
545    #[prost(uint32, tag = "1")]
546    pub stream_id_alias: u32,
547    #[prost(uint32, tag = "2")]
548    pub ack_id: u32,
549    #[prost(enumeration = "ResultCode", tag = "3")]
550    pub result_code: i32,
551    #[prost(string, tag = "4")]
552    pub result_string: ::prost::alloc::string::String,
553    #[prost(message, optional, tag = "5")]
554    pub extension_fields: ::core::option::Option<
555        extensions::DownstreamChunkAckCompleteExtensionFields,
556    >,
557}
558#[derive(serde::Serialize, serde::Deserialize)]
559#[derive(Clone, PartialEq, ::prost::Message)]
560pub struct DownstreamMetadata {
561    #[prost(uint32, tag = "1")]
562    pub request_id: u32,
563    #[prost(uint32, tag = "13")]
564    pub stream_id_alias: u32,
565    #[prost(string, tag = "11")]
566    pub source_node_id: ::prost::alloc::string::String,
567    #[prost(message, optional, tag = "12")]
568    pub extension_fields: ::core::option::Option<
569        extensions::DownstreamMetadataExtensionFields,
570    >,
571    #[prost(
572        oneof = "downstream_metadata::Metadata",
573        tags = "2, 3, 4, 5, 6, 7, 8, 9, 10"
574    )]
575    pub metadata: ::core::option::Option<downstream_metadata::Metadata>,
576}
577/// Nested message and enum types in `DownstreamMetadata`.
578pub mod downstream_metadata {
579    #[derive(serde::Serialize, serde::Deserialize)]
580    #[derive(Clone, PartialEq, ::prost::Oneof)]
581    pub enum Metadata {
582        #[prost(message, tag = "2")]
583        BaseTime(super::BaseTime),
584        #[prost(message, tag = "3")]
585        UpstreamOpen(super::UpstreamOpen),
586        #[prost(message, tag = "4")]
587        UpstreamAbnormalClose(super::UpstreamAbnormalClose),
588        #[prost(message, tag = "5")]
589        UpstreamResume(super::UpstreamResume),
590        #[prost(message, tag = "6")]
591        UpstreamNormalClose(super::UpstreamNormalClose),
592        #[prost(message, tag = "7")]
593        DownstreamOpen(super::DownstreamOpen),
594        #[prost(message, tag = "8")]
595        DownstreamAbnormalClose(super::DownstreamAbnormalClose),
596        #[prost(message, tag = "9")]
597        DownstreamResume(super::DownstreamResume),
598        #[prost(message, tag = "10")]
599        DownstreamNormalClose(super::DownstreamNormalClose),
600    }
601}
602#[derive(serde::Serialize, serde::Deserialize)]
603#[derive(Clone, PartialEq, ::prost::Message)]
604pub struct DownstreamMetadataAck {
605    #[prost(uint32, tag = "1")]
606    pub request_id: u32,
607    #[prost(enumeration = "ResultCode", tag = "2")]
608    pub result_code: i32,
609    #[prost(string, tag = "3")]
610    pub result_string: ::prost::alloc::string::String,
611    #[prost(message, optional, tag = "4")]
612    pub extension_fields: ::core::option::Option<
613        extensions::DownstreamMetadataAckExtensionFields,
614    >,
615}
616#[derive(serde::Serialize, serde::Deserialize)]
617#[derive(Eq)]
618#[derive(Clone, PartialEq, ::prost::Message)]
619pub struct UpstreamInfo {
620    #[prost(string, tag = "1")]
621    pub session_id: ::prost::alloc::string::String,
622    #[prost(bytes = "bytes", tag = "2")]
623    pub stream_id: ::prost::bytes::Bytes,
624    #[prost(string, tag = "3")]
625    pub source_node_id: ::prost::alloc::string::String,
626}
627#[derive(serde::Serialize, serde::Deserialize)]
628#[derive(Clone, PartialEq, ::prost::Message)]
629pub struct DownstreamChunkResult {
630    #[prost(bytes = "bytes", tag = "1")]
631    pub stream_id_of_upstream: ::prost::bytes::Bytes,
632    #[prost(uint32, tag = "2")]
633    pub sequence_number_in_upstream: u32,
634    #[prost(enumeration = "ResultCode", tag = "3")]
635    pub result_code: i32,
636    #[prost(string, tag = "4")]
637    pub result_string: ::prost::alloc::string::String,
638    #[prost(message, optional, tag = "5")]
639    pub extension_fields: ::core::option::Option<
640        extensions::DownstreamChunkResultExtensionFields,
641    >,
642}
643#[derive(serde::Serialize, serde::Deserialize)]
644#[derive(Clone, PartialEq, ::prost::Message)]
645pub struct UpstreamCall {
646    #[prost(string, tag = "1")]
647    pub call_id: ::prost::alloc::string::String,
648    #[prost(string, tag = "2")]
649    pub request_call_id: ::prost::alloc::string::String,
650    #[prost(string, tag = "3")]
651    pub destination_node_id: ::prost::alloc::string::String,
652    #[prost(string, tag = "4")]
653    pub name: ::prost::alloc::string::String,
654    #[prost(string, tag = "5")]
655    #[serde(rename = "type")]
656    pub type_: ::prost::alloc::string::String,
657    #[prost(bytes = "bytes", tag = "6")]
658    pub payload: ::prost::bytes::Bytes,
659    #[prost(message, optional, tag = "7")]
660    pub extension_fields: ::core::option::Option<
661        extensions::UpstreamCallExtensionFields,
662    >,
663}
664#[derive(serde::Serialize, serde::Deserialize)]
665#[derive(Clone, PartialEq, ::prost::Message)]
666pub struct UpstreamCallAck {
667    #[prost(string, tag = "1")]
668    pub call_id: ::prost::alloc::string::String,
669    #[prost(enumeration = "ResultCode", tag = "2")]
670    pub result_code: i32,
671    #[prost(string, tag = "3")]
672    pub result_string: ::prost::alloc::string::String,
673    #[prost(message, optional, tag = "4")]
674    pub extension_fields: ::core::option::Option<
675        extensions::UpstreamCallAckExtensionFields,
676    >,
677}
678#[derive(serde::Serialize, serde::Deserialize)]
679#[derive(Clone, PartialEq, ::prost::Message)]
680pub struct DownstreamCall {
681    #[prost(string, tag = "1")]
682    pub call_id: ::prost::alloc::string::String,
683    #[prost(string, tag = "2")]
684    pub request_call_id: ::prost::alloc::string::String,
685    #[prost(string, tag = "3")]
686    pub source_node_id: ::prost::alloc::string::String,
687    #[prost(string, tag = "4")]
688    pub name: ::prost::alloc::string::String,
689    #[prost(string, tag = "5")]
690    #[serde(rename = "type")]
691    pub type_: ::prost::alloc::string::String,
692    #[prost(bytes = "bytes", tag = "6")]
693    pub payload: ::prost::bytes::Bytes,
694    #[prost(message, optional, tag = "7")]
695    pub extension_fields: ::core::option::Option<
696        extensions::DownstreamCallExtensionFields,
697    >,
698}
699#[derive(serde::Serialize, serde::Deserialize)]
700#[derive(Clone, Copy, PartialEq, ::prost::Message)]
701pub struct Ping {
702    #[prost(uint32, tag = "1")]
703    pub request_id: u32,
704    #[prost(message, optional, tag = "2")]
705    pub extension_fields: ::core::option::Option<extensions::PingExtensionFields>,
706}
707#[derive(serde::Serialize, serde::Deserialize)]
708#[derive(Clone, Copy, PartialEq, ::prost::Message)]
709pub struct Pong {
710    #[prost(uint32, tag = "1")]
711    pub request_id: u32,
712    #[prost(message, optional, tag = "2")]
713    pub extension_fields: ::core::option::Option<extensions::PongExtensionFields>,
714}
715#[derive(serde::Serialize, serde::Deserialize)]
716#[derive(Clone, PartialEq, ::prost::Message)]
717pub struct UpstreamOpenRequest {
718    #[prost(uint32, tag = "1")]
719    pub request_id: u32,
720    #[prost(string, tag = "2")]
721    pub session_id: ::prost::alloc::string::String,
722    #[prost(uint32, tag = "3")]
723    pub ack_interval: u32,
724    #[prost(uint32, tag = "5")]
725    pub expiry_interval: u32,
726    #[prost(message, repeated, tag = "6")]
727    pub data_ids: ::prost::alloc::vec::Vec<DataId>,
728    #[prost(enumeration = "QoS", tag = "7")]
729    pub qos: i32,
730    #[prost(message, optional, tag = "8")]
731    pub extension_fields: ::core::option::Option<
732        extensions::UpstreamOpenRequestExtensionFields,
733    >,
734}
735#[derive(serde::Serialize, serde::Deserialize)]
736#[derive(Clone, PartialEq, ::prost::Message)]
737pub struct UpstreamOpenResponse {
738    #[prost(uint32, tag = "1")]
739    pub request_id: u32,
740    #[prost(bytes = "bytes", tag = "2")]
741    pub assigned_stream_id: ::prost::bytes::Bytes,
742    #[prost(uint32, tag = "3")]
743    pub assigned_stream_id_alias: u32,
744    #[prost(map = "uint32, message", tag = "4")]
745    pub data_id_aliases: ::std::collections::HashMap<u32, DataId>,
746    #[prost(sint64, tag = "5")]
747    pub server_time: i64,
748    #[prost(enumeration = "ResultCode", tag = "6")]
749    pub result_code: i32,
750    #[prost(string, tag = "7")]
751    pub result_string: ::prost::alloc::string::String,
752    #[prost(message, optional, tag = "8")]
753    pub extension_fields: ::core::option::Option<
754        extensions::UpstreamOpenResponseExtensionFields,
755    >,
756    #[prost(string, tag = "9")]
757    pub resume_token: ::prost::alloc::string::String,
758}
759#[derive(serde::Serialize, serde::Deserialize)]
760#[derive(Clone, PartialEq, ::prost::Message)]
761pub struct UpstreamResumeRequest {
762    #[prost(uint32, tag = "1")]
763    pub request_id: u32,
764    #[prost(bytes = "bytes", tag = "2")]
765    pub stream_id: ::prost::bytes::Bytes,
766    #[prost(message, optional, tag = "3")]
767    pub extension_fields: ::core::option::Option<
768        extensions::UpstreamResumeRequestExtensionFields,
769    >,
770    #[prost(string, tag = "4")]
771    pub resume_token: ::prost::alloc::string::String,
772}
773#[derive(serde::Serialize, serde::Deserialize)]
774#[derive(Clone, PartialEq, ::prost::Message)]
775pub struct UpstreamResumeResponse {
776    #[prost(uint32, tag = "1")]
777    pub request_id: u32,
778    #[prost(uint32, tag = "2")]
779    pub assigned_stream_id_alias: u32,
780    #[prost(enumeration = "ResultCode", tag = "3")]
781    pub result_code: i32,
782    #[prost(string, tag = "4")]
783    pub result_string: ::prost::alloc::string::String,
784    #[prost(message, optional, tag = "5")]
785    pub extension_fields: ::core::option::Option<
786        extensions::UpstreamResumeResponseExtensionFields,
787    >,
788    #[prost(string, tag = "6")]
789    pub resume_token: ::prost::alloc::string::String,
790}
791#[derive(serde::Serialize, serde::Deserialize)]
792#[derive(Clone, PartialEq, ::prost::Message)]
793pub struct UpstreamCloseRequest {
794    #[prost(uint32, tag = "1")]
795    pub request_id: u32,
796    #[prost(bytes = "bytes", tag = "2")]
797    pub stream_id: ::prost::bytes::Bytes,
798    #[prost(uint64, tag = "3")]
799    pub total_data_points: u64,
800    #[prost(uint32, tag = "4")]
801    pub final_sequence_number: u32,
802    #[prost(message, optional, tag = "5")]
803    pub extension_fields: ::core::option::Option<
804        extensions::UpstreamCloseRequestExtensionFields,
805    >,
806}
807#[derive(serde::Serialize, serde::Deserialize)]
808#[derive(Clone, PartialEq, ::prost::Message)]
809pub struct UpstreamCloseResponse {
810    #[prost(uint32, tag = "1")]
811    pub request_id: u32,
812    #[prost(enumeration = "ResultCode", tag = "2")]
813    pub result_code: i32,
814    #[prost(string, tag = "3")]
815    pub result_string: ::prost::alloc::string::String,
816    #[prost(message, optional, tag = "4")]
817    pub extension_fields: ::core::option::Option<
818        extensions::UpstreamCloseResponseExtensionFields,
819    >,
820}
821#[derive(serde::Serialize, serde::Deserialize)]
822#[derive(Clone, PartialEq, ::prost::Message)]
823pub struct UpstreamChunk {
824    #[prost(uint32, tag = "1")]
825    pub stream_id_alias: u32,
826    #[prost(message, optional, tag = "2")]
827    pub stream_chunk: ::core::option::Option<StreamChunk>,
828    #[prost(message, repeated, tag = "3")]
829    pub data_ids: ::prost::alloc::vec::Vec<DataId>,
830    #[prost(message, optional, tag = "4")]
831    pub extension_fields: ::core::option::Option<
832        extensions::UpstreamChunkExtensionFields,
833    >,
834}
835#[derive(serde::Serialize, serde::Deserialize)]
836#[derive(Clone, PartialEq, ::prost::Message)]
837pub struct UpstreamChunkAck {
838    #[prost(uint32, tag = "1")]
839    pub stream_id_alias: u32,
840    #[prost(message, repeated, tag = "2")]
841    pub results: ::prost::alloc::vec::Vec<UpstreamChunkResult>,
842    #[prost(map = "uint32, message", tag = "3")]
843    pub data_id_aliases: ::std::collections::HashMap<u32, DataId>,
844    #[prost(message, optional, tag = "4")]
845    pub extension_fields: ::core::option::Option<
846        extensions::UpstreamChunkAckExtensionFields,
847    >,
848}
849#[derive(serde::Serialize, serde::Deserialize)]
850#[derive(Clone, PartialEq, ::prost::Message)]
851pub struct UpstreamMetadata {
852    #[prost(uint32, tag = "1")]
853    pub request_id: u32,
854    #[prost(message, optional, tag = "4")]
855    pub extension_fields: ::core::option::Option<
856        extensions::UpstreamMetadataExtensionFields,
857    >,
858    #[prost(oneof = "upstream_metadata::Metadata", tags = "2")]
859    pub metadata: ::core::option::Option<upstream_metadata::Metadata>,
860}
861/// Nested message and enum types in `UpstreamMetadata`.
862pub mod upstream_metadata {
863    #[derive(serde::Serialize, serde::Deserialize)]
864    #[derive(Clone, PartialEq, ::prost::Oneof)]
865    pub enum Metadata {
866        #[prost(message, tag = "2")]
867        BaseTime(super::BaseTime),
868    }
869}
870#[derive(serde::Serialize, serde::Deserialize)]
871#[derive(Clone, PartialEq, ::prost::Message)]
872pub struct UpstreamMetadataAck {
873    #[prost(uint32, tag = "1")]
874    pub request_id: u32,
875    #[prost(enumeration = "ResultCode", tag = "2")]
876    pub result_code: i32,
877    #[prost(string, tag = "3")]
878    pub result_string: ::prost::alloc::string::String,
879    #[prost(message, optional, tag = "4")]
880    pub extension_fields: ::core::option::Option<
881        extensions::UpstreamMetadataAckExtensionFields,
882    >,
883}
884#[derive(serde::Serialize, serde::Deserialize)]
885#[derive(Clone, PartialEq, ::prost::Message)]
886pub struct UpstreamChunkResult {
887    #[prost(uint32, tag = "1")]
888    pub sequence_number: u32,
889    #[prost(enumeration = "ResultCode", tag = "2")]
890    pub result_code: i32,
891    #[prost(string, tag = "3")]
892    pub result_string: ::prost::alloc::string::String,
893    #[prost(message, optional, tag = "4")]
894    pub extension_fields: ::core::option::Option<
895        extensions::UpstreamChunkResultExtensionFields,
896    >,
897}
898#[derive(serde::Serialize, serde::Deserialize)]
899#[derive(Clone, PartialEq, ::prost::Message)]
900pub struct Message {
901    #[prost(
902        oneof = "message::Message",
903        tags = "1, 2, 3, 64, 65, 66, 67, 68, 69, 70, 71, 72, 73, 128, 129, 130, 131, 132, 133, 134, 135, 136, 137, 138, 192, 193, 256, 257, 258"
904    )]
905    pub message: ::core::option::Option<message::Message>,
906}
907/// Nested message and enum types in `Message`.
908pub mod message {
909    #[derive(serde::Serialize, serde::Deserialize)]
910    #[derive(Clone, PartialEq, ::prost::Oneof)]
911    pub enum Message {
912        /// Connect
913        #[prost(message, tag = "1")]
914        ConnectRequest(super::ConnectRequest),
915        #[prost(message, tag = "2")]
916        ConnectResponse(super::ConnectResponse),
917        #[prost(message, tag = "3")]
918        Disconnect(super::Disconnect),
919        /// Upstream
920        #[prost(message, tag = "64")]
921        UpstreamOpenRequest(super::UpstreamOpenRequest),
922        #[prost(message, tag = "65")]
923        UpstreamOpenResponse(super::UpstreamOpenResponse),
924        #[prost(message, tag = "66")]
925        UpstreamResumeRequest(super::UpstreamResumeRequest),
926        #[prost(message, tag = "67")]
927        UpstreamResumeResponse(super::UpstreamResumeResponse),
928        #[prost(message, tag = "68")]
929        UpstreamCloseRequest(super::UpstreamCloseRequest),
930        #[prost(message, tag = "69")]
931        UpstreamCloseResponse(super::UpstreamCloseResponse),
932        #[prost(message, tag = "70")]
933        UpstreamChunk(super::UpstreamChunk),
934        #[prost(message, tag = "71")]
935        UpstreamChunkAck(super::UpstreamChunkAck),
936        #[prost(message, tag = "72")]
937        UpstreamMetadata(super::UpstreamMetadata),
938        #[prost(message, tag = "73")]
939        UpstreamMetadataAck(super::UpstreamMetadataAck),
940        /// Downstream
941        #[prost(message, tag = "128")]
942        DownstreamOpenRequest(super::DownstreamOpenRequest),
943        #[prost(message, tag = "129")]
944        DownstreamOpenResponse(super::DownstreamOpenResponse),
945        #[prost(message, tag = "130")]
946        DownstreamResumeRequest(super::DownstreamResumeRequest),
947        #[prost(message, tag = "131")]
948        DownstreamResumeResponse(super::DownstreamResumeResponse),
949        #[prost(message, tag = "132")]
950        DownstreamCloseRequest(super::DownstreamCloseRequest),
951        #[prost(message, tag = "133")]
952        DownstreamCloseResponse(super::DownstreamCloseResponse),
953        #[prost(message, tag = "134")]
954        DownstreamChunk(super::DownstreamChunk),
955        #[prost(message, tag = "135")]
956        DownstreamChunkAck(super::DownstreamChunkAck),
957        #[prost(message, tag = "136")]
958        DownstreamChunkAckComplete(super::DownstreamChunkAckComplete),
959        #[prost(message, tag = "137")]
960        DownstreamMetadata(super::DownstreamMetadata),
961        #[prost(message, tag = "138")]
962        DownstreamMetadataAck(super::DownstreamMetadataAck),
963        /// Ping/Pong
964        #[prost(message, tag = "192")]
965        Ping(super::Ping),
966        #[prost(message, tag = "193")]
967        Pong(super::Pong),
968        /// E2E Call
969        #[prost(message, tag = "256")]
970        UpstreamCall(super::UpstreamCall),
971        #[prost(message, tag = "257")]
972        UpstreamCallAck(super::UpstreamCallAck),
973        #[prost(message, tag = "258")]
974        DownstreamCall(super::DownstreamCall),
975    }
976}
iscp/message/proto/iscp2.v1.rs

iscp/message/proto/
iscp2.v1.rs
