ytsaurus-proto 0.3.1

// This file is @generated by prost-build.
/// COMPAT(max42).
/// A legacy analog of NYT.NYTree.NProto.TAttributeFilter.
/// It is different in that universal filter is encoded via all = true
/// rather than absence of filter at all.
/// Modern clients serialize attribute filters using TAttributeFilter, so
/// hopefully in a couple of years we will be able to drop support of it...
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TLegacyAttributeKeys {
    #[prost(bool, optional, tag = "1")]
    pub all: ::core::option::Option<bool>,
    #[prost(string, repeated, tag = "2")]
    pub keys: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
/// Each rowset is decodeable solely with the descriptor, which encodes rowset kind,
/// column names and column types. Actual data is passed via attachments in the wire
/// protocol.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRowsetDescriptor {
    /// Currently, there is only one version. This field is reserved for future changes.
    #[prost(int32, optional, tag = "1", default = "1")]
    pub wire_format_version: ::core::option::Option<i32>,
    /// Specifies the kind of rows comprising the rowset.
    #[prost(enumeration = "ERowsetKind", optional, tag = "2", default = "RkUnversioned")]
    pub rowset_kind: ::core::option::Option<i32>,
    /// Specifies the format of data representation.
    #[prost(enumeration = "ERowsetFormat", optional, tag = "4", default = "RfYtWire")]
    pub rowset_format: ::core::option::Option<i32>,
    /// Specifies column names.
    /// COMPAT(babenko): also types.
    #[prost(message, repeated, tag = "3")]
    pub name_table_entries: ::prost::alloc::vec::Vec<
        t_rowset_descriptor::TNameTableEntry,
    >,
    /// Specifies rowset schema.
    /// Could be missing (in this case name table is always present).
    #[prost(message, optional, tag = "5")]
    pub schema: ::core::option::Option<TTableSchema>,
}
/// Nested message and enum types in `TRowsetDescriptor`.
pub mod t_rowset_descriptor {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TNameTableEntry {
        #[prost(string, optional, tag = "1")]
        pub name: ::core::option::Option<::prost::alloc::string::String>,
        /// COMPAT(babenko)
        #[prost(int32, optional, tag = "2")]
        pub r#type: ::core::option::Option<i32>,
        /// COMPAT(babenko)
        #[prost(int32, optional, tag = "3")]
        pub logical_type: ::core::option::Option<i32>,
    }
}
/// Could be embedded into response attachment block sequence along with the actual data
/// to indidate the progress of table reader/writer.
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRowsetStatistics {
    #[prost(int64, required, tag = "1")]
    pub total_row_count: i64,
    #[prost(message, required, tag = "2")]
    pub data_statistics: super::super::super::n_chunk_client::n_proto::TDataStatistics,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqStartTransaction {
    #[prost(enumeration = "ETransactionType", required, tag = "1")]
    pub r#type: i32,
    #[prost(int64, optional, tag = "2")]
    pub timeout: ::core::option::Option<i64>,
    /// If not null then the transaction must use this externally provided id.
    /// Only applicable to tablet transactions.
    #[prost(message, optional, tag = "3")]
    pub id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(message, optional, tag = "4")]
    pub parent_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    /// COMPAT(kiselyovp) next option is unused and should get removed
    #[prost(bool, optional, tag = "5", default = "false")]
    pub auto_abort: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "6", default = "false")]
    pub sticky: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "7", default = "true")]
    pub ping: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "8", default = "true")]
    pub ping_ancestors: ::core::option::Option<bool>,
    #[prost(enumeration = "EAtomicity", optional, tag = "9", default = "AFull")]
    pub atomicity: ::core::option::Option<i32>,
    #[prost(enumeration = "EDurability", optional, tag = "10", default = "DSync")]
    pub durability: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "11")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeDictionary,
    >,
    #[prost(uint64, optional, tag = "12")]
    pub deadline: ::core::option::Option<u64>,
    #[prost(message, repeated, tag = "13")]
    pub prerequisite_transaction_ids: ::prost::alloc::vec::Vec<
        super::super::super::n_proto::TGuid,
    >,
    #[prost(uint64, optional, tag = "14")]
    pub start_timestamp: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "15")]
    pub replicate_to_master_cell_tags: ::core::option::Option<
        t_req_start_transaction::TReplicateToMasterCellTags,
    >,
    /// Address of the last client that pinged transaction.
    #[prost(string, optional, tag = "16")]
    pub pinger_address: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
