kortex_gen_grpc 2.6.0

// @generated
// This file is @generated by prost-build.
/// *
/// GetAuthUrlRequest is a request to get an auth url for the given an identity provider.
/// DEPRECATED: Client initiates auth flow outside of this API.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetAuthUrlRequest {
    #[prost(enumeration="IdentityProvider", tag="1")]
    pub provider: i32,
}
/// *
/// AuthInfo provides the auth url, code_verifier and CSRF secrets for the client.
/// DEPRECATED: Client initiates auth flow outside of this API.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AuthInfo {
    #[prost(string, tag="1")]
    pub url: ::prost::alloc::string::String,
    #[prost(string, tag="2")]
    pub cover_verifier: ::prost::alloc::string::String,
    #[prost(string, tag="3")]
    pub csrf_token: ::prost::alloc::string::String,
    #[prost(string, tag="4")]
    pub nonce: ::prost::alloc::string::String,
}
/// *
/// GetAuthUrlResponse is the AuthInfo such as the auth url, or an HSTPError.
/// DEPRECATED: Client initiates auth flow outside of this API.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetAuthUrlResponse {
    #[prost(oneof="get_auth_url_response::Response", tags="1, 2")]
    pub response: ::core::option::Option<get_auth_url_response::Response>,
}
/// Nested message and enum types in `GetAuthUrlResponse`.
pub mod get_auth_url_response {
    #[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Response {
        #[prost(message, tag="1")]
        AuthInfo(super::AuthInfo),
        #[prost(message, tag="2")]
        Error(super::HstpError),
    }
}
/// *
/// ArchiveRequest archives an entity with the given SWID.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchiveRequest {
    /// The SWID of the entity to archive
    #[prost(string, tag="1")]
    pub swid: ::prost::alloc::string::String,
}
/// *
/// ArchiveResponse contains the entity that was successfully archived, or an HSTPError.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchiveResponse {
    #[prost(oneof="archive_response::Response", tags="1, 2")]
    pub response: ::core::option::Option<archive_response::Response>,
}
/// Nested message and enum types in `ArchiveResponse`.
pub mod archive_response {
    #[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Response {
        #[prost(string, tag="1")]
        Entity(::prost::alloc::string::String),
        #[prost(message, tag="2")]
        Error(super::HstpError),
    }
}
/// *
/// BatchArchiveRequest is just an array of ArchiveRequest.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchArchiveRequest {
    #[prost(message, repeated, tag="1")]
    pub requests: ::prost::alloc::vec::Vec<ArchiveRequest>,
}
/// *
/// BatchArchiveResponse archives an array of entities with the given SWIDs.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchArchiveResponse {
    #[prost(message, repeated, tag="1")]
    pub responses: ::prost::alloc::vec::Vec<ArchiveResponse>,
}
/// *
/// ReadRequest is a request to read an entity with the given SWID.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReadRequest {
    #[prost(string, tag="1")]
    pub swid: ::prost::alloc::string::String,
}
/// *
/// ReadResponse is the entity with the given SWID, or an HSTPError.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReadResponse {
    #[prost(oneof="read_response::Response", tags="1, 2")]
    pub response: ::core::option::Option<read_response::Response>,
}
/// Nested message and enum types in `ReadResponse`.
pub mod read_response {
    #[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Response {
        #[prost(string, tag="1")]
        Entity(::prost::alloc::string::String),
        #[prost(message, tag="2")]
        Error(super::HstpError),
    }
}
/// *
/// BatchReadRequest is an array of ReadRequest.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchReadRequest {
    #[prost(message, repeated, tag="1")]
    pub requests: ::prost::alloc::vec::Vec<ReadRequest>,
}
/// *
/// BatchReadResponse is an array of ReadResponse.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchReadResponse {
    #[prost(message, repeated, tag="1")]
    pub responses: ::prost::alloc::vec::Vec<ReadResponse>,
}
/// *
/// UpsertRequest is a request to upsert an entity.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpsertRequest {
    #[prost(string, tag="1")]
    pub entity: ::prost::alloc::string::String,
    #[prost(enumeration="CollisionStrategy", tag="2")]
    pub collision_strategy: i32,
}
/// *
/// UpsertResponse is the upserted entity, or an HSTPError.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpsertResponse {
    #[prost(oneof="upsert_response::Response", tags="1, 2")]
    pub response: ::core::option::Option<upsert_response::Response>,
}
/// Nested message and enum types in `UpsertResponse`.
pub mod upsert_response {
    #[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Response {
        #[prost(string, tag="1")]
        Entity(::prost::alloc::string::String),
        #[prost(message, tag="2")]
        Error(super::HstpError),
    }
}
/// *
/// BatchUpsertRequest is an array of UpsertRequest.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchUpsertRequest {
    #[prost(message, repeated, tag="1")]
    pub requests: ::prost::alloc::vec::Vec<UpsertRequest>,
}
/// *
/// BatchUpsertResponse is an array of UpsertResponse.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchUpsertResponse {
    #[prost(message, repeated, tag="1")]
    pub responses: ::prost::alloc::vec::Vec<UpsertResponse>,
}
/// *
/// RestoreRequest is a request to restore an archived entity with the given SWID.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RestoreRequest {
    #[prost(string, tag="1")]
    pub swid: ::prost::alloc::string::String,
}
/// *
/// RestoreResponse is the restored entity, or an HSTPError.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RestoreResponse {
    #[prost(oneof="restore_response::Response", tags="1, 2")]
    pub response: ::core::option::Option<restore_response::Response>,
}
/// Nested message and enum types in `RestoreResponse`.
pub mod restore_response {
    #[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Response {
        #[prost(string, tag="1")]
        Entity(::prost::alloc::string::String),
        #[prost(message, tag="2")]
        Error(super::HstpError),
    }
}
/// *
/// BatchRestoreRequest is an array of RestoreRequest.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchRestoreRequest {
    #[prost(message, repeated, tag="1")]
    pub requests: ::prost::alloc::vec::Vec<RestoreRequest>,
}
/// *
/// BatchRestoreResponse is an array of RestoreResponse.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchRestoreResponse {
    #[prost(message, repeated, tag="1")]
    pub responses: ::prost::alloc::vec::Vec<RestoreResponse>,
}
/// *
/// Point is a helper message for NearestRequest. It contains the coordinates of a point in a space.
/// The space is specified in the containing message.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Point {
    #[prost(double, repeated, tag="1")]
    pub coordinates: ::prost::alloc::vec::Vec<f64>,
}
/// *
/// NearestRequest is a request to get the k nearest entities to the given point in a given space.
/// The point can be specified as a SWID or as a Point. The space must be specified as a swid. topk is a uint64.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct NearestRequest {
    #[prost(string, tag="3")]
    pub space_swid: ::prost::alloc::string::String,
    #[prost(uint64, tag="4")]
    pub topk: u64,
    #[prost(oneof="nearest_request::Target", tags="1, 2")]
    pub target: ::core::option::Option<nearest_request::Target>,
}
/// Nested message and enum types in `NearestRequest`.
pub mod nearest_request {
    #[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Target {
        #[prost(string, tag="1")]
        Swid(::prost::alloc::string::String),
        #[prost(message, tag="2")]
        Point(super::Point),
    }
}
/// *
/// EntityDistance is a helper message for NearestResponse. It is an entity with its distance (from the query).
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EntityDistance {
    #[prost(string, tag="1")]
    pub entity: ::prost::alloc::string::String,
    #[prost(double, tag="2")]
    pub distance: f64,
}
/// *
/// EntityDistanceList is a helper message for NearestResponse. It is an array of EntityDistances.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EntityDistanceList {
    #[prost(message, repeated, tag="1")]
    pub entities: ::prost::alloc::vec::Vec<EntityDistance>,
}
/// *
/// EntityList is a helper message for NearestResponse. It is an array of entities.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EntityList {
    #[prost(string, repeated, tag="1")]
    pub entities: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
