#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RequestEnvelope {
#[prost(uint32, tag = "1")]
pub msg_id: u32,
#[prost(string, tag = "2")]
pub entity_id: ::prost::alloc::string::String,
#[prost(enumeration = "EntityType", tag = "3")]
pub entity_type: i32,
#[prost(message, optional, tag = "50")]
pub payload: ::core::option::Option<Request>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ResponseEnvelope {
#[prost(uint32, tag = "1")]
pub msg_id: u32,
#[prost(string, tag = "2")]
pub entity_id: ::prost::alloc::string::String,
#[prost(enumeration = "EntityType", tag = "3")]
pub entity_type: i32,
#[prost(message, optional, tag = "50")]
pub payload: ::core::option::Option<Response>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Request {
#[prost(
oneof = "request::ClientReq",
tags = "1, 2, 3, 5, 6, 7, 8, 23, 24, 10, 11, 28, 12, 13, 14, 16, 17, 18, 19, 25, 26, 20, 29, 21, 22, 27, 31, 32, 33, 34, 35, 36"
)]
pub client_req: ::core::option::Option<request::ClientReq>,
}
pub mod request {
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum ClientReq {
#[prost(message, tag = "1")]
MakeTableReq(super::MakeTableReq),
#[prost(message, tag = "2")]
TableDeleteReq(super::TableDeleteReq),
#[prost(message, tag = "3")]
TableSizeReq(super::TableSizeReq),
#[prost(message, tag = "5")]
TableSchemaReq(super::TableSchemaReq),
#[prost(message, tag = "6")]
TableMakePortReq(super::TableMakePortReq),
#[prost(message, tag = "7")]
TableValidateExprReq(super::TableValidateExprReq),
#[prost(message, tag = "8")]
TableMakeViewReq(super::TableMakeViewReq),
#[prost(message, tag = "23")]
TableOnDeleteReq(super::TableOnDeleteReq),
#[prost(message, tag = "24")]
TableRemoveDeleteReq(super::TableRemoveDeleteReq),
#[prost(message, tag = "10")]
TableUpdateReq(super::TableUpdateReq),
#[prost(message, tag = "11")]
TableReplaceReq(super::TableReplaceReq),
#[prost(message, tag = "28")]
TableRemoveReq(super::TableRemoveReq),
#[prost(message, tag = "12")]
ViewSchemaReq(super::ViewSchemaReq),
#[prost(message, tag = "13")]
ViewDimensionsReq(super::ViewDimensionsReq),
#[prost(message, tag = "14")]
ViewGetConfigReq(super::ViewGetConfigReq),
#[prost(message, tag = "16")]
ViewColumnPathsReq(super::ViewColumnPathsReq),
#[prost(message, tag = "17")]
ViewDeleteReq(super::ViewDeleteReq),
#[prost(message, tag = "18")]
ViewExpressionSchemaReq(super::ViewExpressionSchemaReq),
#[prost(message, tag = "19")]
ViewOnUpdateReq(super::ViewOnUpdateReq),
#[prost(message, tag = "25")]
ViewOnDeleteReq(super::ViewOnDeleteReq),
#[prost(message, tag = "26")]
ViewRemoveDeleteReq(super::ViewRemoveDeleteReq),
#[prost(message, tag = "20")]
ViewToColumnsStringReq(super::ViewToColumnsStringReq),
#[prost(message, tag = "29")]
ViewToRowsStringReq(super::ViewToRowsStringReq),
#[prost(message, tag = "21")]
ViewToCsvReq(super::ViewToCsvReq),
#[prost(message, tag = "22")]
ViewToArrowReq(super::ViewToArrowReq),
#[prost(message, tag = "27")]
ViewGetMinMaxReq(super::ViewGetMinMaxReq),
#[prost(message, tag = "31")]
ViewRemoveOnUpdateReq(super::ViewRemoveOnUpdateReq),
#[prost(message, tag = "32")]
ViewCollapseReq(super::ViewCollapseReq),
#[prost(message, tag = "33")]
ViewExpandReq(super::ViewExpandReq),
#[prost(message, tag = "34")]
ViewSetDepthReq(super::ViewSetDepthReq),
#[prost(message, tag = "35")]
GetHostedTablesReq(super::GetHostedTablesReq),
#[prost(message, tag = "36")]
ServerSystemInfoReq(super::ServerSystemInfoReq),
}
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Response {
#[prost(
oneof = "response::ClientResp",
tags = "1, 2, 3, 4, 6, 7, 8, 9, 24, 25, 11, 12, 29, 13, 14, 15, 17, 18, 19, 20, 26, 27, 21, 30, 22, 23, 28, 32, 33, 34, 35, 36, 37"
)]
pub client_resp: ::core::option::Option<response::ClientResp>,
}
pub mod response {
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum ClientResp {
#[prost(message, tag = "1")]
ServerError(super::ServerError),
#[prost(message, tag = "2")]
MakeTableResp(super::MakeTableResp),
#[prost(message, tag = "3")]
TableDeleteResp(super::TableDeleteResp),
#[prost(message, tag = "4")]
TableSizeResp(super::TableSizeResp),
#[prost(message, tag = "6")]
TableSchemaResp(super::TableSchemaResp),
#[prost(message, tag = "7")]
TableMakePortResp(super::TableMakePortResp),
#[prost(message, tag = "8")]
TableValidateExprResp(super::TableValidateExprResp),
#[prost(message, tag = "9")]
TableMakeViewResp(super::TableMakeViewResp),
#[prost(message, tag = "24")]
TableOnDeleteResp(super::TableOnDeleteResp),
#[prost(message, tag = "25")]
TableRemoveDeleteResp(super::TableRemoveDeleteResp),
#[prost(message, tag = "11")]
TableUpdateResp(super::TableUpdateResp),
#[prost(message, tag = "12")]
TableReplaceResp(super::TableReplaceResp),
#[prost(message, tag = "29")]
TableRemoveResp(super::TableRemoveResp),
#[prost(message, tag = "13")]
ViewSchemaResp(super::ViewSchemaResp),
#[prost(message, tag = "14")]
ViewDimensionsResp(super::ViewDimensionsResp),
#[prost(message, tag = "15")]
ViewGetConfigResp(super::ViewGetConfigResp),
#[prost(message, tag = "17")]
ViewColumnPathsResp(super::ViewColumnPathsResp),
#[prost(message, tag = "18")]
ViewDeleteResp(super::ViewDeleteResp),
#[prost(message, tag = "19")]
ViewExpressionSchemaResp(super::ViewExpressionSchemaResp),
#[prost(message, tag = "20")]
ViewOnUpdateResp(super::ViewOnUpdateResp),
#[prost(message, tag = "26")]
ViewOnDeleteResp(super::ViewOnDeleteResp),
#[prost(message, tag = "27")]
ViewRemoveDeleteResp(super::ViewRemoveDeleteResp),
#[prost(message, tag = "21")]
ViewToColumnsStringResp(super::ViewToColumnsStringResp),
#[prost(message, tag = "30")]
ViewToRowsStringResp(super::ViewToRowsStringResp),
#[prost(message, tag = "22")]
ViewToCsvResp(super::ViewToCsvResp),
#[prost(message, tag = "23")]
ViewToArrowResp(super::ViewToArrowResp),
#[prost(message, tag = "28")]
ViewGetMinMaxResp(super::ViewGetMinMaxResp),
#[prost(message, tag = "32")]
ViewRemoveOnUpdateResp(super::ViewRemoveOnUpdateResp),
#[prost(message, tag = "33")]
ViewCollapseResp(super::ViewCollapseResp),
#[prost(message, tag = "34")]
ViewExpandResp(super::ViewExpandResp),
#[prost(message, tag = "35")]
ViewSetDepthResp(super::ViewSetDepthResp),
#[prost(message, tag = "36")]
GetHostedTablesResp(super::GetHostedTablesResp),
#[prost(message, tag = "37")]
ServerSystemInfoResp(super::ServerSystemInfoResp),
}
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetHostedTablesReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetHostedTablesResp {
#[prost(string, repeated, tag = "1")]
pub table_names: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ServerError {
#[prost(string, tag = "1")]
pub message: ::prost::alloc::string::String,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MakeTableReq {
#[prost(message, optional, tag = "1")]
pub data: ::core::option::Option<MakeTableData>,
#[prost(message, optional, tag = "2")]
pub options: ::core::option::Option<MakeTableOptions>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MakeTableOptions {
#[prost(oneof = "make_table_options::MakeTableType", tags = "1, 2")]
pub make_table_type: ::core::option::Option<make_table_options::MakeTableType>,
}
pub mod make_table_options {
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum MakeTableType {
#[prost(message, tag = "1")]
MakeIndexTable(super::MakeIndexTable),
#[prost(message, tag = "2")]
MakeLimitTable(super::MakeLimitTable),
}
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MakeIndexTable {
#[prost(string, tag = "1")]
pub index: ::prost::alloc::string::String,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MakeLimitTable {
#[prost(uint32, tag = "1")]
pub limit: u32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MakeTableData {
#[prost(oneof = "make_table_data::Data", tags = "1, 2, 3, 4, 5, 6")]
pub data: ::core::option::Option<make_table_data::Data>,
}
pub mod make_table_data {
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Data {
#[prost(message, tag = "1")]
FromSchema(super::Schema),
#[prost(string, tag = "2")]
FromCsv(::prost::alloc::string::String),
#[prost(bytes, tag = "3")]
FromArrow(::prost::alloc::vec::Vec<u8>),
#[prost(string, tag = "4")]
FromRows(::prost::alloc::string::String),
#[prost(string, tag = "5")]
FromCols(::prost::alloc::string::String),
#[prost(string, tag = "6")]
FromView(::prost::alloc::string::String),
}
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct KeyTypePair {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(enumeration = "ColumnType", tag = "2")]
pub r#type: i32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Schema {
#[prost(message, repeated, tag = "1")]
pub schema: ::prost::alloc::vec::Vec<KeyTypePair>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MakeTableResp {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableDeleteReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableDeleteResp {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableSizeReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableSizeResp {
#[prost(uint32, tag = "2")]
pub size: u32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableSchemaReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableSchemaResp {
#[prost(message, optional, tag = "1")]
pub schema: ::core::option::Option<Schema>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableMakePortReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableMakePortResp {
#[prost(uint32, tag = "1")]
pub port_id: u32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableValidateExprReq {
#[prost(map = "string, string", tag = "1")]
pub column_to_expr: ::std::collections::HashMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
}
#[derive(serde::Serialize)]
#[derive(serde::Deserialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableValidateExprResp {
#[prost(map = "string, enumeration(ColumnType)", tag = "1")]
pub expression_schema: ::std::collections::HashMap<
::prost::alloc::string::String,
i32,
>,
#[prost(map = "string, message", tag = "2")]
pub errors: ::std::collections::HashMap<
::prost::alloc::string::String,
ExprValidationError,
>,
#[prost(map = "string, string", tag = "3")]
pub expression_alias: ::std::collections::HashMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
}
#[derive(serde::Serialize)]
#[derive(serde::Deserialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ExprValidationError {
#[prost(string, tag = "1")]
pub error_message: ::prost::alloc::string::String,
#[prost(uint32, tag = "2")]
pub line: u32,
#[prost(uint32, tag = "3")]
pub column: u32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableMakeViewReq {
#[prost(string, tag = "1")]
pub view_id: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub config: ::core::option::Option<ViewConfig>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableMakeViewResp {
#[prost(string, tag = "1")]
pub view_id: ::prost::alloc::string::String,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableOnDeleteReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableOnDeleteResp {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableRemoveDeleteReq {
#[prost(uint32, tag = "1")]
pub id: u32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableRemoveDeleteResp {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableUpdateReq {
#[prost(message, optional, tag = "1")]
pub data: ::core::option::Option<MakeTableData>,
#[prost(uint32, tag = "2")]
pub port_id: u32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableUpdateResp {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableReplaceReq {
#[prost(message, optional, tag = "1")]
pub data: ::core::option::Option<MakeTableData>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableReplaceResp {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableRemoveReq {
#[prost(message, optional, tag = "1")]
pub data: ::core::option::Option<MakeTableData>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableRemoveResp {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewSchemaReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewSchemaResp {
#[prost(map = "string, enumeration(ColumnType)", tag = "1")]
pub schema: ::std::collections::HashMap<::prost::alloc::string::String, i32>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewDimensionsReq {}
#[derive(serde::Serialize)]
#[derive(serde::Deserialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewDimensionsResp {
#[prost(uint32, tag = "1")]
pub num_table_rows: u32,
#[prost(uint32, tag = "2")]
pub num_table_columns: u32,
#[prost(uint32, tag = "3")]
pub num_view_rows: u32,
#[prost(uint32, tag = "4")]
pub num_view_columns: u32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewGetConfigReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewGetConfigResp {
#[prost(message, optional, tag = "1")]
pub config: ::core::option::Option<ViewConfig>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewOnUpdateReq {
#[prost(enumeration = "view_on_update_req::Mode", optional, tag = "1")]
pub mode: ::core::option::Option<i32>,
}
pub mod view_on_update_req {
#[derive(serde::Serialize)]
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum Mode {
Row = 0,
}
impl Mode {
pub fn as_str_name(&self) -> &'static str {
match self {
Mode::Row => "ROW",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"ROW" => Some(Self::Row),
_ => None,
}
}
}
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewOnUpdateResp {
#[prost(bytes = "vec", optional, tag = "1")]
pub arrow: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
#[prost(uint32, tag = "2")]
pub port_id: u32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewOnDeleteReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewOnDeleteResp {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewRemoveDeleteReq {
#[prost(uint32, tag = "1")]
pub id: u32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewRemoveDeleteResp {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewPort {
#[prost(uint32, optional, tag = "1")]
pub start_row: ::core::option::Option<u32>,
#[prost(uint32, optional, tag = "2")]
pub start_col: ::core::option::Option<u32>,
#[prost(uint32, optional, tag = "3")]
pub end_row: ::core::option::Option<u32>,
#[prost(uint32, optional, tag = "4")]
pub end_col: ::core::option::Option<u32>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewToColumnsStringReq {
#[prost(message, optional, tag = "1")]
pub viewport: ::core::option::Option<ViewPort>,
#[prost(bool, optional, tag = "2")]
pub id: ::core::option::Option<bool>,
#[prost(bool, optional, tag = "3")]
pub index: ::core::option::Option<bool>,
#[prost(bool, optional, tag = "4")]
pub formatted: ::core::option::Option<bool>,
#[prost(bool, optional, tag = "5")]
pub leaves_only: ::core::option::Option<bool>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewToColumnsStringResp {
#[prost(string, tag = "1")]
pub json_string: ::prost::alloc::string::String,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewToRowsStringReq {
#[prost(message, optional, tag = "1")]
pub viewport: ::core::option::Option<ViewPort>,
#[prost(bool, optional, tag = "2")]
pub id: ::core::option::Option<bool>,
#[prost(bool, optional, tag = "3")]
pub index: ::core::option::Option<bool>,
#[prost(bool, optional, tag = "4")]
pub formatted: ::core::option::Option<bool>,
#[prost(bool, optional, tag = "5")]
pub leaves_only: ::core::option::Option<bool>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewToRowsStringResp {
#[prost(string, tag = "1")]
pub json_string: ::prost::alloc::string::String,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewToArrowReq {
#[prost(message, optional, tag = "1")]
pub viewport: ::core::option::Option<ViewPort>,
#[prost(string, optional, tag = "2")]
pub compression: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewToArrowResp {
#[prost(bytes = "vec", tag = "1")]
pub arrow: ::prost::alloc::vec::Vec<u8>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewColumnPathsReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewColumnPathsResp {
#[prost(string, repeated, tag = "1")]
pub paths: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewDeleteReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewDeleteResp {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewGetMinMaxReq {
#[prost(string, tag = "1")]
pub column_name: ::prost::alloc::string::String,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewGetMinMaxResp {
#[prost(string, tag = "1")]
pub min: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub max: ::prost::alloc::string::String,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewExpressionSchemaReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewExpressionSchemaResp {
#[prost(map = "string, enumeration(ColumnType)", tag = "1")]
pub schema: ::std::collections::HashMap<::prost::alloc::string::String, i32>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewToCsvReq {
#[prost(message, optional, tag = "1")]
pub viewport: ::core::option::Option<ViewPort>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewToCsvResp {
#[prost(string, tag = "1")]
pub csv: ::prost::alloc::string::String,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewRemoveOnUpdateReq {
#[prost(uint32, tag = "1")]
pub id: u32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewRemoveOnUpdateResp {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewCollapseReq {
#[prost(int32, tag = "1")]
pub row_index: i32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewCollapseResp {
#[prost(int64, tag = "1")]
pub num_changed: i64,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewExpandReq {
#[prost(int32, tag = "1")]
pub row_index: i32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewExpandResp {
#[prost(int64, tag = "1")]
pub num_changed: i64,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewSetDepthReq {
#[prost(int32, tag = "1")]
pub depth: i32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewSetDepthResp {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ServerSystemInfoReq {}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ServerSystemInfoResp {
#[prost(uint64, tag = "1")]
pub heap_size: u64,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Scalar {
#[prost(oneof = "scalar::Scalar", tags = "1, 2, 3, 4, 5, 6, 7")]
pub scalar: ::core::option::Option<scalar::Scalar>,
}
pub mod scalar {
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Scalar {
#[prost(bool, tag = "1")]
Bool(bool),
#[prost(int64, tag = "2")]
Date(i64),
#[prost(int64, tag = "3")]
Datetime(i64),
#[prost(double, tag = "4")]
Float(f64),
#[prost(int32, tag = "5")]
Int(i32),
#[prost(string, tag = "6")]
String(::prost::alloc::string::String),
#[prost(enumeration = "::prost_types::NullValue", tag = "7")]
Null(i32),
}
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Sort {
#[prost(string, tag = "1")]
pub column: ::prost::alloc::string::String,
#[prost(enumeration = "SortOp", tag = "2")]
pub op: i32,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Filter {
#[prost(string, tag = "1")]
pub column: ::prost::alloc::string::String,
#[prost(enumeration = "FilterOp", tag = "2")]
pub op: i32,
#[prost(message, repeated, tag = "3")]
pub value: ::prost::alloc::vec::Vec<Scalar>,
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ViewConfig {
#[prost(string, repeated, tag = "1")]
pub group_by: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, repeated, tag = "2")]
pub split_by: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(message, optional, tag = "3")]
pub columns: ::core::option::Option<ColumnsUpdate>,
#[prost(message, repeated, tag = "4")]
pub filter: ::prost::alloc::vec::Vec<Filter>,
#[prost(message, repeated, tag = "5")]
pub sort: ::prost::alloc::vec::Vec<Sort>,
#[prost(map = "string, string", tag = "6")]
pub expressions: ::std::collections::HashMap<
::prost::alloc::string::String,
::prost::alloc::string::String,
>,
#[prost(map = "string, message", tag = "7")]
pub aggregates: ::std::collections::HashMap<
::prost::alloc::string::String,
view_config::AggList,
>,
#[prost(enumeration = "FilterReducer", tag = "8")]
pub filter_op: i32,
#[prost(int32, optional, tag = "9")]
pub group_by_depth: ::core::option::Option<i32>,
}
pub mod view_config {
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AggList {
#[prost(string, repeated, tag = "1")]
pub aggregations: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ColumnsUpdate {
#[prost(oneof = "columns_update::OptColumns", tags = "1, 2")]
pub opt_columns: ::core::option::Option<columns_update::OptColumns>,
}
pub mod columns_update {
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum OptColumns {
#[prost(enumeration = "::prost_types::NullValue", tag = "1")]
DefaultColumns(i32),
#[prost(message, tag = "2")]
Columns(super::Columns),
}
}
#[derive(serde::Serialize)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Columns {
#[prost(string, repeated, tag = "1")]
pub columns: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(serde::Serialize)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EntityType {
Unknown = 0,
Table = 1,
View = 2,
}
impl EntityType {
pub fn as_str_name(&self) -> &'static str {
match self {
EntityType::Unknown => "UNKNOWN",
EntityType::Table => "TABLE",
EntityType::View => "VIEW",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"UNKNOWN" => Some(Self::Unknown),
"TABLE" => Some(Self::Table),
"VIEW" => Some(Self::View),
_ => None,
}
}
}
#[derive(serde::Serialize)]
#[derive(serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ColumnType {
String = 0,
Date = 1,
Datetime = 2,
Integer = 3,
Float = 4,
Boolean = 5,
}
impl ColumnType {
pub fn as_str_name(&self) -> &'static str {
match self {
ColumnType::String => "STRING",
ColumnType::Date => "DATE",
ColumnType::Datetime => "DATETIME",
ColumnType::Integer => "INTEGER",
ColumnType::Float => "FLOAT",
ColumnType::Boolean => "BOOLEAN",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"STRING" => Some(Self::String),
"DATE" => Some(Self::Date),
"DATETIME" => Some(Self::Datetime),
"INTEGER" => Some(Self::Integer),
"FLOAT" => Some(Self::Float),
"BOOLEAN" => Some(Self::Boolean),
_ => None,
}
}
}
#[derive(serde::Serialize)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum FilterOp {
FilterUnknown = 0,
FilterLt = 1,
FilterLteq = 2,
FilterGt = 3,
FilterGteq = 4,
FilterEq = 5,
FilterNe = 6,
FilterBeginsWith = 7,
FilterEndsWith = 8,
FilterIn = 9,
FilterContains = 10,
FilterNotIn = 11,
FilterAnd = 12,
FilterOr = 13,
FilterIsNull = 14,
FilterIsNotNull = 15,
}
impl FilterOp {
pub fn as_str_name(&self) -> &'static str {
match self {
FilterOp::FilterUnknown => "FILTER_UNKNOWN",
FilterOp::FilterLt => "FILTER_LT",
FilterOp::FilterLteq => "FILTER_LTEQ",
FilterOp::FilterGt => "FILTER_GT",
FilterOp::FilterGteq => "FILTER_GTEQ",
FilterOp::FilterEq => "FILTER_EQ",
FilterOp::FilterNe => "FILTER_NE",
FilterOp::FilterBeginsWith => "FILTER_BEGINS_WITH",
FilterOp::FilterEndsWith => "FILTER_ENDS_WITH",
FilterOp::FilterIn => "FILTER_IN",
FilterOp::FilterContains => "FILTER_CONTAINS",
FilterOp::FilterNotIn => "FILTER_NOT_IN",
FilterOp::FilterAnd => "FILTER_AND",
FilterOp::FilterOr => "FILTER_OR",
FilterOp::FilterIsNull => "FILTER_IS_NULL",
FilterOp::FilterIsNotNull => "FILTER_IS_NOT_NULL",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"FILTER_UNKNOWN" => Some(Self::FilterUnknown),
"FILTER_LT" => Some(Self::FilterLt),
"FILTER_LTEQ" => Some(Self::FilterLteq),
"FILTER_GT" => Some(Self::FilterGt),
"FILTER_GTEQ" => Some(Self::FilterGteq),
"FILTER_EQ" => Some(Self::FilterEq),
"FILTER_NE" => Some(Self::FilterNe),
"FILTER_BEGINS_WITH" => Some(Self::FilterBeginsWith),
"FILTER_ENDS_WITH" => Some(Self::FilterEndsWith),
"FILTER_IN" => Some(Self::FilterIn),
"FILTER_CONTAINS" => Some(Self::FilterContains),
"FILTER_NOT_IN" => Some(Self::FilterNotIn),
"FILTER_AND" => Some(Self::FilterAnd),
"FILTER_OR" => Some(Self::FilterOr),
"FILTER_IS_NULL" => Some(Self::FilterIsNull),
"FILTER_IS_NOT_NULL" => Some(Self::FilterIsNotNull),
_ => None,
}
}
}
#[derive(serde::Serialize)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SortOp {
SortNone = 0,
SortAsc = 1,
SortDesc = 2,
SortColAsc = 3,
SortColDesc = 4,
SortAscAbs = 5,
SortDescAbs = 6,
SortColAscAbs = 7,
SortColDescAbs = 8,
}
impl SortOp {
pub fn as_str_name(&self) -> &'static str {
match self {
SortOp::SortNone => "SORT_NONE",
SortOp::SortAsc => "SORT_ASC",
SortOp::SortDesc => "SORT_DESC",
SortOp::SortColAsc => "SORT_COL_ASC",
SortOp::SortColDesc => "SORT_COL_DESC",
SortOp::SortAscAbs => "SORT_ASC_ABS",
SortOp::SortDescAbs => "SORT_DESC_ABS",
SortOp::SortColAscAbs => "SORT_COL_ASC_ABS",
SortOp::SortColDescAbs => "SORT_COL_DESC_ABS",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"SORT_NONE" => Some(Self::SortNone),
"SORT_ASC" => Some(Self::SortAsc),
"SORT_DESC" => Some(Self::SortDesc),
"SORT_COL_ASC" => Some(Self::SortColAsc),
"SORT_COL_DESC" => Some(Self::SortColDesc),
"SORT_ASC_ABS" => Some(Self::SortAscAbs),
"SORT_DESC_ABS" => Some(Self::SortDescAbs),
"SORT_COL_ASC_ABS" => Some(Self::SortColAscAbs),
"SORT_COL_DESC_ABS" => Some(Self::SortColDescAbs),
_ => None,
}
}
}
#[derive(serde::Serialize)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum FilterReducer {
And = 0,
Or = 1,
}
impl FilterReducer {
pub fn as_str_name(&self) -> &'static str {
match self {
FilterReducer::And => "AND",
FilterReducer::Or => "OR",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"AND" => Some(Self::And),
"OR" => Some(Self::Or),
_ => None,
}
}
}