/// Nested message and enum types in `TReqStartTransaction`.
pub mod t_req_start_transaction {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TReplicateToMasterCellTags {
        #[prost(uint32, repeated, packed = "false", tag = "1")]
        pub cell_tags: ::prost::alloc::vec::Vec<u32>,
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspStartTransaction {
    #[prost(message, required, tag = "1")]
    pub id: super::super::super::n_proto::TGuid,
    #[prost(uint64, required, tag = "2")]
    pub start_timestamp: u64,
    /// Sequence number source id allocated for this client if transaction is tablet.
    /// Client is free not to use this source id and generate source id on its own,
    /// for example, for backward compatibility. In this case client is responsible for
    /// source id uniqueness between all transaction clients.
    /// See TReqModifyRows.sequence_number_source_id for details.
    #[prost(int64, optional, tag = "3")]
    pub sequence_number_source_id: ::core::option::Option<i64>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqPingTransaction {
    #[prost(message, required, tag = "1")]
    pub transaction_id: super::super::super::n_proto::TGuid,
    #[prost(bool, optional, tag = "7", default = "true")]
    pub ping_ancestors: ::core::option::Option<bool>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspPingTransaction {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqCommitTransaction {
    #[prost(message, required, tag = "1")]
    pub transaction_id: super::super::super::n_proto::TGuid,
    #[prost(message, repeated, tag = "7")]
    pub additional_participant_cell_ids: ::prost::alloc::vec::Vec<
        super::super::super::n_proto::TGuid,
    >,
    #[prost(uint64, optional, tag = "8")]
    pub max_allowed_commit_timestamp: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspCommitTransaction {
    #[prost(message, optional, tag = "1")]
    pub commit_timestamps: ::core::option::Option<
        super::super::super::n_hive_client::n_proto::TTimestampMap,
    >,
    #[prost(uint64, optional, tag = "2")]
    pub primary_commit_timestamp: ::core::option::Option<u64>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqFlushTransaction {
    #[prost(message, required, tag = "1")]
    pub transaction_id: super::super::super::n_proto::TGuid,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspFlushTransaction {
    #[prost(message, repeated, tag = "1")]
    pub participant_cell_ids: ::prost::alloc::vec::Vec<
        super::super::super::n_proto::TGuid,
    >,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqAbortTransaction {
    #[prost(message, required, tag = "1")]
    pub transaction_id: super::super::super::n_proto::TGuid,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspAbortTransaction {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqLookupRows {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(uint64, optional, tag = "3", default = "4611686018427387649")]
    pub timestamp: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "10", default = "0")]
    pub retention_timestamp: ::core::option::Option<u64>,
    #[prost(string, repeated, tag = "2")]
    pub columns: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "4", default = "true")]
    pub keep_missing_rows: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "7", default = "false")]
    pub enable_partial_result: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "9", default = "false")]
    pub use_lookup_cache: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "14", default = "false")]
    pub allow_missing_key_columns: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "106")]
    pub tablet_read_options: ::core::option::Option<TTabletReadOptions>,
    #[prost(enumeration = "EReplicaConsistency", optional, tag = "11")]
    pub replica_consistency: ::core::option::Option<i32>,
    #[prost(enumeration = "EMultiplexingBand", optional, tag = "8")]
    pub multiplexing_band: ::core::option::Option<i32>,
    #[prost(message, required, tag = "200")]
    pub rowset_descriptor: TRowsetDescriptor,
    #[prost(message, optional, tag = "12")]
    pub versioned_read_options: ::core::option::Option<
        super::super::super::n_table_client::n_proto::TVersionedReadOptions,
    >,
    #[prost(string, optional, tag = "13")]
    pub execution_pool: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspLookupRows {
    #[prost(message, required, tag = "200")]
    pub rowset_descriptor: TRowsetDescriptor,
    #[prost(int32, repeated, packed = "false", tag = "201")]
    pub unavailable_key_indexes: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRetentionConfig {
    #[prost(uint64, optional, tag = "1", default = "1")]
    pub min_data_versions: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "2", default = "1")]
    pub max_data_versions: ::core::option::Option<u64>,
    /// TDuration, 30 minutes by default
    #[prost(uint64, optional, tag = "3", default = "1800000000")]
    pub min_data_ttl: ::core::option::Option<u64>,
    /// TDuration, 30 minutes by default
    #[prost(uint64, optional, tag = "4", default = "1800000000")]
    pub max_data_ttl: ::core::option::Option<u64>,
    #[prost(bool, optional, tag = "5", default = "false")]
    pub ignore_major_timestamp: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqVersionedLookupRows {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(uint64, optional, tag = "3", default = "4611686018427387649")]
    pub timestamp: ::core::option::Option<u64>,
    #[prost(string, repeated, tag = "2")]
    pub columns: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "4", default = "true")]
    pub keep_missing_rows: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "6")]
    pub retention_config: ::core::option::Option<TRetentionConfig>,
    #[prost(bool, optional, tag = "7", default = "false")]
    pub enable_partial_result: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "9", default = "false")]
    pub use_lookup_cache: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "12", default = "false")]
    pub allow_missing_key_columns: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "106")]
    pub tablet_read_options: ::core::option::Option<TTabletReadOptions>,
    #[prost(enumeration = "EReplicaConsistency", optional, tag = "10")]
    pub replica_consistency: ::core::option::Option<i32>,
    #[prost(enumeration = "EMultiplexingBand", optional, tag = "8")]
    pub multiplexing_band: ::core::option::Option<i32>,
    #[prost(message, required, tag = "200")]
    pub rowset_descriptor: TRowsetDescriptor,
    #[prost(string, optional, tag = "11")]
    pub execution_pool: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspVersionedLookupRows {
    #[prost(message, required, tag = "200")]
    pub rowset_descriptor: TRowsetDescriptor,
    #[prost(int32, repeated, packed = "false", tag = "201")]
    pub unavailable_key_indexes: ::prost::alloc::vec::Vec<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqMultiLookup {
    #[prost(message, repeated, tag = "1")]
    pub subrequests: ::prost::alloc::vec::Vec<t_req_multi_lookup::TSubrequest>,
    #[prost(uint64, optional, tag = "2", default = "4611686018427387649")]
    pub timestamp: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "5", default = "0")]
    pub retention_timestamp: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "3")]
    pub tablet_read_options: ::core::option::Option<TTabletReadOptions>,
    #[prost(enumeration = "EReplicaConsistency", optional, tag = "6")]
    pub replica_consistency: ::core::option::Option<i32>,
    #[prost(enumeration = "EMultiplexingBand", optional, tag = "4")]
    pub multiplexing_band: ::core::option::Option<i32>,
}
/// Nested message and enum types in `TReqMultiLookup`.
pub mod t_req_multi_lookup {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TSubrequest {
        /// YPath
        #[prost(bytes = "vec", required, tag = "1")]
        pub path: ::prost::alloc::vec::Vec<u8>,
        #[prost(string, repeated, tag = "2")]
        pub columns: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
        #[prost(bool, optional, tag = "3", default = "true")]
        pub keep_missing_rows: ::core::option::Option<bool>,
        #[prost(bool, optional, tag = "4", default = "false")]
        pub enable_partial_result: ::core::option::Option<bool>,
        #[prost(bool, optional, tag = "5", default = "false")]
        pub use_lookup_cache: ::core::option::Option<bool>,
        #[prost(bool, optional, tag = "10", default = "false")]
        pub allow_missing_key_columns: ::core::option::Option<bool>,
        #[prost(message, required, tag = "6")]
        pub rowset_descriptor: super::TRowsetDescriptor,
        #[prost(int32, required, tag = "7")]
        pub attachment_count: i32,
        #[prost(message, optional, tag = "8")]
        pub versioned_read_options: ::core::option::Option<
            super::super::super::super::n_table_client::n_proto::TVersionedReadOptions,
        >,
        #[prost(string, optional, tag = "9")]
        pub execution_pool: ::core::option::Option<::prost::alloc::string::String>,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspMultiLookup {
    #[prost(message, repeated, tag = "1")]
    pub subresponses: ::prost::alloc::vec::Vec<t_rsp_multi_lookup::TSubresponse>,
}
/// Nested message and enum types in `TRspMultiLookup`.
pub mod t_rsp_multi_lookup {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TSubresponse {
        #[prost(message, required, tag = "1")]
        pub rowset_descriptor: super::TRowsetDescriptor,
        #[prost(int32, required, tag = "2")]
        pub attachment_count: i32,
        #[prost(int32, repeated, packed = "false", tag = "3")]
        pub unavailable_key_indexes: ::prost::alloc::vec::Vec<i32>,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TQueryStatistics {
    /// COMPAT(sabdenovch)
    #[prost(int64, optional, tag = "1")]
    pub rows_read: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "2")]
    pub data_weight_read: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "3")]
    pub rows_written: ::core::option::Option<i64>,
    /// TDuration
    #[prost(uint64, optional, tag = "4")]
    pub sync_time: ::core::option::Option<u64>,
    /// TDuration
    #[prost(uint64, optional, tag = "5")]
    pub async_time: ::core::option::Option<u64>,
    /// TDuration
    #[prost(uint64, optional, tag = "6")]
    pub execute_time: ::core::option::Option<u64>,
    /// TDuration
    #[prost(uint64, optional, tag = "7")]
    pub read_time: ::core::option::Option<u64>,
    /// TDuration
    #[prost(uint64, optional, tag = "8")]
    pub write_time: ::core::option::Option<u64>,
    /// TDuration
    #[prost(uint64, optional, tag = "9")]
    pub codegen_time: ::core::option::Option<u64>,
    /// TDuration
    #[prost(uint64, optional, tag = "10")]
    pub wait_on_ready_event_time: ::core::option::Option<u64>,
    #[prost(int64, optional, tag = "16")]
    pub grouped_row_count: ::core::option::Option<i64>,
    #[prost(uint64, optional, tag = "15")]
    pub memory_usage: ::core::option::Option<u64>,
    #[prost(bool, optional, tag = "11")]
    pub incomplete_input: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "12")]
    pub incomplete_output: ::core::option::Option<bool>,
    #[prost(int64, optional, tag = "17", default = "1")]
    pub query_count: ::core::option::Option<i64>,
    #[prost(message, optional, tag = "21")]
    pub rows_read_aggr: ::core::option::Option<t_query_statistics::TAggregate>,
    #[prost(message, optional, tag = "22")]
    pub data_weight_read_aggr: ::core::option::Option<t_query_statistics::TAggregate>,
    #[prost(message, optional, tag = "23")]
    pub rows_written_aggr: ::core::option::Option<t_query_statistics::TAggregate>,
    #[prost(message, optional, tag = "24")]
    pub sync_time_aggr: ::core::option::Option<t_query_statistics::TAggregate>,
    #[prost(message, optional, tag = "25")]
    pub async_time_aggr: ::core::option::Option<t_query_statistics::TAggregate>,
    #[prost(message, optional, tag = "26")]
    pub execute_time_aggr: ::core::option::Option<t_query_statistics::TAggregate>,
    #[prost(message, optional, tag = "27")]
    pub read_time_aggr: ::core::option::Option<t_query_statistics::TAggregate>,
    #[prost(message, optional, tag = "28")]
    pub write_time_aggr: ::core::option::Option<t_query_statistics::TAggregate>,
    #[prost(message, optional, tag = "29")]
    pub codegen_time_aggr: ::core::option::Option<t_query_statistics::TAggregate>,
    #[prost(message, optional, tag = "30")]
    pub wait_on_ready_event_time_aggr: ::core::option::Option<
        t_query_statistics::TAggregate,
    >,
    #[prost(message, optional, tag = "31")]
    pub memory_usage_aggr: ::core::option::Option<t_query_statistics::TAggregate>,
    #[prost(message, optional, tag = "32")]
    pub grouped_row_count_aggr: ::core::option::Option<t_query_statistics::TAggregate>,
    #[prost(message, repeated, tag = "14")]
    pub inner_statistics: ::prost::alloc::vec::Vec<TQueryStatistics>,
}
/// Nested message and enum types in `TQueryStatistics`.
pub mod t_query_statistics {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TAggregate {
        #[prost(int64, optional, tag = "1")]
        pub total: ::core::option::Option<i64>,
        #[prost(int64, optional, tag = "2")]
        pub max: ::core::option::Option<i64>,
        #[prost(string, optional, tag = "3")]
        pub argmax_node: ::core::option::Option<::prost::alloc::string::String>,
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqSelectRows {
    #[prost(string, required, tag = "1")]
    pub query: ::prost::alloc::string::String,
    /// optional NYT.NProto.TGuid transaction_id = 2;
    #[prost(uint64, optional, tag = "3", default = "4611686018427387649")]
    pub timestamp: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "16", default = "0")]
    pub retention_timestamp: ::core::option::Option<u64>,
    /// NHydra::EPeerKind
    #[prost(int32, optional, tag = "34")]
    pub read_from: ::core::option::Option<i32>,
    #[prost(uint64, optional, tag = "4")]
    pub input_row_limit: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "5")]
    pub output_row_limit: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "6")]
    pub range_expansion_limit: ::core::option::Option<u64>,
    #[prost(bool, optional, tag = "7")]
    pub fail_on_incomplete_result: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "8")]
    pub verbose_logging: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "9")]
    pub enable_code_cache: ::core::option::Option<bool>,
    #[prost(int32, optional, tag = "10")]
    pub max_subqueries: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "11")]
    pub allow_full_scan: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "12")]
    pub allow_join_without_index: ::core::option::Option<bool>,
    /// YPath
    #[prost(bytes = "vec", optional, tag = "13")]
    pub udf_registry_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(uint64, optional, tag = "14")]
    pub memory_limit_per_node: ::core::option::Option<u64>,
    #[prost(string, optional, tag = "15")]
    pub execution_pool: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "EReplicaConsistency", optional, tag = "17")]
    pub replica_consistency: ::core::option::Option<i32>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "18")]
    pub placeholder_values: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, optional, tag = "19")]
    pub new_range_inference: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "20")]
    pub use_canonical_null_relations: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "21")]
    pub merge_versioned_rows: ::core::option::Option<bool>,
    #[prost(int32, optional, tag = "22", default = "1")]
    pub syntax_version: ::core::option::Option<i32>,
    /// EExecutionBackend
    #[prost(int32, optional, tag = "23")]
    pub execution_backend: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "25")]
    pub versioned_read_options: ::core::option::Option<
        super::super::super::n_table_client::n_proto::TVersionedReadOptions,
    >,
    #[prost(bool, optional, tag = "26")]
    pub use_lookup_cache: ::core::option::Option<bool>,
    #[prost(int64, optional, tag = "27")]
    pub min_row_count_per_subquery: ::core::option::Option<i64>,
    #[prost(int32, optional, tag = "28", default = "1")]
    pub expression_builder_version: ::core::option::Option<i32>,
    #[prost(int64, optional, tag = "29")]
    pub rowset_processing_batch_size: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "30")]
    pub write_rowset_size: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "31")]
    pub max_join_batch_size: ::core::option::Option<i64>,
    #[prost(bool, optional, tag = "32")]
    pub use_order_by_in_join_subqueries: ::core::option::Option<bool>,
    /// EStatisticsAggregation
    #[prost(int32, optional, tag = "33")]
    pub statistics_aggregation: ::core::option::Option<i32>,
    /// EOptimizationLevel
    #[prost(int32, optional, tag = "35")]
    pub optimization_level: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "104")]
    pub suppressable_access_tracking_options: ::core::option::Option<
        TSuppressableAccessTrackingOptions,
    >,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspSelectRows {
    #[prost(message, required, tag = "200")]
    pub rowset_descriptor: TRowsetDescriptor,
    #[prost(message, optional, tag = "201")]
    pub statistics: ::core::option::Option<TQueryStatistics>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqAdvanceQueueConsumer {
    #[prost(message, optional, tag = "1")]
    pub transaction_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "2")]
    pub consumer_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "3")]
    pub queue_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(int32, optional, tag = "4")]
    pub partition_index: ::core::option::Option<i32>,
    #[prost(int64, optional, tag = "5")]
    pub old_offset: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "6")]
    pub new_offset: ::core::option::Option<i64>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspAdvanceQueueConsumer {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqPushQueueProducer {
    #[prost(message, optional, tag = "1")]
    pub transaction_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "2")]
    pub producer_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "3")]
    pub queue_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(string, optional, tag = "4")]
    pub session_id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(int64, optional, tag = "5")]
    pub epoch: ::core::option::Option<i64>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "6")]
    pub user_meta: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(int64, optional, tag = "7")]
    pub sequence_number: ::core::option::Option<i64>,
    #[prost(bool, optional, tag = "8")]
    pub require_sync_replica: ::core::option::Option<bool>,
    #[prost(message, required, tag = "200")]
    pub rowset_descriptor: TRowsetDescriptor,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspPushQueueProducer {
    #[prost(int64, optional, tag = "1")]
    pub last_sequence_number: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "2")]
    pub skipped_row_count: ::core::option::Option<i64>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRowBatchReadOptions {
    #[prost(int64, optional, tag = "1")]
    pub max_row_count: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "2")]
    pub max_data_weight: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "3")]
    pub data_weight_per_row_hint: ::core::option::Option<i64>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqPullQueue {
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "1")]
    pub queue_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(int64, optional, tag = "2")]
    pub offset: ::core::option::Option<i64>,
    #[prost(int32, optional, tag = "3")]
    pub partition_index: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "4")]
    pub row_batch_read_options: ::core::option::Option<TRowBatchReadOptions>,
    #[prost(bool, optional, tag = "5", default = "false")]
    pub use_native_tablet_node_api: ::core::option::Option<bool>,
    #[prost(enumeration = "EReplicaConsistency", optional, tag = "6")]
    pub replica_consistency: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspPullQueue {
    #[prost(message, optional, tag = "1")]
    pub rowset_descriptor: ::core::option::Option<TRowsetDescriptor>,
    #[prost(int64, optional, tag = "2")]
    pub start_offset: ::core::option::Option<i64>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqPullQueueConsumer {
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "1")]
    pub consumer_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "2")]
    pub queue_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(int64, optional, tag = "3")]
    pub offset: ::core::option::Option<i64>,
    #[prost(int32, optional, tag = "4")]
    pub partition_index: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "5")]
    pub row_batch_read_options: ::core::option::Option<TRowBatchReadOptions>,
    #[prost(enumeration = "EReplicaConsistency", optional, tag = "6")]
    pub replica_consistency: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspPullQueueConsumer {
    #[prost(message, optional, tag = "1")]
    pub rowset_descriptor: ::core::option::Option<TRowsetDescriptor>,
    #[prost(int64, optional, tag = "2")]
    pub start_offset: ::core::option::Option<i64>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqRegisterQueueConsumer {
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "1")]
    pub queue_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "2")]
    pub consumer_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, optional, tag = "3")]
    pub vital: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "4")]
    pub partitions: ::core::option::Option<
        t_req_register_queue_consumer::TRegistrationPartitions,
    >,
}
/// Nested message and enum types in `TReqRegisterQueueConsumer`.
pub mod t_req_register_queue_consumer {
    /// The most reasonable way to make a std::optional<std::vector<int>> field.
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TRegistrationPartitions {
        #[prost(int32, repeated, packed = "false", tag = "1")]
        pub items: ::prost::alloc::vec::Vec<i32>,
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspRegisterQueueConsumer {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqUnregisterQueueConsumer {
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "1")]
    pub queue_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "2")]
    pub consumer_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspUnregisterQueueConsumer {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqListQueueConsumerRegistrations {
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "1")]
    pub queue_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "2")]
    pub consumer_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspListQueueConsumerRegistrations {
    #[prost(message, repeated, tag = "1")]
    pub registrations: ::prost::alloc::vec::Vec<
        t_rsp_list_queue_consumer_registrations::TQueueConsumerRegistration,
    >,
}
/// Nested message and enum types in `TRspListQueueConsumerRegistrations`.
pub mod t_rsp_list_queue_consumer_registrations {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TQueueConsumerRegistration {
        /// RichYPath
        #[prost(bytes = "vec", optional, tag = "1")]
        pub queue_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
        /// RichYPath
        #[prost(bytes = "vec", optional, tag = "2")]
        pub consumer_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
        #[prost(bool, optional, tag = "3")]
        pub vital: ::core::option::Option<bool>,
        #[prost(message, optional, tag = "4")]
        pub partitions: ::core::option::Option<
            t_queue_consumer_registration::TRegistrationPartitions,
        >,
    }
    /// Nested message and enum types in `TQueueConsumerRegistration`.
    pub mod t_queue_consumer_registration {
        /// The most reasonable way to make a std::optional<std::vector<int>> field.
        #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
        pub struct TRegistrationPartitions {
            #[prost(int32, repeated, packed = "false", tag = "1")]
            pub items: ::prost::alloc::vec::Vec<i32>,
        }
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqCreateQueueProducerSession {
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "1")]
    pub producer_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "2")]
    pub queue_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(string, optional, tag = "3")]
    pub session_id: ::core::option::Option<::prost::alloc::string::String>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "4")]
    pub user_meta: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspCreateQueueProducerSession {
    #[prost(int64, optional, tag = "1")]
    pub sequence_number: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "2")]
    pub epoch: ::core::option::Option<i64>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "3")]
    pub user_meta: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqRemoveQueueProducerSession {
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "1")]
    pub producer_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// RichYPath
    #[prost(bytes = "vec", optional, tag = "2")]
    pub queue_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(string, optional, tag = "3")]
    pub session_id: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspRemoveQueueProducerSession {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqExplainQuery {
    #[prost(string, required, tag = "1")]
    pub query: ::prost::alloc::string::String,
    #[prost(uint64, optional, tag = "3", default = "4611686018427387649")]
    pub timestamp: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "4")]
    pub input_row_limit: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "5")]
    pub output_row_limit: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "6")]
    pub range_expansion_limit: ::core::option::Option<u64>,
    #[prost(int32, optional, tag = "7")]
    pub max_subqueries: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "8")]
    pub allow_full_scan: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "9")]
    pub allow_join_without_index: ::core::option::Option<bool>,
    /// YPath
    #[prost(bytes = "vec", optional, tag = "10")]
    pub udf_registry_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(string, optional, tag = "11")]
    pub execution_pool: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "12")]
    pub new_range_inference: ::core::option::Option<bool>,
    #[prost(int32, optional, tag = "13", default = "1")]
    pub syntax_version: ::core::option::Option<i32>,
    #[prost(int64, optional, tag = "14")]
    pub min_row_count_per_subquery: ::core::option::Option<i64>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspExplainQuery {
    /// YSON
    #[prost(bytes = "vec", required, tag = "1")]
    pub value: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReplicationRowIndex {
    #[prost(message, required, tag = "1")]
    pub tablet_id: super::super::super::n_proto::TGuid,
    #[prost(int64, required, tag = "2")]
    pub row_index: i64,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqPullRows {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, required, tag = "2")]
    pub upstream_replica_id: super::super::super::n_proto::TGuid,
    #[prost(bool, required, tag = "3")]
    pub order_rows_by_timestamp: bool,
    #[prost(int64, required, tag = "4")]
    pub tablet_rows_per_read: i64,
    #[prost(message, required, tag = "5")]
    pub replication_progress: super::super::super::n_chaos_client::n_proto::TReplicationProgress,
    #[prost(uint64, optional, tag = "6")]
    pub upper_timestamp: ::core::option::Option<u64>,
    #[prost(message, repeated, tag = "7")]
    pub start_replication_row_indexes: ::prost::alloc::vec::Vec<TReplicationRowIndex>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspPullRows {
    #[prost(int64, required, tag = "1")]
    pub row_count: i64,
    #[prost(int64, required, tag = "2")]
    pub data_weight: i64,
    #[prost(message, required, tag = "3")]
    pub replication_progress: super::super::super::n_chaos_client::n_proto::TReplicationProgress,
    #[prost(message, repeated, tag = "4")]
    pub end_replication_row_indexes: ::prost::alloc::vec::Vec<TReplicationRowIndex>,
    #[prost(message, required, tag = "5")]
    pub rowset_descriptor: TRowsetDescriptor,
    #[prost(bool, optional, tag = "6", default = "true")]
    pub versioned: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqGetInSyncReplicas {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(uint64, optional, tag = "2", default = "0")]
    pub timestamp: ::core::option::Option<u64>,
    /// TDuration
    #[prost(uint64, optional, tag = "3")]
    pub cached_sync_replicas_timeout: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "200")]
    pub rowset_descriptor: ::core::option::Option<TRowsetDescriptor>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspGetInSyncReplicas {
    #[prost(message, repeated, tag = "1")]
    pub replica_ids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetTabletInfos {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int32, repeated, packed = "false", tag = "2")]
    pub tablet_indexes: ::prost::alloc::vec::Vec<i32>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub request_errors: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspGetTabletInfos {
    #[prost(message, repeated, tag = "1")]
    pub tablets: ::prost::alloc::vec::Vec<t_rsp_get_tablet_infos::TTabletInfo>,
}
/// Nested message and enum types in `TRspGetTabletInfos`.
pub mod t_rsp_get_tablet_infos {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TTabletInfo {
        #[prost(int64, required, tag = "1")]
        pub total_row_count: i64,
        #[prost(int64, required, tag = "2")]
        pub trimmed_row_count: i64,
        #[prost(int64, optional, tag = "7")]
        pub delayed_lockless_row_count: ::core::option::Option<i64>,
        #[prost(uint64, optional, tag = "3")]
        pub barrier_timestamp: ::core::option::Option<u64>,
        #[prost(uint64, optional, tag = "4")]
        pub last_write_timestamp: ::core::option::Option<u64>,
        #[prost(message, repeated, tag = "5")]
        pub replicas: ::prost::alloc::vec::Vec<t_tablet_info::TReplicaInfo>,
        #[prost(message, repeated, tag = "6")]
        pub tablet_errors: ::prost::alloc::vec::Vec<
            super::super::super::super::n_proto::TError,
        >,
    }
    /// Nested message and enum types in `TTabletInfo`.
    pub mod t_tablet_info {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct TReplicaInfo {
            #[prost(message, required, tag = "1")]
            pub replica_id: super::super::super::super::super::n_proto::TGuid,
            #[prost(uint64, required, tag = "2")]
            pub last_replication_timestamp: u64,
            /// ETableReplicaMode
            #[prost(int32, required, tag = "3")]
            pub mode: i32,
            #[prost(int64, required, tag = "4")]
            pub current_replication_row_index: i64,
            #[prost(int64, required, tag = "6")]
            pub committed_replication_row_index: i64,
            #[prost(message, optional, tag = "5")]
            pub replication_error: ::core::option::Option<
                super::super::super::super::super::n_proto::TError,
            >,
        }
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetTabletErrors {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int64, optional, tag = "2")]
    pub limit: ::core::option::Option<i64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspGetTabletErrors {
    #[prost(message, repeated, tag = "1")]
    pub tablet_ids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
    #[prost(message, repeated, tag = "2")]
    pub tablet_errors: ::prost::alloc::vec::Vec<t_rsp_get_tablet_errors::TErrorList>,
    #[prost(message, repeated, tag = "3")]
    pub replica_ids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
    #[prost(message, repeated, tag = "4")]
    pub replication_errors: ::prost::alloc::vec::Vec<
        t_rsp_get_tablet_errors::TErrorList,
    >,
    #[prost(bool, optional, tag = "5")]
    pub incomplete: ::core::option::Option<bool>,
}
/// Nested message and enum types in `TRspGetTabletErrors`.
pub mod t_rsp_get_tablet_errors {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TErrorList {
        #[prost(message, repeated, tag = "1")]
        pub errors: ::prost::alloc::vec::Vec<
            super::super::super::super::n_proto::TError,
        >,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqModifyRows {
    /// Modifications are sent asynchronously. Sequential numbering is
    /// required to restore their order (optional for compatibility).
    #[prost(int64, optional, tag = "6")]
    pub sequence_number: ::core::option::Option<i64>,
    /// Modifications can be sent from several sources in case of several clients
    /// attached to the same transaction.
    ///
    /// Modifications within one source will be serialized by this source sequence numbers.
    /// Modifications from different sources will be serialized arbitrarily, that is why
    /// different sources must send independent modifications.
    ///
    /// If sequence number is missing, source id is ignored.
    /// Otherwise missing source id is interpreted as source id = 0.
    #[prost(int64, optional, tag = "9")]
    pub sequence_number_source_id: ::core::option::Option<i64>,
    #[prost(message, required, tag = "1")]
    pub transaction_id: super::super::super::n_proto::TGuid,
    /// YPath
    #[prost(bytes = "vec", required, tag = "2")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(enumeration = "ERowModificationType", repeated, packed = "false", tag = "3")]
    pub row_modification_types: ::prost::alloc::vec::Vec<i32>,
    /// COMPAT(lukyan): Remove after RPC protocol version update
    #[prost(uint32, repeated, packed = "false", tag = "7")]
    pub row_legacy_read_locks: ::prost::alloc::vec::Vec<u32>,
    /// COMPAT(ponasenko-rs): Remove after RPC protocol version update
    #[prost(uint64, repeated, packed = "false", tag = "8")]
    pub row_legacy_locks: ::prost::alloc::vec::Vec<u64>,
    #[prost(bool, optional, tag = "4")]
    pub require_sync_replica: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "5")]
    pub upstream_replica_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(bool, optional, tag = "10")]
    pub allow_missing_key_columns: ::core::option::Option<bool>,
    #[prost(message, repeated, tag = "11")]
    pub row_locks: ::prost::alloc::vec::Vec<
        super::super::super::n_tablet_client::n_proto::TLockMask,
    >,
    #[prost(message, required, tag = "200")]
    pub rowset_descriptor: TRowsetDescriptor,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspModifyRows {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqBatchModifyRows {
    #[prost(message, required, tag = "1")]
    pub transaction_id: super::super::super::n_proto::TGuid,
    #[prost(int64, repeated, packed = "false", tag = "2")]
    pub part_counts: ::prost::alloc::vec::Vec<i64>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspBatchModifyRows {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqBuildSnapshot {
    #[prost(message, optional, tag = "1")]
    pub cell_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(bool, optional, tag = "2", default = "false")]
    pub set_read_only: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "3", default = "true")]
    pub wait_for_snapshot_completion: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "4", default = "true")]
    pub enable_automaton_read_only_barrier: ::core::option::Option<bool>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspBuildSnapshot {
    #[prost(int64, required, tag = "1")]
    pub snapshot_id: i64,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqExitReadOnly {
    #[prost(message, required, tag = "1")]
    pub cell_id: super::super::super::n_proto::TGuid,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspExitReadOnly {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqMasterExitReadOnly {
    #[prost(bool, required, tag = "1")]
    pub retry: bool,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspMasterExitReadOnly {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqResetDynamicallyPropagatedMasterCells {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspResetDynamicallyPropagatedMasterCells {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqDiscombobulateNonvotingPeers {
    #[prost(message, required, tag = "1")]
    pub cell_id: super::super::super::n_proto::TGuid,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspDiscombobulateNonvotingPeers {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGcCollect {
    #[prost(message, optional, tag = "1")]
    pub cell_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGcCollect {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqSuspendCoordinator {
    #[prost(message, optional, tag = "1")]
    pub coordinator_cell_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspSuspendCoordinator {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqResumeCoordinator {
    #[prost(message, optional, tag = "1")]
    pub coordinator_cell_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspResumeCoordinator {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqMigrateReplicationCards {
    #[prost(message, required, tag = "1")]
    pub chaos_cell_id: super::super::super::n_proto::TGuid,
    #[prost(message, optional, tag = "2")]
    pub destination_cell_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(message, repeated, tag = "3")]
    pub replication_card_ids: ::prost::alloc::vec::Vec<
        super::super::super::n_proto::TGuid,
    >,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspMigrateReplicationCards {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqSuspendChaosCells {
    #[prost(message, repeated, tag = "1")]
    pub cell_ids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspSuspendChaosCells {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqResumeChaosCells {
    #[prost(message, repeated, tag = "1")]
    pub cell_ids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspResumeChaosCells {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqSuspendTabletCells {
    #[prost(message, repeated, tag = "1")]
    pub cell_ids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspSuspendTabletCells {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqResumeTabletCells {
    #[prost(message, repeated, tag = "1")]
    pub cell_ids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspResumeTabletCells {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqAddMaintenance {
    #[prost(enumeration = "EMaintenanceComponent", required, tag = "1")]
    pub component: i32,
    #[prost(string, required, tag = "2")]
    pub address: ::prost::alloc::string::String,
    #[prost(enumeration = "EMaintenanceType", required, tag = "3")]
    pub r#type: i32,
    #[prost(string, required, tag = "4")]
    pub comment: ::prost::alloc::string::String,
    /// COMPAT(kvk1920): For compatibility with pre-24.2 RPC clients.
    #[prost(bool, optional, tag = "5", default = "false")]
    pub supports_per_target_response: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspAddMaintenance {
    /// COMPAT(kvk1920): For compatibility with pre-24.2 RPC clients.
    ///
    /// TMaintenanceId
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    /// Key: component address
    /// Value: TMaintenanceId
    #[prost(map = "string, message", tag = "2")]
    pub id_per_target: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        super::super::super::n_proto::TGuid,
    >,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqRemoveMaintenance {
    #[prost(enumeration = "EMaintenanceComponent", required, tag = "1")]
    pub component: i32,
    #[prost(string, required, tag = "2")]
    pub address: ::prost::alloc::string::String,
    /// TMaintenanceId
    #[prost(message, repeated, tag = "3")]
    pub ids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
    #[prost(enumeration = "EMaintenanceType", optional, tag = "4")]
    pub r#type: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "5")]
    pub user: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "6", default = "false")]
    pub mine: ::core::option::Option<bool>,
    /// COMPAT(kvk1920): Compatibility with pre-24.2 RPC clients.
    #[prost(bool, optional, tag = "7", default = "false")]
    pub supports_per_target_response: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspRemoveMaintenance {
    /// COMPAT(kvk1920): For compatibility with pre-23.2.
    #[prost(int32, optional, tag = "1")]
    pub ban: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "2")]
    pub decommission: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "3")]
    pub disable_scheduler_jobs: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "4")]
    pub disable_write_sessions: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "5")]
    pub disable_tablet_cells: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "8")]
    pub pending_restart: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "6", default = "false")]
    pub use_map_instead_of_fields: ::core::option::Option<bool>,
    /// COMPAT(kvk1920): For compatibility with pre-24.2 RPC clients.
    ///
    /// Key: EMaintenanceType
    #[prost(map = "int32, int32", tag = "7")]
    pub removed_maintenance_counts: ::std::collections::HashMap<i32, i32>,
    /// COMPAT(kvk1920): For compatibility with pre-24.2 RPC proxies.
    #[prost(bool, optional, tag = "9", default = "false")]
    pub supports_per_target_response: ::core::option::Option<bool>,
    /// Key: component address
    #[prost(map = "string, message", tag = "10")]
    pub removed_maintenance_counts_per_target: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        t_rsp_remove_maintenance::TMaintenanceCounts,
    >,
}
/// Nested message and enum types in `TRspRemoveMaintenance`.
pub mod t_rsp_remove_maintenance {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TMaintenanceCounts {
        /// Key: EMaintenanceType
        #[prost(map = "int32, int32", tag = "1")]
        pub counts: ::std::collections::HashMap<i32, i32>,
    }
}
/// 100
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TTransactionalOptions {
    #[prost(message, optional, tag = "1")]
    pub transaction_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(bool, optional, tag = "2", default = "false")]
    pub ping: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub ping_ancestors: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "5")]
    pub suppress_transaction_coordinator_sync: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "6")]
    pub suppress_upstream_sync: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "7")]
    pub suppress_strongly_ordered_transaction_barrier: ::core::option::Option<bool>,
}
/// 101
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TPrerequisiteOptions {
    #[prost(message, repeated, tag = "1")]
    pub transactions: ::prost::alloc::vec::Vec<
        t_prerequisite_options::TTransactionPrerequisite,
    >,
    #[prost(message, repeated, tag = "2")]
    pub revisions: ::prost::alloc::vec::Vec<
        t_prerequisite_options::TRevisionPrerequisite,
    >,
}
/// Nested message and enum types in `TPrerequisiteOptions`.
pub mod t_prerequisite_options {
    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TTransactionPrerequisite {
        #[prost(message, required, tag = "1")]
        pub transaction_id: super::super::super::super::n_proto::TGuid,
    }
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TRevisionPrerequisite {
        /// YPath
        #[prost(bytes = "vec", required, tag = "2")]
        pub path: ::prost::alloc::vec::Vec<u8>,
        #[prost(uint64, required, tag = "3")]
        pub revision: u64,
    }
}
/// 102
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TMasterReadOptions {
    #[prost(
        enumeration = "EMasterReadKind",
        optional,
        tag = "1",
        default = "MrkFollower"
    )]
    pub read_from: ::core::option::Option<i32>,
    /// TDuration
    #[prost(int64, optional, tag = "2")]
    pub expire_after_successful_update_time: ::core::option::Option<i64>,
    /// TDuration
    #[prost(int64, optional, tag = "3")]
    pub expire_after_failed_update_time: ::core::option::Option<i64>,
    #[prost(int32, optional, tag = "4")]
    pub cache_sticky_group_size: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "5")]
    pub disable_per_user_cache: ::core::option::Option<bool>,
    /// TDuration
    #[prost(int64, optional, tag = "6")]
    pub success_staleness_bound: ::core::option::Option<i64>,
}
/// 103
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TMutatingOptions {
    #[prost(message, optional, tag = "1")]
    pub mutation_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(bool, optional, tag = "2")]
    pub retry: ::core::option::Option<bool>,
}
/// 104
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TSuppressableAccessTrackingOptions {
    #[prost(bool, optional, tag = "1", default = "false")]
    pub suppress_access_tracking: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "2", default = "false")]
    pub suppress_modification_tracking: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub suppress_expiration_timeout_renewal: ::core::option::Option<bool>,
}
/// 105
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TTabletRangeOptions {
    #[prost(int32, optional, tag = "1")]
    pub first_tablet_index: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "2")]
    pub last_tablet_index: ::core::option::Option<i32>,
}
/// 106
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TTabletReadOptions {
    #[prost(enumeration = "ETabletReadKind", optional, tag = "1", default = "TrkLeader")]
    pub read_from: ::core::option::Option<i32>,
    /// TDuration
    #[prost(uint64, optional, tag = "2")]
    pub cached_sync_replicas_timeout: ::core::option::Option<u64>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGenerateTimestamps {
    #[prost(int32, optional, tag = "1", default = "1")]
    pub count: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "2")]
    pub clock_cluster_tag: ::core::option::Option<i32>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGenerateTimestamps {
    #[prost(uint64, required, tag = "1")]
    pub timestamp: u64,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqExistsNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "102")]
    pub master_read_options: ::core::option::Option<TMasterReadOptions>,
    #[prost(message, optional, tag = "104")]
    pub suppressable_access_tracking_options: ::core::option::Option<
        TSuppressableAccessTrackingOptions,
    >,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspExistsNode {
    #[prost(bool, required, tag = "1")]
    pub exists: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqGetNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    /// COMPAT(max42): see comment around TLegacyAttributeKeys.
    #[prost(message, optional, tag = "2")]
    pub legacy_attributes: ::core::option::Option<TLegacyAttributeKeys>,
    #[prost(message, optional, tag = "4")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeFilter,
    >,
    #[prost(int64, optional, tag = "3")]
    pub max_size: ::core::option::Option<i64>,
    #[prost(message, optional, tag = "6")]
    pub complexity_limits: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TReadRequestComplexityLimits,
    >,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "102")]
    pub master_read_options: ::core::option::Option<TMasterReadOptions>,
    #[prost(message, optional, tag = "104")]
    pub suppressable_access_tracking_options: ::core::option::Option<
        TSuppressableAccessTrackingOptions,
    >,
    #[prost(message, optional, tag = "200")]
    pub options: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeDictionary,
    >,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetNode {
    /// YSON
    #[prost(bytes = "vec", required, tag = "1")]
    pub value: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqListNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    /// COMPAT(max42): see comment around TLegacyAttributeKeys.
    #[prost(message, optional, tag = "2")]
    pub legacy_attributes: ::core::option::Option<TLegacyAttributeKeys>,
    #[prost(message, optional, tag = "4")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeFilter,
    >,
    #[prost(int64, optional, tag = "3")]
    pub max_size: ::core::option::Option<i64>,
    #[prost(message, optional, tag = "6")]
    pub complexity_limits: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TReadRequestComplexityLimits,
    >,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "102")]
    pub master_read_options: ::core::option::Option<TMasterReadOptions>,
    #[prost(message, optional, tag = "104")]
    pub suppressable_access_tracking_options: ::core::option::Option<
        TSuppressableAccessTrackingOptions,
    >,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspListNode {
    /// YSON
    #[prost(bytes = "vec", required, tag = "1")]
    pub value: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqCreateObject {
    /// NObjectClient::EObjectType
    #[prost(int32, required, tag = "1")]
    pub r#type: i32,
    #[prost(bool, optional, tag = "3")]
    pub ignore_existing: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "4")]
    pub sync: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "2")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeDictionary,
    >,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspCreateObject {
    #[prost(message, required, tag = "1")]
    pub object_id: super::super::super::n_proto::TGuid,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TColumnSchema {
    #[prost(string, required, tag = "1")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, optional, tag = "12")]
    pub stable_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(int32, optional, tag = "2")]
    pub r#type: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "3")]
    pub logical_type: ::core::option::Option<i32>,
    /// YSON representation of type_v3
    #[prost(bytes = "vec", optional, tag = "11")]
    pub type_v3: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(string, optional, tag = "4")]
    pub lock: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "5")]
    pub expression: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "13")]
    pub materialized: ::core::option::Option<bool>,
    #[prost(string, optional, tag = "6")]
    pub aggregate: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(int32, optional, tag = "7")]
    pub sort_order: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "8")]
    pub group: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "9", default = "false")]
    pub required: ::core::option::Option<bool>,
    #[prost(int64, optional, tag = "10")]
    pub max_inline_hunk_size: ::core::option::Option<i64>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TDeletedColumn {
    #[prost(string, required, tag = "1")]
    pub stable_name: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TTableSchema {
    #[prost(message, repeated, tag = "1")]
    pub columns: ::prost::alloc::vec::Vec<TColumnSchema>,
    #[prost(bool, optional, tag = "2", default = "true")]
    pub strict: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub unique_keys: ::core::option::Option<bool>,
    #[prost(message, repeated, tag = "5")]
    pub deleted_columns: ::prost::alloc::vec::Vec<TDeletedColumn>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TTabletInfo {
    #[prost(message, required, tag = "1")]
    pub tablet_id: super::super::super::n_proto::TGuid,
    #[prost(uint64, required, tag = "2")]
    pub mount_revision: u64,
    #[prost(int32, required, tag = "3")]
    pub state: i32,
    #[prost(bytes = "vec", required, tag = "4")]
    pub pivot_key: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "5")]
    pub cell_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(int32, optional, tag = "6")]
    pub cell_config_version: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReplicaInfo {
    #[prost(message, required, tag = "1")]
    pub replica_id: super::super::super::n_proto::TGuid,
    #[prost(string, required, tag = "2")]
    pub cluster_name: ::prost::alloc::string::String,
    /// YPath
    #[prost(bytes = "vec", required, tag = "3")]
    pub replica_path: ::prost::alloc::vec::Vec<u8>,
    /// ETableReplicaMode
    #[prost(int32, required, tag = "4")]
    pub mode: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TIndexInfo {
    #[prost(message, required, tag = "1")]
    pub index_table_id: super::super::super::n_proto::TGuid,
    /// NTableClient::ESecondaryIndexKind
    #[prost(int32, required, tag = "2")]
    pub index_kind: i32,
    #[prost(string, optional, tag = "3")]
    pub predicate: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "4")]
    pub unfolded_column: ::core::option::Option<::prost::alloc::string::String>,
    /// NTableClient::ESecondaryIndexState
    #[prost(int32, optional, tag = "6")]
    pub index_correspondence: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "7")]
    pub evaluated_columns_schema: ::core::option::Option<TTableSchema>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetTableMountInfo {
    /// RichYPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspGetTableMountInfo {
    #[prost(message, required, tag = "1")]
    pub table_id: super::super::super::n_proto::TGuid,
    #[prost(message, required, tag = "2")]
    pub schema: TTableSchema,
    #[prost(message, repeated, tag = "3")]
    pub tablets: ::prost::alloc::vec::Vec<TTabletInfo>,
    #[prost(bool, required, tag = "4")]
    pub dynamic: bool,
    #[prost(message, required, tag = "5")]
    pub upstream_replica_id: super::super::super::n_proto::TGuid,
    #[prost(message, repeated, tag = "6")]
    pub replicas: ::prost::alloc::vec::Vec<TReplicaInfo>,
    /// YPath
    #[prost(bytes = "vec", optional, tag = "7")]
    pub physical_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, repeated, tag = "8")]
    pub indices: ::prost::alloc::vec::Vec<TIndexInfo>,
    #[prost(int32, optional, tag = "9")]
    pub tablet_count: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetTablePivotKeys {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(bool, optional, tag = "2")]
    pub represent_key_as_list: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetTablePivotKeys {
    /// YSON
    #[prost(bytes = "vec", required, tag = "1")]
    pub value: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TTableBackupManifest {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub source_path: ::prost::alloc::vec::Vec<u8>,
    /// YPath
    #[prost(bytes = "vec", required, tag = "2")]
    pub destination_path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int32, required, tag = "3")]
    pub ordered_mode: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TBackupManifest {
    #[prost(message, repeated, tag = "1")]
    pub clusters: ::prost::alloc::vec::Vec<t_backup_manifest::TClusterManifest>,
}
/// Nested message and enum types in `TBackupManifest`.
pub mod t_backup_manifest {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TClusterManifest {
        #[prost(string, required, tag = "1")]
        pub cluster: ::prost::alloc::string::String,
        #[prost(message, repeated, tag = "2")]
        pub table_manifests: ::prost::alloc::vec::Vec<super::TTableBackupManifest>,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqCreateTableBackup {
    #[prost(message, required, tag = "1")]
    pub manifest: TBackupManifest,
    #[prost(uint64, required, tag = "2")]
    pub checkpoint_timestamp_delay: u64,
    #[prost(uint64, required, tag = "3")]
    pub checkpoint_check_period: u64,
    #[prost(uint64, required, tag = "4")]
    pub checkpoint_check_timeout: u64,
    #[prost(bool, required, tag = "5")]
    pub force: bool,
    #[prost(bool, required, tag = "6")]
    pub preserve_account: bool,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspCreateTableBackup {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqRestoreTableBackup {
    #[prost(message, required, tag = "1")]
    pub manifest: TBackupManifest,
    #[prost(bool, required, tag = "2")]
    pub force: bool,
    #[prost(bool, required, tag = "3")]
    pub mount: bool,
    #[prost(bool, required, tag = "4")]
    pub enable_replicas: bool,
    #[prost(bool, required, tag = "5")]
    pub preserve_account: bool,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspRestoreTableBackup {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqCreateNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    /// NObjectClient::EObjectType
    #[prost(int32, required, tag = "2")]
    pub r#type: i32,
    #[prost(message, optional, tag = "3")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeDictionary,
    >,
    #[prost(bool, optional, tag = "4", default = "false")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "5", default = "false")]
    pub force: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "6", default = "false")]
    pub ignore_existing: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "7", default = "false")]
    pub lock_existing: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "8", default = "false")]
    pub ignore_type_mismatch: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspCreateNode {
    #[prost(message, required, tag = "1")]
    pub node_id: super::super::super::n_proto::TGuid,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqRemoveNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(bool, optional, tag = "2", default = "true")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub force: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspRemoveNode {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqSetNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    /// YSON
    #[prost(bytes = "vec", required, tag = "2")]
    pub value: ::prost::alloc::vec::Vec<u8>,
    #[prost(bool, optional, tag = "3")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "4")]
    pub force: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
    #[prost(message, optional, tag = "104")]
    pub suppressable_access_tracking_options: ::core::option::Option<
        TSuppressableAccessTrackingOptions,
    >,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspSetNode {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqMultisetAttributesNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, repeated, tag = "2")]
    pub subrequests: ::prost::alloc::vec::Vec<
        t_req_multiset_attributes_node::TSubrequest,
    >,
    #[prost(bool, optional, tag = "3")]
    pub force: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
    #[prost(message, optional, tag = "104")]
    pub suppressable_access_tracking_options: ::core::option::Option<
        TSuppressableAccessTrackingOptions,
    >,
}
/// Nested message and enum types in `TReqMultisetAttributesNode`.
pub mod t_req_multiset_attributes_node {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TSubrequest {
        #[prost(string, required, tag = "1")]
        pub attribute: ::prost::alloc::string::String,
        /// YSON
        #[prost(bytes = "vec", required, tag = "2")]
        pub value: ::prost::alloc::vec::Vec<u8>,
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspMultisetAttributesNode {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqLockNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    /// NCypressClient::ELockMode
    #[prost(int32, required, tag = "2")]
    pub mode: i32,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub waitable: ::core::option::Option<bool>,
    #[prost(string, optional, tag = "4")]
    pub child_key: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "5")]
    pub attribute_key: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspLockNode {
    #[prost(message, required, tag = "1")]
    pub node_id: super::super::super::n_proto::TGuid,
    #[prost(message, required, tag = "2")]
    pub lock_id: super::super::super::n_proto::TGuid,
    #[prost(uint64, optional, tag = "3")]
    pub revision: ::core::option::Option<u64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqUnlockNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspUnlockNode {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqCopyNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub src_path: ::prost::alloc::vec::Vec<u8>,
    /// YPath
    #[prost(bytes = "vec", required, tag = "2")]
    pub dst_path: ::prost::alloc::vec::Vec<u8>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "4", default = "false")]
    pub force: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "5", default = "false")]
    pub preserve_account: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "7", default = "false")]
    pub preserve_creation_time: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "10", default = "false")]
    pub preserve_modification_time: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "6", default = "false")]
    pub preserve_expiration_time: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "14", default = "false")]
    pub preserve_expiration_timeout: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "11", default = "false")]
    pub preserve_owner: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "12", default = "false")]
    pub preserve_acl: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "8", default = "false")]
    pub ignore_existing: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "13", default = "false")]
    pub lock_existing: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "9", default = "true")]
    pub pessimistic_quota_check: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "15", default = "true")]
    pub enable_cross_cell_copying: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "16", default = "false")]
    pub allow_secondary_index_abandonment: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspCopyNode {
    #[prost(message, required, tag = "1")]
    pub node_id: super::super::super::n_proto::TGuid,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqMoveNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub src_path: ::prost::alloc::vec::Vec<u8>,
    /// YPath
    #[prost(bytes = "vec", required, tag = "2")]
    pub dst_path: ::prost::alloc::vec::Vec<u8>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "4", default = "false")]
    pub force: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "5", default = "false")]
    pub preserve_account: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "8", default = "false")]
    pub preserve_creation_time: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "9", default = "false")]
    pub preserve_modification_time: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "6", default = "false")]
    pub preserve_expiration_time: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "12", default = "false")]
    pub preserve_expiration_timeout: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "11", default = "false")]
    pub preserve_owner: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "14", default = "false")]
    pub preserve_acl: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "7", default = "true")]
    pub pessimistic_quota_check: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "13", default = "true")]
    pub enable_cross_cell_copying: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "15", default = "false")]
    pub allow_secondary_index_abandonment: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspMoveNode {
    #[prost(message, required, tag = "1")]
    pub node_id: super::super::super::n_proto::TGuid,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqLinkNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub src_path: ::prost::alloc::vec::Vec<u8>,
    /// YPath
    #[prost(bytes = "vec", required, tag = "2")]
    pub dst_path: ::prost::alloc::vec::Vec<u8>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub recursive: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "4", default = "false")]
    pub force: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "5", default = "false")]
    pub ignore_existing: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "6", default = "false")]
    pub lock_existing: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "7")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeDictionary,
    >,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspLinkNode {
    #[prost(message, required, tag = "1")]
    pub node_id: super::super::super::n_proto::TGuid,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqConcatenateNodes {
    /// YPath
    #[prost(bytes = "vec", repeated, tag = "1")]
    pub src_paths: ::prost::alloc::vec::Vec<::prost::alloc::vec::Vec<u8>>,
    /// YPath
    #[prost(bytes = "vec", required, tag = "2")]
    pub dst_path: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "3")]
    pub fetcher: ::core::option::Option<t_req_concatenate_nodes::TFetcher>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    /// TODO(sandello): Prerequisite?
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
/// Nested message and enum types in `TReqConcatenateNodes`.
pub mod t_req_concatenate_nodes {
    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TFetcher {
        /// TDuration, 30 seconds by default
        #[prost(uint64, optional, tag = "1", default = "30000000")]
        pub node_rpc_timeout: ::core::option::Option<u64>,
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspConcatenateNodes {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqExternalizeNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int32, required, tag = "2")]
    pub cell_tag: i32,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspExternalizeNode {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqInternalizeNode {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspInternalizeNode {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqAttachTransaction {
    #[prost(message, required, tag = "1")]
    pub transaction_id: super::super::super::n_proto::TGuid,
    /// COMPAT(kiselyovp) next option is unused and should get removed
    #[prost(bool, optional, tag = "2", default = "false")]
    pub auto_abort: ::core::option::Option<bool>,
    /// TDuration
    #[prost(uint64, optional, tag = "4")]
    pub ping_period: ::core::option::Option<u64>,
    #[prost(bool, optional, tag = "5", default = "true")]
    pub ping: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "6", default = "false")]
    pub ping_ancestors: ::core::option::Option<bool>,
    /// Address of the last client that pinged transaction.
    #[prost(string, optional, tag = "7")]
    pub pinger_address: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspAttachTransaction {
    #[prost(enumeration = "ETransactionType", required, tag = "1")]
    pub r#type: i32,
    #[prost(uint64, required, tag = "2")]
    pub start_timestamp: u64,
    #[prost(enumeration = "EAtomicity", required, tag = "3")]
    pub atomicity: i32,
    #[prost(enumeration = "EDurability", required, tag = "4")]
    pub durability: i32,
    #[prost(int64, required, tag = "5")]
    pub timeout: i64,
    /// Sequence number source id allocated for this client if transaction is tablet.
    /// Client is free not to use this source id and generate source id on its own,
    /// for example, for backward compatibility. In this case client is responsible for
    /// source id uniqueness between all transaction clients.
    /// See TReqModifyRows.sequence_number_source_id for details.
    #[prost(int64, optional, tag = "6")]
    pub sequence_number_source_id: ::core::option::Option<i64>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqDetachTransaction {
    #[prost(message, required, tag = "1")]
    pub transaction_id: super::super::super::n_proto::TGuid,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspDetachTransaction {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqMountTable {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "2")]
    pub cell_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub freeze: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
    #[prost(message, optional, tag = "104")]
    pub tablet_range_options: ::core::option::Option<TTabletRangeOptions>,
    #[prost(message, repeated, tag = "4")]
    pub target_cell_ids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspMountTable {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqUnmountTable {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(bool, optional, tag = "2", default = "false")]
    pub force: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
    #[prost(message, optional, tag = "104")]
    pub tablet_range_options: ::core::option::Option<TTabletRangeOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspUnmountTable {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqRemountTable {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
    #[prost(message, optional, tag = "104")]
    pub tablet_range_options: ::core::option::Option<TTabletRangeOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspRemountTable {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqFreezeTable {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
    #[prost(message, optional, tag = "104")]
    pub tablet_range_options: ::core::option::Option<TTabletRangeOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspFreezeTable {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqUnfreezeTable {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
    #[prost(message, optional, tag = "104")]
    pub tablet_range_options: ::core::option::Option<TTabletRangeOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspUnfreezeTable {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqReshardTable {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int32, optional, tag = "3")]
    pub tablet_count: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "4")]
    pub uniform: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "5")]
    pub enable_slicing: ::core::option::Option<bool>,
    #[prost(double, optional, tag = "6")]
    pub slicing_accuracy: ::core::option::Option<f64>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
    #[prost(message, optional, tag = "104")]
    pub tablet_range_options: ::core::option::Option<TTabletRangeOptions>,
    #[prost(message, optional, tag = "200")]
    pub rowset_descriptor: ::core::option::Option<TRowsetDescriptor>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspReshardTable {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqReshardTableAutomatic {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(bool, required, tag = "2", default = "false")]
    pub keep_actions: bool,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
    #[prost(message, optional, tag = "104")]
    pub tablet_range_options: ::core::option::Option<TTabletRangeOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspReshardTableAutomatic {
    #[prost(message, repeated, tag = "1")]
    pub tablet_actions: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqTrimTable {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int32, required, tag = "2")]
    pub tablet_index: i32,
    #[prost(uint64, required, tag = "3")]
    pub trimmed_row_count: u64,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspTrimTable {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqAlterTable {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "2")]
    pub schema: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, optional, tag = "3")]
    pub dynamic: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "4")]
    pub upstream_replica_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(enumeration = "ETableSchemaModification", optional, tag = "5")]
    pub schema_modification: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "6")]
    pub replication_progress: ::core::option::Option<
        super::super::super::n_chaos_client::n_proto::TReplicationProgress,
    >,
    #[prost(message, optional, tag = "7")]
    pub schema_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(uint64, optional, tag = "8")]
    pub clip_timestamp: ::core::option::Option<u64>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "9")]
    pub constrained_schema: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "10")]
    pub constraints: ::core::option::Option<
        super::super::super::n_table_client::n_proto::TColumnNameToConstraintMap,
    >,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    /// XXX(sandello): Prerequisite?
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspAlterTable {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqAlterTableReplica {
    #[prost(message, required, tag = "1")]
    pub replica_id: super::super::super::n_proto::TGuid,
    #[prost(bool, optional, tag = "2")]
    pub enabled: ::core::option::Option<bool>,
    #[prost(enumeration = "ETableReplicaMode", optional, tag = "3")]
    pub mode: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "4")]
    pub preserve_timestamps: ::core::option::Option<bool>,
    #[prost(enumeration = "EAtomicity", optional, tag = "5")]
    pub atomicity: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "6")]
    pub enable_replicated_table_tracker: ::core::option::Option<bool>,
    /// YPath
    #[prost(bytes = "vec", optional, tag = "7")]
    pub replica_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, optional, tag = "8")]
    pub force: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "100")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspAlterTableReplica {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqAlterReplicationCard {
    /// NChaosClient::TReplicationCardId
    #[prost(message, required, tag = "1")]
    pub replication_card_id: super::super::super::n_proto::TGuid,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "2")]
    pub replicated_table_options: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, optional, tag = "3")]
    pub enable_replicated_table_tracker: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "4")]
    pub replication_card_collocation_id: ::core::option::Option<
        super::super::super::n_proto::TGuid,
    >,
    /// NTabletClient::TReplicationCollocationOptions
    #[prost(bytes = "vec", optional, tag = "5")]
    pub collocation_options: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "100")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspAlterReplicationCard {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqPingChaosLease {
    /// NChaosClient::TChaosLeaseId
    #[prost(message, required, tag = "1")]
    pub chaos_lease_id: super::super::super::n_proto::TGuid,
    #[prost(bool, optional, tag = "2", default = "true")]
    pub ping_ancestors: ::core::option::Option<bool>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspPingChaosLease {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TFetchChunkSpecConfig {
    #[prost(int32, optional, tag = "1")]
    pub max_chunk_per_fetch: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "2")]
    pub max_chunk_per_locate_request: ::core::option::Option<i32>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TFetcherConfig {
    /// TDuration
    #[prost(uint64, optional, tag = "1")]
    pub node_rpc_timeout: ::core::option::Option<u64>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetColumnarStatistics {
    /// RichYPath
    #[prost(bytes = "vec", repeated, tag = "1")]
    pub paths: ::prost::alloc::vec::Vec<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "2")]
    pub fetch_chunk_spec_config: ::core::option::Option<TFetchChunkSpecConfig>,
    #[prost(message, optional, tag = "3")]
    pub fetcher_config: ::core::option::Option<TFetcherConfig>,
    #[prost(enumeration = "EColumnarStatisticsFetcherMode", optional, tag = "4")]
    pub fetcher_mode: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "5", default = "false")]
    pub enable_early_finish: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "6", default = "false")]
    pub enable_read_size_estimation: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TColumnarStatistics {
    #[prost(int64, repeated, packed = "false", tag = "1")]
    pub column_data_weights: ::prost::alloc::vec::Vec<i64>,
    #[prost(int64, optional, tag = "2")]
    pub timestamp_total_weight: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "3", default = "0")]
    pub legacy_chunk_data_weight: ::core::option::Option<i64>,
    /// Per-column approximate minimum values. For more information check comments in NYT::NTableClient::TColumnarStatistics.
    #[prost(bytes = "vec", optional, tag = "9")]
    pub column_min_values: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// Per-column approximate maximum values. For more information check comments in NYT::NTableClient::TColumnarStatistics.
    #[prost(bytes = "vec", optional, tag = "10")]
    pub column_max_values: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// Number of non-null values in each column.
    #[prost(int64, repeated, packed = "false", tag = "11")]
    pub column_non_null_value_counts: ::prost::alloc::vec::Vec<i64>,
    /// Total number of rows in all chunks whose meta contains columnar statistics.
    #[prost(int64, optional, tag = "12")]
    pub chunk_row_count: ::core::option::Option<i64>,
    /// Total number of rows in legacy chunks whose meta misses columnar statistics.
    #[prost(int64, optional, tag = "13")]
    pub legacy_chunk_row_count: ::core::option::Option<i64>,
    /// Per-column hyperloglog digest to approximate number of unique values
    #[prost(message, repeated, tag = "14")]
    pub column_hyperloglog_digests: ::prost::alloc::vec::Vec<
        super::super::super::n_proto::THyperLogLogDigest,
    >,
    #[prost(int64, optional, tag = "15")]
    pub read_size_estimation: ::core::option::Option<i64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspGetColumnarStatistics {
    #[prost(message, repeated, tag = "1")]
    pub statistics: ::prost::alloc::vec::Vec<TColumnarStatistics>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqDisableChunkLocations {
    #[prost(string, required, tag = "1")]
    pub node_address: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "2")]
    pub location_uuids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspDisableChunkLocations {
    #[prost(message, repeated, tag = "1")]
    pub location_uuids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqDestroyChunkLocations {
    #[prost(string, required, tag = "1")]
    pub node_address: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "2")]
    pub location_uuids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub recover_unlinked_disks: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspDestroyChunkLocations {
    #[prost(message, repeated, tag = "1")]
    pub location_uuids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqResurrectChunkLocations {
    #[prost(string, required, tag = "1")]
    pub node_address: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "2")]
    pub location_uuids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspResurrectChunkLocations {
    #[prost(message, repeated, tag = "1")]
    pub location_uuids: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqRequestRestart {
    #[prost(string, required, tag = "1")]
    pub node_address: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspRequestRestart {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqPartitionTables {
    /// RichYPath
    #[prost(bytes = "vec", repeated, tag = "1")]
    pub paths: ::prost::alloc::vec::Vec<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "2")]
    pub fetch_chunk_spec_config: ::core::option::Option<TFetchChunkSpecConfig>,
    #[prost(message, optional, tag = "3")]
    pub fetcher_config: ::core::option::Option<TFetcherConfig>,
    #[prost(message, optional, tag = "4")]
    pub chunk_slice_fetcher_config: ::core::option::Option<
        t_req_partition_tables::TChunkSliceFetcherConfig,
    >,
    #[prost(enumeration = "EPartitionTablesMode", required, tag = "5")]
    pub partition_mode: i32,
    #[prost(int64, optional, tag = "6")]
    pub data_weight_per_partition: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "14")]
    pub compressed_data_size_per_partition: ::core::option::Option<i64>,
    #[prost(int32, optional, tag = "7")]
    pub max_partition_count: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "8")]
    pub enable_key_guarantee: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "9")]
    pub adjust_data_weight_per_partition: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "10")]
    pub enable_cookies: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "15")]
    pub fetch_cookie_node_descriptors: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "13")]
    pub omit_inaccessible_rows: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
}
/// Nested message and enum types in `TReqPartitionTables`.
pub mod t_req_partition_tables {
    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TChunkSliceFetcherConfig {
        #[prost(int32, optional, tag = "1")]
        pub max_slices_per_fetch: ::core::option::Option<i32>,
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TMultiTablePartition {
    /// RichYPath
    #[prost(bytes = "vec", repeated, tag = "1")]
    pub table_ranges: ::prost::alloc::vec::Vec<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "2")]
    pub aggregate_statistics: ::core::option::Option<
        t_multi_table_partition::TStatistics,
    >,
    #[prost(bytes = "vec", optional, tag = "3")]
    pub cookie: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
/// Nested message and enum types in `TMultiTablePartition`.
pub mod t_multi_table_partition {
    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TStatistics {
        #[prost(int64, optional, tag = "1")]
        pub chunk_count: ::core::option::Option<i64>,
        #[prost(int64, optional, tag = "2")]
        pub data_weight: ::core::option::Option<i64>,
        #[prost(int64, optional, tag = "3")]
        pub row_count: ::core::option::Option<i64>,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspPartitionTables {
    #[prost(message, repeated, tag = "1")]
    pub partitions: ::prost::alloc::vec::Vec<TMultiTablePartition>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqReadTablePartition {
    #[prost(bytes = "vec", optional, tag = "1")]
    pub cookie: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, optional, tag = "2", default = "false")]
    pub unordered: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub omit_inaccessible_columns: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "5", default = "false")]
    pub enable_table_index: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "6", default = "false")]
    pub enable_row_index: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "7", default = "false")]
    pub enable_range_index: ::core::option::Option<bool>,
    /// YSON-serialized TTableReaderConfig
    #[prost(bytes = "vec", optional, tag = "4")]
    pub config: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(enumeration = "ERowsetFormat", optional, tag = "8", default = "RfYtWire")]
    pub desired_rowset_format: ::core::option::Option<i32>,
    #[prost(enumeration = "ERowsetFormat", optional, tag = "10", default = "RfYtWire")]
    pub arrow_fallback_rowset_format: ::core::option::Option<i32>,
    /// YSON-serialized TFormat
    #[prost(bytes = "vec", optional, tag = "9")]
    pub format: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspReadTablePartition {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspReadTablePartitionMeta {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqBalanceTabletCells {
    #[prost(string, required, tag = "1")]
    pub bundle: ::prost::alloc::string::String,
    #[prost(string, repeated, tag = "2")]
    pub movable_tables: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(bool, required, tag = "3", default = "false")]
    pub keep_actions: bool,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspBalanceTabletCells {
    #[prost(message, repeated, tag = "1")]
    pub tablet_actions: ::prost::alloc::vec::Vec<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetFileFromCache {
    #[prost(string, required, tag = "1")]
    pub md5: ::prost::alloc::string::String,
    /// YPath
    #[prost(bytes = "vec", required, tag = "2")]
    pub cache_path: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "102")]
    pub master_read_options: ::core::option::Option<TMasterReadOptions>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetFileFromCache {
    #[prost(message, required, tag = "1")]
    pub result: TGetFileFromCacheResult,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqPutFileToCache {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(string, required, tag = "2")]
    pub md5: ::prost::alloc::string::String,
    /// YPath
    #[prost(bytes = "vec", required, tag = "3")]
    pub cache_path: ::prost::alloc::vec::Vec<u8>,
    #[prost(bool, optional, tag = "4", default = "false")]
    pub preserve_expiration_timeout: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "102")]
    pub master_read_options: ::core::option::Option<TMasterReadOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspPutFileToCache {
    #[prost(message, required, tag = "1")]
    pub result: TPutFileToCacheResult,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqStartOperation {
    #[prost(enumeration = "EOperationType", required, tag = "1")]
    pub r#type: i32,
    /// YSON
    #[prost(bytes = "vec", required, tag = "2")]
    pub spec: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspStartOperation {
    #[prost(message, required, tag = "1")]
    pub operation_id: super::super::super::n_proto::TGuid,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqAbortOperation {
    #[prost(string, optional, tag = "2")]
    pub abort_message: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(oneof = "t_req_abort_operation::OperationIdOrAlias", tags = "1, 3")]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_abort_operation::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqAbortOperation`.
pub mod t_req_abort_operation {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "3")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspAbortOperation {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqSuspendOperation {
    #[prost(bool, optional, tag = "2", default = "false")]
    pub abort_running_jobs: ::core::option::Option<bool>,
    #[prost(string, optional, tag = "4")]
    pub reason: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(oneof = "t_req_suspend_operation::OperationIdOrAlias", tags = "1, 3")]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_suspend_operation::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqSuspendOperation`.
pub mod t_req_suspend_operation {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "3")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspSuspendOperation {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqResumeOperation {
    #[prost(oneof = "t_req_resume_operation::OperationIdOrAlias", tags = "1, 2")]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_resume_operation::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqResumeOperation`.
pub mod t_req_resume_operation {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "2")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspResumeOperation {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqCompleteOperation {
    #[prost(oneof = "t_req_complete_operation::OperationIdOrAlias", tags = "1, 2")]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_complete_operation::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqCompleteOperation`.
pub mod t_req_complete_operation {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "2")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspCompleteOperation {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqUpdateOperationParameters {
    /// YSON
    #[prost(bytes = "vec", required, tag = "2")]
    pub parameters: ::prost::alloc::vec::Vec<u8>,
    #[prost(
        oneof = "t_req_update_operation_parameters::OperationIdOrAlias",
        tags = "1, 3"
    )]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_update_operation_parameters::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqUpdateOperationParameters`.
pub mod t_req_update_operation_parameters {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "3")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspUpdateOperationParameters {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqPatchOperationSpec {
    #[prost(message, repeated, tag = "3")]
    pub patches: ::prost::alloc::vec::Vec<
        super::super::super::n_scheduler::n_proto::TSpecPatch,
    >,
    #[prost(oneof = "t_req_patch_operation_spec::OperationIdOrAlias", tags = "1, 2")]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_patch_operation_spec::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqPatchOperationSpec`.
pub mod t_req_patch_operation_spec {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "2")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspPatchOperationSpec {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqListOperationEvents {
    #[prost(enumeration = "EOperationEventType", optional, tag = "3")]
    pub event_type: ::core::option::Option<i32>,
    #[prost(uint64, optional, tag = "4", default = "1000")]
    pub limit: ::core::option::Option<u64>,
    #[prost(oneof = "t_req_list_operation_events::OperationIdOrAlias", tags = "1, 2")]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_list_operation_events::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqListOperationEvents`.
pub mod t_req_list_operation_events {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "2")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspListOperationEvents {
    #[prost(message, repeated, tag = "1")]
    pub events: ::prost::alloc::vec::Vec<TOperationEvent>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetOperation {
    /// COMPAT(max42): see comment around TLegacyAttributeKeys with the only
    /// difference that attributes were serialized as repeated string historically.
    #[prost(string, repeated, tag = "2")]
    pub legacy_attributes: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeFilter,
    >,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub include_runtime: ::core::option::Option<bool>,
    /// TDuration
    #[prost(int64, optional, tag = "5")]
    pub maximum_cypress_progress_age: ::core::option::Option<i64>,
    #[prost(message, optional, tag = "102")]
    pub master_read_options: ::core::option::Option<TMasterReadOptions>,
    #[prost(oneof = "t_req_get_operation::OperationIdOrAlias", tags = "1, 4")]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_get_operation::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqGetOperation`.
pub mod t_req_get_operation {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "4")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetOperation {
    /// YSON
    #[prost(bytes = "vec", required, tag = "1")]
    pub meta: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqListOperations {
    /// TInstant
    #[prost(uint64, optional, tag = "1")]
    pub from_time: ::core::option::Option<u64>,
    /// TInstant
    #[prost(uint64, optional, tag = "2")]
    pub to_time: ::core::option::Option<u64>,
    /// TInstant
    #[prost(uint64, optional, tag = "3")]
    pub cursor_time: ::core::option::Option<u64>,
    #[prost(
        enumeration = "EOperationSortDirection",
        optional,
        tag = "4",
        default = "OsdPast"
    )]
    pub cursor_direction: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "5")]
    pub user_filter: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "EOperationState", optional, tag = "7")]
    pub state_filter: ::core::option::Option<i32>,
    #[prost(enumeration = "EOperationType", optional, tag = "8")]
    pub type_filter: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "9")]
    pub substr_filter: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "10")]
    pub pool: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "11")]
    pub with_failed_jobs: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "12", default = "false")]
    pub include_archive: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "13", default = "true")]
    pub include_counters: ::core::option::Option<bool>,
    #[prost(uint64, optional, tag = "14", default = "100")]
    pub limit: ::core::option::Option<u64>,
    /// COMPAT(max42): see comment around TLegacyAttributeKeys.
    #[prost(message, optional, tag = "15")]
    pub legacy_attributes: ::core::option::Option<TLegacyAttributeKeys>,
    #[prost(message, optional, tag = "20")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeFilter,
    >,
    #[prost(bool, optional, tag = "16", default = "false")]
    pub enable_ui_mode: ::core::option::Option<bool>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "17")]
    pub access_filter: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// TDuration, 3 seconds by default
    #[prost(uint64, optional, tag = "18", default = "3000000")]
    pub archive_fetching_timeout: ::core::option::Option<u64>,
    #[prost(string, optional, tag = "19")]
    pub pool_tree: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "102")]
    pub master_read_options: ::core::option::Option<TMasterReadOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspListOperations {
    #[prost(message, required, tag = "1")]
    pub result: TListOperationsResult,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqListJobs {
    #[prost(enumeration = "EJobType", optional, tag = "2")]
    pub r#type: ::core::option::Option<i32>,
    #[prost(enumeration = "EJobState", optional, tag = "3")]
    pub state: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "4")]
    pub address: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "5")]
    pub with_stderr: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "6")]
    pub with_fail_context: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "7")]
    pub with_spec: ::core::option::Option<bool>,
    #[prost(enumeration = "EJobSortField", optional, tag = "8", default = "JsfNone")]
    pub sort_field: ::core::option::Option<i32>,
    #[prost(
        enumeration = "EJobSortDirection",
        optional,
        tag = "9",
        default = "JsdAscending"
    )]
    pub sort_order: ::core::option::Option<i32>,
    #[prost(int64, optional, tag = "10", default = "1000")]
    pub limit: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "11", default = "0")]
    pub offset: ::core::option::Option<i64>,
    #[prost(bool, optional, tag = "12", default = "false")]
    pub include_cypress: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "13", default = "false")]
    pub include_controller_agent: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "14", default = "false")]
    pub include_archive: ::core::option::Option<bool>,
    #[prost(enumeration = "EDataSource", optional, tag = "15", default = "DsAuto")]
    pub data_source: ::core::option::Option<i32>,
    #[prost(uint64, optional, tag = "16")]
    pub running_jobs_lookbehind_period: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "17")]
    pub job_competition_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(bool, optional, tag = "18")]
    pub with_competitors: ::core::option::Option<bool>,
    #[prost(string, optional, tag = "19")]
    pub task_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "21")]
    pub with_monitoring_descriptor: ::core::option::Option<bool>,
    #[prost(string, optional, tag = "25")]
    pub operation_incarnation: ::core::option::Option<::prost::alloc::string::String>,
    /// TInstant
    #[prost(uint64, optional, tag = "22")]
    pub from_time: ::core::option::Option<u64>,
    /// TInstant
    #[prost(uint64, optional, tag = "23")]
    pub to_time: ::core::option::Option<u64>,
    #[prost(string, optional, tag = "24")]
    pub continuation_token: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "26")]
    pub with_interruption_info: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "27")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeFilter,
    >,
    #[prost(string, optional, tag = "28")]
    pub monitoring_descriptor: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "29")]
    pub collective_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(message, optional, tag = "102")]
    pub master_read_options: ::core::option::Option<TMasterReadOptions>,
    #[prost(oneof = "t_req_list_jobs::OperationIdOrAlias", tags = "1, 20")]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_list_jobs::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqListJobs`.