/// *
/// NearestResponse is the response to a single NearestRequest. It contains the k nearest entities, or an HSTPError.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct NearestResponse {
    #[prost(oneof="nearest_response::Response", tags="1, 2, 3")]
    pub response: ::core::option::Option<nearest_response::Response>,
}
/// Nested message and enum types in `NearestResponse`.
pub mod nearest_response {
    #[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Response {
        #[prost(message, tag="1")]
        Entities(super::EntityList),
        #[prost(message, tag="2")]
        Error(super::HstpError),
        #[prost(message, tag="3")]
        EntityDistances(super::EntityDistanceList),
    }
}
/// *
/// BatchNearestRequest is an array of NearestRequest.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchNearestRequest {
    #[prost(message, repeated, tag="1")]
    pub requests: ::prost::alloc::vec::Vec<NearestRequest>,
}
/// *
/// BatchNearestResponse is an array of NearestResponse.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchNearestResponse {
    #[prost(message, repeated, tag="1")]
    pub responses: ::prost::alloc::vec::Vec<NearestResponse>,
}
/// *
/// ListenRequest is a request to listen for changes to an entity with the given SWID.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListenRequest {
    #[prost(string, tag="1")]
    pub swid: ::prost::alloc::string::String,
    #[prost(enumeration="ListenType", tag="2")]
    pub r#type: i32,
}
/// *
/// ListenResponse is a response to a ListenRequest. It contains the entity that was added or removed, or an HSTPError.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListenResponse {
    #[deprecated]
    #[prost(enumeration="ListenType", tag="3")]
    pub r#type: i32,
    #[prost(enumeration="ListenResponseType", tag="4")]
    pub response_type: i32,
    #[prost(oneof="listen_response::Response", tags="1, 2")]
    pub response: ::core::option::Option<listen_response::Response>,
}
/// Nested message and enum types in `ListenResponse`.
pub mod listen_response {
    #[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Response {
        #[prost(string, tag="1")]
        Entity(::prost::alloc::string::String),
        #[prost(message, tag="2")]
        Error(super::HstpError),
    }
}
/// *
/// BatchListenRequest is an array of ListenRequest.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchListenRequest {
    #[prost(message, repeated, tag="1")]
    pub requests: ::prost::alloc::vec::Vec<ListenRequest>,
}
/// *
/// BatchListenResponse is an array of ListenResponse.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchListenResponse {
    #[prost(message, repeated, tag="1")]
    pub responses: ::prost::alloc::vec::Vec<ListenResponse>,
}
/// *
/// LinksRequest is a request to get the links for an entity with the given SWID.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LinksRequest {
    #[prost(string, tag="1")]
    pub swid: ::prost::alloc::string::String,
}
/// *
/// LinksResponse is a response to a LinksRequest. It contains the links for the given entity, or an HSTPError.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LinksResponse {
    #[prost(oneof="links_response::Response", tags="1, 2")]
    pub response: ::core::option::Option<links_response::Response>,
}
/// Nested message and enum types in `LinksResponse`.
pub mod links_response {
    #[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Response {
        #[prost(message, tag="1")]
        Links(super::Links),
        #[prost(message, tag="2")]
        Error(super::HstpError),
    }
}
/// *
/// BatchLinksRequest is an array of LinksRequest.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchLinksRequest {
    #[prost(message, repeated, tag="1")]
    pub requests: ::prost::alloc::vec::Vec<LinksRequest>,
}
/// *
/// BatchLinksResponse is an array of LinksResponse.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BatchLinksResponse {
    #[prost(message, repeated, tag="1")]
    pub responses: ::prost::alloc::vec::Vec<LinksResponse>,
}
/// *
/// IngestRequest is a request for ingestion of a given document to Alexandria.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IngestRequest {
    #[prost(enumeration="IngestType", tag="1")]
    pub doctype: i32,
    #[prost(string, tag="2")]
    pub document: ::prost::alloc::string::String,
    #[prost(bool, tag="3")]
    pub dry_run: bool,
}
/// *
/// IngestSuccess is the successful response from an ingest request.
/// Ingested SWIDs are the new documents inserted.
/// Ingested schemas are the new schemas inserted (if any).
/// If there is an error, the error is returned.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IngestSuccess {
    #[prost(string, repeated, tag="1")]
    pub ingested_swids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(string, repeated, tag="2")]
    pub ingested_schemas: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
