Current section
Files
Jump to
Current section
Files
lib/ada/v1/ingest.pb.ex
defmodule Ada.V1.IngestMode do
@moduledoc false
use Protobuf,
enum: true,
full_name: "ada.v1.IngestMode",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:INGEST_MODE_UNSPECIFIED, 0)
field(:INGEST_MODE_DOCUMENT, 1)
end
defmodule Ada.V1.DocumentStatus do
@moduledoc false
use Protobuf,
enum: true,
full_name: "ada.v1.DocumentStatus",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:DOCUMENT_STATUS_UNSPECIFIED, 0)
field(:DOCUMENT_STATUS_PENDING, 1)
field(:DOCUMENT_STATUS_PROCESSING, 2)
field(:DOCUMENT_STATUS_COMPLETED, 3)
field(:DOCUMENT_STATUS_FAILED, 4)
end
defmodule Ada.V1.IngestJobStatus do
@moduledoc false
use Protobuf,
enum: true,
full_name: "ada.v1.IngestJobStatus",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:INGEST_JOB_STATUS_UNSPECIFIED, 0)
field(:INGEST_JOB_STATUS_PENDING, 1)
field(:INGEST_JOB_STATUS_RUNNING, 2)
field(:INGEST_JOB_STATUS_COMPLETED, 3)
field(:INGEST_JOB_STATUS_FAILED, 4)
field(:INGEST_JOB_STATUS_CANCELED, 5)
field(:INGEST_JOB_STATUS_RETRYING, 6)
end
defmodule Ada.V1.IngestJobStage do
@moduledoc false
use Protobuf,
enum: true,
full_name: "ada.v1.IngestJobStage",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:INGEST_JOB_STAGE_UNSPECIFIED, 0)
field(:INGEST_JOB_STAGE_DOCUMENT_REGISTRATION, 1)
field(:INGEST_JOB_STAGE_CONTENT_EXTRACTION, 2)
field(:INGEST_JOB_STAGE_CHUNKING, 3)
field(:INGEST_JOB_STAGE_EMBEDDING, 4)
field(:INGEST_JOB_STAGE_ENTITY_EXTRACTION, 5)
field(:INGEST_JOB_STAGE_RELATION_EXTRACTION, 6)
field(:INGEST_JOB_STAGE_ATOM_EXTRACTION, 7)
field(:INGEST_JOB_STAGE_DEDUPLICATION, 8)
field(:INGEST_JOB_STAGE_CONFLICT_RESOLUTION, 9)
field(:INGEST_JOB_STAGE_GRAPH_PERSISTENCE, 10)
field(:INGEST_JOB_STAGE_VECTOR_PERSISTENCE, 11)
field(:INGEST_JOB_STAGE_COMMUNITY_DETECTION, 12)
field(:INGEST_JOB_STAGE_TEMPORAL_GRAPH, 13)
field(:INGEST_JOB_STAGE_COMPLETION, 14)
field(:INGEST_JOB_STAGE_DISTILLING, 15)
field(:INGEST_JOB_STAGE_RECALLING, 16)
field(:INGEST_JOB_STAGE_RETRYING, 17)
end
defmodule Ada.V1.IngestAccountingStatus do
@moduledoc false
use Protobuf,
enum: true,
full_name: "ada.v1.IngestAccountingStatus",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:INGEST_ACCOUNTING_STATUS_UNSPECIFIED, 0)
field(:INGEST_ACCOUNTING_STATUS_PENDING, 1)
field(:INGEST_ACCOUNTING_STATUS_COMPUTED, 2)
field(:INGEST_ACCOUNTING_STATUS_FAILED, 3)
end
defmodule Ada.V1.AccountingContext do
@moduledoc false
use Protobuf,
full_name: "ada.v1.AccountingContext",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:organization_id, 1, type: :string, json_name: "organizationId")
field(:project_id, 2, type: :string, json_name: "projectId")
field(:principal_id, 3, type: :string, json_name: "principalId")
field(:invocation_id, 4, type: :string, json_name: "invocationId")
field(:run_id, 5, type: :string, json_name: "runId")
field(:tool_invocation_id, 6, type: :string, json_name: "toolInvocationId")
field(:tool_attempt_id, 7, type: :string, json_name: "toolAttemptId")
field(:application_name, 8, type: :string, json_name: "applicationName")
field(:resource_name, 9, type: :string, json_name: "resourceName")
field(:tool_name, 10, type: :string, json_name: "toolName")
field(:source_id, 11, type: :string, json_name: "sourceId")
end
defmodule Ada.V1.DocumentPayload do
@moduledoc false
use Protobuf,
full_name: "ada.v1.DocumentPayload",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:title, 1, type: :string)
field(:text, 2, type: :string)
end
defmodule Ada.V1.GetDocumentStatusRequest do
@moduledoc false
use Protobuf,
full_name: "ada.v1.GetDocumentStatusRequest",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:document_id, 1, type: :string, json_name: "documentId")
field(:source_id, 2, type: :string, json_name: "sourceId")
field(:principal_id, 100, type: :string, json_name: "principalId")
end
defmodule Ada.V1.GetDocumentStatusResponse do
@moduledoc false
use Protobuf,
full_name: "ada.v1.GetDocumentStatusResponse",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:found, 1, type: :bool)
field(:document_id, 2, type: :string, json_name: "documentId")
field(:source_id, 3, type: :string, json_name: "sourceId")
field(:status, 4, type: Ada.V1.DocumentStatus, enum: true)
field(:version, 5, type: :int32)
field(:size_bytes, 6, type: :int64, json_name: "sizeBytes")
field(:chunk_count, 7, type: :int32, json_name: "chunkCount")
field(:created_at, 8, type: Google.Protobuf.Timestamp, json_name: "createdAt")
field(:updated_at, 9, type: Google.Protobuf.Timestamp, json_name: "updatedAt")
field(:name, 10, type: :string)
field(:mime_type, 11, type: :string, json_name: "mimeType")
end
defmodule Ada.V1.GetJobStatusRequest do
@moduledoc false
use Protobuf,
full_name: "ada.v1.GetJobStatusRequest",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:job_id, 1, type: :string, json_name: "jobId")
field(:principal_id, 100, type: :string, json_name: "principalId")
end
defmodule Ada.V1.GetJobStatusResponse do
@moduledoc false
use Protobuf,
full_name: "ada.v1.GetJobStatusResponse",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:found, 1, type: :bool)
field(:job, 2, type: Ada.V1.JobStatus)
end
defmodule Ada.V1.GetIngestAccountingRequest do
@moduledoc false
use Protobuf,
full_name: "ada.v1.GetIngestAccountingRequest",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:job_id, 1, type: :string, json_name: "jobId")
field(:principal_id, 100, type: :string, json_name: "principalId")
end
defmodule Ada.V1.IngestAccounting do
@moduledoc false
use Protobuf,
full_name: "ada.v1.IngestAccounting",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:job_id, 1, type: :string, json_name: "jobId")
field(:document_id, 2, type: :string, json_name: "documentId")
field(:status, 3, type: Ada.V1.IngestAccountingStatus, enum: true)
field(:accounting_version, 4, type: :int32, json_name: "accountingVersion")
field(:document_size_bytes, 5, type: :int64, json_name: "documentSizeBytes")
field(:chunk_count, 6, type: :int64, json_name: "chunkCount")
field(:postgres_bytes, 7, type: :int64, json_name: "postgresBytes")
field(:postgres_row_count, 8, type: :int64, json_name: "postgresRowCount")
field(:qdrant_estimated_bytes, 9, type: :int64, json_name: "qdrantEstimatedBytes")
field(:qdrant_point_count, 10, type: :int64, json_name: "qdrantPointCount")
field(:qdrant_vector_dimensions, 11, type: :int32, json_name: "qdrantVectorDimensions")
field(:neo4j_estimated_bytes, 12, type: :int64, json_name: "neo4jEstimatedBytes")
field(:neo4j_statement_count, 13, type: :int64, json_name: "neo4jStatementCount")
field(:object_store_bytes, 14, type: :int64, json_name: "objectStoreBytes")
field(:total_estimated_bytes, 15, type: :int64, json_name: "totalEstimatedBytes")
field(:details, 16, type: Google.Protobuf.Struct)
field(:error, 17, type: :string)
field(:computed_at, 18, type: Google.Protobuf.Timestamp, json_name: "computedAt")
field(:created_at, 19, type: Google.Protobuf.Timestamp, json_name: "createdAt")
field(:updated_at, 20, type: Google.Protobuf.Timestamp, json_name: "updatedAt")
end
defmodule Ada.V1.GetIngestAccountingResponse do
@moduledoc false
use Protobuf,
full_name: "ada.v1.GetIngestAccountingResponse",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:found, 1, type: :bool)
field(:accounting, 2, type: Ada.V1.IngestAccounting)
end
defmodule Ada.V1.GetLatestJobByDocumentRequest do
@moduledoc false
use Protobuf,
full_name: "ada.v1.GetLatestJobByDocumentRequest",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:document_id, 1, type: :string, json_name: "documentId")
field(:principal_id, 100, type: :string, json_name: "principalId")
end
defmodule Ada.V1.IngestAcceptedResponse do
@moduledoc false
use Protobuf,
full_name: "ada.v1.IngestAcceptedResponse",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:mode, 1, type: Ada.V1.IngestMode, enum: true)
field(:document_id, 2, type: :string, json_name: "documentId")
field(:extraction_model, 3, type: :string, json_name: "extractionModel")
field(:job_id, 4, type: :string, json_name: "jobId")
field(:job_status, 5, type: Ada.V1.IngestJobStatus, json_name: "jobStatus", enum: true)
end
defmodule Ada.V1.IngestRequest.MetadataEntry do
@moduledoc false
use Protobuf,
full_name: "ada.v1.IngestRequest.MetadataEntry",
map: true,
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:key, 1, type: :string)
field(:value, 2, type: :string)
end
defmodule Ada.V1.IngestRequest do
@moduledoc false
use Protobuf,
full_name: "ada.v1.IngestRequest",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:mode, 1, type: Ada.V1.IngestMode, enum: true)
field(:document, 4, type: Ada.V1.DocumentPayload)
field(:source, 5, type: Ada.V1.SourcePayload)
field(:metadata, 6, repeated: true, type: Ada.V1.IngestRequest.MetadataEntry, map: true)
field(:include_details, 7, proto3_optional: true, type: :bool, json_name: "includeDetails")
field(:reference_time_utc, 8,
proto3_optional: true,
type: Google.Protobuf.Timestamp,
json_name: "referenceTimeUtc"
)
field(:extraction_model, 9, proto3_optional: true, type: :string, json_name: "extractionModel")
field(:distill_model, 10, proto3_optional: true, type: :string, json_name: "distillModel")
field(:available_tokens, 12, type: :int64, json_name: "availableTokens")
field(:accounting_context, 13, type: Ada.V1.AccountingContext, json_name: "accountingContext")
field(:principal_id, 100, type: :string, json_name: "principalId")
end
defmodule Ada.V1.EstimateIngestRequest do
@moduledoc false
use Protobuf,
full_name: "ada.v1.EstimateIngestRequest",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:text, 1, type: :string)
field(:principal_id, 100, type: :string, json_name: "principalId")
end
defmodule Ada.V1.EstimateIngestResponse do
@moduledoc false
use Protobuf,
full_name: "ada.v1.EstimateIngestResponse",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:estimated_tokens, 1, type: :int64, json_name: "estimatedTokens")
field(:sufficient, 2, type: :bool)
field(:available_tokens, 3, type: :int64, json_name: "availableTokens")
end
defmodule Ada.V1.JobProgress do
@moduledoc false
use Protobuf,
full_name: "ada.v1.JobProgress",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:stage, 1, type: Ada.V1.IngestJobStage, enum: true)
field(:percentage, 2, type: :int32)
field(:overall_percentage, 3, type: :int32, json_name: "overallPercentage")
field(:message, 4, type: :string)
end
defmodule Ada.V1.JobStatus do
@moduledoc false
use Protobuf,
full_name: "ada.v1.JobStatus",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:id, 1, type: :string)
field(:document_id, 2, type: :string, json_name: "documentId")
field(:source_id, 3, type: :string, json_name: "sourceId")
field(:content_type, 4, type: :string, json_name: "contentType")
field(:status, 5, type: Ada.V1.IngestJobStatus, enum: true)
field(:progress, 6, type: Ada.V1.JobProgress)
field(:error, 7, type: :string)
field(:retry_count, 8, type: :int32, json_name: "retryCount")
field(:max_retries, 9, type: :int32, json_name: "maxRetries")
field(:partial_failure, 10, type: :bool, json_name: "partialFailure")
field(:partial_failure_causes, 11,
repeated: true,
type: :string,
json_name: "partialFailureCauses"
)
field(:extraction_model, 12, type: :string, json_name: "extractionModel")
field(:created_at, 13, type: Google.Protobuf.Timestamp, json_name: "createdAt")
field(:updated_at, 14, type: Google.Protobuf.Timestamp, json_name: "updatedAt")
field(:started_at, 15, type: Google.Protobuf.Timestamp, json_name: "startedAt")
field(:completed_at, 16, type: Google.Protobuf.Timestamp, json_name: "completedAt")
field(:llm_call_count, 17, type: :int64, json_name: "llmCallCount")
field(:llm_input_tokens, 18, type: :int64, json_name: "llmInputTokens")
field(:llm_output_tokens, 19, type: :int64, json_name: "llmOutputTokens")
field(:llm_total_tokens, 20, type: :int64, json_name: "llmTotalTokens")
field(:accounting_context, 24, type: Ada.V1.AccountingContext, json_name: "accountingContext")
end
defmodule Ada.V1.JobStarted do
@moduledoc false
use Protobuf,
full_name: "ada.v1.JobStarted",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:job, 1, type: Ada.V1.JobStatus)
end
defmodule Ada.V1.JobProgressed do
@moduledoc false
use Protobuf,
full_name: "ada.v1.JobProgressed",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:job, 1, type: Ada.V1.JobStatus)
end
defmodule Ada.V1.JobFinished do
@moduledoc false
use Protobuf,
full_name: "ada.v1.JobFinished",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:job, 1, type: Ada.V1.JobStatus)
end
defmodule Ada.V1.JobStatusStreamEvent do
@moduledoc false
use Protobuf,
full_name: "ada.v1.JobStatusStreamEvent",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
oneof(:event, 0)
field(:job_id, 3, type: :string, json_name: "jobId")
field(:timestamp, 4, type: Google.Protobuf.Timestamp)
field(:event_id, 6, type: :string, json_name: "eventId")
field(:principal_id, 100, type: :string, json_name: "principalId")
field(:started, 20, type: Ada.V1.JobStarted, oneof: 0)
field(:progressed, 21, type: Ada.V1.JobProgressed, oneof: 0)
field(:finished, 22, type: Ada.V1.JobFinished, oneof: 0)
end
defmodule Ada.V1.SourcePayload do
@moduledoc false
use Protobuf,
full_name: "ada.v1.SourcePayload",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:type, 1, type: :string)
field(:id, 2, type: :string)
end
defmodule Ada.V1.StreamJobsRequest do
@moduledoc false
use Protobuf,
full_name: "ada.v1.StreamJobsRequest",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:after_event_id, 1, type: :string, json_name: "afterEventId")
field(:replay_limit, 2, type: :int32, json_name: "replayLimit")
field(:principal_id, 100, type: :string, json_name: "principalId")
field(:scope_mode, 101, type: Ada.V1.StreamScopeMode, json_name: "scopeMode", enum: true)
end
defmodule Ada.V1.SetMeEntityRequest do
@moduledoc false
use Protobuf,
full_name: "ada.v1.SetMeEntityRequest",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:entity_id, 1, type: :string, json_name: "entityId")
field(:principal_id, 100, type: :string, json_name: "principalId")
end
defmodule Ada.V1.SetMeEntityResponse do
@moduledoc false
use Protobuf,
full_name: "ada.v1.SetMeEntityResponse",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:ok, 1, type: :bool)
field(:entity_id, 2, type: :string, json_name: "entityId")
end
defmodule Ada.V1.GetMeEntityRequest do
@moduledoc false
use Protobuf,
full_name: "ada.v1.GetMeEntityRequest",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:principal_id, 100, type: :string, json_name: "principalId")
end
defmodule Ada.V1.GetMeEntityResponse do
@moduledoc false
use Protobuf,
full_name: "ada.v1.GetMeEntityResponse",
protoc_gen_elixir_version: "0.17.0",
syntax: :proto3
field(:found, 1, type: :bool)
field(:entity_id, 2, type: :string, json_name: "entityId")
end
defmodule Ada.V1.IngestService.Service do
@moduledoc false
use GRPC.Service, name: "ada.v1.IngestService", protoc_gen_elixir_version: "0.17.0"
rpc(:GetDocumentStatus, Ada.V1.GetDocumentStatusRequest, Ada.V1.GetDocumentStatusResponse)
rpc(:GetJobStatus, Ada.V1.GetJobStatusRequest, Ada.V1.GetJobStatusResponse)
rpc(:GetIngestAccounting, Ada.V1.GetIngestAccountingRequest, Ada.V1.GetIngestAccountingResponse)
rpc(:GetLatestJobByDocument, Ada.V1.GetLatestJobByDocumentRequest, Ada.V1.GetJobStatusResponse)
rpc(:EstimateIngest, Ada.V1.EstimateIngestRequest, Ada.V1.EstimateIngestResponse)
rpc(:Ingest, Ada.V1.IngestRequest, Ada.V1.IngestAcceptedResponse)
rpc(:StreamJobs, Ada.V1.StreamJobsRequest, stream(Ada.V1.JobStatusStreamEvent))
rpc(:SetMeEntity, Ada.V1.SetMeEntityRequest, Ada.V1.SetMeEntityResponse)
rpc(:GetMeEntity, Ada.V1.GetMeEntityRequest, Ada.V1.GetMeEntityResponse)
end
defmodule Ada.V1.IngestService.Stub do
@moduledoc false
use GRPC.Stub, service: Ada.V1.IngestService.Service
end