typedb_protocol/

typedb.protocol.rs

// This file is @generated by prost-build.
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum Version {
    Unspecified = 0,
    Version = 4,
}
impl Version {
    /// 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::Unspecified => "UNSPECIFIED",
            Self::Version => "VERSION",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "UNSPECIFIED" => Some(Self::Unspecified),
            "VERSION" => Some(Self::Version),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DatabaseManager {}
/// Nested message and enum types in `DatabaseManager`.
pub mod database_manager {
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Get {}
    /// Nested message and enum types in `Get`.
    pub mod get {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub name: ::prost::alloc::string::String,
        }
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(message, optional, tag = "1")]
            pub database: ::core::option::Option<super::super::DatabaseReplicas>,
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct All {}
    /// Nested message and enum types in `All`.
    pub mod all {
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Req {}
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(message, repeated, tag = "1")]
            pub databases: ::prost::alloc::vec::Vec<super::super::DatabaseReplicas>,
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Contains {}
    /// Nested message and enum types in `Contains`.
    pub mod contains {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub name: ::prost::alloc::string::String,
        }
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(bool, tag = "1")]
            pub contains: bool,
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Create {}
    /// Nested message and enum types in `Create`.
    pub mod create {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub name: ::prost::alloc::string::String,
        }
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(message, optional, tag = "1")]
            pub database: ::core::option::Option<super::super::DatabaseReplicas>,
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DatabaseReplicas {
    #[prost(string, tag = "1")]
    pub name: ::prost::alloc::string::String,
    #[prost(message, repeated, tag = "2")]
    pub replicas: ::prost::alloc::vec::Vec<database_replicas::Replica>,
}
/// Nested message and enum types in `DatabaseReplicas`.
pub mod database_replicas {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Replica {
        #[prost(string, tag = "1")]
        pub address: ::prost::alloc::string::String,
        #[prost(bool, tag = "2")]
        pub primary: bool,
        #[prost(bool, tag = "3")]
        pub preferred: bool,
        #[prost(int64, tag = "4")]
        pub term: i64,
    }
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct Database {}
/// Nested message and enum types in `Database`.
pub mod database {
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Schema {}
    /// Nested message and enum types in `Schema`.
    pub mod schema {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub name: ::prost::alloc::string::String,
        }
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(string, tag = "1")]
            pub schema: ::prost::alloc::string::String,
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct TypeSchema {}
    /// Nested message and enum types in `TypeSchema`.
    pub mod type_schema {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub name: ::prost::alloc::string::String,
        }
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(string, tag = "1")]
            pub schema: ::prost::alloc::string::String,
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Delete {}
    /// Nested message and enum types in `Delete`.
    pub mod delete {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub name: ::prost::alloc::string::String,
        }
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Res {}
    }
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct Connection {}
/// Nested message and enum types in `Connection`.
pub mod connection {
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Open {}
    /// Nested message and enum types in `Open`.
    pub mod open {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(enumeration = "super::super::Version", tag = "1")]
            pub version: i32,
            #[prost(string, tag = "2")]
            pub driver_lang: ::prost::alloc::string::String,
            #[prost(string, tag = "3")]
            pub driver_version: ::prost::alloc::string::String,
        }
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(uint64, tag = "1")]
            pub server_duration_millis: u64,
            #[prost(message, optional, tag = "2")]
            pub connection_id: ::core::option::Option<super::super::ConnectionId>,
            /// pre-send all databases and replica info
            #[prost(message, optional, tag = "3")]
            pub databases_all: ::core::option::Option<
                super::super::database_manager::all::Res,
            >,
        }
    }
}
/// Connection ID and Token are expected in all message metadata
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConnectionId {
    #[prost(bytes = "vec", tag = "1")]
    pub id: ::prost::alloc::vec::Vec<u8>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ServerManager {}
/// Nested message and enum types in `ServerManager`.
pub mod server_manager {
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct All {}
    /// Nested message and enum types in `All`.
    pub mod all {
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Req {}
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(message, repeated, tag = "1")]
            pub servers: ::prost::alloc::vec::Vec<super::super::Server>,
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Server {
    #[prost(string, tag = "1")]
    pub address: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct UserManager {}
/// Nested message and enum types in `UserManager`.
pub mod user_manager {
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct All {}
    /// Nested message and enum types in `All`.
    pub mod all {
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Req {}
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(message, repeated, tag = "1")]
            pub users: ::prost::alloc::vec::Vec<super::super::User>,
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Contains {}
    /// Nested message and enum types in `Contains`.
    pub mod contains {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub name: ::prost::alloc::string::String,
        }
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(bool, tag = "1")]
            pub contains: bool,
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Get {}
    /// Nested message and enum types in `Get`.
    pub mod get {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub name: ::prost::alloc::string::String,
        }
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(message, optional, tag = "1")]
            pub user: ::core::option::Option<super::super::User>,
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Create {}
    /// Nested message and enum types in `Create`.
    pub mod create {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(message, optional, tag = "1")]
            pub user: ::core::option::Option<super::super::User>,
        }
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Res {}
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct User {
    #[prost(string, tag = "1")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, optional, tag = "2")]
    pub password: ::core::option::Option<::prost::alloc::string::String>,
}
/// Nested message and enum types in `User`.
pub mod user {
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Update {}
    /// Nested message and enum types in `Update`.
    pub mod update {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub name: ::prost::alloc::string::String,
            #[prost(message, optional, tag = "2")]
            pub user: ::core::option::Option<super::super::User>,
        }
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Res {}
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Delete {}
    /// Nested message and enum types in `Delete`.
    pub mod delete {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub name: ::prost::alloc::string::String,
        }
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Res {}
    }
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct Options {
    ///     optional bool infer = 1;
    ///     optional bool trace_inference = 2;
    ///     optional bool explain = 3;
    #[prost(bool, optional, tag = "4")]
    pub parallel: ::core::option::Option<bool>,
    #[prost(uint64, optional, tag = "5")]
    pub prefetch_size: ::core::option::Option<u64>,
    #[prost(bool, optional, tag = "6")]
    pub prefetch: ::core::option::Option<bool>,
    ///     optional int32 session_idle_timeout_millis = 7;
    #[prost(uint64, optional, tag = "8")]
    pub transaction_timeout_millis: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "9")]
    pub schema_lock_acquire_timeout_millis: ::core::option::Option<u64>,
    #[prost(bool, optional, tag = "10")]
    pub read_any_replica: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Concept {
    #[prost(oneof = "concept::Concept", tags = "1, 2, 3, 4, 5, 6, 7")]
    pub concept: ::core::option::Option<concept::Concept>,
}
/// Nested message and enum types in `Concept`.
pub mod concept {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Concept {
        #[prost(message, tag = "1")]
        EntityType(super::EntityType),
        #[prost(message, tag = "2")]
        RelationType(super::RelationType),
        #[prost(message, tag = "3")]
        AttributeType(super::AttributeType),
        #[prost(message, tag = "4")]
        RoleType(super::RoleType),
        #[prost(message, tag = "5")]
        Entity(super::Entity),
        #[prost(message, tag = "6")]
        Relation(super::Relation),
        #[prost(message, tag = "7")]
        Attribute(super::Attribute),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Thing {
    #[prost(oneof = "thing::Thing", tags = "1, 2, 3")]
    pub thing: ::core::option::Option<thing::Thing>,
}
/// Nested message and enum types in `Thing`.
pub mod thing {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Thing {
        #[prost(message, tag = "1")]
        Entity(super::Entity),
        #[prost(message, tag = "2")]
        Relation(super::Relation),
        #[prost(message, tag = "3")]
        Attribute(super::Attribute),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Entity {
    #[prost(bytes = "vec", tag = "1")]
    pub iid: ::prost::alloc::vec::Vec<u8>,
    /// TODO: not sure we should include types by default, since now they can get quite large with annotations included in every single response!
    ///        perhaps it's a query option?
    #[prost(message, optional, tag = "2")]
    pub entity_type: ::core::option::Option<EntityType>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Relation {
    #[prost(bytes = "vec", tag = "1")]
    pub iid: ::prost::alloc::vec::Vec<u8>,
    /// TODO: not sure we should include types by default, since now they can get quite large with annotations included in every single response!
    ///        perhaps it's a query option?
    #[prost(message, optional, tag = "2")]
    pub relation_type: ::core::option::Option<RelationType>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Attribute {
    #[prost(bytes = "vec", tag = "1")]
    pub iid: ::prost::alloc::vec::Vec<u8>,
    /// TODO: not sure we should include types by default, since now they can get quite large with annotations included in every single response!
    ///        perhaps it's a query option?
    #[prost(message, optional, tag = "2")]
    pub attribute_type: ::core::option::Option<AttributeType>,
    #[prost(message, optional, tag = "3")]
    pub value: ::core::option::Option<Value>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Value {
    #[prost(oneof = "value::Value", tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10")]
    pub value: ::core::option::Option<value::Value>,
}
/// Nested message and enum types in `Value`.
pub mod value {
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Decimal {
        #[prost(sint64, tag = "1")]
        pub integer: i64,
        #[prost(uint64, tag = "2")]
        pub fractional: u64,
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Date {
        /// days since January 1, 0001 as day 1 in the Gregorian Calendar (following Rust conventions)
        #[prost(sint32, tag = "1")]
        pub num_days_since_ce: i32,
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Datetime {
        /// seconds since epoch
        #[prost(sint64, tag = "1")]
        pub seconds: i64,
        #[prost(uint32, tag = "2")]
        pub nanos: u32,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct DatetimeTz {
        #[prost(message, optional, tag = "1")]
        pub datetime: ::core::option::Option<Datetime>,
        #[prost(oneof = "datetime_tz::Timezone", tags = "2, 3")]
        pub timezone: ::core::option::Option<datetime_tz::Timezone>,
    }
    /// Nested message and enum types in `Datetime_TZ`.
    pub mod datetime_tz {
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Timezone {
            #[prost(string, tag = "2")]
            Named(::prost::alloc::string::String),
            /// offset in seconds
            #[prost(sint32, tag = "3")]
            Offset(i32),
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Duration {
        #[prost(uint32, tag = "1")]
        pub months: u32,
        #[prost(uint32, tag = "2")]
        pub days: u32,
        #[prost(uint64, tag = "3")]
        pub nanos: u64,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Struct {
        #[prost(string, tag = "1")]
        pub struct_type_name: ::prost::alloc::string::String,
    }
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Value {
        #[prost(bool, tag = "1")]
        Boolean(bool),
        #[prost(sint64, tag = "2")]
        Integer(i64),
        #[prost(double, tag = "3")]
        Double(f64),
        #[prost(message, tag = "4")]
        Decimal(Decimal),
        #[prost(string, tag = "5")]
        String(::prost::alloc::string::String),
        #[prost(message, tag = "6")]
        Date(Date),
        /// time since epoch in milliseconds
        #[prost(message, tag = "7")]
        Datetime(Datetime),
        #[prost(message, tag = "8")]
        DatetimeTz(DatetimeTz),
        #[prost(message, tag = "9")]
        Duration(Duration),
        #[prost(message, tag = "10")]
        Struct(Struct),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Type {
    #[prost(oneof = "r#type::Type", tags = "1, 2, 3, 4")]
    pub r#type: ::core::option::Option<r#type::Type>,
}
/// Nested message and enum types in `Type`.
pub mod r#type {
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Type {
        #[prost(message, tag = "1")]
        EntityType(super::EntityType),
        #[prost(message, tag = "2")]
        RelationType(super::RelationType),
        #[prost(message, tag = "3")]
        AttributeType(super::AttributeType),
        #[prost(message, tag = "4")]
        RoleType(super::RoleType),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RoleType {
    #[prost(string, tag = "1")]
    pub label: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EntityType {
    #[prost(string, tag = "1")]
    pub label: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RelationType {
    #[prost(string, tag = "1")]
    pub label: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AttributeType {
    #[prost(string, tag = "1")]
    pub label: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "2")]
    pub value_type: ::core::option::Option<ValueType>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ValueType {
    #[prost(oneof = "value_type::ValueType", tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10")]
    pub value_type: ::core::option::Option<value_type::ValueType>,
}
/// Nested message and enum types in `ValueType`.
pub mod value_type {
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Boolean {}
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Integer {}
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Double {}
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Decimal {}
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct String {}
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Date {}
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct DateTime {}
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct DateTimeTz {}
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Duration {}
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Struct {
        #[prost(string, tag = "1")]
        pub name: ::prost::alloc::string::String,
    }
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum ValueType {
        #[prost(message, tag = "1")]
        Boolean(Boolean),
        #[prost(message, tag = "2")]
        Integer(Integer),
        #[prost(message, tag = "3")]
        Double(Double),
        #[prost(message, tag = "4")]
        Decimal(Decimal),
        #[prost(message, tag = "5")]
        String(String),
        #[prost(message, tag = "6")]
        Date(Date),
        #[prost(message, tag = "7")]
        Datetime(DateTime),
        #[prost(message, tag = "8")]
        DatetimeTz(DateTimeTz),
        #[prost(message, tag = "9")]
        Duration(Duration),
        #[prost(message, tag = "10")]
        Struct(Struct),
    }
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct Annotation {
    #[prost(oneof = "annotation::Annotation", tags = "1, 2")]
    pub annotation: ::core::option::Option<annotation::Annotation>,
}
/// Nested message and enum types in `Annotation`.
pub mod annotation {
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Key {}
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Unique {}
    #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
    pub enum Annotation {
        #[prost(message, tag = "1")]
        Key(Key),
        /// TODO
        #[prost(message, tag = "2")]
        Unique(Unique),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConceptRow {
    ///     Explainables explainables = 2;
    #[prost(message, repeated, tag = "1")]
    pub row: ::prost::alloc::vec::Vec<RowEntry>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RowEntry {
    #[prost(oneof = "row_entry::Entry", tags = "1, 2, 3, 4, 5")]
    pub entry: ::core::option::Option<row_entry::Entry>,
}
/// Nested message and enum types in `RowEntry`.
pub mod row_entry {
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Empty {}
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ConceptList {
        #[prost(message, repeated, tag = "1")]
        pub concepts: ::prost::alloc::vec::Vec<super::Concept>,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ValueList {
        #[prost(message, repeated, tag = "1")]
        pub values: ::prost::alloc::vec::Vec<super::Value>,
    }
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Entry {
        #[prost(message, tag = "1")]
        Empty(Empty),
        #[prost(message, tag = "2")]
        Concept(super::Concept),
        #[prost(message, tag = "3")]
        Value(super::Value),
        #[prost(message, tag = "4")]
        ConceptList(ConceptList),
        #[prost(message, tag = "5")]
        ValueList(ValueList),
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ConceptDocument {
    #[prost(message, optional, tag = "1")]
    pub root: ::core::option::Option<concept_document::Node>,
}
/// Nested message and enum types in `ConceptDocument`.
pub mod concept_document {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Node {
        #[prost(oneof = "node::Node", tags = "1, 2, 3")]
        pub node: ::core::option::Option<node::Node>,
    }
    /// Nested message and enum types in `Node`.
    pub mod node {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Map {
            #[prost(map = "string, message", tag = "1")]
            pub map: ::std::collections::HashMap<
                ::prost::alloc::string::String,
                super::Node,
            >,
        }
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct List {
            #[prost(message, repeated, tag = "1")]
            pub list: ::prost::alloc::vec::Vec<super::Node>,
        }
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Leaf {
            #[prost(oneof = "leaf::Leaf", tags = "1, 10, 11, 12, 13, 15, 20, 21, 30")]
            pub leaf: ::core::option::Option<leaf::Leaf>,
        }
        /// Nested message and enum types in `Leaf`.
        pub mod leaf {
            #[derive(Clone, Copy, PartialEq, ::prost::Message)]
            pub struct Empty {}
            #[derive(
                Clone,
                Copy,
                Debug,
                PartialEq,
                Eq,
                Hash,
                PartialOrd,
                Ord,
                ::prost::Enumeration
            )]
            #[repr(i32)]
            pub enum Kind {
                Entity = 0,
                Relation = 1,
                Attribute = 3,
                Role = 4,
            }
            impl Kind {
                /// 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::Entity => "Entity",
                        Self::Relation => "Relation",
                        Self::Attribute => "Attribute",
                        Self::Role => "Role",
                    }
                }
                /// Creates an enum from field names used in the ProtoBuf definition.
                pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
                    match value {
                        "Entity" => Some(Self::Entity),
                        "Relation" => Some(Self::Relation),
                        "Attribute" => Some(Self::Attribute),
                        "Role" => Some(Self::Role),
                        _ => None,
                    }
                }
            }
            #[derive(Clone, PartialEq, ::prost::Oneof)]
            pub enum Leaf {
                #[prost(message, tag = "1")]
                Empty(Empty),
                #[prost(message, tag = "10")]
                EntityType(super::super::super::EntityType),
                #[prost(message, tag = "11")]
                RelationType(super::super::super::RelationType),
                #[prost(message, tag = "12")]
                AttributeType(super::super::super::AttributeType),
                #[prost(message, tag = "13")]
                RoleType(super::super::super::RoleType),
                #[prost(message, tag = "15")]
                ValueType(super::super::super::ValueType),
                #[prost(message, tag = "20")]
                Attribute(super::super::super::Attribute),
                #[prost(message, tag = "21")]
                Value(super::super::super::Value),
                #[prost(enumeration = "Kind", tag = "30")]
                Kind(i32),
            }
        }
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Node {
            #[prost(message, tag = "1")]
            Map(Map),
            #[prost(message, tag = "2")]
            List(List),
            #[prost(message, tag = "3")]
            Leaf(Leaf),
        }
    }
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct Query {}
/// Nested message and enum types in `Query`.
pub mod query {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Req {
        #[prost(message, optional, tag = "1")]
        pub options: ::core::option::Option<super::Options>,
        #[prost(string, tag = "2")]
        pub query: ::prost::alloc::string::String,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct InitialRes {
        #[prost(oneof = "initial_res::Res", tags = "1, 2")]
        pub res: ::core::option::Option<initial_res::Res>,
    }
    /// Nested message and enum types in `InitialRes`.
    pub mod initial_res {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Ok {
            #[prost(oneof = "ok::Ok", tags = "1, 3, 4")]
            pub ok: ::core::option::Option<ok::Ok>,
        }
        /// Nested message and enum types in `Ok`.
        pub mod ok {
            #[derive(Clone, Copy, PartialEq, ::prost::Message)]
            pub struct Done {
                #[prost(enumeration = "super::super::Type", tag = "1")]
                pub query_type: i32,
            }
            #[derive(Clone, Copy, PartialEq, ::prost::Message)]
            pub struct ConceptDocumentStream {
                /// note: we could use this first response to record debug info, type annotations, warnings, etc
                /// TODO: network optimisation: replace keys with IDs, sending keys in the header to rebuild the document on the client side
                /// TODO: network optimisation: replace types (== mostly constant strings) with a IDs, sending types in the header to rebuild on the client side
                #[prost(enumeration = "super::super::Type", tag = "2")]
                pub query_type: i32,
            }
            #[derive(Clone, PartialEq, ::prost::Message)]
            pub struct ConceptRowStream {
                /// TODO: network optimisation: replace types (== mostly constant strings) with a IDs, sending types in the header to rebuild on the client side
                #[prost(string, repeated, tag = "1")]
                pub column_variable_names: ::prost::alloc::vec::Vec<
                    ::prost::alloc::string::String,
                >,
                #[prost(enumeration = "super::super::Type", tag = "2")]
                pub query_type: i32,
            }
            #[derive(Clone, PartialEq, ::prost::Oneof)]
            pub enum Ok {
                #[prost(message, tag = "1")]
                Done(Done),
                #[prost(message, tag = "3")]
                ConceptDocumentStream(ConceptDocumentStream),
                #[prost(message, tag = "4")]
                ConceptRowStream(ConceptRowStream),
            }
        }
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Res {
            #[prost(message, tag = "1")]
            Error(super::super::Error),
            #[prost(message, tag = "2")]
            Ok(Ok),
        }
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ResPart {
        #[prost(oneof = "res_part::Res", tags = "1, 2")]
        pub res: ::core::option::Option<res_part::Res>,
    }
    /// Nested message and enum types in `ResPart`.
    pub mod res_part {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct ConceptDocumentsRes {
            #[prost(message, repeated, tag = "1")]
            pub documents: ::prost::alloc::vec::Vec<super::super::ConceptDocument>,
        }
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct ConceptRowsRes {
            #[prost(message, repeated, tag = "1")]
            pub rows: ::prost::alloc::vec::Vec<super::super::ConceptRow>,
        }
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Res {
            #[prost(message, tag = "1")]
            DocumentsRes(ConceptDocumentsRes),
            #[prost(message, tag = "2")]
            RowsRes(ConceptRowsRes),
        }
    }
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum Type {
        Read = 0,
        Write = 1,
        Schema = 2,
    }
    impl Type {
        /// 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::Read => "READ",
                Self::Write => "WRITE",
                Self::Schema => "SCHEMA",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "READ" => Some(Self::Read),
                "WRITE" => Some(Self::Write),
                "SCHEMA" => Some(Self::Schema),
                _ => None,
            }
        }
    }
}
/// This is an emulation of the google ErrorDetails message. Sometimes we submit ErrorDetails via the GRPC error mechanism
/// and sometimes (in streams) we have to manually send errors
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Error {
    #[prost(string, tag = "1")]
    pub error_code: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub domain: ::prost::alloc::string::String,
    #[prost(string, repeated, tag = "3")]
    pub stack_trace: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct Transaction {}
/// Nested message and enum types in `Transaction`.
pub mod transaction {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Client {
        #[prost(message, repeated, tag = "1")]
        pub reqs: ::prost::alloc::vec::Vec<Req>,
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Server {
        #[prost(oneof = "server::Server", tags = "1, 2")]
        pub server: ::core::option::Option<server::Server>,
    }
    /// Nested message and enum types in `Server`.
    pub mod server {
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Server {
            #[prost(message, tag = "1")]
            Res(super::Res),
            #[prost(message, tag = "2")]
            ResPart(super::ResPart),
        }
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Req {
        #[prost(bytes = "vec", tag = "1")]
        pub req_id: ::prost::alloc::vec::Vec<u8>,
        #[prost(map = "string, string", tag = "2")]
        pub metadata: ::std::collections::HashMap<
            ::prost::alloc::string::String,
            ::prost::alloc::string::String,
        >,
        #[prost(oneof = "req::Req", tags = "3, 4, 5, 6, 7, 8")]
        pub req: ::core::option::Option<req::Req>,
    }
    /// Nested message and enum types in `Req`.
    pub mod req {
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Req {
            #[prost(message, tag = "3")]
            OpenReq(super::open::Req),
            #[prost(message, tag = "4")]
            QueryReq(super::super::query::Req),
            #[prost(message, tag = "5")]
            StreamReq(super::stream_signal::Req),
            #[prost(message, tag = "6")]
            CommitReq(super::commit::Req),
            #[prost(message, tag = "7")]
            RollbackReq(super::rollback::Req),
            #[prost(message, tag = "8")]
            CloseReq(super::close::Req),
        }
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Res {
        #[prost(bytes = "vec", tag = "1")]
        pub req_id: ::prost::alloc::vec::Vec<u8>,
        #[prost(oneof = "res::Res", tags = "2, 3, 5, 6")]
        pub res: ::core::option::Option<res::Res>,
    }
    /// Nested message and enum types in `Res`.
    pub mod res {
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Res {
            #[prost(message, tag = "2")]
            OpenRes(super::open::Res),
            #[prost(message, tag = "3")]
            QueryInitialRes(super::super::query::InitialRes),
            #[prost(message, tag = "5")]
            CommitRes(super::commit::Res),
            #[prost(message, tag = "6")]
            RollbackRes(super::rollback::Res),
        }
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ResPart {
        #[prost(bytes = "vec", tag = "1")]
        pub req_id: ::prost::alloc::vec::Vec<u8>,
        #[prost(oneof = "res_part::ResPart", tags = "2, 3")]
        pub res_part: ::core::option::Option<res_part::ResPart>,
    }
    /// Nested message and enum types in `ResPart`.
    pub mod res_part {
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum ResPart {
            #[prost(message, tag = "2")]
            QueryRes(super::super::query::ResPart),
            #[prost(message, tag = "3")]
            StreamRes(super::stream_signal::ResPart),
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Open {}
    /// Nested message and enum types in `Open`.
    pub mod open {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub database: ::prost::alloc::string::String,
            #[prost(enumeration = "super::Type", tag = "2")]
            pub r#type: i32,
            #[prost(message, optional, tag = "3")]
            pub options: ::core::option::Option<super::super::Options>,
            #[prost(uint64, tag = "4")]
            pub network_latency_millis: u64,
        }
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(uint64, tag = "2")]
            pub server_duration_millis: u64,
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Commit {}
    /// Nested message and enum types in `Commit`.
    pub mod commit {
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Req {}
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Res {}
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Rollback {}
    /// Nested message and enum types in `Rollback`.
    pub mod rollback {
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Req {}
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Res {}
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Close {}
    /// Nested message and enum types in `Close`.
    pub mod close {
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Req {}
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Res {}
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct GetSchemaExceptions {}
    /// Nested message and enum types in `GetSchemaExceptions`.
    pub mod get_schema_exceptions {
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Req {}
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(message, repeated, tag = "1")]
            pub exceptions: ::prost::alloc::vec::Vec<super::SchemaException>,
        }
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct SchemaException {
        #[prost(string, tag = "1")]
        pub code: ::prost::alloc::string::String,
        #[prost(string, tag = "2")]
        pub message: ::prost::alloc::string::String,
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct StreamSignal {}
    /// Nested message and enum types in `StreamSignal`.
    pub mod stream_signal {
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Req {}
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct ResPart {
            #[prost(oneof = "res_part::State", tags = "1, 2, 3")]
            pub state: ::core::option::Option<res_part::State>,
        }
        /// Nested message and enum types in `ResPart`.
        pub mod res_part {
            #[derive(Clone, Copy, PartialEq, ::prost::Message)]
            pub struct Continue {}
            #[derive(Clone, Copy, PartialEq, ::prost::Message)]
            pub struct Done {}
            #[derive(Clone, PartialEq, ::prost::Oneof)]
            pub enum State {
                #[prost(message, tag = "1")]
                Continue(Continue),
                #[prost(message, tag = "2")]
                Done(Done),
                #[prost(message, tag = "3")]
                Error(super::super::super::Error),
            }
        }
    }
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum Type {
        Read = 0,
        Write = 1,
        Schema = 2,
    }
    impl Type {
        /// 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::Read => "READ",
                Self::Write => "WRITE",
                Self::Schema => "SCHEMA",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "READ" => Some(Self::Read),
                "WRITE" => Some(Self::Write),
                "SCHEMA" => Some(Self::Schema),
                _ => None,
            }
        }
    }
}
/// Generated client implementations.
#[allow(non_camel_case_types)]
pub mod type_db_client {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct TypeDbClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl TypeDbClient<tonic::transport::Channel> {
        /// Attempt to create a new client by connecting to a given endpoint.
        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
        where
            D: TryInto<tonic::transport::Endpoint>,
            D::Error: Into<StdError>,
        {
            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
            Ok(Self::new(conn))
        }
    }
    impl<T> TypeDbClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::BoxBody>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
    {
        pub fn new(inner: T) -> Self {
            let inner = tonic::client::Grpc::new(inner);
            Self { inner }
        }
        pub fn with_origin(inner: T, origin: Uri) -> Self {
            let inner = tonic::client::Grpc::with_origin(inner, origin);
            Self { inner }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> TypeDbClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::BoxBody>,
            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
        {
            TypeDbClient::new(InterceptedService::new(inner, interceptor))
        }
        /// Compress requests with the given encoding.
        ///
        /// This requires the server to support it otherwise it might respond with an
        /// error.
        #[must_use]
        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.send_compressed(encoding);
            self
        }
        /// Enable decompressing responses.
        #[must_use]
        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.accept_compressed(encoding);
            self
        }
        /// Limits the maximum size of a decoded message.
        ///
        /// Default: `4MB`
        #[must_use]
        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_decoding_message_size(limit);
            self
        }
        /// Limits the maximum size of an encoded message.
        ///
        /// Default: `usize::MAX`
        #[must_use]
        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_encoding_message_size(limit);
            self
        }
        /// Connection API
        pub async fn connection_open(
            &mut self,
            request: impl tonic::IntoRequest<super::connection::open::Req>,
        ) -> std::result::Result<
            tonic::Response<super::connection::open::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/connection_open",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "connection_open"));
            self.inner.unary(req, path, codec).await
        }
        /// Server Manager API
        pub async fn servers_all(
            &mut self,
            request: impl tonic::IntoRequest<super::server_manager::all::Req>,
        ) -> std::result::Result<
            tonic::Response<super::server_manager::all::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/servers_all",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "servers_all"));
            self.inner.unary(req, path, codec).await
        }
        /// User Manager API
        pub async fn users_get(
            &mut self,
            request: impl tonic::IntoRequest<super::user_manager::get::Req>,
        ) -> std::result::Result<
            tonic::Response<super::user_manager::get::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/users_get",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "users_get"));
            self.inner.unary(req, path, codec).await
        }
        pub async fn users_all(
            &mut self,
            request: impl tonic::IntoRequest<super::user_manager::all::Req>,
        ) -> std::result::Result<
            tonic::Response<super::user_manager::all::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/users_all",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "users_all"));
            self.inner.unary(req, path, codec).await
        }
        pub async fn users_contains(
            &mut self,
            request: impl tonic::IntoRequest<super::user_manager::contains::Req>,
        ) -> std::result::Result<
            tonic::Response<super::user_manager::contains::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/users_contains",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "users_contains"));
            self.inner.unary(req, path, codec).await
        }
        pub async fn users_create(
            &mut self,
            request: impl tonic::IntoRequest<super::user_manager::create::Req>,
        ) -> std::result::Result<
            tonic::Response<super::user_manager::create::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/users_create",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "users_create"));
            self.inner.unary(req, path, codec).await
        }
        /// User API
        pub async fn users_update(
            &mut self,
            request: impl tonic::IntoRequest<super::user::update::Req>,
        ) -> std::result::Result<
            tonic::Response<super::user::update::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/users_update",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "users_update"));
            self.inner.unary(req, path, codec).await
        }
        pub async fn users_delete(
            &mut self,
            request: impl tonic::IntoRequest<super::user::delete::Req>,
        ) -> std::result::Result<
            tonic::Response<super::user::delete::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/users_delete",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "users_delete"));
            self.inner.unary(req, path, codec).await
        }
        /// Database Manager API
        pub async fn databases_get(
            &mut self,
            request: impl tonic::IntoRequest<super::database_manager::get::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database_manager::get::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/databases_get",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "databases_get"));
            self.inner.unary(req, path, codec).await
        }
        pub async fn databases_all(
            &mut self,
            request: impl tonic::IntoRequest<super::database_manager::all::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database_manager::all::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/databases_all",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "databases_all"));
            self.inner.unary(req, path, codec).await
        }
        pub async fn databases_contains(
            &mut self,
            request: impl tonic::IntoRequest<super::database_manager::contains::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database_manager::contains::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/databases_contains",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "databases_contains"));
            self.inner.unary(req, path, codec).await
        }
        pub async fn databases_create(
            &mut self,
            request: impl tonic::IntoRequest<super::database_manager::create::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database_manager::create::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/databases_create",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "databases_create"));
            self.inner.unary(req, path, codec).await
        }
        /// Database API
        pub async fn database_schema(
            &mut self,
            request: impl tonic::IntoRequest<super::database::schema::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database::schema::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/database_schema",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "database_schema"));
            self.inner.unary(req, path, codec).await
        }
        pub async fn database_type_schema(
            &mut self,
            request: impl tonic::IntoRequest<super::database::type_schema::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database::type_schema::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/database_type_schema",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("typedb.protocol.TypeDB", "database_type_schema"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn database_delete(
            &mut self,
            request: impl tonic::IntoRequest<super::database::delete::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database::delete::Res>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/database_delete",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "database_delete"));
            self.inner.unary(req, path, codec).await
        }
        /// Transaction Streaming API
        /// Opens a bi-directional stream representing a stateful transaction, streaming
        /// requests and responses back-and-forth. The first transaction client message must
        /// be {Transaction.Open.Req}. Closing the stream closes the transaction.
        pub async fn transaction(
            &mut self,
            request: impl tonic::IntoStreamingRequest<
                Message = super::transaction::Client,
            >,
        ) -> std::result::Result<
            tonic::Response<tonic::codec::Streaming<super::transaction::Server>>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/typedb.protocol.TypeDB/transaction",
            );
            let mut req = request.into_streaming_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("typedb.protocol.TypeDB", "transaction"));
            self.inner.streaming(req, path, codec).await
        }
    }
}
/// Generated server implementations.
#[allow(non_camel_case_types)]
pub mod type_db_server {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    /// Generated trait containing gRPC methods that should be implemented for use with TypeDbServer.
    #[async_trait]
    pub trait TypeDb: std::marker::Send + std::marker::Sync + 'static {
        /// Connection API
        async fn connection_open(
            &self,
            request: tonic::Request<super::connection::open::Req>,
        ) -> std::result::Result<
            tonic::Response<super::connection::open::Res>,
            tonic::Status,
        >;
        /// Server Manager API
        async fn servers_all(
            &self,
            request: tonic::Request<super::server_manager::all::Req>,
        ) -> std::result::Result<
            tonic::Response<super::server_manager::all::Res>,
            tonic::Status,
        >;
        /// User Manager API
        async fn users_get(
            &self,
            request: tonic::Request<super::user_manager::get::Req>,
        ) -> std::result::Result<
            tonic::Response<super::user_manager::get::Res>,
            tonic::Status,
        >;
        async fn users_all(
            &self,
            request: tonic::Request<super::user_manager::all::Req>,
        ) -> std::result::Result<
            tonic::Response<super::user_manager::all::Res>,
            tonic::Status,
        >;
        async fn users_contains(
            &self,
            request: tonic::Request<super::user_manager::contains::Req>,
        ) -> std::result::Result<
            tonic::Response<super::user_manager::contains::Res>,
            tonic::Status,
        >;
        async fn users_create(
            &self,
            request: tonic::Request<super::user_manager::create::Req>,
        ) -> std::result::Result<
            tonic::Response<super::user_manager::create::Res>,
            tonic::Status,
        >;
        /// User API
        async fn users_update(
            &self,
            request: tonic::Request<super::user::update::Req>,
        ) -> std::result::Result<
            tonic::Response<super::user::update::Res>,
            tonic::Status,
        >;
        async fn users_delete(
            &self,
            request: tonic::Request<super::user::delete::Req>,
        ) -> std::result::Result<
            tonic::Response<super::user::delete::Res>,
            tonic::Status,
        >;
        /// Database Manager API
        async fn databases_get(
            &self,
            request: tonic::Request<super::database_manager::get::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database_manager::get::Res>,
            tonic::Status,
        >;
        async fn databases_all(
            &self,
            request: tonic::Request<super::database_manager::all::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database_manager::all::Res>,
            tonic::Status,
        >;
        async fn databases_contains(
            &self,
            request: tonic::Request<super::database_manager::contains::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database_manager::contains::Res>,
            tonic::Status,
        >;
        async fn databases_create(
            &self,
            request: tonic::Request<super::database_manager::create::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database_manager::create::Res>,
            tonic::Status,
        >;
        /// Database API
        async fn database_schema(
            &self,
            request: tonic::Request<super::database::schema::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database::schema::Res>,
            tonic::Status,
        >;
        async fn database_type_schema(
            &self,
            request: tonic::Request<super::database::type_schema::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database::type_schema::Res>,
            tonic::Status,
        >;
        async fn database_delete(
            &self,
            request: tonic::Request<super::database::delete::Req>,
        ) -> std::result::Result<
            tonic::Response<super::database::delete::Res>,
            tonic::Status,
        >;
        /// Server streaming response type for the transaction method.
        type transactionStream: tonic::codegen::tokio_stream::Stream<
                Item = std::result::Result<super::transaction::Server, tonic::Status>,
            >
            + std::marker::Send
            + 'static;
        /// Transaction Streaming API
        /// Opens a bi-directional stream representing a stateful transaction, streaming
        /// requests and responses back-and-forth. The first transaction client message must
        /// be {Transaction.Open.Req}. Closing the stream closes the transaction.
        async fn transaction(
            &self,
            request: tonic::Request<tonic::Streaming<super::transaction::Client>>,
        ) -> std::result::Result<
            tonic::Response<Self::transactionStream>,
            tonic::Status,
        >;
    }
    #[derive(Debug)]
    pub struct TypeDbServer<T> {
        inner: Arc<T>,
        accept_compression_encodings: EnabledCompressionEncodings,
        send_compression_encodings: EnabledCompressionEncodings,
        max_decoding_message_size: Option<usize>,
        max_encoding_message_size: Option<usize>,
    }
    impl<T> TypeDbServer<T> {
        pub fn new(inner: T) -> Self {
            Self::from_arc(Arc::new(inner))
        }
        pub fn from_arc(inner: Arc<T>) -> Self {
            Self {
                inner,
                accept_compression_encodings: Default::default(),
                send_compression_encodings: Default::default(),
                max_decoding_message_size: None,
                max_encoding_message_size: None,
            }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> InterceptedService<Self, F>
        where
            F: tonic::service::Interceptor,
        {
            InterceptedService::new(Self::new(inner), interceptor)
        }
        /// Enable decompressing requests with the given encoding.
        #[must_use]
        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.accept_compression_encodings.enable(encoding);
            self
        }
        /// Compress responses with the given encoding, if the client supports it.
        #[must_use]
        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.send_compression_encodings.enable(encoding);
            self
        }
        /// Limits the maximum size of a decoded message.
        ///
        /// Default: `4MB`
        #[must_use]
        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
            self.max_decoding_message_size = Some(limit);
            self
        }
        /// Limits the maximum size of an encoded message.
        ///
        /// Default: `usize::MAX`
        #[must_use]
        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
            self.max_encoding_message_size = Some(limit);
            self
        }
    }
    impl<T, B> tonic::codegen::Service<http::Request<B>> for TypeDbServer<T>
    where
        T: TypeDb,
        B: Body + std::marker::Send + 'static,
        B::Error: Into<StdError> + std::marker::Send + 'static,
    {
        type Response = http::Response<tonic::body::BoxBody>;
        type Error = std::convert::Infallible;
        type Future = BoxFuture<Self::Response, Self::Error>;
        fn poll_ready(
            &mut self,
            _cx: &mut Context<'_>,
        ) -> Poll<std::result::Result<(), Self::Error>> {
            Poll::Ready(Ok(()))
        }
        fn call(&mut self, req: http::Request<B>) -> Self::Future {
            match req.uri().path() {
                "/typedb.protocol.TypeDB/connection_open" => {
                    #[allow(non_camel_case_types)]
                    struct connection_openSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::connection::open::Req>
                    for connection_openSvc<T> {
                        type Response = super::connection::open::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::connection::open::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::connection_open(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = connection_openSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/servers_all" => {
                    #[allow(non_camel_case_types)]
                    struct servers_allSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::server_manager::all::Req>
                    for servers_allSvc<T> {
                        type Response = super::server_manager::all::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::server_manager::all::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::servers_all(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = servers_allSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/users_get" => {
                    #[allow(non_camel_case_types)]
                    struct users_getSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::user_manager::get::Req>
                    for users_getSvc<T> {
                        type Response = super::user_manager::get::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::user_manager::get::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::users_get(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = users_getSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/users_all" => {
                    #[allow(non_camel_case_types)]
                    struct users_allSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::user_manager::all::Req>
                    for users_allSvc<T> {
                        type Response = super::user_manager::all::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::user_manager::all::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::users_all(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = users_allSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/users_contains" => {
                    #[allow(non_camel_case_types)]
                    struct users_containsSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::user_manager::contains::Req>
                    for users_containsSvc<T> {
                        type Response = super::user_manager::contains::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::user_manager::contains::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::users_contains(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = users_containsSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/users_create" => {
                    #[allow(non_camel_case_types)]
                    struct users_createSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::user_manager::create::Req>
                    for users_createSvc<T> {
                        type Response = super::user_manager::create::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::user_manager::create::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::users_create(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = users_createSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/users_update" => {
                    #[allow(non_camel_case_types)]
                    struct users_updateSvc<T: TypeDb>(pub Arc<T>);
                    impl<T: TypeDb> tonic::server::UnaryService<super::user::update::Req>
                    for users_updateSvc<T> {
                        type Response = super::user::update::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::user::update::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::users_update(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = users_updateSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/users_delete" => {
                    #[allow(non_camel_case_types)]
                    struct users_deleteSvc<T: TypeDb>(pub Arc<T>);
                    impl<T: TypeDb> tonic::server::UnaryService<super::user::delete::Req>
                    for users_deleteSvc<T> {
                        type Response = super::user::delete::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::user::delete::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::users_delete(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = users_deleteSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/databases_get" => {
                    #[allow(non_camel_case_types)]
                    struct databases_getSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::database_manager::get::Req>
                    for databases_getSvc<T> {
                        type Response = super::database_manager::get::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::database_manager::get::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::databases_get(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = databases_getSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/databases_all" => {
                    #[allow(non_camel_case_types)]
                    struct databases_allSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::database_manager::all::Req>
                    for databases_allSvc<T> {
                        type Response = super::database_manager::all::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::database_manager::all::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::databases_all(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = databases_allSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/databases_contains" => {
                    #[allow(non_camel_case_types)]
                    struct databases_containsSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::database_manager::contains::Req>
                    for databases_containsSvc<T> {
                        type Response = super::database_manager::contains::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::database_manager::contains::Req,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::databases_contains(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = databases_containsSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/databases_create" => {
                    #[allow(non_camel_case_types)]
                    struct databases_createSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::database_manager::create::Req>
                    for databases_createSvc<T> {
                        type Response = super::database_manager::create::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::database_manager::create::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::databases_create(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = databases_createSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/database_schema" => {
                    #[allow(non_camel_case_types)]
                    struct database_schemaSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::database::schema::Req>
                    for database_schemaSvc<T> {
                        type Response = super::database::schema::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::database::schema::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::database_schema(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = database_schemaSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/database_type_schema" => {
                    #[allow(non_camel_case_types)]
                    struct database_type_schemaSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::database::type_schema::Req>
                    for database_type_schemaSvc<T> {
                        type Response = super::database::type_schema::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::database::type_schema::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::database_type_schema(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = database_type_schemaSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/database_delete" => {
                    #[allow(non_camel_case_types)]
                    struct database_deleteSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::UnaryService<super::database::delete::Req>
                    for database_deleteSvc<T> {
                        type Response = super::database::delete::Res;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::database::delete::Req>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::database_delete(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = database_deleteSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/typedb.protocol.TypeDB/transaction" => {
                    #[allow(non_camel_case_types)]
                    struct transactionSvc<T: TypeDb>(pub Arc<T>);
                    impl<
                        T: TypeDb,
                    > tonic::server::StreamingService<super::transaction::Client>
                    for transactionSvc<T> {
                        type Response = super::transaction::Server;
                        type ResponseStream = T::transactionStream;
                        type Future = BoxFuture<
                            tonic::Response<Self::ResponseStream>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                tonic::Streaming<super::transaction::Client>,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as TypeDb>::transaction(&inner, request).await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = transactionSvc(inner);
                        let codec = tonic::codec::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.streaming(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                _ => {
                    Box::pin(async move {
                        let mut response = http::Response::new(empty_body());
                        let headers = response.headers_mut();
                        headers
                            .insert(
                                tonic::Status::GRPC_STATUS,
                                (tonic::Code::Unimplemented as i32).into(),
                            );
                        headers
                            .insert(
                                http::header::CONTENT_TYPE,
                                tonic::metadata::GRPC_CONTENT_TYPE,
                            );
                        Ok(response)
                    })
                }
            }
        }
    }
    impl<T> Clone for TypeDbServer<T> {
        fn clone(&self) -> Self {
            let inner = self.inner.clone();
            Self {
                inner,
                accept_compression_encodings: self.accept_compression_encodings,
                send_compression_encodings: self.send_compression_encodings,
                max_decoding_message_size: self.max_decoding_message_size,
                max_encoding_message_size: self.max_encoding_message_size,
            }
        }
    }
    /// Generated gRPC service name
    pub const SERVICE_NAME: &str = "typedb.protocol.TypeDB";
    impl<T> tonic::server::NamedService for TypeDbServer<T> {
        const NAME: &'static str = SERVICE_NAME;
    }
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct LogicManager {}
/// Nested message and enum types in `LogicManager`.
pub mod logic_manager {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Req {
        #[prost(oneof = "req::Req", tags = "1, 2, 3")]
        pub req: ::core::option::Option<req::Req>,
    }
    /// Nested message and enum types in `Req`.
    pub mod req {
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Req {
            #[prost(message, tag = "1")]
            GetRuleReq(super::get_rule::Req),
            #[prost(message, tag = "2")]
            PutRuleReq(super::put_rule::Req),
            #[prost(message, tag = "3")]
            GetRulesReq(super::get_rules::Req),
        }
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Res {
        #[prost(oneof = "res::Res", tags = "1, 2")]
        pub res: ::core::option::Option<res::Res>,
    }
    /// Nested message and enum types in `Res`.
    pub mod res {
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Res {
            #[prost(message, tag = "1")]
            GetRuleRes(super::get_rule::Res),
            #[prost(message, tag = "2")]
            PutRuleRes(super::put_rule::Res),
        }
    }
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ResPart {
        #[prost(message, optional, tag = "1")]
        pub get_rules_res_part: ::core::option::Option<get_rules::ResPart>,
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct GetRule {}
    /// Nested message and enum types in `GetRule`.
    pub mod get_rule {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub label: ::prost::alloc::string::String,
        }
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(message, optional, tag = "1")]
            pub rule: ::core::option::Option<super::super::Rule>,
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct PutRule {}
    /// Nested message and enum types in `PutRule`.
    pub mod put_rule {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub label: ::prost::alloc::string::String,
            #[prost(string, tag = "2")]
            pub when: ::prost::alloc::string::String,
            #[prost(string, tag = "3")]
            pub then: ::prost::alloc::string::String,
        }
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Res {
            #[prost(message, optional, tag = "1")]
            pub rule: ::core::option::Option<super::super::Rule>,
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct GetRules {}
    /// Nested message and enum types in `GetRules`.
    pub mod get_rules {
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Req {}
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct ResPart {
            #[prost(message, repeated, tag = "1")]
            pub rules: ::prost::alloc::vec::Vec<super::super::Rule>,
        }
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Rule {
    #[prost(string, tag = "1")]
    pub label: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub when: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub then: ::prost::alloc::string::String,
}
/// Nested message and enum types in `Rule`.
pub mod rule {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Req {
        #[prost(string, tag = "1")]
        pub label: ::prost::alloc::string::String,
        #[prost(oneof = "req::Req", tags = "100, 101")]
        pub req: ::core::option::Option<req::Req>,
    }
    /// Nested message and enum types in `Req`.
    pub mod req {
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Req {
            #[prost(message, tag = "100")]
            RuleDeleteReq(super::delete::Req),
            #[prost(message, tag = "101")]
            RuleSetLabelReq(super::set_label::Req),
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Res {
        #[prost(oneof = "res::Res", tags = "100, 101")]
        pub res: ::core::option::Option<res::Res>,
    }
    /// Nested message and enum types in `Res`.
    pub mod res {
        #[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
        pub enum Res {
            #[prost(message, tag = "100")]
            RuleDeleteRes(super::delete::Res),
            #[prost(message, tag = "101")]
            RuleSetLabelRes(super::set_label::Res),
        }
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct Delete {}
    /// Nested message and enum types in `Delete`.
    pub mod delete {
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Req {}
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Res {}
    }
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct SetLabel {}
    /// Nested message and enum types in `SetLabel`.
    pub mod set_label {
        #[derive(Clone, PartialEq, ::prost::Message)]
        pub struct Req {
            #[prost(string, tag = "1")]
            pub label: ::prost::alloc::string::String,
        }
        #[derive(Clone, Copy, PartialEq, ::prost::Message)]
        pub struct Res {}
    }
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Explanation {
    #[prost(message, optional, tag = "1")]
    pub rule: ::core::option::Option<Rule>,
    #[prost(map = "string, message", tag = "2")]
    pub var_mapping: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        explanation::VarList,
    >,
    #[prost(message, optional, tag = "3")]
    pub condition: ::core::option::Option<ConceptRow>,
    #[prost(message, optional, tag = "4")]
    pub conclusion: ::core::option::Option<ConceptRow>,
}
/// Nested message and enum types in `Explanation`.
pub mod explanation {
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct VarList {
        #[prost(string, repeated, tag = "1")]
        pub vars: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    }
}