pancake_db_idl/
dml.rs

1///WRITING
2#[derive(Clone, PartialEq, ::prost::Message)]
3pub struct PartitionFieldValue {
4    #[prost(oneof = "partition_field_value::Value", tags = "2, 3, 4, 5")]
5    pub value: ::core::option::Option<partition_field_value::Value>,
6}
7/// Nested message and enum types in `PartitionFieldValue`.
8pub mod partition_field_value {
9    #[derive(Clone, PartialEq, ::prost::Oneof)]
10    pub enum Value {
11        #[prost(string, tag = "2")]
12        StringVal(::prost::alloc::string::String),
13        #[prost(bool, tag = "3")]
14        BoolVal(bool),
15        #[prost(int64, tag = "4")]
16        Int64Val(i64),
17        #[prost(message, tag = "5")]
18        TimestampVal(::prost_types::Timestamp),
19    }
20}
21#[derive(Clone, PartialEq, ::prost::Message)]
22pub struct RepeatedFieldValue {
23    #[prost(message, repeated, tag = "1")]
24    pub vals: ::prost::alloc::vec::Vec<FieldValue>,
25}
26#[derive(Clone, PartialEq, ::prost::Message)]
27pub struct FieldValue {
28    #[prost(oneof = "field_value::Value", tags = "1, 2, 3, 4, 5, 6, 7, 8")]
29    pub value: ::core::option::Option<field_value::Value>,
30}
31/// Nested message and enum types in `FieldValue`.
32pub mod field_value {
33    #[derive(Clone, PartialEq, ::prost::Oneof)]
34    pub enum Value {
35        #[prost(message, tag = "1")]
36        ListVal(super::RepeatedFieldValue),
37        #[prost(string, tag = "2")]
38        StringVal(::prost::alloc::string::String),
39        #[prost(bool, tag = "3")]
40        BoolVal(bool),
41        #[prost(bytes, tag = "4")]
42        BytesVal(::prost::alloc::vec::Vec<u8>),
43        #[prost(int64, tag = "5")]
44        Int64Val(i64),
45        #[prost(float, tag = "6")]
46        Float32Val(f32),
47        #[prost(double, tag = "7")]
48        Float64Val(f64),
49        #[prost(message, tag = "8")]
50        TimestampVal(::prost_types::Timestamp),
51    }
52}
53#[derive(Clone, PartialEq, ::prost::Message)]
54pub struct Row {
55    #[prost(map = "string, message", tag = "1")]
56    pub fields: ::std::collections::HashMap<::prost::alloc::string::String, FieldValue>,
57}
58#[derive(Clone, PartialEq, ::prost::Message)]
59pub struct WriteToPartitionRequest {
60    #[prost(string, tag = "1")]
61    pub table_name: ::prost::alloc::string::String,
62    #[prost(map = "string, message", tag = "2")]
63    pub partition: ::std::collections::HashMap<::prost::alloc::string::String, PartitionFieldValue>,
64    #[prost(message, repeated, tag = "3")]
65    pub rows: ::prost::alloc::vec::Vec<Row>,
66}
67#[derive(Clone, PartialEq, ::prost::Message)]
68pub struct WriteToPartitionResponse {}
69///LISTING SEGMENTS
70#[derive(Clone, PartialEq, ::prost::Message)]
71pub struct PartitionFieldComparison {
72    #[prost(string, tag = "1")]
73    pub name: ::prost::alloc::string::String,
74    #[prost(enumeration = "partition_field_comparison::Operator", tag = "2")]
75    pub operator: i32,
76    #[prost(message, optional, tag = "3")]
77    pub value: ::core::option::Option<PartitionFieldValue>,
78}
79/// Nested message and enum types in `PartitionFieldComparison`.
80pub mod partition_field_comparison {
81    #[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
82    #[repr(i32)]
83    pub enum Operator {
84        EqTo = 0,
85        LessOrEqTo = 1,
86        Less = 2,
87        GreaterOrEqTo = 3,
88        Greater = 4,
89    }
90}
91#[derive(Clone, PartialEq, ::prost::Message)]
92pub struct PartitionFilter {
93    #[prost(oneof = "partition_filter::Value", tags = "1")]
94    pub value: ::core::option::Option<partition_filter::Value>,
95}
96/// Nested message and enum types in `PartitionFilter`.
97pub mod partition_filter {
98    #[derive(Clone, PartialEq, ::prost::Oneof)]
99    pub enum Value {
100        #[prost(message, tag = "1")]
101        Comparison(super::PartitionFieldComparison),
102    }
103}
104#[derive(Clone, PartialEq, ::prost::Message)]
105pub struct ListSegmentsRequest {
106    #[prost(string, tag = "1")]
107    pub table_name: ::prost::alloc::string::String,
108    #[prost(message, repeated, tag = "2")]
109    pub partition_filter: ::prost::alloc::vec::Vec<PartitionFilter>,
110    #[prost(bool, tag = "3")]
111    pub include_metadata: bool,
112}
113#[derive(Clone, PartialEq, ::prost::Message)]
114pub struct SegmentMetadata {
115    #[prost(uint32, tag = "1")]
116    pub row_count: u32,
117}
118#[derive(Clone, PartialEq, ::prost::Message)]
119pub struct Segment {
120    #[prost(map = "string, message", tag = "1")]
121    pub partition: ::std::collections::HashMap<::prost::alloc::string::String, PartitionFieldValue>,
122    #[prost(string, tag = "2")]
123    pub segment_id: ::prost::alloc::string::String,
124    #[prost(message, optional, tag = "3")]
125    pub metadata: ::core::option::Option<SegmentMetadata>,
126}
127#[derive(Clone, PartialEq, ::prost::Message)]
128pub struct ListSegmentsResponse {
129    #[prost(message, repeated, tag = "1")]
130    pub segments: ::prost::alloc::vec::Vec<Segment>,
131}
132///READING SEGMENT COLUMNS
133#[derive(Clone, PartialEq, ::prost::Message)]
134pub struct ReadSegmentColumnRequest {
135    #[prost(string, tag = "1")]
136    pub table_name: ::prost::alloc::string::String,
137    #[prost(map = "string, message", tag = "2")]
138    pub partition: ::std::collections::HashMap<::prost::alloc::string::String, PartitionFieldValue>,
139    #[prost(string, tag = "3")]
140    pub segment_id: ::prost::alloc::string::String,
141    #[prost(string, tag = "4")]
142    pub column_name: ::prost::alloc::string::String,
143    #[prost(string, tag = "5")]
144    pub correlation_id: ::prost::alloc::string::String,
145}
146#[derive(Clone, PartialEq, ::prost::Message)]
147pub struct ReadSegmentColumnResponse {
148    #[prost(string, tag = "1")]
149    pub codec: ::prost::alloc::string::String,
150    #[prost(bytes = "vec", tag = "2")]
151    pub data: ::prost::alloc::vec::Vec<u8>,
152    #[prost(uint32, tag = "3")]
153    pub row_count: u32,
154    #[prost(uint32, tag = "4")]
155    pub deletion_count: u32,
156    #[prost(uint32, tag = "5")]
157    pub implicit_nulls_count: u32,
158}
159///READING DELETIONS
160#[derive(Clone, PartialEq, ::prost::Message)]
161pub struct ReadSegmentDeletionsRequest {
162    #[prost(string, tag = "1")]
163    pub table_name: ::prost::alloc::string::String,
164    #[prost(map = "string, message", tag = "2")]
165    pub partition: ::std::collections::HashMap<::prost::alloc::string::String, PartitionFieldValue>,
166    #[prost(string, tag = "3")]
167    pub segment_id: ::prost::alloc::string::String,
168    #[prost(string, tag = "4")]
169    pub correlation_id: ::prost::alloc::string::String,
170}
171#[derive(Clone, PartialEq, ::prost::Message)]
172pub struct ReadSegmentDeletionsResponse {
173    #[prost(bytes = "vec", tag = "1")]
174    pub data: ::prost::alloc::vec::Vec<u8>,
175}
176///DELETING
177#[derive(Clone, PartialEq, ::prost::Message)]
178pub struct DeleteFromSegmentRequest {
179    #[prost(string, tag = "1")]
180    pub table_name: ::prost::alloc::string::String,
181    #[prost(map = "string, message", tag = "2")]
182    pub partition: ::std::collections::HashMap<::prost::alloc::string::String, PartitionFieldValue>,
183    #[prost(string, tag = "3")]
184    pub segment_id: ::prost::alloc::string::String,
185    #[prost(uint32, repeated, tag = "4")]
186    pub row_ids: ::prost::alloc::vec::Vec<u32>,
187}
188#[derive(Clone, PartialEq, ::prost::Message)]
189pub struct DeleteFromSegmentResponse {
190    #[prost(uint32, tag = "1")]
191    pub n_deleted: u32,
192}
pancake_db_idl/dml.rs

pancake_db_idl/
dml.rs