pub mod t_req_list_jobs {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "20")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspListJobs {
    #[prost(message, required, tag = "1")]
    pub result: TListJobsResult,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqListJobTraces {
    #[prost(message, required, tag = "3")]
    pub job_id: super::super::super::n_proto::TGuid,
    #[prost(bool, optional, tag = "4")]
    pub per_process: ::core::option::Option<bool>,
    #[prost(int64, optional, tag = "5", default = "1000")]
    pub limit: ::core::option::Option<i64>,
    #[prost(oneof = "t_req_list_job_traces::OperationIdOrAlias", tags = "1, 2")]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_list_job_traces::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqListJobTraces`.
pub mod t_req_list_job_traces {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "2")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspListJobTraces {
    #[prost(message, repeated, tag = "1")]
    pub traces: ::prost::alloc::vec::Vec<TJobTrace>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqCheckOperationPermission {
    #[prost(string, required, tag = "1")]
    pub user: ::prost::alloc::string::String,
    #[prost(int32, required, tag = "4")]
    pub permission: i32,
    #[prost(
        oneof = "t_req_check_operation_permission::OperationIdOrAlias",
        tags = "2, 3"
    )]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_check_operation_permission::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqCheckOperationPermission`.
pub mod t_req_check_operation_permission {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "2")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "3")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TCheckOperationPermissionResult {
    #[prost(enumeration = "ESecurityAction", required, tag = "1")]
    pub action: i32,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspCheckOperationPermission {
    #[prost(message, required, tag = "1")]
    pub result: TCheckOperationPermissionResult,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetJob {
    #[prost(message, required, tag = "2")]
    pub job_id: super::super::super::n_proto::TGuid,
    /// COMPAT(max42): see comment around TLegacyAttributeKeys.
    #[prost(message, optional, tag = "3")]
    pub legacy_attributes: ::core::option::Option<TLegacyAttributeKeys>,
    #[prost(message, optional, tag = "5")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeFilter,
    >,
    #[prost(oneof = "t_req_get_job::OperationIdOrAlias", tags = "1, 4")]
    pub operation_id_or_alias: ::core::option::Option<t_req_get_job::OperationIdOrAlias>,
}
/// Nested message and enum types in `TReqGetJob`.
pub mod t_req_get_job {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "4")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetJob {
    /// YSON
    #[prost(bytes = "vec", required, tag = "1")]
    pub info: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetJobInputPaths {
    #[prost(message, required, tag = "1")]
    pub job_id: super::super::super::n_proto::TGuid,
    #[prost(enumeration = "EJobSpecSource", optional, tag = "2", default = "JssAuto")]
    pub job_spec_source: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetJobInputPaths {
    /// YSON
    #[prost(bytes = "vec", required, tag = "1")]
    pub paths: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetJobSpec {
    #[prost(message, required, tag = "1")]
    pub job_id: super::super::super::n_proto::TGuid,
    #[prost(bool, optional, tag = "2", default = "true")]
    pub omit_node_directory: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub omit_input_table_specs: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "4", default = "false")]
    pub omit_output_table_specs: ::core::option::Option<bool>,
    #[prost(enumeration = "EJobSpecSource", optional, tag = "5", default = "JssAuto")]
    pub job_spec_source: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetJobSpec {
    /// YSON
    #[prost(bytes = "vec", required, tag = "1")]
    pub job_spec: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetJobStderr {
    #[prost(message, required, tag = "2")]
    pub job_id: super::super::super::n_proto::TGuid,
    #[prost(int64, optional, tag = "4")]
    pub limit: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "5")]
    pub offset: ::core::option::Option<i64>,
    #[prost(enumeration = "EJobStderrType", optional, tag = "6")]
    pub r#type: ::core::option::Option<i32>,
    #[prost(oneof = "t_req_get_job_stderr::OperationIdOrAlias", tags = "1, 3")]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_get_job_stderr::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqGetJobStderr`.
pub mod t_req_get_job_stderr {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "3")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetJobStderr {
    #[prost(int64, optional, tag = "1")]
    pub end_offset: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "2")]
    pub total_size: ::core::option::Option<i64>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetJobFailContext {
    #[prost(message, required, tag = "2")]
    pub job_id: super::super::super::n_proto::TGuid,
    #[prost(oneof = "t_req_get_job_fail_context::OperationIdOrAlias", tags = "1, 3")]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_get_job_fail_context::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqGetJobFailContext`.
pub mod t_req_get_job_fail_context {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "3")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetJobFailContext {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqDumpJobContext {
    #[prost(message, required, tag = "1")]
    pub job_id: super::super::super::n_proto::TGuid,
    /// YPath
    #[prost(bytes = "vec", required, tag = "2")]
    pub path: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspDumpJobContext {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqAbandonJob {
    #[prost(message, required, tag = "1")]
    pub job_id: super::super::super::n_proto::TGuid,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspAbandonJob {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqPollJobShell {
    #[prost(message, required, tag = "1")]
    pub job_id: super::super::super::n_proto::TGuid,
    /// YSON
    #[prost(bytes = "vec", required, tag = "2")]
    pub parameters: ::prost::alloc::vec::Vec<u8>,
    #[prost(string, optional, tag = "3")]
    pub shell_name: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspPollJobShell {
    /// YSON
    #[prost(bytes = "vec", required, tag = "1")]
    pub result: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqRunJobShellCommand {
    #[prost(message, required, tag = "1")]
    pub job_id: super::super::super::n_proto::TGuid,
    #[prost(string, required, tag = "2")]
    pub command: ::prost::alloc::string::String,
    #[prost(string, optional, tag = "3")]
    pub shell_name: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspRunJobShellCommand {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqAbortJob {
    #[prost(message, required, tag = "1")]
    pub job_id: super::super::super::n_proto::TGuid,
    #[prost(int64, optional, tag = "2")]
    pub interrupt_timeout: ::core::option::Option<i64>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspAbortJob {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqDumpJobProxyLog {
    #[prost(message, required, tag = "1")]
    pub job_id: super::super::super::n_proto::TGuid,
    #[prost(message, required, tag = "2")]
    pub operation_id: super::super::super::n_proto::TGuid,
    /// YPath
    #[prost(bytes = "vec", required, tag = "3")]
    pub path: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspDumpJobProxyLog {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqReadFile {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int64, optional, tag = "2")]
    pub offset: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "3")]
    pub length: ::core::option::Option<i64>,
    /// YSON-serialized TFileReaderConfig
    #[prost(bytes = "vec", optional, tag = "4")]
    pub config: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "104")]
    pub suppressable_access_tracking_options: ::core::option::Option<
        TSuppressableAccessTrackingOptions,
    >,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReadFileMeta {
    #[prost(uint64, required, tag = "1")]
    pub revision: u64,
    /// COMPAT(shakurov): optional for old proxy compatibility.
    #[prost(message, optional, tag = "2")]
    pub id: ::core::option::Option<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspReadFile {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqWriteFile {
    /// RichYPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(bool, optional, tag = "2", default = "false")]
    pub compute_md5: ::core::option::Option<bool>,
    /// YSON-serialized TFileWriterConfig
    #[prost(bytes = "vec", optional, tag = "3")]
    pub config: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspWriteFile {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqReadJournal {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int64, optional, tag = "2")]
    pub first_row_index: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "3")]
    pub row_count: ::core::option::Option<i64>,
    /// YSON-serialized TJournalReaderConfig
    #[prost(bytes = "vec", optional, tag = "4")]
    pub config: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "104")]
    pub suppressable_access_tracking_options: ::core::option::Option<
        TSuppressableAccessTrackingOptions,
    >,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspReadJournal {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqWriteJournal {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    /// YSON-serialized TJournalWriterConfig
    #[prost(bytes = "vec", optional, tag = "2")]
    pub config: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, optional, tag = "3", default = "true")]
    pub enable_multiplexing: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "4", default = "false")]
    pub enable_chunk_preallocation: ::core::option::Option<bool>,
    #[prost(int64, optional, tag = "5", default = "32768")]
    pub replica_lag_limit: ::core::option::Option<i64>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspWriteJournal {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqTruncateJournal {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int64, required, tag = "2")]
    pub row_count: i64,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspTruncateJournal {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqReadTable {
    /// RichYPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(bool, optional, tag = "2", default = "false")]
    pub unordered: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "3", default = "false")]
    pub omit_inaccessible_columns: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "12", default = "false")]
    pub omit_inaccessible_rows: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "5", default = "false")]
    pub enable_table_index: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "6", default = "false")]
    pub enable_row_index: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "7", default = "false")]
    pub enable_range_index: ::core::option::Option<bool>,
    /// YSON-serialized TTableReaderConfig
    #[prost(bytes = "vec", optional, tag = "4")]
    pub config: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(enumeration = "ERowsetFormat", optional, tag = "8", default = "RfYtWire")]
    pub desired_rowset_format: ::core::option::Option<i32>,
    #[prost(enumeration = "ERowsetFormat", optional, tag = "10", default = "RfYtWire")]
    pub arrow_fallback_rowset_format: ::core::option::Option<i32>,
    /// YSON-serialized TFormat
    #[prost(bytes = "vec", optional, tag = "9")]
    pub format: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, optional, tag = "11", default = "true")]
    pub enable_any_unpacking: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub suppressable_access_tracking_options: ::core::option::Option<
        TSuppressableAccessTrackingOptions,
    >,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspReadTableMeta {
    #[prost(int64, required, tag = "1")]
    pub start_row_index: i64,
    #[prost(string, repeated, tag = "3")]
    pub omitted_inaccessible_columns: ::prost::alloc::vec::Vec<
        ::prost::alloc::string::String,
    >,
    #[prost(message, required, tag = "5")]
    pub schema: TTableSchema,
    #[prost(message, required, tag = "4")]
    pub statistics: TRowsetStatistics,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspReadTable {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqWriteTable {
    /// RichYPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    /// YSON-serialized TTableWriterConfig
    #[prost(bytes = "vec", optional, tag = "2")]
    pub config: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON-serialized TFormat
    #[prost(bytes = "vec", optional, tag = "3")]
    pub format: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TWriteTableMeta {
    #[prost(message, required, tag = "1")]
    pub schema: TTableSchema,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspWriteTable {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetJobTrace {
    #[prost(message, required, tag = "3")]
    pub job_id: super::super::super::n_proto::TGuid,
    #[prost(message, optional, tag = "4")]
    pub trace_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(int64, optional, tag = "5")]
    pub from_time: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "6")]
    pub to_time: ::core::option::Option<i64>,
    #[prost(oneof = "t_req_get_job_trace::OperationIdOrAlias", tags = "1, 2")]
    pub operation_id_or_alias: ::core::option::Option<
        t_req_get_job_trace::OperationIdOrAlias,
    >,
}
/// Nested message and enum types in `TReqGetJobTrace`.
pub mod t_req_get_job_trace {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
    pub enum OperationIdOrAlias {
        #[prost(message, tag = "1")]
        OperationId(super::super::super::super::n_proto::TGuid),
        #[prost(string, tag = "2")]
        OperationAlias(::prost::alloc::string::String),
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetJobTrace {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetJobInput {
    #[prost(message, required, tag = "1")]
    pub job_id: super::super::super::n_proto::TGuid,
    #[prost(enumeration = "EJobSpecSource", optional, tag = "2", default = "JssAuto")]
    pub job_spec_source: ::core::option::Option<i32>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetJobInput {}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetCurrentUser {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetCurrentUser {
    #[prost(string, required, tag = "1")]
    pub user: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqAddMember {
    #[prost(string, required, tag = "1")]
    pub group: ::prost::alloc::string::String,
    #[prost(string, required, tag = "2")]
    pub member: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
    #[prost(message, optional, tag = "104")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspAddMember {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqRemoveMember {
    #[prost(string, required, tag = "1")]
    pub group: ::prost::alloc::string::String,
    #[prost(string, required, tag = "2")]
    pub member: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
    #[prost(message, optional, tag = "104")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspRemoveMember {}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqCheckPermission {
    #[prost(string, required, tag = "1")]
    pub user: ::prost::alloc::string::String,
    /// YPath
    #[prost(bytes = "vec", required, tag = "2")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    /// bit enum consisting of 7 bits
    #[prost(int32, required, tag = "3")]
    pub permission: i32,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "102")]
    pub master_read_options: ::core::option::Option<TMasterReadOptions>,
    #[prost(message, optional, tag = "4")]
    pub columns: ::core::option::Option<t_req_check_permission::TColumns>,
    #[prost(bool, optional, tag = "5")]
    pub vital: ::core::option::Option<bool>,
}
/// Nested message and enum types in `TReqCheckPermission`.
pub mod t_req_check_permission {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TColumns {
        #[prost(string, repeated, tag = "1")]
        pub items: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspCheckPermission {
    #[prost(message, required, tag = "1")]
    pub result: TCheckPermissionResult,
    #[prost(message, optional, tag = "2")]
    pub columns: ::core::option::Option<t_rsp_check_permission::TColumns>,
}
/// Nested message and enum types in `TRspCheckPermission`.
pub mod t_rsp_check_permission {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TColumns {
        #[prost(message, repeated, tag = "1")]
        pub items: ::prost::alloc::vec::Vec<super::TCheckPermissionResult>,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqCheckPermissionByAcl {
    #[prost(string, optional, tag = "1")]
    pub user: ::core::option::Option<::prost::alloc::string::String>,
    /// bit enum consisting of 7 bits
    #[prost(int32, required, tag = "2")]
    pub permission: i32,
    #[prost(string, required, tag = "3")]
    pub acl: ::prost::alloc::string::String,
    #[prost(bool, optional, tag = "4", default = "false")]
    pub ignore_missing_subjects: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "5", default = "false")]
    pub ignore_pending_removal_subjects: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "101")]
    pub prerequisite_options: ::core::option::Option<TPrerequisiteOptions>,
    #[prost(message, optional, tag = "102")]
    pub master_read_options: ::core::option::Option<TMasterReadOptions>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspCheckPermissionByAcl {
    #[prost(message, required, tag = "1")]
    pub result: TCheckPermissionByAclResult,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqTransferAccountResources {
    #[prost(string, required, tag = "1")]
    pub src_account: ::prost::alloc::string::String,
    #[prost(string, required, tag = "2")]
    pub dst_account: ::prost::alloc::string::String,
    /// YSON
    #[prost(bytes = "vec", required, tag = "3")]
    pub resource_delta: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspTransferAccountResources {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqTransferPoolResources {
    #[prost(string, required, tag = "1")]
    pub src_pool: ::prost::alloc::string::String,
    #[prost(string, required, tag = "2")]
    pub dst_pool: ::prost::alloc::string::String,
    #[prost(string, required, tag = "3")]
    pub pool_tree: ::prost::alloc::string::String,
    /// YSON
    #[prost(bytes = "vec", required, tag = "4")]
    pub resource_delta: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspTransferPoolResources {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqTransferBundleResources {
    #[prost(string, required, tag = "1")]
    pub src_bundle: ::prost::alloc::string::String,
    #[prost(string, required, tag = "2")]
    pub dst_bundle: ::prost::alloc::string::String,
    /// YSON
    #[prost(bytes = "vec", required, tag = "3")]
    pub resource_delta: ::prost::alloc::vec::Vec<u8>,
    #[prost(message, optional, tag = "103")]
    pub mutating_options: ::core::option::Option<TMutatingOptions>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspTransferBundleResources {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqCheckClusterLiveness {
    #[prost(bool, required, tag = "1")]
    pub check_cypress_root: bool,
    #[prost(bool, optional, tag = "2")]
    pub check_secondary_master_cells: ::core::option::Option<bool>,
    #[prost(string, optional, tag = "3")]
    pub check_tablet_cell_bundle: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspCheckClusterLiveness {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetPipelineSpec {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub pipeline_path: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetPipelineSpec {
    #[prost(int64, required, tag = "1")]
    pub version: i64,
    /// YSON
    #[prost(bytes = "vec", required, tag = "2")]
    pub spec: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqSetPipelineSpec {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub pipeline_path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int64, optional, tag = "2")]
    pub expected_version: ::core::option::Option<i64>,
    /// YSON
    #[prost(bytes = "vec", required, tag = "3")]
    pub spec: ::prost::alloc::vec::Vec<u8>,
    /// Update spec even if pipeline is not stopped, just paused.
    #[prost(bool, optional, tag = "4")]
    pub force: ::core::option::Option<bool>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspSetPipelineSpec {
    #[prost(int64, required, tag = "1")]
    pub version: i64,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetPipelineDynamicSpec {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub pipeline_path: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetPipelineDynamicSpec {
    #[prost(int64, required, tag = "1")]
    pub version: i64,
    /// YSON
    #[prost(bytes = "vec", required, tag = "2")]
    pub spec: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqSetPipelineDynamicSpec {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub pipeline_path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int64, optional, tag = "2")]
    pub expected_version: ::core::option::Option<i64>,
    /// YSON
    #[prost(bytes = "vec", required, tag = "3")]
    pub spec: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspSetPipelineDynamicSpec {
    #[prost(int64, required, tag = "1")]
    pub version: i64,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqStartPipeline {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub pipeline_path: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspStartPipeline {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqPausePipeline {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub pipeline_path: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspPausePipeline {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqStopPipeline {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub pipeline_path: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspStopPipeline {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetPipelineState {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub pipeline_path: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetPipelineState {
    /// TODO(babenko): provide native proto enum
    ///
    /// EPipelineState
    #[prost(int32, required, tag = "1")]
    pub state: i32,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetFlowView {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub pipeline_path: ::prost::alloc::vec::Vec<u8>,
    /// YPath
    #[prost(bytes = "vec", optional, tag = "2")]
    pub view_path: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, optional, tag = "3", default = "true")]
    pub cache: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetFlowView {
    /// YSON
    #[prost(bytes = "vec", required, tag = "1")]
    pub flow_view_part: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqFlowExecute {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub pipeline_path: ::prost::alloc::vec::Vec<u8>,
    #[prost(string, optional, tag = "2")]
    pub command: ::core::option::Option<::prost::alloc::string::String>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "3")]
    pub argument: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspFlowExecute {
    /// YSON
    #[prost(bytes = "vec", optional, tag = "1")]
    pub result: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TOperation {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(enumeration = "EOperationType", optional, tag = "2")]
    pub r#type: ::core::option::Option<i32>,
    #[prost(enumeration = "EOperationState", optional, tag = "3")]
    pub state: ::core::option::Option<i32>,
    /// TInstant
    #[prost(uint64, optional, tag = "4")]
    pub start_time: ::core::option::Option<u64>,
    /// TInstant
    #[prost(uint64, optional, tag = "5")]
    pub finish_time: ::core::option::Option<u64>,
    #[prost(string, optional, tag = "6")]
    pub authenticated_user: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "8")]
    pub pools: ::core::option::Option<t_operation::TStrings>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "9")]
    pub brief_spec: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "10")]
    pub spec: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "27")]
    pub provided_spec: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "11")]
    pub full_spec: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "12")]
    pub unrecognized_spec: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "14")]
    pub brief_progress: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "15")]
    pub progress: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "16")]
    pub runtime_parameters: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, optional, tag = "17")]
    pub suspended: ::core::option::Option<bool>,
    #[prost(string, optional, tag = "29")]
    pub suspend_reason: ::core::option::Option<::prost::alloc::string::String>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "18")]
    pub events: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "19")]
    pub result: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "28")]
    pub scheduling_attributes_per_pool_tree: ::core::option::Option<
        ::prost::alloc::vec::Vec<u8>,
    >,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "20")]
    pub slot_index_per_pool_tree: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "21")]
    pub task_names: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "22")]
    pub experiment_assignments: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "23")]
    pub experiment_assignment_names: ::core::option::Option<
        ::prost::alloc::vec::Vec<u8>,
    >,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "24")]
    pub alerts: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "25")]
    pub controller_features: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "26")]
    pub alert_events: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "50")]
    pub other_attributes: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
