nominal-api-proto 0.1479.0

// This file is @generated by prost-build.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateDriveIndexJobRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateDriveIndexJobResponse {
    #[prost(message, optional, tag = "1")]
    pub drive_index_job: ::core::option::Option<DriveIndexJob>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDriveIndexJobRequest {
    #[prost(string, tag = "1")]
    pub drive_index_job_rid: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDriveIndexJobResponse {
    #[prost(message, optional, tag = "1")]
    pub drive_index_job: ::core::option::Option<DriveIndexJob>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListDriveIndexJobsRequest {
    #[prost(int32, optional, tag = "1")]
    pub page_size: ::core::option::Option<i32>,
    #[prost(string, tag = "2")]
    pub page_token: ::prost::alloc::string::String,
    #[prost(string, optional, tag = "10")]
    pub drive_rid: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListDriveIndexJobsResponse {
    #[prost(message, repeated, tag = "1")]
    pub drive_index_jobs: ::prost::alloc::vec::Vec<DriveIndexJobSummary>,
    #[prost(string, tag = "2")]
    pub next_page_token: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListDriveIndexJobSourcesRequest {
    #[prost(string, tag = "1")]
    pub drive_index_job_rid: ::prost::alloc::string::String,
    #[prost(int32, optional, tag = "2")]
    pub page_size: ::core::option::Option<i32>,
    #[prost(string, tag = "3")]
    pub page_token: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListDriveIndexJobSourcesResponse {
    #[prost(message, repeated, tag = "1")]
    pub sources: ::prost::alloc::vec::Vec<DriveIndexSourceExecution>,
    #[prost(string, tag = "2")]
    pub next_page_token: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DriveIndexJobSummary {
    #[prost(string, tag = "1")]
    pub drive_index_job_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(enumeration = "DriveIndexJobState", tag = "3")]
    pub state: i32,
    #[prost(uint64, tag = "4")]
    pub completed_source_count: u64,
    #[prost(uint64, tag = "5")]
    pub successful_chunk_count: u64,
    #[prost(message, optional, tag = "6")]
    pub created_at: ::core::option::Option<
        super::super::super::google::protobuf::Timestamp,
    >,
    #[prost(uint64, tag = "7")]
    pub admitted_source_count: u64,
    #[prost(bool, tag = "8")]
    pub enumeration_complete: bool,
    #[prost(message, optional, tag = "10")]
    pub debug: ::core::option::Option<DriveIndexJobSummaryDebug>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DriveIndexJob {
    #[prost(string, tag = "1")]
    pub drive_index_job_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(enumeration = "DriveIndexJobState", tag = "3")]
    pub state: i32,
    #[prost(uint64, tag = "4")]
    pub completed_source_count: u64,
    #[prost(uint64, tag = "5")]
    pub successful_chunk_count: u64,
    #[prost(message, repeated, tag = "6")]
    pub sources: ::prost::alloc::vec::Vec<DriveIndexSourceExecution>,
    #[prost(bool, tag = "7")]
    pub sources_truncated: bool,
    #[prost(uint64, tag = "8")]
    pub admitted_source_count: u64,
    #[prost(bool, tag = "9")]
    pub enumeration_complete: bool,
    #[prost(string, repeated, tag = "10")]
    pub run_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(bool, tag = "11")]
    pub temporal_history_available: bool,
    #[prost(message, optional, tag = "20")]
    pub debug: ::core::option::Option<DriveIndexJobDebug>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DriveIndexSourceExecution {
    #[prost(string, tag = "1")]
    pub source_rid: ::prost::alloc::string::String,
    #[prost(enumeration = "DriveIndexSourceExecutionState", tag = "2")]
    pub state: i32,
    #[prost(string, tag = "3")]
    pub failure_category: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub revision_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "5")]
    pub child_workflow_id: ::prost::alloc::string::String,
    #[prost(string, tag = "6")]
    pub child_run_id: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "10")]
    pub debug: ::core::option::Option<DriveIndexSourceExecutionDebug>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct KnowledgeChunk {
    #[prost(string, tag = "1")]
    pub sample_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub source_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub source_locator: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub partition_key: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct QueryRequest {
    #[prost(string, tag = "1")]
    pub query: ::prost::alloc::string::String,
    #[prost(string, tag = "4")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(int32, optional, tag = "2")]
    pub page_size: ::core::option::Option<i32>,
    #[prost(string, tag = "3")]
    pub page_token: ::prost::alloc::string::String,
    #[prost(bool, optional, tag = "10")]
    pub include_debug: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct QueryResponse {
    #[prost(message, repeated, tag = "1")]
    pub chunks: ::prost::alloc::vec::Vec<KnowledgeChunk>,
    #[prost(string, tag = "2")]
    pub next_page_token: ::prost::alloc::string::String,
    #[prost(message, optional, tag = "10")]
    pub debug: ::core::option::Option<QueryDebug>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DriveIndexJobSummaryDebug {
    #[prost(string, optional, tag = "1")]
    pub workspace_rid: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "2")]
    pub completed_at: ::core::option::Option<
        super::super::super::google::protobuf::Timestamp,
    >,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DriveIndexJobDebug {
    #[prost(message, optional, tag = "1")]
    pub created_at: ::core::option::Option<
        super::super::super::google::protobuf::Timestamp,
    >,
    #[prost(message, optional, tag = "2")]
    pub completed_at: ::core::option::Option<
        super::super::super::google::protobuf::Timestamp,
    >,
    #[prost(string, optional, tag = "3")]
    pub workspace_rid: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "4")]
    pub caller_workspace_rid: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(uint32, optional, tag = "5")]
    pub running_source_count: ::core::option::Option<u32>,
    #[prost(uint32, optional, tag = "6")]
    pub succeeded_source_count: ::core::option::Option<u32>,
    #[prost(uint32, optional, tag = "7")]
    pub failed_source_count: ::core::option::Option<u32>,
    #[prost(message, repeated, tag = "8")]
    pub failed_source_counts: ::prost::alloc::vec::Vec<FailedSourceCategoryCount>,
    #[prost(message, repeated, tag = "9")]
    pub attention_list: ::prost::alloc::vec::Vec<DriveIndexSourceExecution>,
    #[prost(bool, optional, tag = "10")]
    pub attention_list_truncated: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FailedSourceCategoryCount {
    #[prost(string, optional, tag = "1")]
    pub failure_category: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(uint32, optional, tag = "2")]
    pub count: ::core::option::Option<u32>,
}
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DriveIndexSourceExecutionDebug {
    #[prost(message, optional, tag = "1")]
    pub started_at: ::core::option::Option<
        super::super::super::google::protobuf::Timestamp,
    >,
    #[prost(message, optional, tag = "2")]
    pub completed_at: ::core::option::Option<
        super::super::super::google::protobuf::Timestamp,
    >,
    #[prost(uint32, optional, tag = "3")]
    pub chunk_count: ::core::option::Option<u32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct QueryDebug {
    #[prost(string, optional, tag = "1")]
    pub searched_workspace_rid: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, repeated, tag = "2")]
    pub retrievers: ::prost::alloc::vec::Vec<QueryRetrieverDebug>,
    #[prost(string, optional, tag = "3")]
    pub fusion_rule: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "4")]
    pub normalization_rule: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "5")]
    pub tie_break_rule: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(uint32, optional, tag = "6")]
    pub distinct_candidate_count: ::core::option::Option<u32>,
    #[prost(string, repeated, tag = "7")]
    pub query_terms: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(uint32, optional, tag = "8")]
    pub query_term_count: ::core::option::Option<u32>,
    #[prost(bool, optional, tag = "9")]
    pub query_terms_truncated: ::core::option::Option<bool>,
    #[prost(message, repeated, tag = "10")]
    pub candidates: ::prost::alloc::vec::Vec<QueryCandidateDebug>,
    #[prost(message, repeated, tag = "11")]
    pub excluded_candidates: ::prost::alloc::vec::Vec<QueryCandidateDebug>,
    #[prost(bool, optional, tag = "12")]
    pub excluded_candidates_truncated: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "13")]
    pub embedding: ::core::option::Option<KnowledgeEmbeddingDebug>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct QueryRetrieverDebug {
    #[prost(string, optional, tag = "1")]
    pub retriever_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "2")]
    pub representation_id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(double, optional, tag = "3")]
    pub weight: ::core::option::Option<f64>,
    #[prost(string, optional, tag = "4")]
    pub skip_reason: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(uint32, optional, tag = "5")]
    pub candidate_count: ::core::option::Option<u32>,
    #[prost(uint32, optional, tag = "6")]
    pub candidate_limit: ::core::option::Option<u32>,
    #[prost(bool, optional, tag = "7")]
    pub limit_reached: ::core::option::Option<bool>,
    #[prost(string, optional, tag = "8")]
    pub limit_order: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(double, optional, tag = "9")]
    pub normalization_min: ::core::option::Option<f64>,
    #[prost(double, optional, tag = "10")]
    pub normalization_max: ::core::option::Option<f64>,
    #[prost(bool, optional, tag = "11")]
    pub excluded_list_truncated: ::core::option::Option<bool>,
    #[prost(map = "string, double", tag = "12")]
    pub parameters: ::std::collections::HashMap<::prost::alloc::string::String, f64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct QueryCandidateDebug {
    #[prost(string, optional, tag = "1")]
    pub sample_rid: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(uint32, optional, tag = "2")]
    pub fused_rank: ::core::option::Option<u32>,
    #[prost(double, optional, tag = "3")]
    pub fused_score: ::core::option::Option<f64>,
    #[prost(message, repeated, tag = "4")]
    pub scores: ::prost::alloc::vec::Vec<QueryRetrieverScoreDebug>,
    #[prost(string, optional, tag = "5")]
    pub withheld_reason: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "6")]
    pub chunk_pointer: ::core::option::Option<KnowledgeChunk>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct QueryRetrieverScoreDebug {
    #[prost(string, optional, tag = "1")]
    pub retriever_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "2")]
    pub matched: ::core::option::Option<bool>,
    #[prost(uint32, optional, tag = "3")]
    pub rank: ::core::option::Option<u32>,
    #[prost(double, optional, tag = "4")]
    pub raw_score: ::core::option::Option<f64>,
    #[prost(double, optional, tag = "5")]
    pub normalized_score: ::core::option::Option<f64>,
    #[prost(double, optional, tag = "6")]
    pub weighted_score: ::core::option::Option<f64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct KnowledgeEmbeddingDebug {
    #[prost(string, optional, tag = "1")]
    pub provider: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "2")]
    pub text_embedder_active: ::core::option::Option<bool>,
    #[prost(string, optional, tag = "3")]
    pub active_text_representation_id: ::core::option::Option<
        ::prost::alloc::string::String,
    >,
    #[prost(string, optional, tag = "4")]
    pub active_multimodal_representation_id: ::core::option::Option<
        ::prost::alloc::string::String,
    >,
    #[prost(string, repeated, tag = "5")]
    pub written_representation_ids: ::prost::alloc::vec::Vec<
        ::prost::alloc::string::String,
    >,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListSourceChunkDebugRequest {
    #[prost(string, tag = "1")]
    pub drive_rid: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub source_rid: ::prost::alloc::string::String,
    #[prost(uint32, optional, tag = "3")]
    pub page_size: ::core::option::Option<u32>,
    #[prost(string, optional, tag = "4")]
    pub page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListSourceChunkDebugResponse {
    #[prost(message, repeated, tag = "1")]
    pub chunks: ::prost::alloc::vec::Vec<KnowledgeChunkDebug>,
    #[prost(string, optional, tag = "2")]
    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(message, optional, tag = "3")]
    pub source: ::core::option::Option<KnowledgeSourceDebug>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct KnowledgeSourceDebug {
    #[prost(uint32, optional, tag = "1")]
    pub stored_chunk_count: ::core::option::Option<u32>,
    #[prost(string, repeated, tag = "2")]
    pub partitions: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(bool, optional, tag = "3")]
    pub partitions_truncated: ::core::option::Option<bool>,
    #[prost(message, optional, tag = "4")]
    pub embedding: ::core::option::Option<KnowledgeEmbeddingDebug>,
    #[prost(message, repeated, tag = "5")]
    pub representation_chunk_counts: ::prost::alloc::vec::Vec<RepresentationChunkCount>,
    #[prost(message, optional, tag = "6")]
    pub latest_execution: ::core::option::Option<DriveIndexSourceExecution>,
    #[prost(bool, optional, tag = "7")]
    pub representation_chunk_counts_truncated: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RepresentationChunkCount {
    #[prost(string, optional, tag = "1")]
    pub representation_id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(uint32, optional, tag = "2")]
    pub chunk_count: ::core::option::Option<u32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct KnowledgeChunkDebug {
    #[prost(message, optional, tag = "1")]
    pub chunk_pointer: ::core::option::Option<KnowledgeChunk>,
    #[prost(message, repeated, tag = "2")]
    pub lexemes: ::prost::alloc::vec::Vec<KnowledgeLexemeDebug>,
    #[prost(bool, optional, tag = "3")]
    pub lexemes_truncated: ::core::option::Option<bool>,
    #[prost(uint32, optional, tag = "4")]
    pub stored_document_length: ::core::option::Option<u32>,
    #[prost(message, repeated, tag = "5")]
    pub representations: ::prost::alloc::vec::Vec<KnowledgeRepresentationDebug>,
    #[prost(bool, optional, tag = "6")]
    pub representations_truncated: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct KnowledgeLexemeDebug {
    #[prost(string, optional, tag = "1")]
    pub term: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(uint32, optional, tag = "2")]
    pub count: ::core::option::Option<u32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct KnowledgeRepresentationDebug {
    #[prost(string, optional, tag = "1")]
    pub representation_id: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "2")]
    pub family: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "3")]
    pub provider: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "4")]
    pub model: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(uint32, optional, tag = "5")]
    pub dimensions: ::core::option::Option<u32>,
    #[prost(double, optional, tag = "6")]
    pub l2_norm: ::core::option::Option<f64>,
    #[prost(double, repeated, packed = "false", tag = "7")]
    pub first_values: ::prost::alloc::vec::Vec<f64>,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum DriveIndexJobState {
    Unspecified = 0,
    Queued = 1,
    Running = 2,
    Succeeded = 3,
    SucceededWithFailures = 4,
}
impl DriveIndexJobState {
    /// 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 => "DRIVE_INDEX_JOB_STATE_UNSPECIFIED",
            Self::Queued => "DRIVE_INDEX_JOB_STATE_QUEUED",
            Self::Running => "DRIVE_INDEX_JOB_STATE_RUNNING",
            Self::Succeeded => "DRIVE_INDEX_JOB_STATE_SUCCEEDED",
            Self::SucceededWithFailures => {
                "DRIVE_INDEX_JOB_STATE_SUCCEEDED_WITH_FAILURES"
            }
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "DRIVE_INDEX_JOB_STATE_UNSPECIFIED" => Some(Self::Unspecified),
            "DRIVE_INDEX_JOB_STATE_QUEUED" => Some(Self::Queued),
            "DRIVE_INDEX_JOB_STATE_RUNNING" => Some(Self::Running),
            "DRIVE_INDEX_JOB_STATE_SUCCEEDED" => Some(Self::Succeeded),
            "DRIVE_INDEX_JOB_STATE_SUCCEEDED_WITH_FAILURES" => {
                Some(Self::SucceededWithFailures)
            }
            _ => None,
        }
    }
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum DriveIndexSourceExecutionState {
    Unspecified = 0,
    Succeeded = 1,
    PermanentlyFailed = 2,
    Running = 3,
}
impl DriveIndexSourceExecutionState {
    /// 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 => "DRIVE_INDEX_SOURCE_EXECUTION_STATE_UNSPECIFIED",
            Self::Succeeded => "DRIVE_INDEX_SOURCE_EXECUTION_STATE_SUCCEEDED",
            Self::PermanentlyFailed => {
                "DRIVE_INDEX_SOURCE_EXECUTION_STATE_PERMANENTLY_FAILED"
            }
            Self::Running => "DRIVE_INDEX_SOURCE_EXECUTION_STATE_RUNNING",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "DRIVE_INDEX_SOURCE_EXECUTION_STATE_UNSPECIFIED" => Some(Self::Unspecified),
            "DRIVE_INDEX_SOURCE_EXECUTION_STATE_SUCCEEDED" => Some(Self::Succeeded),
            "DRIVE_INDEX_SOURCE_EXECUTION_STATE_PERMANENTLY_FAILED" => {
                Some(Self::PermanentlyFailed)
            }
            "DRIVE_INDEX_SOURCE_EXECUTION_STATE_RUNNING" => Some(Self::Running),
            _ => None,
        }
    }
}
/// Generated client implementations.
pub mod knowledge_service_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 KnowledgeServiceClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl KnowledgeServiceClient<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> KnowledgeServiceClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::Body>,
        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,
        ) -> KnowledgeServiceClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::Body>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::Body>,
            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
        {
            KnowledgeServiceClient::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
        }
        pub async fn create_drive_index_job(
            &mut self,
            request: impl tonic::IntoRequest<super::CreateDriveIndexJobRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CreateDriveIndexJobResponse>,
            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(
                "/nominal.knowledge.v1.KnowledgeService/CreateDriveIndexJob",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.knowledge.v1.KnowledgeService",
                        "CreateDriveIndexJob",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_drive_index_job(
            &mut self,
            request: impl tonic::IntoRequest<super::GetDriveIndexJobRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetDriveIndexJobResponse>,
            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(
                "/nominal.knowledge.v1.KnowledgeService/GetDriveIndexJob",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.knowledge.v1.KnowledgeService",
                        "GetDriveIndexJob",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_drive_index_jobs(
            &mut self,
            request: impl tonic::IntoRequest<super::ListDriveIndexJobsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListDriveIndexJobsResponse>,
            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(
                "/nominal.knowledge.v1.KnowledgeService/ListDriveIndexJobs",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.knowledge.v1.KnowledgeService",
                        "ListDriveIndexJobs",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_drive_index_job_sources(
            &mut self,
            request: impl tonic::IntoRequest<super::ListDriveIndexJobSourcesRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListDriveIndexJobSourcesResponse>,
            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(
                "/nominal.knowledge.v1.KnowledgeService/ListDriveIndexJobSources",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.knowledge.v1.KnowledgeService",
                        "ListDriveIndexJobSources",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn query(
            &mut self,
            request: impl tonic::IntoRequest<super::QueryRequest>,
        ) -> std::result::Result<tonic::Response<super::QueryResponse>, 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(
                "/nominal.knowledge.v1.KnowledgeService/Query",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("nominal.knowledge.v1.KnowledgeService", "Query"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_source_chunk_debug(
            &mut self,
            request: impl tonic::IntoRequest<super::ListSourceChunkDebugRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListSourceChunkDebugResponse>,
            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(
                "/nominal.knowledge.v1.KnowledgeService/ListSourceChunkDebug",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "nominal.knowledge.v1.KnowledgeService",
                        "ListSourceChunkDebug",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
    }
}