wowlab_centrifuge/home/dev/pallet/wowlab/crates/target/debug/build/wowlab-centrifuge-67d3bc67034686f6/out/
centrifugal.centrifuge.protocol.rs

1// This file is @generated by prost-build.
2#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
3pub struct Error {
4    #[prost(uint32, tag = "1")]
5    pub code: u32,
6    #[prost(string, tag = "2")]
7    pub message: ::prost::alloc::string::String,
8    #[prost(bool, tag = "3")]
9    pub temporary: bool,
10}
11#[derive(Clone, PartialEq, ::prost::Message)]
12pub struct Command {
13    #[prost(uint32, tag = "1")]
14    pub id: u32,
15    #[prost(message, optional, tag = "4")]
16    pub connect: ::core::option::Option<ConnectRequest>,
17    #[prost(message, optional, tag = "5")]
18    pub subscribe: ::core::option::Option<SubscribeRequest>,
19    #[prost(message, optional, tag = "6")]
20    pub unsubscribe: ::core::option::Option<UnsubscribeRequest>,
21    #[prost(message, optional, tag = "7")]
22    pub publish: ::core::option::Option<PublishRequest>,
23    #[prost(message, optional, tag = "8")]
24    pub presence: ::core::option::Option<PresenceRequest>,
25    #[prost(message, optional, tag = "9")]
26    pub presence_stats: ::core::option::Option<PresenceStatsRequest>,
27    #[prost(message, optional, tag = "10")]
28    pub history: ::core::option::Option<HistoryRequest>,
29    #[prost(message, optional, tag = "11")]
30    pub ping: ::core::option::Option<PingRequest>,
31    #[prost(message, optional, tag = "12")]
32    pub send: ::core::option::Option<SendRequest>,
33    #[prost(message, optional, tag = "13")]
34    pub rpc: ::core::option::Option<RpcRequest>,
35    #[prost(message, optional, tag = "14")]
36    pub refresh: ::core::option::Option<RefreshRequest>,
37    #[prost(message, optional, tag = "15")]
38    pub sub_refresh: ::core::option::Option<SubRefreshRequest>,
39}
40#[derive(Clone, PartialEq, ::prost::Message)]
41pub struct Reply {
42    #[prost(uint32, tag = "1")]
43    pub id: u32,
44    #[prost(message, optional, tag = "2")]
45    pub error: ::core::option::Option<Error>,
46    #[prost(message, optional, tag = "4")]
47    pub push: ::core::option::Option<Push>,
48    #[prost(message, optional, tag = "5")]
49    pub connect: ::core::option::Option<ConnectResult>,
50    #[prost(message, optional, tag = "6")]
51    pub subscribe: ::core::option::Option<SubscribeResult>,
52    #[prost(message, optional, tag = "7")]
53    pub unsubscribe: ::core::option::Option<UnsubscribeResult>,
54    #[prost(message, optional, tag = "8")]
55    pub publish: ::core::option::Option<PublishResult>,
56    #[prost(message, optional, tag = "9")]
57    pub presence: ::core::option::Option<PresenceResult>,
58    #[prost(message, optional, tag = "10")]
59    pub presence_stats: ::core::option::Option<PresenceStatsResult>,
60    #[prost(message, optional, tag = "11")]
61    pub history: ::core::option::Option<HistoryResult>,
62    #[prost(message, optional, tag = "12")]
63    pub ping: ::core::option::Option<PingResult>,
64    #[prost(message, optional, tag = "13")]
65    pub rpc: ::core::option::Option<RpcResult>,
66    #[prost(message, optional, tag = "14")]
67    pub refresh: ::core::option::Option<RefreshResult>,
68    #[prost(message, optional, tag = "15")]
69    pub sub_refresh: ::core::option::Option<SubRefreshResult>,
70}
71#[derive(Clone, PartialEq, ::prost::Message)]
72pub struct Push {
73    #[prost(int64, tag = "1")]
74    pub id: i64,
75    #[prost(string, tag = "2")]
76    pub channel: ::prost::alloc::string::String,
77    #[prost(message, optional, tag = "4")]
78    pub r#pub: ::core::option::Option<Publication>,
79    #[prost(message, optional, tag = "5")]
80    pub join: ::core::option::Option<Join>,
81    #[prost(message, optional, tag = "6")]
82    pub leave: ::core::option::Option<Leave>,
83    #[prost(message, optional, tag = "7")]
84    pub unsubscribe: ::core::option::Option<Unsubscribe>,
85    #[prost(message, optional, tag = "8")]
86    pub message: ::core::option::Option<Message>,
87    #[prost(message, optional, tag = "9")]
88    pub subscribe: ::core::option::Option<Subscribe>,
89    #[prost(message, optional, tag = "10")]
90    pub connect: ::core::option::Option<Connect>,
91    #[prost(message, optional, tag = "11")]
92    pub disconnect: ::core::option::Option<Disconnect>,
93    #[prost(message, optional, tag = "12")]
94    pub refresh: ::core::option::Option<Refresh>,
95}
96#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
97pub struct ClientInfo {
98    #[prost(string, tag = "1")]
99    pub user: ::prost::alloc::string::String,
100    #[prost(string, tag = "2")]
101    pub client: ::prost::alloc::string::String,
102    #[prost(bytes = "vec", tag = "3")]
103    pub conn_info: ::prost::alloc::vec::Vec<u8>,
104    #[prost(bytes = "vec", tag = "4")]
105    pub chan_info: ::prost::alloc::vec::Vec<u8>,
106}
107#[derive(Clone, PartialEq, ::prost::Message)]
108pub struct Publication {
109    #[prost(bytes = "vec", tag = "4")]
110    pub data: ::prost::alloc::vec::Vec<u8>,
111    #[prost(message, optional, tag = "5")]
112    pub info: ::core::option::Option<ClientInfo>,
113    #[prost(uint64, tag = "6")]
114    pub offset: u64,
115    #[prost(map = "string, string", tag = "7")]
116    pub tags: ::std::collections::HashMap<
117        ::prost::alloc::string::String,
118        ::prost::alloc::string::String,
119    >,
120    #[prost(bool, tag = "8")]
121    pub delta: bool,
122    #[prost(int64, tag = "9")]
123    pub time: i64,
124    #[prost(string, tag = "10")]
125    pub channel: ::prost::alloc::string::String,
126}
127#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
128pub struct Join {
129    #[prost(message, optional, tag = "1")]
130    pub info: ::core::option::Option<ClientInfo>,
131}
132#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
133pub struct Leave {
134    #[prost(message, optional, tag = "1")]
135    pub info: ::core::option::Option<ClientInfo>,
136}
137#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
138pub struct Unsubscribe {
139    #[prost(uint32, tag = "2")]
140    pub code: u32,
141    #[prost(string, tag = "3")]
142    pub reason: ::prost::alloc::string::String,
143}
144#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
145pub struct Subscribe {
146    #[prost(bool, tag = "1")]
147    pub recoverable: bool,
148    #[prost(string, tag = "4")]
149    pub epoch: ::prost::alloc::string::String,
150    #[prost(uint64, tag = "5")]
151    pub offset: u64,
152    #[prost(bool, tag = "6")]
153    pub positioned: bool,
154    #[prost(bytes = "vec", tag = "7")]
155    pub data: ::prost::alloc::vec::Vec<u8>,
156}
157#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
158pub struct Message {
159    #[prost(bytes = "vec", tag = "1")]
160    pub data: ::prost::alloc::vec::Vec<u8>,
161}
162#[derive(Clone, PartialEq, ::prost::Message)]
163pub struct Connect {
164    #[prost(string, tag = "1")]
165    pub client: ::prost::alloc::string::String,
166    #[prost(string, tag = "2")]
167    pub version: ::prost::alloc::string::String,
168    #[prost(bytes = "vec", tag = "3")]
169    pub data: ::prost::alloc::vec::Vec<u8>,
170    #[prost(map = "string, message", tag = "4")]
171    pub subs: ::std::collections::HashMap<
172        ::prost::alloc::string::String,
173        SubscribeResult,
174    >,
175    #[prost(bool, tag = "5")]
176    pub expires: bool,
177    #[prost(uint32, tag = "6")]
178    pub ttl: u32,
179    #[prost(uint32, tag = "7")]
180    pub ping: u32,
181    #[prost(bool, tag = "8")]
182    pub pong: bool,
183    #[prost(string, tag = "9")]
184    pub session: ::prost::alloc::string::String,
185    #[prost(string, tag = "10")]
186    pub node: ::prost::alloc::string::String,
187    #[prost(int64, tag = "11")]
188    pub time: i64,
189}
190#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
191pub struct Disconnect {
192    #[prost(uint32, tag = "1")]
193    pub code: u32,
194    #[prost(string, tag = "2")]
195    pub reason: ::prost::alloc::string::String,
196    #[prost(bool, tag = "3")]
197    pub reconnect: bool,
198}
199#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
200pub struct Refresh {
201    #[prost(bool, tag = "1")]
202    pub expires: bool,
203    #[prost(uint32, tag = "2")]
204    pub ttl: u32,
205}
206#[derive(Clone, PartialEq, ::prost::Message)]
207pub struct ConnectRequest {
208    #[prost(string, tag = "1")]
209    pub token: ::prost::alloc::string::String,
210    #[prost(bytes = "vec", tag = "2")]
211    pub data: ::prost::alloc::vec::Vec<u8>,
212    #[prost(map = "string, message", tag = "3")]
213    pub subs: ::std::collections::HashMap<
214        ::prost::alloc::string::String,
215        SubscribeRequest,
216    >,
217    #[prost(string, tag = "4")]
218    pub name: ::prost::alloc::string::String,
219    #[prost(string, tag = "5")]
220    pub version: ::prost::alloc::string::String,
221    #[prost(map = "string, string", tag = "6")]
222    pub headers: ::std::collections::HashMap<
223        ::prost::alloc::string::String,
224        ::prost::alloc::string::String,
225    >,
226    #[prost(int64, tag = "7")]
227    pub flag: i64,
228}
229#[derive(Clone, PartialEq, ::prost::Message)]
230pub struct ConnectResult {
231    #[prost(string, tag = "1")]
232    pub client: ::prost::alloc::string::String,
233    #[prost(string, tag = "2")]
234    pub version: ::prost::alloc::string::String,
235    #[prost(bool, tag = "3")]
236    pub expires: bool,
237    #[prost(uint32, tag = "4")]
238    pub ttl: u32,
239    #[prost(bytes = "vec", tag = "5")]
240    pub data: ::prost::alloc::vec::Vec<u8>,
241    #[prost(map = "string, message", tag = "6")]
242    pub subs: ::std::collections::HashMap<
243        ::prost::alloc::string::String,
244        SubscribeResult,
245    >,
246    #[prost(uint32, tag = "7")]
247    pub ping: u32,
248    #[prost(bool, tag = "8")]
249    pub pong: bool,
250    #[prost(string, tag = "9")]
251    pub session: ::prost::alloc::string::String,
252    #[prost(string, tag = "10")]
253    pub node: ::prost::alloc::string::String,
254    #[prost(int64, tag = "11")]
255    pub time: i64,
256}
257#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
258pub struct RefreshRequest {
259    #[prost(string, tag = "1")]
260    pub token: ::prost::alloc::string::String,
261}
262#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
263pub struct RefreshResult {
264    #[prost(string, tag = "1")]
265    pub client: ::prost::alloc::string::String,
266    #[prost(string, tag = "2")]
267    pub version: ::prost::alloc::string::String,
268    #[prost(bool, tag = "3")]
269    pub expires: bool,
270    #[prost(uint32, tag = "4")]
271    pub ttl: u32,
272}
273#[derive(Clone, PartialEq, ::prost::Message)]
274pub struct SubscribeRequest {
275    #[prost(string, tag = "1")]
276    pub channel: ::prost::alloc::string::String,
277    #[prost(string, tag = "2")]
278    pub token: ::prost::alloc::string::String,
279    #[prost(bool, tag = "3")]
280    pub recover: bool,
281    #[prost(string, tag = "6")]
282    pub epoch: ::prost::alloc::string::String,
283    #[prost(uint64, tag = "7")]
284    pub offset: u64,
285    #[prost(bytes = "vec", tag = "8")]
286    pub data: ::prost::alloc::vec::Vec<u8>,
287    #[prost(bool, tag = "9")]
288    pub positioned: bool,
289    #[prost(bool, tag = "10")]
290    pub recoverable: bool,
291    #[prost(bool, tag = "11")]
292    pub join_leave: bool,
293    #[prost(string, tag = "12")]
294    pub delta: ::prost::alloc::string::String,
295    #[prost(message, optional, tag = "13")]
296    pub tf: ::core::option::Option<FilterNode>,
297    #[prost(int64, tag = "14")]
298    pub flag: i64,
299}
300#[derive(Clone, PartialEq, ::prost::Message)]
301pub struct SubscribeResult {
302    #[prost(bool, tag = "1")]
303    pub expires: bool,
304    #[prost(uint32, tag = "2")]
305    pub ttl: u32,
306    #[prost(bool, tag = "3")]
307    pub recoverable: bool,
308    #[prost(string, tag = "6")]
309    pub epoch: ::prost::alloc::string::String,
310    #[prost(message, repeated, tag = "7")]
311    pub publications: ::prost::alloc::vec::Vec<Publication>,
312    #[prost(bool, tag = "8")]
313    pub recovered: bool,
314    #[prost(uint64, tag = "9")]
315    pub offset: u64,
316    #[prost(bool, tag = "10")]
317    pub positioned: bool,
318    #[prost(bytes = "vec", tag = "11")]
319    pub data: ::prost::alloc::vec::Vec<u8>,
320    #[prost(bool, tag = "12")]
321    pub was_recovering: bool,
322    #[prost(bool, tag = "13")]
323    pub delta: bool,
324    #[prost(int64, tag = "14")]
325    pub id: i64,
326}
327#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
328pub struct SubRefreshRequest {
329    #[prost(string, tag = "1")]
330    pub channel: ::prost::alloc::string::String,
331    #[prost(string, tag = "2")]
332    pub token: ::prost::alloc::string::String,
333}
334#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
335pub struct SubRefreshResult {
336    #[prost(bool, tag = "1")]
337    pub expires: bool,
338    #[prost(uint32, tag = "2")]
339    pub ttl: u32,
340}
341#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
342pub struct UnsubscribeRequest {
343    #[prost(string, tag = "1")]
344    pub channel: ::prost::alloc::string::String,
345}
346#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
347pub struct UnsubscribeResult {}
348#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
349pub struct PublishRequest {
350    #[prost(string, tag = "1")]
351    pub channel: ::prost::alloc::string::String,
352    #[prost(bytes = "vec", tag = "2")]
353    pub data: ::prost::alloc::vec::Vec<u8>,
354}
355#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
356pub struct PublishResult {}
357#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
358pub struct PresenceRequest {
359    #[prost(string, tag = "1")]
360    pub channel: ::prost::alloc::string::String,
361}
362#[derive(Clone, PartialEq, ::prost::Message)]
363pub struct PresenceResult {
364    #[prost(map = "string, message", tag = "1")]
365    pub presence: ::std::collections::HashMap<
366        ::prost::alloc::string::String,
367        ClientInfo,
368    >,
369}
370#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
371pub struct PresenceStatsRequest {
372    #[prost(string, tag = "1")]
373    pub channel: ::prost::alloc::string::String,
374}
375#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
376pub struct PresenceStatsResult {
377    #[prost(uint32, tag = "1")]
378    pub num_clients: u32,
379    #[prost(uint32, tag = "2")]
380    pub num_users: u32,
381}
382#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
383pub struct StreamPosition {
384    #[prost(uint64, tag = "1")]
385    pub offset: u64,
386    #[prost(string, tag = "2")]
387    pub epoch: ::prost::alloc::string::String,
388}
389#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
390pub struct HistoryRequest {
391    #[prost(string, tag = "1")]
392    pub channel: ::prost::alloc::string::String,
393    #[prost(int32, tag = "7")]
394    pub limit: i32,
395    #[prost(message, optional, tag = "8")]
396    pub since: ::core::option::Option<StreamPosition>,
397    #[prost(bool, tag = "9")]
398    pub reverse: bool,
399}
400#[derive(Clone, PartialEq, ::prost::Message)]
401pub struct HistoryResult {
402    #[prost(message, repeated, tag = "1")]
403    pub publications: ::prost::alloc::vec::Vec<Publication>,
404    #[prost(string, tag = "2")]
405    pub epoch: ::prost::alloc::string::String,
406    #[prost(uint64, tag = "3")]
407    pub offset: u64,
408}
409#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
410pub struct PingRequest {}
411#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
412pub struct PingResult {}
413#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
414pub struct RpcRequest {
415    #[prost(bytes = "vec", tag = "1")]
416    pub data: ::prost::alloc::vec::Vec<u8>,
417    #[prost(string, tag = "2")]
418    pub method: ::prost::alloc::string::String,
419}
420#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
421pub struct RpcResult {
422    #[prost(bytes = "vec", tag = "1")]
423    pub data: ::prost::alloc::vec::Vec<u8>,
424}
425#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
426pub struct SendRequest {
427    #[prost(bytes = "vec", tag = "1")]
428    pub data: ::prost::alloc::vec::Vec<u8>,
429}
430#[derive(Clone, PartialEq, ::prost::Message)]
431pub struct FilterNode {
432    #[prost(string, tag = "1")]
433    pub op: ::prost::alloc::string::String,
434    #[prost(string, tag = "2")]
435    pub key: ::prost::alloc::string::String,
436    #[prost(string, tag = "3")]
437    pub cmp: ::prost::alloc::string::String,
438    #[prost(string, tag = "4")]
439    pub val: ::prost::alloc::string::String,
440    #[prost(string, repeated, tag = "5")]
441    pub vals: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
442    #[prost(message, repeated, tag = "6")]
443    pub nodes: ::prost::alloc::vec::Vec<FilterNode>,
444}
wowlab_centrifuge/home/dev/pallet/wowlab/crates/target/debug/build/wowlab-centrifuge-67d3bc67034686f6/out/centrifugal.centrifuge.protocol.rs

wowlab_centrifuge/home/dev/pallet/wowlab/crates/target/debug/build/wowlab-centrifuge-67d3bc67034686f6/out/
centrifugal.centrifuge.protocol.rs