/// Nested message and enum types in `TOperation`.
pub mod t_operation {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TStrings {
        #[prost(string, repeated, tag = "1")]
        pub data: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TListOperationsResult {
    #[prost(message, repeated, tag = "1")]
    pub operations: ::prost::alloc::vec::Vec<TOperation>,
    #[prost(message, optional, tag = "2")]
    pub pool_counts: ::core::option::Option<t_list_operations_result::TPoolCounts>,
    #[prost(message, optional, tag = "3")]
    pub user_counts: ::core::option::Option<t_list_operations_result::TUserCounts>,
    #[prost(message, optional, tag = "4")]
    pub state_counts: ::core::option::Option<
        t_list_operations_result::TOperationStateCounts,
    >,
    #[prost(message, optional, tag = "5")]
    pub type_counts: ::core::option::Option<
        t_list_operations_result::TOperationTypeCounts,
    >,
    #[prost(int64, optional, tag = "6")]
    pub failed_jobs_count: ::core::option::Option<i64>,
    #[prost(bool, optional, tag = "7", default = "false")]
    pub incomplete: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "8")]
    pub pool_tree_counts: ::core::option::Option<
        t_list_operations_result::TPoolTreeCounts,
    >,
}
/// Nested message and enum types in `TListOperationsResult`.
pub mod t_list_operations_result {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TPoolCounts {
        #[prost(message, repeated, tag = "1")]
        pub entries: ::prost::alloc::vec::Vec<t_pool_counts::TPoolCount>,
    }
    /// Nested message and enum types in `TPoolCounts`.
    pub mod t_pool_counts {
        #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
        pub struct TPoolCount {
            #[prost(string, required, tag = "1")]
            pub pool: ::prost::alloc::string::String,
            #[prost(int64, required, tag = "2")]
            pub count: i64,
        }
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TUserCounts {
        #[prost(message, repeated, tag = "1")]
        pub entries: ::prost::alloc::vec::Vec<t_user_counts::TUserCount>,
    }
    /// Nested message and enum types in `TUserCounts`.
    pub mod t_user_counts {
        #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
        pub struct TUserCount {
            #[prost(string, required, tag = "1")]
            pub user: ::prost::alloc::string::String,
            #[prost(int64, required, tag = "2")]
            pub count: i64,
        }
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TOperationStateCounts {
        #[prost(message, repeated, tag = "1")]
        pub entries: ::prost::alloc::vec::Vec<
            t_operation_state_counts::TOperationStateCount,
        >,
    }
    /// Nested message and enum types in `TOperationStateCounts`.
    pub mod t_operation_state_counts {
        #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
        pub struct TOperationStateCount {
            #[prost(enumeration = "super::super::EOperationState", required, tag = "1")]
            pub state: i32,
            #[prost(int64, required, tag = "2")]
            pub count: i64,
        }
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TOperationTypeCounts {
        #[prost(message, repeated, tag = "1")]
        pub entries: ::prost::alloc::vec::Vec<
            t_operation_type_counts::TOperationTypeCount,
        >,
    }
    /// Nested message and enum types in `TOperationTypeCounts`.
    pub mod t_operation_type_counts {
        #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
        pub struct TOperationTypeCount {
            #[prost(enumeration = "super::super::EOperationType", required, tag = "1")]
            pub r#type: i32,
            #[prost(int64, required, tag = "2")]
            pub count: i64,
        }
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TPoolTreeCounts {
        #[prost(map = "string, int64", tag = "1")]
        pub entries: ::std::collections::HashMap<::prost::alloc::string::String, i64>,
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TOperationEvent {
    /// TInstant
    #[prost(uint64, optional, tag = "1")]
    pub timestamp: ::core::option::Option<u64>,
    #[prost(enumeration = "EOperationEventType", optional, tag = "2")]
    pub event_type: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "3")]
    pub incarnation: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "EIncarnationSwitchReason", optional, tag = "4")]
    pub incarnation_switch_reason: ::core::option::Option<i32>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "5")]
    pub incarnation_switch_info: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TJobTrace {
    #[prost(message, optional, tag = "1")]
    pub trace_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(enumeration = "EJobTraceProgress", optional, tag = "2")]
    pub progress: ::core::option::Option<i32>,
    #[prost(enumeration = "EJobTraceHealth", optional, tag = "3")]
    pub health: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "4")]
    pub process_trace_metas: ::core::option::Option<t_job_trace::TPerProcessTraceMeta>,
}
/// Nested message and enum types in `TJobTrace`.
pub mod t_job_trace {
    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TProcessTraceMeta {
        #[prost(enumeration = "super::EJobTraceState", optional, tag = "1")]
        pub state: ::core::option::Option<i32>,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TPerProcessTraceMeta {
        #[prost(map = "int32, message", tag = "1")]
        pub pids: ::std::collections::HashMap<i32, TProcessTraceMeta>,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TJob {
    #[prost(message, optional, tag = "1")]
    pub id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(enumeration = "EJobType", optional, tag = "2")]
    pub r#type: ::core::option::Option<i32>,
    #[prost(enumeration = "EJobState", optional, tag = "3")]
    pub state: ::core::option::Option<i32>,
    /// TInstant
    #[prost(uint64, optional, tag = "4")]
    pub start_time: ::core::option::Option<u64>,
    /// TInstant
    #[prost(uint64, optional, tag = "5")]
    pub finish_time: ::core::option::Option<u64>,
    #[prost(string, optional, tag = "6")]
    pub address: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(double, optional, tag = "7")]
    pub progress: ::core::option::Option<f64>,
    #[prost(uint64, optional, tag = "8")]
    pub stderr_size: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "9")]
    pub fail_context_size: ::core::option::Option<u64>,
    #[prost(bool, optional, tag = "10")]
    pub has_spec: ::core::option::Option<bool>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "11")]
    pub error: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "28")]
    pub interruption_info: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "12")]
    pub brief_statistics: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "13")]
    pub input_paths: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "14")]
    pub core_infos: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "15")]
    pub operation_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(enumeration = "EJobState", optional, tag = "16")]
    pub controller_state: ::core::option::Option<i32>,
    #[prost(enumeration = "EJobState", optional, tag = "17")]
    pub archive_state: ::core::option::Option<i32>,
    #[prost(message, optional, tag = "18")]
    pub job_competition_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(bool, optional, tag = "19")]
    pub has_competitors: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "20")]
    pub is_stale: ::core::option::Option<bool>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "21")]
    pub exec_attributes: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(string, optional, tag = "22")]
    pub task_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "23")]
    pub pool_tree: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "24")]
    pub pool: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "25")]
    pub probing_job_competition_id: ::core::option::Option<
        super::super::super::n_proto::TGuid,
    >,
    #[prost(bool, optional, tag = "26")]
    pub has_probing_competitors: ::core::option::Option<bool>,
    #[prost(uint64, optional, tag = "27")]
    pub job_cookie: ::core::option::Option<u64>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "29")]
    pub archive_features: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(string, optional, tag = "30")]
    pub monitoring_descriptor: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "31")]
    pub operation_incarnation: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "32")]
    pub allocation_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
    #[prost(message, optional, tag = "33")]
    pub addresses: ::core::option::Option<
        super::super::super::n_node_tracker_client::n_proto::TAddressMap,
    >,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "34")]
    pub events: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "35")]
    pub statistics: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(int64, optional, tag = "36")]
    pub gang_rank: ::core::option::Option<i64>,
    #[prost(uint64, optional, tag = "37")]
    pub collective_member_rank: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "38")]
    pub collective_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TListJobsStatistics {
    #[prost(message, required, tag = "1")]
    pub state_counts: t_list_jobs_statistics::TJobStateCounts,
    #[prost(message, required, tag = "2")]
    pub type_counts: t_list_jobs_statistics::TJobTypeCounts,
}
/// Nested message and enum types in `TListJobsStatistics`.
pub mod t_list_jobs_statistics {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TJobStateCounts {
        #[prost(message, repeated, tag = "1")]
        pub entries: ::prost::alloc::vec::Vec<t_job_state_counts::TJobStateCount>,
    }
    /// Nested message and enum types in `TJobStateCounts`.
    pub mod t_job_state_counts {
        #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
        pub struct TJobStateCount {
            #[prost(enumeration = "super::super::EJobState", required, tag = "1")]
            pub state: i32,
            #[prost(int64, required, tag = "2")]
            pub count: i64,
        }
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct TJobTypeCounts {
        #[prost(message, repeated, tag = "1")]
        pub entries: ::prost::alloc::vec::Vec<t_job_type_counts::TJobTypeCount>,
    }
    /// Nested message and enum types in `TJobTypeCounts`.
    pub mod t_job_type_counts {
        #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
        pub struct TJobTypeCount {
            #[prost(enumeration = "super::super::EJobType", required, tag = "1")]
            pub r#type: i32,
            #[prost(int64, required, tag = "2")]
            pub count: i64,
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TListJobsResult {
    #[prost(message, repeated, tag = "1")]
    pub jobs: ::prost::alloc::vec::Vec<TJob>,
    #[prost(int32, optional, tag = "2")]
    pub cypress_job_count: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "3")]
    pub controller_agent_job_count: ::core::option::Option<i32>,
    #[prost(int32, optional, tag = "4")]
    pub archive_job_count: ::core::option::Option<i32>,
    #[prost(message, required, tag = "5")]
    pub statistics: TListJobsStatistics,
    #[prost(message, repeated, tag = "6")]
    pub errors: ::prost::alloc::vec::Vec<super::super::super::n_proto::TError>,
    #[prost(string, optional, tag = "7")]
    pub continuation_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TJobTraceEvent {
    #[prost(message, required, tag = "1")]
    pub operation_id: super::super::super::n_proto::TGuid,
    #[prost(message, required, tag = "2")]
    pub job_id: super::super::super::n_proto::TGuid,
    #[prost(message, required, tag = "3")]
    pub trace_id: super::super::super::n_proto::TGuid,
    #[prost(int64, required, tag = "4")]
    pub event_index: i64,
    #[prost(string, required, tag = "5")]
    pub event: ::prost::alloc::string::String,
    /// TInstant
    #[prost(int64, required, tag = "6")]
    pub event_time: i64,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TGetFileFromCacheResult {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TPutFileToCacheResult {
    /// YPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TCheckPermissionResult {
    #[prost(enumeration = "ESecurityAction", required, tag = "1")]
    pub action: i32,
    #[prost(message, required, tag = "2")]
    pub object_id: super::super::super::n_proto::TGuid,
    #[prost(string, optional, tag = "3")]
    pub object_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, required, tag = "4")]
    pub subject_id: super::super::super::n_proto::TGuid,
    #[prost(string, optional, tag = "5")]
    pub subject_name: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TCheckPermissionByAclResult {
    #[prost(enumeration = "ESecurityAction", required, tag = "1")]
    pub action: i32,
    #[prost(message, required, tag = "2")]
    pub subject_id: super::super::super::n_proto::TGuid,
    #[prost(string, optional, tag = "3")]
    pub subject_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, repeated, tag = "4")]
    pub missing_subjects: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(string, repeated, tag = "5")]
    pub pending_removal_subjects: ::prost::alloc::vec::Vec<
        ::prost::alloc::string::String,
    >,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TReqStartQuery {
    #[prost(string, required, tag = "1")]
    pub query_tracker_stage: ::prost::alloc::string::String,
    #[prost(enumeration = "EQueryEngine", required, tag = "2")]
    pub engine: i32,
    #[prost(string, required, tag = "3")]
    pub query: ::prost::alloc::string::String,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "4")]
    pub settings: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, optional, tag = "5")]
    pub draft: ::core::option::Option<bool>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "6")]
    pub annotations: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, repeated, tag = "7")]
    pub files: ::prost::alloc::vec::Vec<t_req_start_query::TQueryFile>,
    /// COMPAT(mpereskokova)
    #[prost(string, optional, tag = "8")]
    pub access_control_object: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "9")]
    pub access_control_objects: ::core::option::Option<
        t_req_start_query::TAccessControlObjects,
    >,
    #[prost(message, repeated, tag = "10")]
    pub secrets: ::prost::alloc::vec::Vec<t_req_start_query::TSecret>,
}
/// Nested message and enum types in `TReqStartQuery`.
pub mod t_req_start_query {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TQueryFile {
        #[prost(string, required, tag = "1")]
        pub name: ::prost::alloc::string::String,
        #[prost(string, required, tag = "2")]
        pub content: ::prost::alloc::string::String,
        #[prost(enumeration = "super::EContentType", required, tag = "3")]
        pub r#type: i32,
    }
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TAccessControlObjects {
        #[prost(string, repeated, tag = "1")]
        pub items: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    }
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TSecret {
        #[prost(string, optional, tag = "1")]
        pub id: ::core::option::Option<::prost::alloc::string::String>,
        #[prost(string, optional, tag = "2")]
        pub category: ::core::option::Option<::prost::alloc::string::String>,
        #[prost(string, optional, tag = "3")]
        pub subcategory: ::core::option::Option<::prost::alloc::string::String>,
        #[prost(string, optional, tag = "4")]
        pub ypath: ::core::option::Option<::prost::alloc::string::String>,
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspStartQuery {
    #[prost(message, optional, tag = "1")]
    pub query_id: ::core::option::Option<super::super::super::n_proto::TGuid>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqAbortQuery {
    #[prost(string, required, tag = "1")]
    pub query_tracker_stage: ::prost::alloc::string::String,
    #[prost(message, required, tag = "2")]
    pub query_id: super::super::super::n_proto::TGuid,
    #[prost(string, optional, tag = "3")]
    pub abort_message: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspAbortQuery {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetQueryResult {
    #[prost(string, required, tag = "1")]
    pub query_tracker_stage: ::prost::alloc::string::String,
    #[prost(message, required, tag = "2")]
    pub query_id: super::super::super::n_proto::TGuid,
    #[prost(int64, required, tag = "3")]
    pub result_index: i64,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspGetQueryResult {
    #[prost(message, required, tag = "1")]
    pub query_id: super::super::super::n_proto::TGuid,
    #[prost(int64, required, tag = "2")]
    pub result_index: i64,
    #[prost(message, optional, tag = "3")]
    pub error: ::core::option::Option<super::super::super::n_proto::TError>,
    #[prost(message, optional, tag = "4")]
    pub schema: ::core::option::Option<TTableSchema>,
    #[prost(message, required, tag = "5")]
    pub data_statistics: super::super::super::n_chunk_client::n_proto::TDataStatistics,
    #[prost(bool, required, tag = "6")]
    pub is_truncated: bool,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "7")]
    pub full_result: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqReadQueryResult {
    #[prost(string, required, tag = "1")]
    pub query_tracker_stage: ::prost::alloc::string::String,
    #[prost(message, required, tag = "2")]
    pub query_id: super::super::super::n_proto::TGuid,
    #[prost(int64, required, tag = "3")]
    pub result_index: i64,
    #[prost(message, optional, tag = "4")]
    pub columns: ::core::option::Option<t_req_read_query_result::TColumns>,
    #[prost(int64, optional, tag = "5")]
    pub lower_row_index: ::core::option::Option<i64>,
    #[prost(int64, optional, tag = "6")]
    pub upper_row_index: ::core::option::Option<i64>,
}
/// Nested message and enum types in `TReqReadQueryResult`.
pub mod t_req_read_query_result {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TColumns {
        #[prost(string, repeated, tag = "1")]
        pub items: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspReadQueryResult {
    #[prost(message, required, tag = "1")]
    pub rowset_descriptor: TRowsetDescriptor,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TQuery {
    #[prost(message, required, tag = "1")]
    pub id: super::super::super::n_proto::TGuid,
    #[prost(enumeration = "EQueryEngine", optional, tag = "2")]
    pub engine: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "3")]
    pub query: ::core::option::Option<::prost::alloc::string::String>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "4")]
    pub files: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// TInstant
    #[prost(uint64, optional, tag = "5")]
    pub start_time: ::core::option::Option<u64>,
    /// TInstant
    #[prost(uint64, optional, tag = "6")]
    pub finish_time: ::core::option::Option<u64>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "7")]
    pub settings: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(string, optional, tag = "8")]
    pub user: ::core::option::Option<::prost::alloc::string::String>,
    /// COMPAT(mpereskokova)
    #[prost(string, optional, tag = "9")]
    pub access_control_object: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "EQueryState", optional, tag = "10")]
    pub state: ::core::option::Option<i32>,
    #[prost(int64, optional, tag = "11")]
    pub result_count: ::core::option::Option<i64>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "12")]
    pub progress: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "13")]
    pub error: ::core::option::Option<super::super::super::n_proto::TError>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "14")]
    pub annotations: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(message, optional, tag = "15")]
    pub other_attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeDictionary,
    >,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "16")]
    pub access_control_objects: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "17")]
    pub secrets: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(bool, optional, tag = "18")]
    pub is_indexed: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetQuery {
    #[prost(string, required, tag = "1")]
    pub query_tracker_stage: ::prost::alloc::string::String,
    #[prost(message, required, tag = "2")]
    pub query_id: super::super::super::n_proto::TGuid,
    #[prost(message, optional, tag = "3")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeFilter,
    >,
    #[prost(uint64, optional, tag = "4")]
    pub timestamp: ::core::option::Option<u64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspGetQuery {
    #[prost(message, optional, tag = "1")]
    pub query: ::core::option::Option<TQuery>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqListQueries {
    #[prost(string, required, tag = "1")]
    pub query_tracker_stage: ::prost::alloc::string::String,
    /// TInstant
    #[prost(uint64, optional, tag = "2")]
    pub from_time: ::core::option::Option<u64>,
    /// TInstant
    #[prost(uint64, optional, tag = "3")]
    pub to_time: ::core::option::Option<u64>,
    /// TInstant
    #[prost(uint64, optional, tag = "4")]
    pub cursor_time: ::core::option::Option<u64>,
    #[prost(
        enumeration = "EOperationSortDirection",
        optional,
        tag = "5",
        default = "OsdPast"
    )]
    pub cursor_direction: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "6")]
    pub user_filter: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "EQueryState", optional, tag = "7")]
    pub state_filter: ::core::option::Option<i32>,
    #[prost(enumeration = "EQueryEngine", optional, tag = "8")]
    pub engine_filter: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "9")]
    pub substr_filter: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(uint64, optional, tag = "10", default = "100")]
    pub limit: ::core::option::Option<u64>,
    #[prost(message, optional, tag = "11")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeFilter,
    >,
    #[prost(bool, optional, tag = "12", default = "false")]
    pub search_by_token_prefix: ::core::option::Option<bool>,
    #[prost(bool, optional, tag = "13", default = "false")]
    pub use_full_text_search: ::core::option::Option<bool>,
    #[prost(
        enumeration = "EListQueriesSortOrder",
        optional,
        tag = "14",
        default = "LqsoCursor"
    )]
    pub sort_order: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "15", default = "false")]
    pub tutorial_filter: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TRspListQueries {
    #[prost(message, repeated, tag = "1")]
    pub queries: ::prost::alloc::vec::Vec<TQuery>,
    #[prost(bool, required, tag = "2")]
    pub incomplete: bool,
    #[prost(uint64, required, tag = "3")]
    pub timestamp: u64,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqAlterQuery {
    #[prost(string, required, tag = "1")]
    pub query_tracker_stage: ::prost::alloc::string::String,
    #[prost(message, required, tag = "2")]
    pub query_id: super::super::super::n_proto::TGuid,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "3")]
    pub annotations: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// COMPAT(mpereskokova)
    #[prost(string, optional, tag = "4")]
    pub access_control_object: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "5")]
    pub access_control_objects: ::core::option::Option<
        t_req_alter_query::TAccessControlObjects,
    >,
}
/// Nested message and enum types in `TReqAlterQuery`.
pub mod t_req_alter_query {
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TAccessControlObjects {
        #[prost(string, repeated, tag = "1")]
        pub items: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspAlterQuery {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetQueryTrackerInfo {
    #[prost(string, required, tag = "1")]
    pub query_tracker_stage: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub attributes: ::core::option::Option<
        super::super::super::ny_tree::n_proto::TAttributeFilter,
    >,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "3")]
    pub settings: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetQueryTrackerInfo {
    #[prost(string, required, tag = "1")]
    pub cluster_name: ::prost::alloc::string::String,
    /// YSON
    #[prost(bytes = "vec", required, tag = "2")]
    pub supported_features: ::prost::alloc::vec::Vec<u8>,
    #[prost(string, repeated, tag = "3")]
    pub access_control_objects: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "4")]
    pub query_tracker_stage: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, repeated, tag = "5")]
    pub clusters: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "6")]
    pub engines_info: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(int32, optional, tag = "7")]
    pub expected_tables_version: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqGetQueryDeclaredParametersInfo {
    #[prost(string, required, tag = "1")]
    pub query_tracker_stage: ::prost::alloc::string::String,
    #[prost(string, required, tag = "2")]
    pub query: ::prost::alloc::string::String,
    #[prost(enumeration = "EQueryEngine", required, tag = "3")]
    pub engine: i32,
    /// YSON
    #[prost(bytes = "vec", optional, tag = "4")]
    pub settings: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspGetQueryDeclaredParametersInfo {
    /// YSON
    #[prost(bytes = "vec", required, tag = "1")]
    pub declared_parameters_info: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqStartDistributedWriteSession {
    /// RichYPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int32, required, tag = "2")]
    pub cookie_count: i32,
    #[prost(int64, optional, tag = "3")]
    pub timeout: ::core::option::Option<i64>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspStartDistributedWriteSession {
    /// YSON-serialized TSignedDistributedWriteSessionPtr
    #[prost(bytes = "vec", required, tag = "1")]
    pub signed_session: ::prost::alloc::vec::Vec<u8>,
    /// vector of YSON-serialized TSignedDistributedWriteCookiePtr
    #[prost(bytes = "vec", repeated, tag = "2")]
    pub signed_cookies: ::prost::alloc::vec::Vec<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqPingDistributedWriteSession {
    /// YSON-serialized TSignedDistributedWriteSessionPtr
    #[prost(bytes = "vec", required, tag = "1")]
    pub signed_session: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspPingDistributedWriteSession {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqFinishDistributedWriteSession {
    /// YSON-serialized TSignedDistributedWriteSessionPtr
    #[prost(bytes = "vec", required, tag = "1")]
    pub signed_session: ::prost::alloc::vec::Vec<u8>,
    /// vector of YSON-serialized TSignedWriteFragmentResultPtr
    #[prost(bytes = "vec", repeated, tag = "2")]
    pub signed_write_results: ::prost::alloc::vec::Vec<::prost::alloc::vec::Vec<u8>>,
    /// TODO(achains): Remove after YT-26131
    #[prost(int32, required, tag = "3")]
    pub max_children_per_attach_request: i32,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspFinishDistributedWriteSession {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqWriteTableFragment {
    /// YSON-serialized TTableWriterConfig
    #[prost(bytes = "vec", optional, tag = "1")]
    pub config: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON-serialized TFormat
    #[prost(bytes = "vec", optional, tag = "2")]
    pub format: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    /// YSON-serialized TSignedWriteFragmentCookiePtr
    #[prost(bytes = "vec", required, tag = "3")]
    pub signed_cookie: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspWriteTableFragment {
    /// YSON-serialized TSignedWriteFragmentResultPtr
    #[prost(bytes = "vec", required, tag = "1")]
    pub signed_write_result: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqStartDistributedWriteFileSession {
    /// RichYPath
    #[prost(bytes = "vec", required, tag = "1")]
    pub path: ::prost::alloc::vec::Vec<u8>,
    #[prost(int32, required, tag = "2")]
    pub cookie_count: i32,
    #[prost(int64, optional, tag = "3")]
    pub timeout: ::core::option::Option<i64>,
    #[prost(message, optional, tag = "100")]
    pub transactional_options: ::core::option::Option<TTransactionalOptions>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspStartDistributedWriteFileSession {
    /// YSON-serialized TSignedDistributedWriteFileSessionPtr
    #[prost(bytes = "vec", required, tag = "1")]
    pub signed_session: ::prost::alloc::vec::Vec<u8>,
    /// vector of YSON-serialized TSignedDistributedWriteFileCookiePtr
    #[prost(bytes = "vec", repeated, tag = "2")]
    pub signed_cookies: ::prost::alloc::vec::Vec<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqPingDistributedWriteFileSession {
    /// YSON-serialized TSignedDistributedWriteFileSessionPtr
    #[prost(bytes = "vec", required, tag = "1")]
    pub signed_session: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspPingDistributedWriteFileSession {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqFinishDistributedWriteFileSession {
    /// YSON-serialized TSignedDistributedWriteFileSessionPtr
    #[prost(bytes = "vec", required, tag = "1")]
    pub signed_session: ::prost::alloc::vec::Vec<u8>,
    /// vector of YSON-serialized TSignedWriteFileFragmentResultPtr
    #[prost(bytes = "vec", repeated, tag = "2")]
    pub signed_write_results: ::prost::alloc::vec::Vec<::prost::alloc::vec::Vec<u8>>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspFinishDistributedWriteFileSession {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqWriteFileFragment {
    /// YSON-serialized TSignedWriteFileFragmentCookiePtr
    #[prost(bytes = "vec", required, tag = "1")]
    pub signed_cookie: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspWriteFileFragment {
    /// YSON-serialized TSignedWriteFileFragmentResultPtr
    #[prost(bytes = "vec", required, tag = "1")]
    pub signed_write_result: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqStartShuffle {
    #[prost(string, required, tag = "1")]
    pub account: ::prost::alloc::string::String,
    #[prost(int32, required, tag = "2")]
    pub partition_count: i32,
    #[prost(message, required, tag = "3")]
    pub parent_transaction_id: super::super::super::n_proto::TGuid,
    #[prost(string, optional, tag = "4")]
    pub medium: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(int32, optional, tag = "5")]
    pub replication_factor: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspStartShuffle {
    /// Opaque TSignature with YSON-serialized TShuffleHandle
    #[prost(bytes = "vec", required, tag = "1")]
    pub signed_shuffle_handle: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqReadShuffleData {
    /// Opaque TSignature with YSON-serialized TShuffleHandle
    #[prost(bytes = "vec", required, tag = "1")]
    pub signed_shuffle_handle: ::prost::alloc::vec::Vec<u8>,
    /// YSON-serialized TTableReaderConfig
    #[prost(bytes = "vec", optional, tag = "2")]
    pub reader_config: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(int32, required, tag = "3")]
    pub partition_index: i32,
    #[prost(message, optional, tag = "4")]
    pub writer_index_range: ::core::option::Option<t_req_read_shuffle_data::TIndexRange>,
}
/// Nested message and enum types in `TReqReadShuffleData`.
pub mod t_req_read_shuffle_data {
    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TIndexRange {
        #[prost(int32, required, tag = "1")]
        pub begin: i32,
        #[prost(int32, required, tag = "2")]
        pub end: i32,
    }
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspReadShuffleData {}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqWriteShuffleData {
    /// Opaque TSignature with YSON-serialized TShuffleHandle
    #[prost(bytes = "vec", required, tag = "1")]
    pub signed_shuffle_handle: ::prost::alloc::vec::Vec<u8>,
    /// YSON-serialized TTableWriterConfig
    #[prost(bytes = "vec", optional, tag = "2")]
    pub writer_config: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
    #[prost(string, required, tag = "3")]
    pub partition_column: ::prost::alloc::string::String,
    #[prost(int32, optional, tag = "4")]
    pub writer_index: ::core::option::Option<i32>,
    #[prost(bool, optional, tag = "5", default = "false")]
    pub overwrite_existing_writer_data: ::core::option::Option<bool>,
}
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspWriteShuffleData {}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ETransactionType {
    TtMaster = 0,
    TtTablet = 1,
}
impl ETransactionType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::TtMaster => "TT_MASTER",
            Self::TtTablet => "TT_TABLET",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "TT_MASTER" => Some(Self::TtMaster),
            "TT_TABLET" => Some(Self::TtTablet),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ERowModificationType {
    RmtWrite = 0,
    RmtDelete = 1,
    RmtModify = 3,
}
impl ERowModificationType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::RmtWrite => "RMT_WRITE",
            Self::RmtDelete => "RMT_DELETE",
            Self::RmtModify => "RMT_MODIFY",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "RMT_WRITE" => Some(Self::RmtWrite),
            "RMT_DELETE" => Some(Self::RmtDelete),
            "RMT_MODIFY" => Some(Self::RmtModify),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EAtomicity {
    AFull = 0,
    ANone = 1,
}
impl EAtomicity {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::AFull => "A_FULL",
            Self::ANone => "A_NONE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "A_FULL" => Some(Self::AFull),
            "A_NONE" => Some(Self::ANone),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EDurability {
    DSync = 0,
    DAsync = 1,
}
impl EDurability {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::DSync => "D_SYNC",
            Self::DAsync => "D_ASYNC",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "D_SYNC" => Some(Self::DSync),
            "D_ASYNC" => Some(Self::DAsync),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ETableReplicaMode {
    TrmSync = 0,
    TrmAsync = 1,
    TrmAsyncToSync = 2,
    TrmSyncToSync = 3,
}
impl ETableReplicaMode {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::TrmSync => "TRM_SYNC",
            Self::TrmAsync => "TRM_ASYNC",
            Self::TrmAsyncToSync => "TRM_ASYNC_TO_SYNC",
            Self::TrmSyncToSync => "TRM_SYNC_TO_SYNC",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "TRM_SYNC" => Some(Self::TrmSync),
            "TRM_ASYNC" => Some(Self::TrmAsync),
            "TRM_ASYNC_TO_SYNC" => Some(Self::TrmAsyncToSync),
            "TRM_SYNC_TO_SYNC" => Some(Self::TrmSyncToSync),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EReplicaConsistency {
    RrmNone = 0,
    RrmSync = 1,
}
impl EReplicaConsistency {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::RrmNone => "RRM_NONE",
            Self::RrmSync => "RRM_SYNC",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "RRM_NONE" => Some(Self::RrmNone),
            "RRM_SYNC" => Some(Self::RrmSync),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EMasterReadKind {
    MrkLeader = 0,
    MrkFollower = 1,
    MrkCache = 2,
}
impl EMasterReadKind {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::MrkLeader => "MRK_LEADER",
            Self::MrkFollower => "MRK_FOLLOWER",
            Self::MrkCache => "MRK_CACHE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "MRK_LEADER" => Some(Self::MrkLeader),
            "MRK_FOLLOWER" => Some(Self::MrkFollower),
            "MRK_CACHE" => Some(Self::MrkCache),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ERowsetKind {
    RkUnversioned = 1,
    RkVersioned = 2,
}
impl ERowsetKind {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::RkUnversioned => "RK_UNVERSIONED",
            Self::RkVersioned => "RK_VERSIONED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "RK_UNVERSIONED" => Some(Self::RkUnversioned),
            "RK_VERSIONED" => Some(Self::RkVersioned),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ERowsetFormat {
    RfYtWire = 0,
    RfArrow = 1,
    RfFormat = 2,
}
impl ERowsetFormat {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::RfYtWire => "RF_YT_WIRE",
            Self::RfArrow => "RF_ARROW",
            Self::RfFormat => "RF_FORMAT",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "RF_YT_WIRE" => Some(Self::RfYtWire),
            "RF_ARROW" => Some(Self::RfArrow),
            "RF_FORMAT" => Some(Self::RfFormat),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ETabletReadKind {
    TrkLeader = 0,
    TrkFollower = 1,
    TrkLeaderOrFollower = 2,
}
impl ETabletReadKind {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::TrkLeader => "TRK_LEADER",
            Self::TrkFollower => "TRK_FOLLOWER",
            Self::TrkLeaderOrFollower => "TRK_LEADER_OR_FOLLOWER",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "TRK_LEADER" => Some(Self::TrkLeader),
            "TRK_FOLLOWER" => Some(Self::TrkFollower),
            "TRK_LEADER_OR_FOLLOWER" => Some(Self::TrkLeaderOrFollower),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EOperationType {
    OtUnknown = 100,
    OtMap = 0,
    OtMerge = 1,
    OtErase = 2,
    OtSort = 3,
    OtReduce = 4,
    OtMapReduce = 5,
    OtRemoteCopy = 6,
    OtJoinReduce = 7,
    OtVanilla = 8,
}
impl EOperationType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::OtUnknown => "OT_UNKNOWN",
            Self::OtMap => "OT_MAP",
            Self::OtMerge => "OT_MERGE",
            Self::OtErase => "OT_ERASE",
            Self::OtSort => "OT_SORT",
            Self::OtReduce => "OT_REDUCE",
            Self::OtMapReduce => "OT_MAP_REDUCE",
            Self::OtRemoteCopy => "OT_REMOTE_COPY",
            Self::OtJoinReduce => "OT_JOIN_REDUCE",
            Self::OtVanilla => "OT_VANILLA",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "OT_UNKNOWN" => Some(Self::OtUnknown),
            "OT_MAP" => Some(Self::OtMap),
            "OT_MERGE" => Some(Self::OtMerge),
            "OT_ERASE" => Some(Self::OtErase),
            "OT_SORT" => Some(Self::OtSort),
            "OT_REDUCE" => Some(Self::OtReduce),
            "OT_MAP_REDUCE" => Some(Self::OtMapReduce),
            "OT_REMOTE_COPY" => Some(Self::OtRemoteCopy),
            "OT_JOIN_REDUCE" => Some(Self::OtJoinReduce),
            "OT_VANILLA" => Some(Self::OtVanilla),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EOperationState {
    OsUnknown = 100,
    OsNone = 0,
    OsStarting = 1,
    OsOrphaned = 2,
    OsWaitingForAgent = 3,
    OsInitializing = 4,
    OsPreparing = 5,
    OsMaterializing = 6,
    OsReviving = 7,
    OsRevivingJobs = 8,
    OsPending = 9,
    OsRunning = 10,
    OsCompleting = 11,
    OsCompleted = 12,
    OsAborting = 13,
    OsAborted = 14,
    OsFailing = 15,
    OsFailed = 16,
    OsReviveInitializing = 17,
}
impl EOperationState {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::OsUnknown => "OS_UNKNOWN",
            Self::OsNone => "OS_NONE",
            Self::OsStarting => "OS_STARTING",
            Self::OsOrphaned => "OS_ORPHANED",
            Self::OsWaitingForAgent => "OS_WAITING_FOR_AGENT",
            Self::OsInitializing => "OS_INITIALIZING",
            Self::OsPreparing => "OS_PREPARING",
            Self::OsMaterializing => "OS_MATERIALIZING",
            Self::OsReviving => "OS_REVIVING",
            Self::OsRevivingJobs => "OS_REVIVING_JOBS",
            Self::OsPending => "OS_PENDING",
            Self::OsRunning => "OS_RUNNING",
            Self::OsCompleting => "OS_COMPLETING",
            Self::OsCompleted => "OS_COMPLETED",
            Self::OsAborting => "OS_ABORTING",
            Self::OsAborted => "OS_ABORTED",
            Self::OsFailing => "OS_FAILING",
            Self::OsFailed => "OS_FAILED",
            Self::OsReviveInitializing => "OS_REVIVE_INITIALIZING",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "OS_UNKNOWN" => Some(Self::OsUnknown),
            "OS_NONE" => Some(Self::OsNone),
            "OS_STARTING" => Some(Self::OsStarting),
            "OS_ORPHANED" => Some(Self::OsOrphaned),
            "OS_WAITING_FOR_AGENT" => Some(Self::OsWaitingForAgent),
            "OS_INITIALIZING" => Some(Self::OsInitializing),
            "OS_PREPARING" => Some(Self::OsPreparing),
            "OS_MATERIALIZING" => Some(Self::OsMaterializing),
            "OS_REVIVING" => Some(Self::OsReviving),
            "OS_REVIVING_JOBS" => Some(Self::OsRevivingJobs),
            "OS_PENDING" => Some(Self::OsPending),
            "OS_RUNNING" => Some(Self::OsRunning),
            "OS_COMPLETING" => Some(Self::OsCompleting),
            "OS_COMPLETED" => Some(Self::OsCompleted),
            "OS_ABORTING" => Some(Self::OsAborting),
            "OS_ABORTED" => Some(Self::OsAborted),
            "OS_FAILING" => Some(Self::OsFailing),
            "OS_FAILED" => Some(Self::OsFailed),
            "OS_REVIVE_INITIALIZING" => Some(Self::OsReviveInitializing),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EOperationEventType {
    OetIncarnationStarted = 0,
}
impl EOperationEventType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::OetIncarnationStarted => "OET_INCARNATION_STARTED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "OET_INCARNATION_STARTED" => Some(Self::OetIncarnationStarted),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EIncarnationSwitchReason {
    IsrJobAborted = 0,
    IsrJobFailed = 1,
    IsrJobInterrupted = 2,
    IsrJobLackAfterRevival = 3,
}
impl EIncarnationSwitchReason {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::IsrJobAborted => "ISR_JOB_ABORTED",
            Self::IsrJobFailed => "ISR_JOB_FAILED",
            Self::IsrJobInterrupted => "ISR_JOB_INTERRUPTED",
            Self::IsrJobLackAfterRevival => "ISR_JOB_LACK_AFTER_REVIVAL",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "ISR_JOB_ABORTED" => Some(Self::IsrJobAborted),
            "ISR_JOB_FAILED" => Some(Self::IsrJobFailed),
            "ISR_JOB_INTERRUPTED" => Some(Self::IsrJobInterrupted),
            "ISR_JOB_LACK_AFTER_REVIVAL" => Some(Self::IsrJobLackAfterRevival),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EOperationSortDirection {
    OsdNone = 0,
    OsdPast = 1,
    OsdFuture = 2,
}
impl EOperationSortDirection {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::OsdNone => "OSD_NONE",
            Self::OsdPast => "OSD_PAST",
            Self::OsdFuture => "OSD_FUTURE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "OSD_NONE" => Some(Self::OsdNone),
            "OSD_PAST" => Some(Self::OsdPast),
            "OSD_FUTURE" => Some(Self::OsdFuture),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EListQueriesSortOrder {
    LqsoCursor = 0,
    LqsoAscending = 1,
    LqsoDescending = 2,
}
impl EListQueriesSortOrder {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::LqsoCursor => "LQSO_CURSOR",
            Self::LqsoAscending => "LQSO_ASCENDING",
            Self::LqsoDescending => "LQSO_DESCENDING",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "LQSO_CURSOR" => Some(Self::LqsoCursor),
            "LQSO_ASCENDING" => Some(Self::LqsoAscending),
            "LQSO_DESCENDING" => Some(Self::LqsoDescending),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EJobType {
    JtUnknown = 1000,
    JtMap = 1,
    JtPartitionMap = 2,
    JtSortedMerge = 3,
    JtOrderedMerge = 4,
    JtUnorderedMerge = 5,
    JtPartition = 6,
    JtSimpleSort = 7,
    JtFinalSort = 8,
    JtSortedReduce = 9,
    JtPartitionReduce = 10,
    JtReduceCombiner = 11,
    JtRemoteCopy = 12,
    JtIntermediateSort = 13,
    JtOrderedMap = 14,
    JtJoinReduce = 15,
    JtVanilla = 16,
    JtShallowMerge = 17,
    JtSchedulerUnknown = 98,
    /// Master jobs
    JtReplicateChunk = 100,
    JtRemoveChunk = 101,
    JtRepairChunk = 102,
    JtSealChunk = 103,
    JtMergeChunks = 104,
    JtAutotomizeChunk = 105,
    JtReincarnateChunk = 106,
}
impl EJobType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::JtUnknown => "JT_UNKNOWN",
            Self::JtMap => "JT_MAP",
            Self::JtPartitionMap => "JT_PARTITION_MAP",
            Self::JtSortedMerge => "JT_SORTED_MERGE",
            Self::JtOrderedMerge => "JT_ORDERED_MERGE",
            Self::JtUnorderedMerge => "JT_UNORDERED_MERGE",
            Self::JtPartition => "JT_PARTITION",
            Self::JtSimpleSort => "JT_SIMPLE_SORT",
            Self::JtFinalSort => "JT_FINAL_SORT",
            Self::JtSortedReduce => "JT_SORTED_REDUCE",
            Self::JtPartitionReduce => "JT_PARTITION_REDUCE",
            Self::JtReduceCombiner => "JT_REDUCE_COMBINER",
            Self::JtRemoteCopy => "JT_REMOTE_COPY",
            Self::JtIntermediateSort => "JT_INTERMEDIATE_SORT",
            Self::JtOrderedMap => "JT_ORDERED_MAP",
            Self::JtJoinReduce => "JT_JOIN_REDUCE",
            Self::JtVanilla => "JT_VANILLA",
            Self::JtShallowMerge => "JT_SHALLOW_MERGE",
            Self::JtSchedulerUnknown => "JT_SCHEDULER_UNKNOWN",
            Self::JtReplicateChunk => "JT_REPLICATE_CHUNK",
            Self::JtRemoveChunk => "JT_REMOVE_CHUNK",
            Self::JtRepairChunk => "JT_REPAIR_CHUNK",
            Self::JtSealChunk => "JT_SEAL_CHUNK",
            Self::JtMergeChunks => "JT_MERGE_CHUNKS",
            Self::JtAutotomizeChunk => "JT_AUTOTOMIZE_CHUNK",
            Self::JtReincarnateChunk => "JT_REINCARNATE_CHUNK",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "JT_UNKNOWN" => Some(Self::JtUnknown),
            "JT_MAP" => Some(Self::JtMap),
            "JT_PARTITION_MAP" => Some(Self::JtPartitionMap),
            "JT_SORTED_MERGE" => Some(Self::JtSortedMerge),
            "JT_ORDERED_MERGE" => Some(Self::JtOrderedMerge),
            "JT_UNORDERED_MERGE" => Some(Self::JtUnorderedMerge),
            "JT_PARTITION" => Some(Self::JtPartition),
            "JT_SIMPLE_SORT" => Some(Self::JtSimpleSort),
            "JT_FINAL_SORT" => Some(Self::JtFinalSort),
            "JT_SORTED_REDUCE" => Some(Self::JtSortedReduce),
            "JT_PARTITION_REDUCE" => Some(Self::JtPartitionReduce),
            "JT_REDUCE_COMBINER" => Some(Self::JtReduceCombiner),
            "JT_REMOTE_COPY" => Some(Self::JtRemoteCopy),
            "JT_INTERMEDIATE_SORT" => Some(Self::JtIntermediateSort),
            "JT_ORDERED_MAP" => Some(Self::JtOrderedMap),
            "JT_JOIN_REDUCE" => Some(Self::JtJoinReduce),
            "JT_VANILLA" => Some(Self::JtVanilla),
            "JT_SHALLOW_MERGE" => Some(Self::JtShallowMerge),
            "JT_SCHEDULER_UNKNOWN" => Some(Self::JtSchedulerUnknown),
            "JT_REPLICATE_CHUNK" => Some(Self::JtReplicateChunk),
            "JT_REMOVE_CHUNK" => Some(Self::JtRemoveChunk),
            "JT_REPAIR_CHUNK" => Some(Self::JtRepairChunk),
            "JT_SEAL_CHUNK" => Some(Self::JtSealChunk),
            "JT_MERGE_CHUNKS" => Some(Self::JtMergeChunks),
            "JT_AUTOTOMIZE_CHUNK" => Some(Self::JtAutotomizeChunk),
            "JT_REINCARNATE_CHUNK" => Some(Self::JtReincarnateChunk),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EJobState {
    JsUnknown = 100,
    JsWaiting = 0,
    JsRunning = 1,
    JsAborting = 2,
    JsCompleted = 3,
    JsFailed = 4,
    JsAborted = 5,
    JsLost = 7,
    JsNone = 8,
}
impl EJobState {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::JsUnknown => "JS_UNKNOWN",
            Self::JsWaiting => "JS_WAITING",
            Self::JsRunning => "JS_RUNNING",
            Self::JsAborting => "JS_ABORTING",
            Self::JsCompleted => "JS_COMPLETED",
            Self::JsFailed => "JS_FAILED",
            Self::JsAborted => "JS_ABORTED",
            Self::JsLost => "JS_LOST",
            Self::JsNone => "JS_NONE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "JS_UNKNOWN" => Some(Self::JsUnknown),
            "JS_WAITING" => Some(Self::JsWaiting),
            "JS_RUNNING" => Some(Self::JsRunning),
            "JS_ABORTING" => Some(Self::JsAborting),
            "JS_COMPLETED" => Some(Self::JsCompleted),
            "JS_FAILED" => Some(Self::JsFailed),
            "JS_ABORTED" => Some(Self::JsAborted),
            "JS_LOST" => Some(Self::JsLost),
            "JS_NONE" => Some(Self::JsNone),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EJobTraceProgress {
    JtpInProgress = 0,
    JtpFinished = 1,
}
impl EJobTraceProgress {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::JtpInProgress => "JTP_IN_PROGRESS",
            Self::JtpFinished => "JTP_FINISHED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "JTP_IN_PROGRESS" => Some(Self::JtpInProgress),
            "JTP_FINISHED" => Some(Self::JtpFinished),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EJobTraceHealth {
    JthHealthy = 0,
    JthUnhealthy = 1,
}
impl EJobTraceHealth {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::JthHealthy => "JTH_HEALTHY",
            Self::JthUnhealthy => "JTH_UNHEALTHY",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "JTH_HEALTHY" => Some(Self::JthHealthy),
            "JTH_UNHEALTHY" => Some(Self::JthUnhealthy),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EJobTraceState {
    JtsStarted = 0,
    JtsFinished = 1,
    JtsDropped = 2,
    JtsOrphaned = 3,
}
impl EJobTraceState {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::JtsStarted => "JTS_STARTED",
            Self::JtsFinished => "JTS_FINISHED",
            Self::JtsDropped => "JTS_DROPPED",
            Self::JtsOrphaned => "JTS_ORPHANED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "JTS_STARTED" => Some(Self::JtsStarted),
            "JTS_FINISHED" => Some(Self::JtsFinished),
            "JTS_DROPPED" => Some(Self::JtsDropped),
            "JTS_ORPHANED" => Some(Self::JtsOrphaned),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EJobSortField {
    JsfNone = 0,
    JsfType = 1,
    JsfState = 2,
    JsfStartTime = 3,
    JsfFinishTime = 4,
    JsfAddress = 5,
    JsfDuration = 6,
    JsfProgress = 7,
    JsfId = 8,
    JsfTaskName = 9,
}
impl EJobSortField {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::JsfNone => "JSF_NONE",
            Self::JsfType => "JSF_TYPE",
            Self::JsfState => "JSF_STATE",
            Self::JsfStartTime => "JSF_START_TIME",
            Self::JsfFinishTime => "JSF_FINISH_TIME",
            Self::JsfAddress => "JSF_ADDRESS",
            Self::JsfDuration => "JSF_DURATION",
            Self::JsfProgress => "JSF_PROGRESS",
            Self::JsfId => "JSF_ID",
            Self::JsfTaskName => "JSF_TASK_NAME",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "JSF_NONE" => Some(Self::JsfNone),
            "JSF_TYPE" => Some(Self::JsfType),
            "JSF_STATE" => Some(Self::JsfState),
            "JSF_START_TIME" => Some(Self::JsfStartTime),
            "JSF_FINISH_TIME" => Some(Self::JsfFinishTime),
            "JSF_ADDRESS" => Some(Self::JsfAddress),
            "JSF_DURATION" => Some(Self::JsfDuration),
            "JSF_PROGRESS" => Some(Self::JsfProgress),
            "JSF_ID" => Some(Self::JsfId),
            "JSF_TASK_NAME" => Some(Self::JsfTaskName),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EJobSortDirection {
    JsdAscending = 0,
    JsdDescending = 1,
}
impl EJobSortDirection {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::JsdAscending => "JSD_ASCENDING",
            Self::JsdDescending => "JSD_DESCENDING",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "JSD_ASCENDING" => Some(Self::JsdAscending),
            "JSD_DESCENDING" => Some(Self::JsdDescending),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EDataSource {
    DsArchive = 0,
    DsRuntime = 1,
    DsAuto = 2,
    DsManual = 3,
}
impl EDataSource {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::DsArchive => "DS_ARCHIVE",
            Self::DsRuntime => "DS_RUNTIME",
            Self::DsAuto => "DS_AUTO",
            Self::DsManual => "DS_MANUAL",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "DS_ARCHIVE" => Some(Self::DsArchive),
            "DS_RUNTIME" => Some(Self::DsRuntime),
            "DS_AUTO" => Some(Self::DsAuto),
            "DS_MANUAL" => Some(Self::DsManual),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ESecurityAction {
    SaUndefined = 0,
    SaAllow = 1,
    SaDeny = 2,
}
impl ESecurityAction {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::SaUndefined => "SA_UNDEFINED",
            Self::SaAllow => "SA_ALLOW",
            Self::SaDeny => "SA_DENY",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "SA_UNDEFINED" => Some(Self::SaUndefined),
            "SA_ALLOW" => Some(Self::SaAllow),
            "SA_DENY" => Some(Self::SaDeny),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EMultiplexingBand {
    MbDefault = 0,
    MbControl = 1,
    MbHeavy = 2,
    MbInteractive = 3,
}
impl EMultiplexingBand {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::MbDefault => "MB_DEFAULT",
            Self::MbControl => "MB_CONTROL",
            Self::MbHeavy => "MB_HEAVY",
            Self::MbInteractive => "MB_INTERACTIVE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "MB_DEFAULT" => Some(Self::MbDefault),
            "MB_CONTROL" => Some(Self::MbControl),
            "MB_HEAVY" => Some(Self::MbHeavy),
            "MB_INTERACTIVE" => Some(Self::MbInteractive),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ETableSchemaModification {
    TsmNone = 0,
    TsmUnversionedUpdate = 1,
    TsmUnversionedUpdateUnsorted = 2,
}
impl ETableSchemaModification {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::TsmNone => "TSM_NONE",
            Self::TsmUnversionedUpdate => "TSM_UNVERSIONED_UPDATE",
            Self::TsmUnversionedUpdateUnsorted => "TSM_UNVERSIONED_UPDATE_UNSORTED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "TSM_NONE" => Some(Self::TsmNone),
            "TSM_UNVERSIONED_UPDATE" => Some(Self::TsmUnversionedUpdate),
            "TSM_UNVERSIONED_UPDATE_UNSORTED" => Some(Self::TsmUnversionedUpdateUnsorted),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EColumnarStatisticsFetcherMode {
    CsfmFromNodes = 0,
    CsfmFromMaster = 1,
    CsfmFallback = 2,
}
impl EColumnarStatisticsFetcherMode {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::CsfmFromNodes => "CSFM_FROM_NODES",
            Self::CsfmFromMaster => "CSFM_FROM_MASTER",
            Self::CsfmFallback => "CSFM_FALLBACK",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "CSFM_FROM_NODES" => Some(Self::CsfmFromNodes),
            "CSFM_FROM_MASTER" => Some(Self::CsfmFromMaster),
            "CSFM_FALLBACK" => Some(Self::CsfmFallback),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EPartitionTablesMode {
    TpmSorted = 0,
    TpmOrdered = 1,
    TpmUnordered = 2,
}
impl EPartitionTablesMode {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::TpmSorted => "TPM_SORTED",
            Self::TpmOrdered => "TPM_ORDERED",
            Self::TpmUnordered => "TPM_UNORDERED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "TPM_SORTED" => Some(Self::TpmSorted),
            "TPM_ORDERED" => Some(Self::TpmOrdered),
            "TPM_UNORDERED" => Some(Self::TpmUnordered),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EMaintenanceType {
    MtBan = 1,
    MtDecommission = 2,
    MtDisableSchedulerJobs = 3,
    MtDisableWriteSessions = 4,
    MtDisableTabletCells = 5,
    MtPendingRestart = 6,
}
impl EMaintenanceType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::MtBan => "MT_BAN",
            Self::MtDecommission => "MT_DECOMMISSION",
            Self::MtDisableSchedulerJobs => "MT_DISABLE_SCHEDULER_JOBS",
            Self::MtDisableWriteSessions => "MT_DISABLE_WRITE_SESSIONS",
            Self::MtDisableTabletCells => "MT_DISABLE_TABLET_CELLS",
            Self::MtPendingRestart => "MT_PENDING_RESTART",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "MT_BAN" => Some(Self::MtBan),
            "MT_DECOMMISSION" => Some(Self::MtDecommission),
            "MT_DISABLE_SCHEDULER_JOBS" => Some(Self::MtDisableSchedulerJobs),
            "MT_DISABLE_WRITE_SESSIONS" => Some(Self::MtDisableWriteSessions),
            "MT_DISABLE_TABLET_CELLS" => Some(Self::MtDisableTabletCells),
            "MT_PENDING_RESTART" => Some(Self::MtPendingRestart),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EMaintenanceComponent {
    McClusterNode = 1,
    McHttpProxy = 2,
    McRpcProxy = 3,
    McHost = 4,
}
impl EMaintenanceComponent {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::McClusterNode => "MC_CLUSTER_NODE",
            Self::McHttpProxy => "MC_HTTP_PROXY",
            Self::McRpcProxy => "MC_RPC_PROXY",
            Self::McHost => "MC_HOST",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "MC_CLUSTER_NODE" => Some(Self::McClusterNode),
            "MC_HTTP_PROXY" => Some(Self::McHttpProxy),
            "MC_RPC_PROXY" => Some(Self::McRpcProxy),
            "MC_HOST" => Some(Self::McHost),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EJobSpecSource {
    JssNode = 1,
    JssArchive = 2,
    JssAuto = 65535,
}
impl EJobSpecSource {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::JssNode => "JSS_NODE",
            Self::JssArchive => "JSS_ARCHIVE",
            Self::JssAuto => "JSS_AUTO",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "JSS_NODE" => Some(Self::JssNode),
            "JSS_ARCHIVE" => Some(Self::JssArchive),
            "JSS_AUTO" => Some(Self::JssAuto),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EQueryEngine {
    QeUnknown = 100,
    QeQl = 0,
    QeYql = 1,
    QeChyt = 2,
    QeMock = 3,
    QeSpyt = 4,
}
impl EQueryEngine {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::QeUnknown => "QE_UNKNOWN",
            Self::QeQl => "QE_QL",
            Self::QeYql => "QE_YQL",
            Self::QeChyt => "QE_CHYT",
            Self::QeMock => "QE_MOCK",
            Self::QeSpyt => "QE_SPYT",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "QE_UNKNOWN" => Some(Self::QeUnknown),
            "QE_QL" => Some(Self::QeQl),
            "QE_YQL" => Some(Self::QeYql),
            "QE_CHYT" => Some(Self::QeChyt),
            "QE_MOCK" => Some(Self::QeMock),
            "QE_SPYT" => Some(Self::QeSpyt),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EContentType {
    CtRawInlineData = 0,
    CtUrl = 1,
}
impl EContentType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::CtRawInlineData => "CT_RAW_INLINE_DATA",
            Self::CtUrl => "CT_URL",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "CT_RAW_INLINE_DATA" => Some(Self::CtRawInlineData),
            "CT_URL" => Some(Self::CtUrl),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EQueryState {
    QsUnknown = 100,
    QsDraft = 0,
    QsPending = 1,
    QsRunning = 2,
    QsAborting = 3,
    QsAborted = 4,
    QsCompleting = 5,
    QsCompleted = 6,
    QsFailing = 7,
    QsFailed = 8,
}
impl EQueryState {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::QsUnknown => "QS_UNKNOWN",
            Self::QsDraft => "QS_DRAFT",
            Self::QsPending => "QS_PENDING",
            Self::QsRunning => "QS_RUNNING",
            Self::QsAborting => "QS_ABORTING",
            Self::QsAborted => "QS_ABORTED",
            Self::QsCompleting => "QS_COMPLETING",
            Self::QsCompleted => "QS_COMPLETED",
            Self::QsFailing => "QS_FAILING",
            Self::QsFailed => "QS_FAILED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "QS_UNKNOWN" => Some(Self::QsUnknown),
            "QS_DRAFT" => Some(Self::QsDraft),
            "QS_PENDING" => Some(Self::QsPending),
            "QS_RUNNING" => Some(Self::QsRunning),
            "QS_ABORTING" => Some(Self::QsAborting),
            "QS_ABORTED" => Some(Self::QsAborted),
            "QS_COMPLETING" => Some(Self::QsCompleting),
            "QS_COMPLETED" => Some(Self::QsCompleted),
            "QS_FAILING" => Some(Self::QsFailing),
            "QS_FAILED" => Some(Self::QsFailed),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EJobStderrType {
    JstUserJobStderr = 0,
    JstGpuCheckStderr = 1,
}
impl EJobStderrType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::JstUserJobStderr => "JST_USER_JOB_STDERR",
            Self::JstGpuCheckStderr => "JST_GPU_CHECK_STDERR",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "JST_USER_JOB_STDERR" => Some(Self::JstUserJobStderr),
            "JST_GPU_CHECK_STDERR" => Some(Self::JstGpuCheckStderr),
            _ => None,
        }
    }
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TReqDiscoverProxies {
    #[prost(string, optional, tag = "1")]
    pub role: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(
        enumeration = "EAddressType",
        optional,
        tag = "2",
        default = "AtInternalRpc"
    )]
    pub address_type: ::core::option::Option<i32>,
    #[prost(string, optional, tag = "3")]
    pub network_name: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TRspDiscoverProxies {
    #[prost(string, repeated, tag = "1")]
    pub addresses: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum EAddressType {
    AtInternalRpc = 0,
    AtMonitoringHttp = 1,
    AtTvmOnlyInternalRpc = 2,
}
impl EAddressType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::AtInternalRpc => "AT_INTERNAL_RPC",
            Self::AtMonitoringHttp => "AT_MONITORING_HTTP",
            Self::AtTvmOnlyInternalRpc => "AT_TVM_ONLY_INTERNAL_RPC",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "AT_INTERNAL_RPC" => Some(Self::AtInternalRpc),
            "AT_MONITORING_HTTP" => Some(Self::AtMonitoringHttp),
            "AT_TVM_ONLY_INTERNAL_RPC" => Some(Self::AtTvmOnlyInternalRpc),
            _ => None,
        }
    }
}