/// *
/// IngestDryRunSuccess is the successful response from an ingest request with the dry run flag set.
/// processed_data is the json documents of the documents inserted, after applying generated functors.
/// generated_schemas is the schemas generated from the documents inserted.
/// If there is an error, the error is returned instead.
///
/// This will only be returned if the dry_run flag is set. The database will not be modified, so, the
/// entire entity is returned for both data and schema. This may be a large return.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IngestDryRunSuccess {
    #[prost(string, repeated, tag="1")]
    pub processed_data: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(string, repeated, tag="2")]
    pub generated_schemas: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
/// *
/// The response from an ingest request.
/// Either an IngestSuccess or an HSTPError.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IngestResponse {
    #[prost(oneof="ingest_response::Response", tags="1, 2, 3")]
    pub response: ::core::option::Option<ingest_response::Response>,
}
/// Nested message and enum types in `IngestResponse`.
pub mod ingest_response {
    #[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Response {
        #[prost(message, tag="1")]
        Success(super::IngestSuccess),
        #[prost(message, tag="2")]
        Error(super::HstpError),
        #[prost(message, tag="3")]
        DryRunSuccess(super::IngestDryRunSuccess),
    }
}
/// *
/// QueryRequest is a request to query for entities given an HSQL query string.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct QueryRequest {
    #[prost(string, tag="1")]
    pub query: ::prost::alloc::string::String,
}
/// *
/// QueryResponse is a response to a QueryRequest. It contains the result of the query, or an HSTPError.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct QueryResponse {
    #[prost(oneof="query_response::Response", tags="1, 2")]
    pub response: ::core::option::Option<query_response::Response>,
}
/// Nested message and enum types in `QueryResponse`.
pub mod query_response {
    #[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Response {
        #[prost(string, tag="1")]
        Result(::prost::alloc::string::String),
        #[prost(message, tag="2")]
        Error(super::HstpError),
    }
}
/// *
/// ParseQueryRequest is a request to parse an HSQL query.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ParseQueryRequest {
    #[prost(string, tag="1")]
    pub query: ::prost::alloc::string::String,
}
/// *
/// ParseQueryResponse is a response to a ParseQueryRequest. It contains the parsed query, or an HSTPError.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ParseQueryResponse {
    #[prost(oneof="parse_query_response::Response", tags="1, 2")]
    pub response: ::core::option::Option<parse_query_response::Response>,
}
/// Nested message and enum types in `ParseQueryResponse`.
pub mod parse_query_response {
    #[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Response {
        #[prost(string, tag="1")]
        ResponseType(::prost::alloc::string::String),
        #[prost(message, tag="2")]
        Error(super::HstpError),
    }
}
/// *
/// Links is a message that contains the links for an entity with the given SWID.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Links {
    #[prost(string, tag="1")]
    pub swid: ::prost::alloc::string::String,
    #[prost(message, repeated, tag="2")]
    pub links_with_this_swid_as_dst: ::prost::alloc::vec::Vec<ReadResponse>,
    #[prost(message, repeated, tag="3")]
    pub links_with_this_swid_as_src: ::prost::alloc::vec::Vec<ReadResponse>,
}
/// *
/// Entities is a message that contains a list of entities.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Entities {
    #[prost(string, repeated, tag="1")]
    pub entities: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
