risingwave_pb/
common.rs

1// This file is @generated by prost-build.
2#[derive(prost_helpers::AnyPB)]
3#[derive(Clone, PartialEq, ::prost::Message)]
4pub struct Status {
5    #[prost(enumeration = "status::Code", tag = "1")]
6    pub code: i32,
7    #[prost(string, tag = "2")]
8    pub message: ::prost::alloc::string::String,
9}
10/// Nested message and enum types in `Status`.
11pub mod status {
12    #[derive(prost_helpers::AnyPB)]
13    #[derive(
14        Clone,
15        Copy,
16        Debug,
17        PartialEq,
18        Eq,
19        Hash,
20        PartialOrd,
21        Ord,
22        ::prost::Enumeration
23    )]
24    #[repr(i32)]
25    pub enum Code {
26        Unspecified = 0,
27        Ok = 1,
28        UnknownWorker = 2,
29    }
30    impl Code {
31        /// String value of the enum field names used in the ProtoBuf definition.
32        ///
33        /// The values are not transformed in any way and thus are considered stable
34        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
35        pub fn as_str_name(&self) -> &'static str {
36            match self {
37                Self::Unspecified => "UNSPECIFIED",
38                Self::Ok => "OK",
39                Self::UnknownWorker => "UNKNOWN_WORKER",
40            }
41        }
42        /// Creates an enum from field names used in the ProtoBuf definition.
43        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
44            match value {
45                "UNSPECIFIED" => Some(Self::Unspecified),
46                "OK" => Some(Self::Ok),
47                "UNKNOWN_WORKER" => Some(Self::UnknownWorker),
48                _ => None,
49            }
50        }
51    }
52}
53#[derive(prost_helpers::AnyPB)]
54#[derive(Clone, PartialEq, ::prost::Message)]
55pub struct HostAddress {
56    #[prost(string, tag = "1")]
57    pub host: ::prost::alloc::string::String,
58    #[prost(int32, tag = "2")]
59    pub port: i32,
60}
61/// Encode which host machine an actor resides.
62#[derive(prost_helpers::AnyPB)]
63#[derive(Clone, PartialEq, ::prost::Message)]
64pub struct ActorInfo {
65    #[prost(uint32, tag = "1")]
66    pub actor_id: u32,
67    #[prost(message, optional, tag = "2")]
68    pub host: ::core::option::Option<HostAddress>,
69}
70/// renamed from `ParallelUnit`
71#[derive(prost_helpers::AnyPB)]
72#[derive(Clone, Copy, PartialEq, ::prost::Message)]
73pub struct ActorLocation {
74    #[prost(uint32, tag = "2")]
75    pub worker_node_id: u32,
76}
77#[derive(prost_helpers::AnyPB)]
78#[derive(Clone, PartialEq, ::prost::Message)]
79pub struct WorkerNode {
80    #[prost(uint32, tag = "1")]
81    pub id: u32,
82    #[prost(enumeration = "WorkerType", tag = "2")]
83    pub r#type: i32,
84    #[prost(message, optional, tag = "3")]
85    pub host: ::core::option::Option<HostAddress>,
86    #[prost(enumeration = "worker_node::State", tag = "4")]
87    pub state: i32,
88    #[prost(message, optional, tag = "6")]
89    pub property: ::core::option::Option<worker_node::Property>,
90    /// Ranges from 0 to 1023, used to generate the machine ID field in the global unique ID.
91    #[prost(uint32, optional, tag = "7")]
92    pub transactional_id: ::core::option::Option<u32>,
93    /// Resource spec.
94    /// It's populated by meta node with the value reported by worker node, when the worker node is added by meta node.
95    /// It's not persistent in meta store.
96    #[prost(message, optional, tag = "8")]
97    pub resource: ::core::option::Option<worker_node::Resource>,
98    /// Timestamp the worker node is added by meta node, in seconds.
99    /// It's populated by meta node, when the worker node is added by meta node.
100    /// It's not persistent in meta store.
101    #[prost(uint64, optional, tag = "9")]
102    pub started_at: ::core::option::Option<u64>,
103}
104/// Nested message and enum types in `WorkerNode`.
105pub mod worker_node {
106    /// Fields in `Property` that doesn't fit current worker type are just ignored by receiver.
107    #[derive(prost_helpers::AnyPB)]
108    #[derive(Clone, PartialEq, ::prost::Message)]
109    pub struct Property {
110        #[prost(bool, tag = "1")]
111        pub is_streaming: bool,
112        #[prost(bool, tag = "2")]
113        pub is_serving: bool,
114        #[prost(bool, tag = "3")]
115        pub is_unschedulable: bool,
116        /// This is used for frontend node to register its rpc address
117        #[prost(string, tag = "4")]
118        pub internal_rpc_host_addr: ::prost::alloc::string::String,
119        #[prost(uint32, tag = "6")]
120        pub parallelism: u32,
121        /// resource group for scheduling
122        #[prost(string, optional, tag = "7")]
123        pub resource_group: ::core::option::Option<::prost::alloc::string::String>,
124    }
125    #[derive(prost_helpers::AnyPB)]
126    #[derive(Clone, PartialEq, ::prost::Message)]
127    pub struct Resource {
128        #[prost(string, tag = "1")]
129        pub rw_version: ::prost::alloc::string::String,
130        #[prost(uint64, tag = "2")]
131        pub total_memory_bytes: u64,
132        #[prost(uint64, tag = "3")]
133        pub total_cpu_cores: u64,
134    }
135    #[derive(prost_helpers::AnyPB)]
136    #[derive(
137        Clone,
138        Copy,
139        Debug,
140        PartialEq,
141        Eq,
142        Hash,
143        PartialOrd,
144        Ord,
145        ::prost::Enumeration
146    )]
147    #[repr(i32)]
148    pub enum State {
149        Unspecified = 0,
150        Starting = 1,
151        Running = 2,
152    }
153    impl State {
154        /// String value of the enum field names used in the ProtoBuf definition.
155        ///
156        /// The values are not transformed in any way and thus are considered stable
157        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
158        pub fn as_str_name(&self) -> &'static str {
159            match self {
160                Self::Unspecified => "UNSPECIFIED",
161                Self::Starting => "STARTING",
162                Self::Running => "RUNNING",
163            }
164        }
165        /// Creates an enum from field names used in the ProtoBuf definition.
166        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
167            match value {
168                "UNSPECIFIED" => Some(Self::Unspecified),
169                "STARTING" => Some(Self::Starting),
170                "RUNNING" => Some(Self::Running),
171                _ => None,
172            }
173        }
174    }
175}
176#[derive(prost_helpers::AnyPB)]
177#[derive(Eq)]
178#[derive(Clone, PartialEq, ::prost::Message)]
179pub struct Buffer {
180    #[prost(enumeration = "buffer::CompressionType", tag = "1")]
181    pub compression: i32,
182    #[prost(bytes = "vec", tag = "2")]
183    pub body: ::prost::alloc::vec::Vec<u8>,
184}
185/// Nested message and enum types in `Buffer`.
186pub mod buffer {
187    #[derive(prost_helpers::AnyPB)]
188    #[derive(
189        Clone,
190        Copy,
191        Debug,
192        PartialEq,
193        Eq,
194        Hash,
195        PartialOrd,
196        Ord,
197        ::prost::Enumeration
198    )]
199    #[repr(i32)]
200    pub enum CompressionType {
201        Unspecified = 0,
202        None = 1,
203    }
204    impl CompressionType {
205        /// String value of the enum field names used in the ProtoBuf definition.
206        ///
207        /// The values are not transformed in any way and thus are considered stable
208        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
209        pub fn as_str_name(&self) -> &'static str {
210            match self {
211                Self::Unspecified => "UNSPECIFIED",
212                Self::None => "NONE",
213            }
214        }
215        /// Creates an enum from field names used in the ProtoBuf definition.
216        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
217            match value {
218                "UNSPECIFIED" => Some(Self::Unspecified),
219                "NONE" => Some(Self::None),
220                _ => None,
221            }
222        }
223    }
224}
225/// Vnode mapping for stream fragments. Stores mapping from virtual node to (worker id, slot index).
226#[derive(prost_helpers::AnyPB)]
227#[derive(Clone, PartialEq, ::prost::Message)]
228pub struct WorkerSlotMapping {
229    #[prost(uint32, repeated, tag = "1")]
230    pub original_indices: ::prost::alloc::vec::Vec<u32>,
231    #[prost(uint64, repeated, tag = "2")]
232    pub data: ::prost::alloc::vec::Vec<u64>,
233}
234#[derive(prost_helpers::AnyPB)]
235#[derive(Clone, Copy, PartialEq, ::prost::Message)]
236pub struct BatchQueryCommittedEpoch {
237    #[prost(uint64, tag = "1")]
238    pub epoch: u64,
239    #[prost(uint64, tag = "2")]
240    pub hummock_version_id: u64,
241}
242#[derive(prost_helpers::AnyPB)]
243#[derive(Clone, Copy, PartialEq, ::prost::Message)]
244pub struct BatchQueryEpoch {
245    #[prost(oneof = "batch_query_epoch::Epoch", tags = "1, 2, 3, 4")]
246    pub epoch: ::core::option::Option<batch_query_epoch::Epoch>,
247}
248/// Nested message and enum types in `BatchQueryEpoch`.
249pub mod batch_query_epoch {
250    #[derive(prost_helpers::AnyPB)]
251    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
252    pub enum Epoch {
253        #[prost(message, tag = "1")]
254        Committed(super::BatchQueryCommittedEpoch),
255        #[prost(uint64, tag = "2")]
256        Current(u64),
257        #[prost(uint64, tag = "3")]
258        Backup(u64),
259        #[prost(uint64, tag = "4")]
260        TimeTravel(u64),
261    }
262}
263#[derive(prost_helpers::AnyPB)]
264#[derive(Eq, Hash)]
265#[derive(Clone, Copy, PartialEq, ::prost::Message)]
266pub struct OrderType {
267    #[prost(enumeration = "Direction", tag = "1")]
268    pub direction: i32,
269    #[prost(enumeration = "NullsAre", tag = "2")]
270    pub nulls_are: i32,
271}
272/// Column index with an order type (ASC or DESC). Used to represent a sort key (`repeated ColumnOrder`).
273#[derive(prost_helpers::AnyPB)]
274#[derive(Eq, Hash)]
275#[derive(Clone, Copy, PartialEq, ::prost::Message)]
276pub struct ColumnOrder {
277    #[prost(uint32, tag = "1")]
278    pub column_index: u32,
279    #[prost(message, optional, tag = "2")]
280    pub order_type: ::core::option::Option<OrderType>,
281}
282#[derive(prost_helpers::AnyPB)]
283#[derive(Clone, PartialEq, ::prost::Message)]
284pub struct Uint32Vector {
285    #[prost(uint32, repeated, tag = "1")]
286    pub data: ::prost::alloc::vec::Vec<u32>,
287}
288#[derive(prost_helpers::AnyPB)]
289#[derive(Clone, Copy, PartialEq, ::prost::Message)]
290pub struct OptionalUint32 {
291    #[prost(uint32, optional, tag = "1")]
292    pub value: ::core::option::Option<u32>,
293}
294#[derive(prost_helpers::AnyPB)]
295#[derive(Clone, Copy, PartialEq, ::prost::Message)]
296pub struct OptionalUint64 {
297    #[prost(uint64, optional, tag = "1")]
298    pub value: ::core::option::Option<u64>,
299}
300#[derive(prost_helpers::AnyPB)]
301#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
302#[repr(i32)]
303pub enum WorkerType {
304    Unspecified = 0,
305    Frontend = 1,
306    ComputeNode = 2,
307    RiseCtl = 3,
308    Compactor = 4,
309    Meta = 5,
310}
311impl WorkerType {
312    /// String value of the enum field names used in the ProtoBuf definition.
313    ///
314    /// The values are not transformed in any way and thus are considered stable
315    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
316    pub fn as_str_name(&self) -> &'static str {
317        match self {
318            Self::Unspecified => "WORKER_TYPE_UNSPECIFIED",
319            Self::Frontend => "WORKER_TYPE_FRONTEND",
320            Self::ComputeNode => "WORKER_TYPE_COMPUTE_NODE",
321            Self::RiseCtl => "WORKER_TYPE_RISE_CTL",
322            Self::Compactor => "WORKER_TYPE_COMPACTOR",
323            Self::Meta => "WORKER_TYPE_META",
324        }
325    }
326    /// Creates an enum from field names used in the ProtoBuf definition.
327    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
328        match value {
329            "WORKER_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
330            "WORKER_TYPE_FRONTEND" => Some(Self::Frontend),
331            "WORKER_TYPE_COMPUTE_NODE" => Some(Self::ComputeNode),
332            "WORKER_TYPE_RISE_CTL" => Some(Self::RiseCtl),
333            "WORKER_TYPE_COMPACTOR" => Some(Self::Compactor),
334            "WORKER_TYPE_META" => Some(Self::Meta),
335            _ => None,
336        }
337    }
338}
339#[derive(prost_helpers::AnyPB)]
340#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
341#[repr(i32)]
342pub enum Direction {
343    Unspecified = 0,
344    Ascending = 1,
345    Descending = 2,
346}
347impl Direction {
348    /// String value of the enum field names used in the ProtoBuf definition.
349    ///
350    /// The values are not transformed in any way and thus are considered stable
351    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
352    pub fn as_str_name(&self) -> &'static str {
353        match self {
354            Self::Unspecified => "DIRECTION_UNSPECIFIED",
355            Self::Ascending => "DIRECTION_ASCENDING",
356            Self::Descending => "DIRECTION_DESCENDING",
357        }
358    }
359    /// Creates an enum from field names used in the ProtoBuf definition.
360    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
361        match value {
362            "DIRECTION_UNSPECIFIED" => Some(Self::Unspecified),
363            "DIRECTION_ASCENDING" => Some(Self::Ascending),
364            "DIRECTION_DESCENDING" => Some(Self::Descending),
365            _ => None,
366        }
367    }
368}
369#[derive(prost_helpers::AnyPB)]
370#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
371#[repr(i32)]
372pub enum NullsAre {
373    Unspecified = 0,
374    Largest = 1,
375    Smallest = 2,
376}
377impl NullsAre {
378    /// String value of the enum field names used in the ProtoBuf definition.
379    ///
380    /// The values are not transformed in any way and thus are considered stable
381    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
382    pub fn as_str_name(&self) -> &'static str {
383        match self {
384            Self::Unspecified => "NULLS_ARE_UNSPECIFIED",
385            Self::Largest => "NULLS_ARE_LARGEST",
386            Self::Smallest => "NULLS_ARE_SMALLEST",
387        }
388    }
389    /// Creates an enum from field names used in the ProtoBuf definition.
390    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
391        match value {
392            "NULLS_ARE_UNSPECIFIED" => Some(Self::Unspecified),
393            "NULLS_ARE_LARGEST" => Some(Self::Largest),
394            "NULLS_ARE_SMALLEST" => Some(Self::Smallest),
395            _ => None,
396        }
397    }
398}
399#[derive(prost_helpers::AnyPB)]
400#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
401#[repr(i32)]
402pub enum ObjectType {
403    Unspecified = 0,
404    Database = 1,
405    Schema = 2,
406    Table = 3,
407    Mview = 4,
408    Source = 5,
409    Sink = 6,
410    View = 7,
411    Index = 8,
412    Function = 9,
413    Connection = 10,
414    Subscription = 11,
415    Secret = 12,
416}
417impl ObjectType {
418    /// String value of the enum field names used in the ProtoBuf definition.
419    ///
420    /// The values are not transformed in any way and thus are considered stable
421    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
422    pub fn as_str_name(&self) -> &'static str {
423        match self {
424            Self::Unspecified => "UNSPECIFIED",
425            Self::Database => "DATABASE",
426            Self::Schema => "SCHEMA",
427            Self::Table => "TABLE",
428            Self::Mview => "MVIEW",
429            Self::Source => "SOURCE",
430            Self::Sink => "SINK",
431            Self::View => "VIEW",
432            Self::Index => "INDEX",
433            Self::Function => "FUNCTION",
434            Self::Connection => "CONNECTION",
435            Self::Subscription => "SUBSCRIPTION",
436            Self::Secret => "SECRET",
437        }
438    }
439    /// Creates an enum from field names used in the ProtoBuf definition.
440    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
441        match value {
442            "UNSPECIFIED" => Some(Self::Unspecified),
443            "DATABASE" => Some(Self::Database),
444            "SCHEMA" => Some(Self::Schema),
445            "TABLE" => Some(Self::Table),
446            "MVIEW" => Some(Self::Mview),
447            "SOURCE" => Some(Self::Source),
448            "SINK" => Some(Self::Sink),
449            "VIEW" => Some(Self::View),
450            "INDEX" => Some(Self::Index),
451            "FUNCTION" => Some(Self::Function),
452            "CONNECTION" => Some(Self::Connection),
453            "SUBSCRIPTION" => Some(Self::Subscription),
454            "SECRET" => Some(Self::Secret),
455            _ => None,
456        }
457    }
458}
459#[derive(prost_helpers::AnyPB)]
460#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
461#[repr(i32)]
462pub enum DistanceType {
463    Unspecified = 0,
464    L1 = 1,
465    L2Sqr = 2,
466    Cosine = 3,
467    InnerProduct = 4,
468}
469impl DistanceType {
470    /// String value of the enum field names used in the ProtoBuf definition.
471    ///
472    /// The values are not transformed in any way and thus are considered stable
473    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
474    pub fn as_str_name(&self) -> &'static str {
475        match self {
476            Self::Unspecified => "DISTANCE_TYPE_UNSPECIFIED",
477            Self::L1 => "DISTANCE_TYPE_L1",
478            Self::L2Sqr => "DISTANCE_TYPE_L2_SQR",
479            Self::Cosine => "DISTANCE_TYPE_COSINE",
480            Self::InnerProduct => "DISTANCE_TYPE_INNER_PRODUCT",
481        }
482    }
483    /// Creates an enum from field names used in the ProtoBuf definition.
484    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
485        match value {
486            "DISTANCE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
487            "DISTANCE_TYPE_L1" => Some(Self::L1),
488            "DISTANCE_TYPE_L2_SQR" => Some(Self::L2Sqr),
489            "DISTANCE_TYPE_COSINE" => Some(Self::Cosine),
490            "DISTANCE_TYPE_INNER_PRODUCT" => Some(Self::InnerProduct),
491            _ => None,
492        }
493    }
494}
risingwave_pb/common.rs

risingwave_pb/
common.rs
