mz_compute_client/mnt/build/debug/build/mz-compute-client-dd152749a29eb461/out/
mz_compute_client.protocol.response.rs

1// This file is @generated by prost-build.
2#[allow(missing_docs)]
3#[derive(Clone, PartialEq, ::prost::Message)]
4pub struct ProtoComputeResponse {
5    #[prost(oneof = "proto_compute_response::Kind", tags = "1, 2, 3, 4, 5")]
6    pub kind: ::core::option::Option<proto_compute_response::Kind>,
7}
8/// Nested message and enum types in `ProtoComputeResponse`.
9pub mod proto_compute_response {
10    #[allow(missing_docs)]
11    #[derive(Clone, PartialEq, ::prost::Message)]
12    pub struct ProtoFrontiersKind {
13        #[prost(message, optional, tag = "1")]
14        pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
15        #[prost(message, optional, tag = "2")]
16        pub resp: ::core::option::Option<super::ProtoFrontiersResponse>,
17    }
18    #[allow(missing_docs)]
19    #[derive(Clone, PartialEq, ::prost::Message)]
20    pub struct ProtoPeekResponseKind {
21        #[prost(message, optional, tag = "1")]
22        pub id: ::core::option::Option<::mz_proto::ProtoU128>,
23        #[prost(message, optional, tag = "2")]
24        pub resp: ::core::option::Option<super::ProtoPeekResponse>,
25        #[prost(btree_map = "string, string", tag = "3")]
26        pub otel_ctx: ::prost::alloc::collections::BTreeMap<
27            ::prost::alloc::string::String,
28            ::prost::alloc::string::String,
29        >,
30    }
31    #[allow(missing_docs)]
32    #[derive(Clone, PartialEq, ::prost::Message)]
33    pub struct ProtoSubscribeResponseKind {
34        #[prost(message, optional, tag = "1")]
35        pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
36        #[prost(message, optional, tag = "2")]
37        pub resp: ::core::option::Option<super::ProtoSubscribeResponse>,
38    }
39    #[allow(missing_docs)]
40    #[derive(Clone, PartialEq, ::prost::Message)]
41    pub struct ProtoCopyToResponseKind {
42        #[prost(message, optional, tag = "1")]
43        pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
44        #[prost(message, optional, tag = "2")]
45        pub resp: ::core::option::Option<super::ProtoCopyToResponse>,
46    }
47    #[allow(missing_docs)]
48    #[derive(Clone, PartialEq, ::prost::Oneof)]
49    pub enum Kind {
50        #[prost(message, tag = "1")]
51        Frontiers(ProtoFrontiersKind),
52        #[prost(message, tag = "2")]
53        PeekResponse(ProtoPeekResponseKind),
54        #[prost(message, tag = "3")]
55        SubscribeResponse(ProtoSubscribeResponseKind),
56        #[prost(message, tag = "4")]
57        CopyToResponse(ProtoCopyToResponseKind),
58        #[prost(message, tag = "5")]
59        Status(super::ProtoStatusResponse),
60    }
61}
62#[allow(missing_docs)]
63#[derive(Clone, PartialEq, ::prost::Message)]
64pub struct ProtoFrontiersResponse {
65    #[prost(message, optional, tag = "1")]
66    pub write_frontier: ::core::option::Option<::mz_repr::antichain::ProtoU64Antichain>,
67    #[prost(message, optional, tag = "2")]
68    pub input_frontier: ::core::option::Option<::mz_repr::antichain::ProtoU64Antichain>,
69    #[prost(message, optional, tag = "3")]
70    pub output_frontier: ::core::option::Option<::mz_repr::antichain::ProtoU64Antichain>,
71}
72#[allow(missing_docs)]
73#[derive(Clone, PartialEq, ::prost::Message)]
74pub struct ProtoPeekResponse {
75    #[prost(oneof = "proto_peek_response::Kind", tags = "1, 2, 3")]
76    pub kind: ::core::option::Option<proto_peek_response::Kind>,
77}
78/// Nested message and enum types in `ProtoPeekResponse`.
79pub mod proto_peek_response {
80    #[allow(missing_docs)]
81    #[derive(Clone, PartialEq, ::prost::Oneof)]
82    pub enum Kind {
83        #[prost(message, tag = "1")]
84        Rows(::mz_expr::row::ProtoRowCollection),
85        #[prost(string, tag = "2")]
86        Error(::prost::alloc::string::String),
87        #[prost(message, tag = "3")]
88        Canceled(()),
89    }
90}
91#[allow(missing_docs)]
92#[derive(Clone, PartialEq, ::prost::Message)]
93pub struct ProtoSubscribeResponse {
94    #[prost(oneof = "proto_subscribe_response::Kind", tags = "1, 2")]
95    pub kind: ::core::option::Option<proto_subscribe_response::Kind>,
96}
97/// Nested message and enum types in `ProtoSubscribeResponse`.
98pub mod proto_subscribe_response {
99    #[allow(missing_docs)]
100    #[derive(Clone, PartialEq, ::prost::Oneof)]
101    pub enum Kind {
102        #[prost(message, tag = "1")]
103        Batch(super::ProtoSubscribeBatch),
104        #[prost(message, tag = "2")]
105        DroppedAt(::mz_repr::antichain::ProtoU64Antichain),
106    }
107}
108#[allow(missing_docs)]
109#[derive(Clone, PartialEq, ::prost::Message)]
110pub struct ProtoCopyToResponse {
111    #[prost(oneof = "proto_copy_to_response::Kind", tags = "1, 2, 3")]
112    pub kind: ::core::option::Option<proto_copy_to_response::Kind>,
113}
114/// Nested message and enum types in `ProtoCopyToResponse`.
115pub mod proto_copy_to_response {
116    #[allow(missing_docs)]
117    #[derive(Clone, PartialEq, ::prost::Oneof)]
118    pub enum Kind {
119        #[prost(uint64, tag = "1")]
120        Rows(u64),
121        #[prost(string, tag = "2")]
122        Error(::prost::alloc::string::String),
123        #[prost(message, tag = "3")]
124        Dropped(()),
125    }
126}
127#[allow(missing_docs)]
128#[derive(Clone, PartialEq, ::prost::Message)]
129pub struct ProtoSubscribeBatch {
130    #[prost(message, optional, tag = "1")]
131    pub lower: ::core::option::Option<::mz_repr::antichain::ProtoU64Antichain>,
132    #[prost(message, optional, tag = "2")]
133    pub upper: ::core::option::Option<::mz_repr::antichain::ProtoU64Antichain>,
134    #[prost(message, optional, tag = "4")]
135    pub updates: ::core::option::Option<
136        proto_subscribe_batch::ProtoSubscribeBatchContents,
137    >,
138}
139/// Nested message and enum types in `ProtoSubscribeBatch`.
140pub mod proto_subscribe_batch {
141    #[allow(missing_docs)]
142    #[derive(Clone, PartialEq, ::prost::Message)]
143    pub struct ProtoUpdate {
144        #[prost(uint64, tag = "1")]
145        pub timestamp: u64,
146        #[prost(message, optional, tag = "2")]
147        pub row: ::core::option::Option<::mz_repr::ProtoRow>,
148        #[prost(int64, tag = "3")]
149        pub diff: i64,
150    }
151    #[allow(missing_docs)]
152    #[derive(Clone, PartialEq, ::prost::Message)]
153    pub struct ProtoSubscribeBatchContents {
154        #[prost(oneof = "proto_subscribe_batch_contents::Kind", tags = "1, 2")]
155        pub kind: ::core::option::Option<proto_subscribe_batch_contents::Kind>,
156    }
157    /// Nested message and enum types in `ProtoSubscribeBatchContents`.
158    pub mod proto_subscribe_batch_contents {
159        #[allow(missing_docs)]
160        #[derive(Clone, PartialEq, ::prost::Oneof)]
161        pub enum Kind {
162            #[prost(message, tag = "1")]
163            Updates(super::ProtoSubscribeUpdates),
164            #[prost(string, tag = "2")]
165            Error(::prost::alloc::string::String),
166        }
167    }
168    #[allow(missing_docs)]
169    #[derive(Clone, PartialEq, ::prost::Message)]
170    pub struct ProtoSubscribeUpdates {
171        #[prost(message, repeated, tag = "1")]
172        pub updates: ::prost::alloc::vec::Vec<ProtoUpdate>,
173    }
174}
175#[allow(missing_docs)]
176#[derive(Clone, Copy, PartialEq, ::prost::Message)]
177pub struct ProtoStatusResponse {
178    #[prost(oneof = "proto_status_response::Kind", tags = "1")]
179    pub kind: ::core::option::Option<proto_status_response::Kind>,
180}
181/// Nested message and enum types in `ProtoStatusResponse`.
182pub mod proto_status_response {
183    #[allow(missing_docs)]
184    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
185    pub enum Kind {
186        #[prost(message, tag = "1")]
187        OperatorHydration(super::ProtoOperatorHydrationStatus),
188    }
189}
190#[allow(missing_docs)]
191#[derive(Clone, Copy, PartialEq, ::prost::Message)]
192pub struct ProtoOperatorHydrationStatus {
193    #[prost(message, optional, tag = "1")]
194    pub collection_id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
195    #[prost(uint64, tag = "2")]
196    pub lir_id: u64,
197    #[prost(uint64, tag = "3")]
198    pub worker_id: u64,
199    #[prost(bool, tag = "4")]
200    pub hydrated: bool,
201}
mz_compute_client/mnt/build/debug/build/mz-compute-client-dd152749a29eb461/out/mz_compute_client.protocol.response.rs

mz_compute_client/mnt/build/debug/build/mz-compute-client-dd152749a29eb461/out/
mz_compute_client.protocol.response.rs