/// *
/// HSTPError is a message that contains an error code and message.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HstpError {
    #[prost(enumeration="ErrorCode", tag="1")]
    pub code: i32,
    #[prost(string, tag="2")]
    pub message: ::prost::alloc::string::String,
    #[prost(string, tag="3")]
    pub swid: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ListenType {
    /// This is the default / unset ListenType value.
    None = 0,
    /// Add a listener for an entity.
    Add = 1,
    /// Remove a listener for an entity.
    Remove = 2,
    /// Add a listener for links to an entity.
    LinksAdd = 3,
    /// Remove a listener for links to an entity.
    LinksRemove = 4,
}
impl ListenType {
    /// 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 {
            ListenType::None => "LISTEN_TYPE_NONE",
            ListenType::Add => "LISTEN_TYPE_ADD",
            ListenType::Remove => "LISTEN_TYPE_REMOVE",
            ListenType::LinksAdd => "LISTEN_TYPE_LINKS_ADD",
            ListenType::LinksRemove => "LISTEN_TYPE_LINKS_REMOVE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "LISTEN_TYPE_NONE" => Some(Self::None),
            "LISTEN_TYPE_ADD" => Some(Self::Add),
            "LISTEN_TYPE_REMOVE" => Some(Self::Remove),
            "LISTEN_TYPE_LINKS_ADD" => Some(Self::LinksAdd),
            "LISTEN_TYPE_LINKS_REMOVE" => Some(Self::LinksRemove),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ListenResponseType {
    /// This is the default / unset ListenType value.
    None = 0,
    /// Listener for entity was added.
    Added = 1,
    /// Listener for entity was removed.
    Removed = 2,
    /// When an entity subscribed to was updated
    Updated = 3,
    /// Listener for link to an entity was added.
    LinksAdded = 4,
    /// Listener for a link to an entity was removed.
    LinksRemoved = 5,
    /// When a link entity subscribed to was updated
    LinksUpdated = 6,
}
impl ListenResponseType {
    /// 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 {
            ListenResponseType::None => "LISTEN_RESPONSE_TYPE_NONE",
            ListenResponseType::Added => "LISTEN_RESPONSE_TYPE_ADDED",
            ListenResponseType::Removed => "LISTEN_RESPONSE_TYPE_REMOVED",
            ListenResponseType::Updated => "LISTEN_RESPONSE_TYPE_UPDATED",
            ListenResponseType::LinksAdded => "LISTEN_RESPONSE_TYPE_LINKS_ADDED",
            ListenResponseType::LinksRemoved => "LISTEN_RESPONSE_TYPE_LINKS_REMOVED",
            ListenResponseType::LinksUpdated => "LISTEN_RESPONSE_TYPE_LINKS_UPDATED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "LISTEN_RESPONSE_TYPE_NONE" => Some(Self::None),
            "LISTEN_RESPONSE_TYPE_ADDED" => Some(Self::Added),
            "LISTEN_RESPONSE_TYPE_REMOVED" => Some(Self::Removed),
            "LISTEN_RESPONSE_TYPE_UPDATED" => Some(Self::Updated),
            "LISTEN_RESPONSE_TYPE_LINKS_ADDED" => Some(Self::LinksAdded),
            "LISTEN_RESPONSE_TYPE_LINKS_REMOVED" => Some(Self::LinksRemoved),
            "LISTEN_RESPONSE_TYPE_LINKS_UPDATED" => Some(Self::LinksUpdated),
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum CollisionStrategy {
    None = 0,
    Fail = 1,
    Merge = 2,
    Overwrite = 3,
    ForceOverwrite = 4,
}
impl CollisionStrategy {
    /// 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 {
            CollisionStrategy::None => "COLLISION_STRATEGY_NONE",
            CollisionStrategy::Fail => "COLLISION_STRATEGY_FAIL",
            CollisionStrategy::Merge => "COLLISION_STRATEGY_MERGE",
            CollisionStrategy::Overwrite => "COLLISION_STRATEGY_OVERWRITE",
            CollisionStrategy::ForceOverwrite => "COLLISION_STRATEGY_FORCE_OVERWRITE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "COLLISION_STRATEGY_NONE" => Some(Self::None),
            "COLLISION_STRATEGY_FAIL" => Some(Self::Fail),
            "COLLISION_STRATEGY_MERGE" => Some(Self::Merge),
            "COLLISION_STRATEGY_OVERWRITE" => Some(Self::Overwrite),
            "COLLISION_STRATEGY_FORCE_OVERWRITE" => Some(Self::ForceOverwrite),
            _ => None,
        }
    }
}
/// *
/// This type enumerates the type of ingestion that the server can handle.
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum IngestType {
    /// this is an invalid type and will error if used, but is required by CI 
    None = 0,
    Json = 1,
    Csv = 2,
}
impl IngestType {
    /// 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 {
            IngestType::None => "INGEST_TYPE_NONE",
            IngestType::Json => "INGEST_TYPE_JSON",
            IngestType::Csv => "INGEST_TYPE_CSV",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "INGEST_TYPE_NONE" => Some(Self::None),
            "INGEST_TYPE_JSON" => Some(Self::Json),
            "INGEST_TYPE_CSV" => Some(Self::Csv),
            _ => None,
        }
    }
}
/// *
/// ErrorCode enumerates all error codes.
/// kortex_gen_grpc::hstp::v1::ErrorCode;
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ErrorCode {
    None = 0,
    MissingProperty = 1,
    SchemaValidation = 2,
    EntityNotFound = 3,
    InvalidEntity = 4,
    /// deprecated
    ImmudbError = 5,
    EntityParseError = 6,
    EntitySerializeError = 7,
    UpsertCollision = 8,
    ParseQueryError = 9,
    QueryDimensionMismatch = 10,
    NotImplemented = 11,
    UnhandledError = 12,
    LinksParseError = 13,
    EmbeddedProgramExecuteError = 14,
    SchemaEmbeddingError = 15,
    CozoDbError = 16,
    /// schemas can't be updated unless forced
    CannotUpdateSchema = 17,
    RocksdbError = 18,
    FasttextError = 19,
    InsufficientPermissions = 20,
    /// not allowed to perform this action regardless of permissions
    NotAllowed = 21,
    CsvIngestError = 22,
    /// not a query error (9)
    InvalidHsqlInstruction = 23,
    /// hsql value cannot be compared, sorted etc. or is not expected type
    InvalidOperator = 24,
    /// 2 entities or more with same name etc.
    EntityCollision = 25,
    /// chrono bug
    ClockError = 26,
    TokenExpired = 27,
    JwtParseError = 28,
    JwtNoKeyId = 29,
    JwtNoKeyMatch = 30,
    JwtDecodeError = 31,
    DuplicateFactor = 32,
}
impl ErrorCode {
    /// 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 {
            ErrorCode::None => "ERROR_CODE_NONE",
            ErrorCode::MissingProperty => "ERROR_CODE_MISSING_PROPERTY",
            ErrorCode::SchemaValidation => "ERROR_CODE_SCHEMA_VALIDATION",
            ErrorCode::EntityNotFound => "ERROR_CODE_ENTITY_NOT_FOUND",
            ErrorCode::InvalidEntity => "ERROR_CODE_INVALID_ENTITY",
            ErrorCode::ImmudbError => "ERROR_CODE_IMMUDB_ERROR",
            ErrorCode::EntityParseError => "ERROR_CODE_ENTITY_PARSE_ERROR",
            ErrorCode::EntitySerializeError => "ERROR_CODE_ENTITY_SERIALIZE_ERROR",
            ErrorCode::UpsertCollision => "ERROR_CODE_UPSERT_COLLISION",
            ErrorCode::ParseQueryError => "ERROR_CODE_PARSE_QUERY_ERROR",
            ErrorCode::QueryDimensionMismatch => "ERROR_CODE_QUERY_DIMENSION_MISMATCH",
            ErrorCode::NotImplemented => "ERROR_CODE_NOT_IMPLEMENTED",
            ErrorCode::UnhandledError => "ERROR_CODE_UNHANDLED_ERROR",
            ErrorCode::LinksParseError => "ERROR_CODE_LINKS_PARSE_ERROR",
            ErrorCode::EmbeddedProgramExecuteError => "ERROR_CODE_EMBEDDED_PROGRAM_EXECUTE_ERROR",
            ErrorCode::SchemaEmbeddingError => "ERROR_CODE_SCHEMA_EMBEDDING_ERROR",
            ErrorCode::CozoDbError => "ERROR_CODE_COZO_DB_ERROR",
            ErrorCode::CannotUpdateSchema => "ERROR_CODE_CANNOT_UPDATE_SCHEMA",
            ErrorCode::RocksdbError => "ERROR_CODE_ROCKSDB_ERROR",
            ErrorCode::FasttextError => "ERROR_CODE_FASTTEXT_ERROR",
            ErrorCode::InsufficientPermissions => "ERROR_CODE_INSUFFICIENT_PERMISSIONS",
            ErrorCode::NotAllowed => "ERROR_CODE_NOT_ALLOWED",
            ErrorCode::CsvIngestError => "ERROR_CODE_CSV_INGEST_ERROR",
            ErrorCode::InvalidHsqlInstruction => "ERROR_CODE_INVALID_HSQL_INSTRUCTION",
            ErrorCode::InvalidOperator => "ERROR_CODE_INVALID_OPERATOR",
            ErrorCode::EntityCollision => "ERROR_CODE_ENTITY_COLLISION",
            ErrorCode::ClockError => "ERROR_CODE_CLOCK_ERROR",
            ErrorCode::TokenExpired => "ERROR_CODE_TOKEN_EXPIRED",
            ErrorCode::JwtParseError => "ERROR_CODE_JWT_PARSE_ERROR",
            ErrorCode::JwtNoKeyId => "ERROR_CODE_JWT_NO_KEY_ID",
            ErrorCode::JwtNoKeyMatch => "ERROR_CODE_JWT_NO_KEY_MATCH",
            ErrorCode::JwtDecodeError => "ERROR_CODE_JWT_DECODE_ERROR",
            ErrorCode::DuplicateFactor => "ERROR_CODE_DUPLICATE_FACTOR",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "ERROR_CODE_NONE" => Some(Self::None),
            "ERROR_CODE_MISSING_PROPERTY" => Some(Self::MissingProperty),
            "ERROR_CODE_SCHEMA_VALIDATION" => Some(Self::SchemaValidation),
            "ERROR_CODE_ENTITY_NOT_FOUND" => Some(Self::EntityNotFound),
            "ERROR_CODE_INVALID_ENTITY" => Some(Self::InvalidEntity),
            "ERROR_CODE_IMMUDB_ERROR" => Some(Self::ImmudbError),
            "ERROR_CODE_ENTITY_PARSE_ERROR" => Some(Self::EntityParseError),
            "ERROR_CODE_ENTITY_SERIALIZE_ERROR" => Some(Self::EntitySerializeError),
            "ERROR_CODE_UPSERT_COLLISION" => Some(Self::UpsertCollision),
            "ERROR_CODE_PARSE_QUERY_ERROR" => Some(Self::ParseQueryError),
            "ERROR_CODE_QUERY_DIMENSION_MISMATCH" => Some(Self::QueryDimensionMismatch),
            "ERROR_CODE_NOT_IMPLEMENTED" => Some(Self::NotImplemented),
            "ERROR_CODE_UNHANDLED_ERROR" => Some(Self::UnhandledError),
            "ERROR_CODE_LINKS_PARSE_ERROR" => Some(Self::LinksParseError),
            "ERROR_CODE_EMBEDDED_PROGRAM_EXECUTE_ERROR" => Some(Self::EmbeddedProgramExecuteError),
            "ERROR_CODE_SCHEMA_EMBEDDING_ERROR" => Some(Self::SchemaEmbeddingError),
            "ERROR_CODE_COZO_DB_ERROR" => Some(Self::CozoDbError),
            "ERROR_CODE_CANNOT_UPDATE_SCHEMA" => Some(Self::CannotUpdateSchema),
            "ERROR_CODE_ROCKSDB_ERROR" => Some(Self::RocksdbError),
            "ERROR_CODE_FASTTEXT_ERROR" => Some(Self::FasttextError),
            "ERROR_CODE_INSUFFICIENT_PERMISSIONS" => Some(Self::InsufficientPermissions),
            "ERROR_CODE_NOT_ALLOWED" => Some(Self::NotAllowed),
            "ERROR_CODE_CSV_INGEST_ERROR" => Some(Self::CsvIngestError),
            "ERROR_CODE_INVALID_HSQL_INSTRUCTION" => Some(Self::InvalidHsqlInstruction),
            "ERROR_CODE_INVALID_OPERATOR" => Some(Self::InvalidOperator),
            "ERROR_CODE_ENTITY_COLLISION" => Some(Self::EntityCollision),
            "ERROR_CODE_CLOCK_ERROR" => Some(Self::ClockError),
            "ERROR_CODE_TOKEN_EXPIRED" => Some(Self::TokenExpired),
            "ERROR_CODE_JWT_PARSE_ERROR" => Some(Self::JwtParseError),
            "ERROR_CODE_JWT_NO_KEY_ID" => Some(Self::JwtNoKeyId),
            "ERROR_CODE_JWT_NO_KEY_MATCH" => Some(Self::JwtNoKeyMatch),
            "ERROR_CODE_JWT_DECODE_ERROR" => Some(Self::JwtDecodeError),
            "ERROR_CODE_DUPLICATE_FACTOR" => Some(Self::DuplicateFactor),
            _ => None,
        }
    }
}
/// *
/// IdentityProvider enumerates all identity providers.
/// DEPRECATED: Client initiates auth flow outside of this API.
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum IdentityProvider {
    None = 0,
    Auth0 = 1,
    Google = 2,
    Microsoft = 3,
    Okta = 4,
    Facebook = 5,
    Github = 6,
    /// Previously Twitter
    X = 7,
    Linkedin = 8,
    Apple = 9,
}
impl IdentityProvider {
    /// 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 {
            IdentityProvider::None => "IDENTITY_PROVIDER_NONE",
            IdentityProvider::Auth0 => "IDENTITY_PROVIDER_AUTH0",
            IdentityProvider::Google => "IDENTITY_PROVIDER_GOOGLE",
            IdentityProvider::Microsoft => "IDENTITY_PROVIDER_MICROSOFT",
            IdentityProvider::Okta => "IDENTITY_PROVIDER_OKTA",
            IdentityProvider::Facebook => "IDENTITY_PROVIDER_FACEBOOK",
            IdentityProvider::Github => "IDENTITY_PROVIDER_GITHUB",
            IdentityProvider::X => "IDENTITY_PROVIDER_X",
            IdentityProvider::Linkedin => "IDENTITY_PROVIDER_LINKEDIN",
            IdentityProvider::Apple => "IDENTITY_PROVIDER_APPLE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "IDENTITY_PROVIDER_NONE" => Some(Self::None),
            "IDENTITY_PROVIDER_AUTH0" => Some(Self::Auth0),
            "IDENTITY_PROVIDER_GOOGLE" => Some(Self::Google),
            "IDENTITY_PROVIDER_MICROSOFT" => Some(Self::Microsoft),
            "IDENTITY_PROVIDER_OKTA" => Some(Self::Okta),
            "IDENTITY_PROVIDER_FACEBOOK" => Some(Self::Facebook),
            "IDENTITY_PROVIDER_GITHUB" => Some(Self::Github),
            "IDENTITY_PROVIDER_X" => Some(Self::X),
            "IDENTITY_PROVIDER_LINKEDIN" => Some(Self::Linkedin),
            "IDENTITY_PROVIDER_APPLE" => Some(Self::Apple),
            _ => None,
        }
    }
}
include!("hstp.v1.tonic.rs");
// @@protoc_insertion_point(module)