From 532e7ad67246d1ce42f45ed938ebe88d36cd475f Mon Sep 17 00:00:00 2001 From: Pasha Podolsky Date: Fri, 1 Mar 2024 18:27:49 +0300 Subject: [PATCH] [feat] Remove development tag --- .github/workflows/docker-images.yaml | 2 +- .../aiosumma/proto/consumer_service_pb2.py | 1 + .../aiosumma/proto/consumer_service_pb2.pyi | 18 +- aiosumma/aiosumma/proto/dag_pb_pb2.py | 1 + aiosumma/aiosumma/proto/dag_pb_pb2.pyi | 4 +- aiosumma/aiosumma/proto/index_service_pb2.py | 177 +++++++++--------- aiosumma/aiosumma/proto/index_service_pb2.pyi | 116 ++++++------ aiosumma/aiosumma/proto/public_service_pb2.py | 1 + aiosumma/aiosumma/proto/query_pb2.py | 29 +-- aiosumma/aiosumma/proto/query_pb2.pyi | 100 +++++----- .../aiosumma/proto/reflection_service_pb2.py | 5 +- .../aiosumma/proto/reflection_service_pb2.pyi | 10 +- aiosumma/aiosumma/proto/search_service_pb2.py | 1 + aiosumma/aiosumma/proto/unixfs_pb2.py | 1 + aiosumma/aiosumma/proto/unixfs_pb2.pyi | 6 +- aiosumma/aiosumma/proto/utils_pb2.py | 1 + aiosumma/aiosumma/proto/utils_pb2.pyi | 4 +- aiosumma/build.sh | 2 +- aiosumma/pyproject.toml | 2 +- summa-core/src/components/summa_document.rs | 3 - 20 files changed, 246 insertions(+), 238 deletions(-) diff --git a/.github/workflows/docker-images.yaml b/.github/workflows/docker-images.yaml index e5bd46a1..097907ca 100644 --- a/.github/workflows/docker-images.yaml +++ b/.github/workflows/docker-images.yaml @@ -24,4 +24,4 @@ jobs: context: . platforms: linux/amd64,linux/arm64 push: true - tags: izihawa/summa-server:development \ No newline at end of file + tags: izihawa/summa-server:latest \ No newline at end of file diff --git a/aiosumma/aiosumma/proto/consumer_service_pb2.py b/aiosumma/aiosumma/proto/consumer_service_pb2.py index c2303a63..5c76985f 100644 --- a/aiosumma/aiosumma/proto/consumer_service_pb2.py +++ b/aiosumma/aiosumma/proto/consumer_service_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: consumer_service.proto +# Protobuf Python Version: 4.25.0 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/aiosumma/aiosumma/proto/consumer_service_pb2.pyi b/aiosumma/aiosumma/proto/consumer_service_pb2.pyi index 8ba3ab91..0e40f5c8 100644 --- a/aiosumma/aiosumma/proto/consumer_service_pb2.pyi +++ b/aiosumma/aiosumma/proto/consumer_service_pb2.pyi @@ -6,7 +6,7 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map DESCRIPTOR: _descriptor.FileDescriptor class CreateConsumerRequest(_message.Message): - __slots__ = ["bootstrap_servers", "group_id", "index_name", "consumer_name", "topics"] + __slots__ = ("bootstrap_servers", "group_id", "index_name", "consumer_name", "topics") BOOTSTRAP_SERVERS_FIELD_NUMBER: _ClassVar[int] GROUP_ID_FIELD_NUMBER: _ClassVar[int] INDEX_NAME_FIELD_NUMBER: _ClassVar[int] @@ -20,25 +20,25 @@ class CreateConsumerRequest(_message.Message): def __init__(self, bootstrap_servers: _Optional[_Iterable[str]] = ..., group_id: _Optional[str] = ..., index_name: _Optional[str] = ..., consumer_name: _Optional[str] = ..., topics: _Optional[_Iterable[str]] = ...) -> None: ... class CreateConsumerResponse(_message.Message): - __slots__ = ["consumer"] + __slots__ = ("consumer",) CONSUMER_FIELD_NUMBER: _ClassVar[int] consumer: Consumer def __init__(self, consumer: _Optional[_Union[Consumer, _Mapping]] = ...) -> None: ... class DeleteConsumerRequest(_message.Message): - __slots__ = ["consumer_name"] + __slots__ = ("consumer_name",) CONSUMER_NAME_FIELD_NUMBER: _ClassVar[int] consumer_name: str def __init__(self, consumer_name: _Optional[str] = ...) -> None: ... class DeleteConsumerResponse(_message.Message): - __slots__ = ["consumer_name"] + __slots__ = ("consumer_name",) CONSUMER_NAME_FIELD_NUMBER: _ClassVar[int] consumer_name: str def __init__(self, consumer_name: _Optional[str] = ...) -> None: ... class GetConsumerRequest(_message.Message): - __slots__ = ["index_name", "consumer_name"] + __slots__ = ("index_name", "consumer_name") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] CONSUMER_NAME_FIELD_NUMBER: _ClassVar[int] index_name: str @@ -46,23 +46,23 @@ class GetConsumerRequest(_message.Message): def __init__(self, index_name: _Optional[str] = ..., consumer_name: _Optional[str] = ...) -> None: ... class GetConsumerResponse(_message.Message): - __slots__ = ["consumer"] + __slots__ = ("consumer",) CONSUMER_FIELD_NUMBER: _ClassVar[int] consumer: Consumer def __init__(self, consumer: _Optional[_Union[Consumer, _Mapping]] = ...) -> None: ... class GetConsumersRequest(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class GetConsumersResponse(_message.Message): - __slots__ = ["consumers"] + __slots__ = ("consumers",) CONSUMERS_FIELD_NUMBER: _ClassVar[int] consumers: _containers.RepeatedCompositeFieldContainer[Consumer] def __init__(self, consumers: _Optional[_Iterable[_Union[Consumer, _Mapping]]] = ...) -> None: ... class Consumer(_message.Message): - __slots__ = ["consumer_name", "index_name"] + __slots__ = ("consumer_name", "index_name") CONSUMER_NAME_FIELD_NUMBER: _ClassVar[int] INDEX_NAME_FIELD_NUMBER: _ClassVar[int] consumer_name: str diff --git a/aiosumma/aiosumma/proto/dag_pb_pb2.py b/aiosumma/aiosumma/proto/dag_pb_pb2.py index 5c6f8445..a3bf304e 100644 --- a/aiosumma/aiosumma/proto/dag_pb_pb2.py +++ b/aiosumma/aiosumma/proto/dag_pb_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: dag_pb.proto +# Protobuf Python Version: 4.25.0 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/aiosumma/aiosumma/proto/dag_pb_pb2.pyi b/aiosumma/aiosumma/proto/dag_pb_pb2.pyi index d08b04bb..eef20061 100644 --- a/aiosumma/aiosumma/proto/dag_pb_pb2.pyi +++ b/aiosumma/aiosumma/proto/dag_pb_pb2.pyi @@ -6,7 +6,7 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map DESCRIPTOR: _descriptor.FileDescriptor class PBLink(_message.Message): - __slots__ = ["hash", "name", "t_size"] + __slots__ = ("hash", "name", "t_size") HASH_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] T_SIZE_FIELD_NUMBER: _ClassVar[int] @@ -16,7 +16,7 @@ class PBLink(_message.Message): def __init__(self, hash: _Optional[bytes] = ..., name: _Optional[str] = ..., t_size: _Optional[int] = ...) -> None: ... class PBNode(_message.Message): - __slots__ = ["links", "data"] + __slots__ = ("links", "data") LINKS_FIELD_NUMBER: _ClassVar[int] DATA_FIELD_NUMBER: _ClassVar[int] links: _containers.RepeatedCompositeFieldContainer[PBLink] diff --git a/aiosumma/aiosumma/proto/index_service_pb2.py b/aiosumma/aiosumma/proto/index_service_pb2.py index e5d4da2f..ea08de4e 100644 --- a/aiosumma/aiosumma/proto/index_service_pb2.py +++ b/aiosumma/aiosumma/proto/index_service_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: index_service.proto +# Protobuf Python Version: 4.25.0 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -15,21 +16,21 @@ from . import utils_pb2 as utils__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x13index_service.proto\x12\x0bsumma.proto\x1a\x0bquery.proto\x1a\x0butils.proto\"\x7f\n\x0bMergePolicy\x12*\n\x03log\x18\x0b \x01(\x0b\x32\x1b.summa.proto.LogMergePolicyH\x00\x12\x34\n\x08temporal\x18\x0c \x01(\x0b\x32 .summa.proto.TemporalMergePolicyH\x00\x42\x0e\n\x0cmerge_policy\"\x19\n\x17\x41ttachFileEngineRequest\"L\n\x19\x41ttachRemoteEngineRequest\x12/\n\x06\x63onfig\x18\x01 \x01(\x0b\x32\x1f.summa.proto.RemoteEngineConfig\"\x95\x02\n\x12\x41ttachIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x34\n\x04\x66ile\x18\x02 \x01(\x0b\x32$.summa.proto.AttachFileEngineRequestH\x00\x12\x38\n\x06remote\x18\x03 \x01(\x0b\x32&.summa.proto.AttachRemoteEngineRequestH\x00\x12.\n\x0cmerge_policy\x18\n \x01(\x0b\x32\x18.summa.proto.MergePolicy\x12;\n\x13query_parser_config\x18\x0b \x01(\x0b\x32\x1e.summa.proto.QueryParserConfigB\x0e\n\x0cindex_engine\"C\n\x13\x41ttachIndexResponse\x12,\n\x05index\x18\x01 \x01(\x0b\x32\x1d.summa.proto.IndexDescription\"?\n\x12\x43ommitIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x15\n\rwith_hotcache\x18\x02 \x01(\x08\"+\n\x13\x43ommitIndexResponse\x12\x14\n\x0c\x65lapsed_secs\x18\x01 \x01(\x01\"\xa1\x01\n\x14\x43opyDocumentsRequest\x12\x19\n\x11source_index_name\x18\x01 \x01(\t\x12\x19\n\x11target_index_name\x18\x02 \x01(\t\x12=\n\x11\x63onflict_strategy\x18\x03 \x01(\x0e\x32\x1d.summa.proto.ConflictStrategyH\x00\x88\x01\x01\x42\x14\n\x12_conflict_strategy\"G\n\x15\x43opyDocumentsResponse\x12\x14\n\x0c\x65lapsed_secs\x18\x01 \x01(\x01\x12\x18\n\x10\x63opied_documents\x18\x02 \x01(\r\"\xff\x01\n\x10\x43opyIndexRequest\x12\x19\n\x11source_index_name\x18\x01 \x01(\t\x12\x19\n\x11target_index_name\x18\x02 \x01(\t\x12\x34\n\x04\x66ile\x18\x03 \x01(\x0b\x32$.summa.proto.CreateFileEngineRequestH\x00\x12\x38\n\x06memory\x18\x04 \x01(\x0b\x32&.summa.proto.CreateMemoryEngineRequestH\x00\x12.\n\x0cmerge_policy\x18\x06 \x01(\x0b\x32\x18.summa.proto.MergePolicyB\x15\n\x13target_index_engine\"A\n\x11\x43opyIndexResponse\x12,\n\x05index\x18\x01 \x01(\x0b\x32\x1d.summa.proto.IndexDescription\"?\n\x0bSortByField\x12\r\n\x05\x66ield\x18\x01 \x01(\t\x12!\n\x05order\x18\x02 \x01(\x0e\x32\x12.summa.proto.Order\"\x19\n\x17\x43reateFileEngineRequest\"\x1b\n\x19\x43reateMemoryEngineRequest\"9\n\x0bMappedField\x12\x14\n\x0csource_field\x18\x01 \x01(\t\x12\x14\n\x0ctarget_field\x18\x02 \x01(\t\"\xe7\x01\n\x0fIndexAttributes\x12\x12\n\ncreated_at\x18\x01 \x01(\x04\x12\x15\n\runique_fields\x18\x02 \x03(\t\x12\x14\n\x0cmulti_fields\x18\x04 \x03(\t\x12\x18\n\x0b\x64\x65scription\x18\x06 \x01(\tH\x00\x88\x01\x01\x12\x38\n\x11\x63onflict_strategy\x18\x08 \x01(\x0e\x32\x1d.summa.proto.ConflictStrategy\x12/\n\rmapped_fields\x18\t \x03(\x0b\x32\x18.summa.proto.MappedFieldB\x0e\n\x0c_description\"\xfa\x03\n\x12\x43reateIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x34\n\x04\x66ile\x18\x07 \x01(\x0b\x32$.summa.proto.CreateFileEngineRequestH\x00\x12\x38\n\x06memory\x18\x08 \x01(\x0b\x32&.summa.proto.CreateMemoryEngineRequestH\x00\x12\x0e\n\x06schema\x18\x02 \x01(\t\x12-\n\x0b\x63ompression\x18\x03 \x01(\x0e\x32\x18.summa.proto.Compression\x12\x16\n\tblocksize\x18\x04 \x01(\rH\x01\x88\x01\x01\x12\x34\n\rsort_by_field\x18\x05 \x01(\x0b\x32\x18.summa.proto.SortByFieldH\x02\x88\x01\x01\x12\x36\n\x10index_attributes\x18\x06 \x01(\x0b\x32\x1c.summa.proto.IndexAttributes\x12.\n\x0cmerge_policy\x18\x14 \x01(\x0b\x32\x18.summa.proto.MergePolicy\x12;\n\x13query_parser_config\x18\x15 \x01(\x0b\x32\x1e.summa.proto.QueryParserConfigB\x0e\n\x0cindex_engineB\x0c\n\n_blocksizeB\x10\n\x0e_sort_by_field\"C\n\x13\x43reateIndexResponse\x12,\n\x05index\x18\x01 \x01(\x0b\x32\x1d.summa.proto.IndexDescription\"O\n\x16\x44\x65leteDocumentsRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12!\n\x05query\x18\x02 \x01(\x0b\x32\x12.summa.proto.Query\"4\n\x17\x44\x65leteDocumentsResponse\x12\x19\n\x11\x64\x65leted_documents\x18\x01 \x01(\x04\"(\n\x12\x44\x65leteIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\"1\n\x13\x44\x65leteIndexResponse\x12\x1a\n\x12\x64\x65leted_index_name\x18\x01 \x01(\t\"\x1a\n\x18GetIndicesAliasesRequest\"\xa7\x01\n\x19GetIndicesAliasesResponse\x12S\n\x0findices_aliases\x18\x01 \x03(\x0b\x32:.summa.proto.GetIndicesAliasesResponse.IndicesAliasesEntry\x1a\x35\n\x13IndicesAliasesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"%\n\x0fGetIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\"@\n\x10GetIndexResponse\x12,\n\x05index\x18\x01 \x01(\x0b\x32\x1d.summa.proto.IndexDescription\"\x13\n\x11GetIndicesRequest\")\n\x12GetIndicesResponse\x12\x13\n\x0bindex_names\x18\x01 \x03(\t\"\x98\x01\n\x1aIndexDocumentStreamRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x11\n\tdocuments\x18\x02 \x03(\x0c\x12=\n\x11\x63onflict_strategy\x18\x03 \x01(\x0e\x32\x1d.summa.proto.ConflictStrategyH\x00\x88\x01\x01\x42\x14\n\x12_conflict_strategy\"^\n\x1bIndexDocumentStreamResponse\x12\x14\n\x0c\x65lapsed_secs\x18\x01 \x01(\x01\x12\x14\n\x0csuccess_docs\x18\x02 \x01(\x04\x12\x13\n\x0b\x66\x61iled_docs\x18\x03 \x01(\x04\"<\n\x14IndexDocumentRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x10\n\x08\x64ocument\x18\x02 \x01(\x0c\"\x17\n\x15IndexDocumentResponse\"?\n\x14MergeSegmentsRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x13\n\x0bsegment_ids\x18\x02 \x03(\t\"?\n\x15MergeSegmentsResponse\x12\x17\n\nsegment_id\x18\x01 \x01(\tH\x00\x88\x01\x01\x42\r\n\x0b_segment_id\"?\n\x14SetIndexAliasRequest\x12\x13\n\x0bindex_alias\x18\x01 \x01(\t\x12\x12\n\nindex_name\x18\x02 \x01(\t\"G\n\x15SetIndexAliasResponse\x12\x1b\n\x0eold_index_name\x18\x01 \x01(\tH\x00\x88\x01\x01\x42\x11\n\x0f_old_index_name\"v\n\x10\x44ocumentsRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x0e\n\x06\x66ields\x18\x02 \x03(\t\x12-\n\x0cquery_filter\x18\x03 \x01(\x0b\x32\x12.summa.proto.QueryH\x00\x88\x01\x01\x42\x0f\n\r_query_filter\"%\n\x11\x44ocumentsResponse\x12\x10\n\x08\x64ocument\x18\x01 \x01(\t\"C\n\x12VacuumIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x19\n\x11\x65xcluded_segments\x18\x02 \x03(\t\"0\n\x13VacuumIndexResponse\x12\x19\n\x11\x66reed_space_bytes\x18\x01 \x01(\x04\"9\n\x12WarmupIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x0f\n\x07is_full\x18\x02 \x01(\x08\"+\n\x13WarmupIndexResponse\x12\x14\n\x0c\x65lapsed_secs\x18\x01 \x01(\x01\" \n\x10\x46ileEngineConfig\x12\x0c\n\x04path\x18\x01 \x01(\t\"$\n\x12MemoryEngineConfig\x12\x0e\n\x06schema\x18\x01 \x01(\t\"!\n\x0b\x43\x61\x63heConfig\x12\x12\n\ncache_size\x18\x01 \x01(\x04\"\x9a\x02\n\x12RemoteEngineConfig\x12\x0e\n\x06method\x18\x01 \x01(\t\x12\x14\n\x0curl_template\x18\x02 \x01(\t\x12N\n\x10headers_template\x18\x03 \x03(\x0b\x32\x34.summa.proto.RemoteEngineConfig.HeadersTemplateEntry\x12.\n\x0c\x63\x61\x63he_config\x18\x04 \x01(\x0b\x32\x18.summa.proto.CacheConfig\x12\x17\n\ntimeout_ms\x18\x05 \x01(\rH\x00\x88\x01\x01\x1a\x36\n\x14HeadersTemplateEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x42\r\n\x0b_timeout_ms\"#\n\x0eLogMergePolicy\x12\x11\n\tis_frozen\x18\x01 \x01(\x08\"4\n\x13TemporalMergePolicy\x12\x1d\n\x15merge_older_then_secs\x18\x01 \x01(\x04\"\x9f\x02\n\x11IndexEngineConfig\x12-\n\x04\x66ile\x18\x01 \x01(\x0b\x32\x1d.summa.proto.FileEngineConfigH\x00\x12\x31\n\x06memory\x18\x02 \x01(\x0b\x32\x1f.summa.proto.MemoryEngineConfigH\x00\x12\x31\n\x06remote\x18\x03 \x01(\x0b\x32\x1f.summa.proto.RemoteEngineConfigH\x00\x12.\n\x0cmerge_policy\x18\n \x01(\x0b\x32\x18.summa.proto.MergePolicy\x12;\n\x13query_parser_config\x18\x0b \x01(\x0b\x32\x1e.summa.proto.QueryParserConfigB\x08\n\x06\x63onfig\"\xec\x01\n\x10IndexDescription\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x15\n\rindex_aliases\x18\x02 \x03(\t\x12\x34\n\x0cindex_engine\x18\x03 \x01(\x0b\x32\x1e.summa.proto.IndexEngineConfig\x12\x10\n\x08num_docs\x18\x04 \x01(\x04\x12-\n\x0b\x63ompression\x18\x05 \x01(\x0e\x32\x18.summa.proto.Compression\x12\x36\n\x10index_attributes\x18\x06 \x01(\x0b\x32\x1c.summa.proto.IndexAttributes\"*\n\x16IndexDocumentOperation\x12\x10\n\x08\x64ocument\x18\x01 \x01(\x0c\"\\\n\x0eIndexOperation\x12=\n\x0eindex_document\x18\x02 \x01(\x0b\x32#.summa.proto.IndexDocumentOperationH\x00\x42\x0b\n\toperation*R\n\x10\x43onflictStrategy\x12\x0e\n\nDO_NOTHING\x10\x00\x12\x14\n\x10OVERWRITE_ALWAYS\x10\x01\x12\r\n\tOVERWRITE\x10\x02\x12\t\n\x05MERGE\x10\x03*[\n\x0b\x43ompression\x12\x08\n\x04None\x10\x00\x12\x08\n\x04Zstd\x10\x04\x12\t\n\x05Zstd7\x10\x05\x12\t\n\x05Zstd9\x10\x06\x12\n\n\x06Zstd14\x10\x07\x12\n\n\x06Zstd19\x10\x08\x12\n\n\x06Zstd22\x10\t2\xeb\x0b\n\x08IndexApi\x12S\n\x0c\x61ttach_index\x12\x1f.summa.proto.AttachIndexRequest\x1a .summa.proto.AttachIndexResponse\"\x00\x12S\n\x0c\x63ommit_index\x12\x1f.summa.proto.CommitIndexRequest\x1a .summa.proto.CommitIndexResponse\"\x00\x12Y\n\x0e\x63opy_documents\x12!.summa.proto.CopyDocumentsRequest\x1a\".summa.proto.CopyDocumentsResponse\"\x00\x12S\n\x0c\x63reate_index\x12\x1f.summa.proto.CreateIndexRequest\x1a .summa.proto.CreateIndexResponse\"\x00\x12M\n\ncopy_index\x12\x1d.summa.proto.CopyIndexRequest\x1a\x1e.summa.proto.CopyIndexResponse\"\x00\x12_\n\x10\x64\x65lete_documents\x12#.summa.proto.DeleteDocumentsRequest\x1a$.summa.proto.DeleteDocumentsResponse\"\x00\x12S\n\x0c\x64\x65lete_index\x12\x1f.summa.proto.DeleteIndexRequest\x1a .summa.proto.DeleteIndexResponse\"\x00\x12N\n\tdocuments\x12\x1d.summa.proto.DocumentsRequest\x1a\x1e.summa.proto.DocumentsResponse\"\x00\x30\x01\x12\x66\n\x13get_indices_aliases\x12%.summa.proto.GetIndicesAliasesRequest\x1a&.summa.proto.GetIndicesAliasesResponse\"\x00\x12J\n\tget_index\x12\x1c.summa.proto.GetIndexRequest\x1a\x1d.summa.proto.GetIndexResponse\"\x00\x12P\n\x0bget_indices\x12\x1e.summa.proto.GetIndicesRequest\x1a\x1f.summa.proto.GetIndicesResponse\"\x00\x12n\n\x15index_document_stream\x12\'.summa.proto.IndexDocumentStreamRequest\x1a(.summa.proto.IndexDocumentStreamResponse\"\x00(\x01\x12Y\n\x0eindex_document\x12!.summa.proto.IndexDocumentRequest\x1a\".summa.proto.IndexDocumentResponse\"\x00\x12Y\n\x0emerge_segments\x12!.summa.proto.MergeSegmentsRequest\x1a\".summa.proto.MergeSegmentsResponse\"\x00\x12Z\n\x0fset_index_alias\x12!.summa.proto.SetIndexAliasRequest\x1a\".summa.proto.SetIndexAliasResponse\"\x00\x12S\n\x0cvacuum_index\x12\x1f.summa.proto.VacuumIndexRequest\x1a .summa.proto.VacuumIndexResponse\"\x00\x12S\n\x0cwarmup_index\x12\x1f.summa.proto.WarmupIndexRequest\x1a .summa.proto.WarmupIndexResponse\"\x00\x62\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x13index_service.proto\x12\x0bsumma.proto\x1a\x0bquery.proto\x1a\x0butils.proto\"\x7f\n\x0bMergePolicy\x12*\n\x03log\x18\x0b \x01(\x0b\x32\x1b.summa.proto.LogMergePolicyH\x00\x12\x34\n\x08temporal\x18\x0c \x01(\x0b\x32 .summa.proto.TemporalMergePolicyH\x00\x42\x0e\n\x0cmerge_policy\"\x19\n\x17\x41ttachFileEngineRequest\"L\n\x19\x41ttachRemoteEngineRequest\x12/\n\x06\x63onfig\x18\x01 \x01(\x0b\x32\x1f.summa.proto.RemoteEngineConfig\"\x95\x02\n\x12\x41ttachIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x34\n\x04\x66ile\x18\x02 \x01(\x0b\x32$.summa.proto.AttachFileEngineRequestH\x00\x12\x38\n\x06remote\x18\x03 \x01(\x0b\x32&.summa.proto.AttachRemoteEngineRequestH\x00\x12.\n\x0cmerge_policy\x18\n \x01(\x0b\x32\x18.summa.proto.MergePolicy\x12;\n\x13query_parser_config\x18\x0b \x01(\x0b\x32\x1e.summa.proto.QueryParserConfigB\x0e\n\x0cindex_engine\"C\n\x13\x41ttachIndexResponse\x12,\n\x05index\x18\x01 \x01(\x0b\x32\x1d.summa.proto.IndexDescription\"?\n\x12\x43ommitIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x15\n\rwith_hotcache\x18\x02 \x01(\x08\"+\n\x13\x43ommitIndexResponse\x12\x14\n\x0c\x65lapsed_secs\x18\x01 \x01(\x01\"\xa1\x01\n\x14\x43opyDocumentsRequest\x12\x19\n\x11source_index_name\x18\x01 \x01(\t\x12\x19\n\x11target_index_name\x18\x02 \x01(\t\x12=\n\x11\x63onflict_strategy\x18\x03 \x01(\x0e\x32\x1d.summa.proto.ConflictStrategyH\x00\x88\x01\x01\x42\x14\n\x12_conflict_strategy\"G\n\x15\x43opyDocumentsResponse\x12\x14\n\x0c\x65lapsed_secs\x18\x01 \x01(\x01\x12\x18\n\x10\x63opied_documents\x18\x02 \x01(\r\"\xff\x01\n\x10\x43opyIndexRequest\x12\x19\n\x11source_index_name\x18\x01 \x01(\t\x12\x19\n\x11target_index_name\x18\x02 \x01(\t\x12\x34\n\x04\x66ile\x18\x03 \x01(\x0b\x32$.summa.proto.CreateFileEngineRequestH\x00\x12\x38\n\x06memory\x18\x04 \x01(\x0b\x32&.summa.proto.CreateMemoryEngineRequestH\x00\x12.\n\x0cmerge_policy\x18\x06 \x01(\x0b\x32\x18.summa.proto.MergePolicyB\x15\n\x13target_index_engine\"A\n\x11\x43opyIndexResponse\x12,\n\x05index\x18\x01 \x01(\x0b\x32\x1d.summa.proto.IndexDescription\"?\n\x0bSortByField\x12\r\n\x05\x66ield\x18\x01 \x01(\t\x12!\n\x05order\x18\x02 \x01(\x0e\x32\x12.summa.proto.Order\"\x19\n\x17\x43reateFileEngineRequest\"\x1b\n\x19\x43reateMemoryEngineRequest\"9\n\x0bMappedField\x12\x14\n\x0csource_field\x18\x01 \x01(\t\x12\x14\n\x0ctarget_field\x18\x02 \x01(\t\"\x95\x02\n\x0fIndexAttributes\x12\x12\n\ncreated_at\x18\x01 \x01(\x04\x12\x15\n\runique_fields\x18\x02 \x03(\t\x12\x14\n\x0cmulti_fields\x18\x04 \x03(\t\x12\x18\n\x0b\x64\x65scription\x18\x06 \x01(\tH\x00\x88\x01\x01\x12\x38\n\x11\x63onflict_strategy\x18\x08 \x01(\x0e\x32\x1d.summa.proto.ConflictStrategy\x12/\n\rmapped_fields\x18\t \x03(\x0b\x32\x18.summa.proto.MappedField\x12\x1a\n\rauto_id_field\x18\n \x01(\tH\x01\x88\x01\x01\x42\x0e\n\x0c_descriptionB\x10\n\x0e_auto_id_field\"\xfa\x03\n\x12\x43reateIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x34\n\x04\x66ile\x18\x07 \x01(\x0b\x32$.summa.proto.CreateFileEngineRequestH\x00\x12\x38\n\x06memory\x18\x08 \x01(\x0b\x32&.summa.proto.CreateMemoryEngineRequestH\x00\x12\x0e\n\x06schema\x18\x02 \x01(\t\x12-\n\x0b\x63ompression\x18\x03 \x01(\x0e\x32\x18.summa.proto.Compression\x12\x16\n\tblocksize\x18\x04 \x01(\rH\x01\x88\x01\x01\x12\x34\n\rsort_by_field\x18\x05 \x01(\x0b\x32\x18.summa.proto.SortByFieldH\x02\x88\x01\x01\x12\x36\n\x10index_attributes\x18\x06 \x01(\x0b\x32\x1c.summa.proto.IndexAttributes\x12.\n\x0cmerge_policy\x18\x14 \x01(\x0b\x32\x18.summa.proto.MergePolicy\x12;\n\x13query_parser_config\x18\x15 \x01(\x0b\x32\x1e.summa.proto.QueryParserConfigB\x0e\n\x0cindex_engineB\x0c\n\n_blocksizeB\x10\n\x0e_sort_by_field\"C\n\x13\x43reateIndexResponse\x12,\n\x05index\x18\x01 \x01(\x0b\x32\x1d.summa.proto.IndexDescription\"O\n\x16\x44\x65leteDocumentsRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12!\n\x05query\x18\x02 \x01(\x0b\x32\x12.summa.proto.Query\"4\n\x17\x44\x65leteDocumentsResponse\x12\x19\n\x11\x64\x65leted_documents\x18\x01 \x01(\x04\"(\n\x12\x44\x65leteIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\"1\n\x13\x44\x65leteIndexResponse\x12\x1a\n\x12\x64\x65leted_index_name\x18\x01 \x01(\t\"\x1a\n\x18GetIndicesAliasesRequest\"\xa7\x01\n\x19GetIndicesAliasesResponse\x12S\n\x0findices_aliases\x18\x01 \x03(\x0b\x32:.summa.proto.GetIndicesAliasesResponse.IndicesAliasesEntry\x1a\x35\n\x13IndicesAliasesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"%\n\x0fGetIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\"@\n\x10GetIndexResponse\x12,\n\x05index\x18\x01 \x01(\x0b\x32\x1d.summa.proto.IndexDescription\"\x13\n\x11GetIndicesRequest\")\n\x12GetIndicesResponse\x12\x13\n\x0bindex_names\x18\x01 \x03(\t\"\x98\x01\n\x1aIndexDocumentStreamRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x11\n\tdocuments\x18\x02 \x03(\x0c\x12=\n\x11\x63onflict_strategy\x18\x03 \x01(\x0e\x32\x1d.summa.proto.ConflictStrategyH\x00\x88\x01\x01\x42\x14\n\x12_conflict_strategy\"^\n\x1bIndexDocumentStreamResponse\x12\x14\n\x0c\x65lapsed_secs\x18\x01 \x01(\x01\x12\x14\n\x0csuccess_docs\x18\x02 \x01(\x04\x12\x13\n\x0b\x66\x61iled_docs\x18\x03 \x01(\x04\"<\n\x14IndexDocumentRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x10\n\x08\x64ocument\x18\x02 \x01(\x0c\"\x17\n\x15IndexDocumentResponse\"?\n\x14MergeSegmentsRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x13\n\x0bsegment_ids\x18\x02 \x03(\t\"?\n\x15MergeSegmentsResponse\x12\x17\n\nsegment_id\x18\x01 \x01(\tH\x00\x88\x01\x01\x42\r\n\x0b_segment_id\"?\n\x14SetIndexAliasRequest\x12\x13\n\x0bindex_alias\x18\x01 \x01(\t\x12\x12\n\nindex_name\x18\x02 \x01(\t\"G\n\x15SetIndexAliasResponse\x12\x1b\n\x0eold_index_name\x18\x01 \x01(\tH\x00\x88\x01\x01\x42\x11\n\x0f_old_index_name\"v\n\x10\x44ocumentsRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x0e\n\x06\x66ields\x18\x02 \x03(\t\x12-\n\x0cquery_filter\x18\x03 \x01(\x0b\x32\x12.summa.proto.QueryH\x00\x88\x01\x01\x42\x0f\n\r_query_filter\"%\n\x11\x44ocumentsResponse\x12\x10\n\x08\x64ocument\x18\x01 \x01(\t\"C\n\x12VacuumIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x19\n\x11\x65xcluded_segments\x18\x02 \x03(\t\"0\n\x13VacuumIndexResponse\x12\x19\n\x11\x66reed_space_bytes\x18\x01 \x01(\x04\"9\n\x12WarmupIndexRequest\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x0f\n\x07is_full\x18\x02 \x01(\x08\"+\n\x13WarmupIndexResponse\x12\x14\n\x0c\x65lapsed_secs\x18\x01 \x01(\x01\" \n\x10\x46ileEngineConfig\x12\x0c\n\x04path\x18\x01 \x01(\t\"$\n\x12MemoryEngineConfig\x12\x0e\n\x06schema\x18\x01 \x01(\t\"!\n\x0b\x43\x61\x63heConfig\x12\x12\n\ncache_size\x18\x01 \x01(\x04\"\x9a\x02\n\x12RemoteEngineConfig\x12\x0e\n\x06method\x18\x01 \x01(\t\x12\x14\n\x0curl_template\x18\x02 \x01(\t\x12N\n\x10headers_template\x18\x03 \x03(\x0b\x32\x34.summa.proto.RemoteEngineConfig.HeadersTemplateEntry\x12.\n\x0c\x63\x61\x63he_config\x18\x04 \x01(\x0b\x32\x18.summa.proto.CacheConfig\x12\x17\n\ntimeout_ms\x18\x05 \x01(\rH\x00\x88\x01\x01\x1a\x36\n\x14HeadersTemplateEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x42\r\n\x0b_timeout_ms\"#\n\x0eLogMergePolicy\x12\x11\n\tis_frozen\x18\x01 \x01(\x08\"4\n\x13TemporalMergePolicy\x12\x1d\n\x15merge_older_then_secs\x18\x01 \x01(\x04\"\x9f\x02\n\x11IndexEngineConfig\x12-\n\x04\x66ile\x18\x01 \x01(\x0b\x32\x1d.summa.proto.FileEngineConfigH\x00\x12\x31\n\x06memory\x18\x02 \x01(\x0b\x32\x1f.summa.proto.MemoryEngineConfigH\x00\x12\x31\n\x06remote\x18\x03 \x01(\x0b\x32\x1f.summa.proto.RemoteEngineConfigH\x00\x12.\n\x0cmerge_policy\x18\n \x01(\x0b\x32\x18.summa.proto.MergePolicy\x12;\n\x13query_parser_config\x18\x0b \x01(\x0b\x32\x1e.summa.proto.QueryParserConfigB\x08\n\x06\x63onfig\"\xec\x01\n\x10IndexDescription\x12\x12\n\nindex_name\x18\x01 \x01(\t\x12\x15\n\rindex_aliases\x18\x02 \x03(\t\x12\x34\n\x0cindex_engine\x18\x03 \x01(\x0b\x32\x1e.summa.proto.IndexEngineConfig\x12\x10\n\x08num_docs\x18\x04 \x01(\x04\x12-\n\x0b\x63ompression\x18\x05 \x01(\x0e\x32\x18.summa.proto.Compression\x12\x36\n\x10index_attributes\x18\x06 \x01(\x0b\x32\x1c.summa.proto.IndexAttributes\"*\n\x16IndexDocumentOperation\x12\x10\n\x08\x64ocument\x18\x01 \x01(\x0c\"\\\n\x0eIndexOperation\x12=\n\x0eindex_document\x18\x02 \x01(\x0b\x32#.summa.proto.IndexDocumentOperationH\x00\x42\x0b\n\toperation*R\n\x10\x43onflictStrategy\x12\x0e\n\nDO_NOTHING\x10\x00\x12\x14\n\x10OVERWRITE_ALWAYS\x10\x01\x12\r\n\tOVERWRITE\x10\x02\x12\t\n\x05MERGE\x10\x03*[\n\x0b\x43ompression\x12\x08\n\x04None\x10\x00\x12\x08\n\x04Zstd\x10\x04\x12\t\n\x05Zstd7\x10\x05\x12\t\n\x05Zstd9\x10\x06\x12\n\n\x06Zstd14\x10\x07\x12\n\n\x06Zstd19\x10\x08\x12\n\n\x06Zstd22\x10\t2\xeb\x0b\n\x08IndexApi\x12S\n\x0c\x61ttach_index\x12\x1f.summa.proto.AttachIndexRequest\x1a .summa.proto.AttachIndexResponse\"\x00\x12S\n\x0c\x63ommit_index\x12\x1f.summa.proto.CommitIndexRequest\x1a .summa.proto.CommitIndexResponse\"\x00\x12Y\n\x0e\x63opy_documents\x12!.summa.proto.CopyDocumentsRequest\x1a\".summa.proto.CopyDocumentsResponse\"\x00\x12S\n\x0c\x63reate_index\x12\x1f.summa.proto.CreateIndexRequest\x1a .summa.proto.CreateIndexResponse\"\x00\x12M\n\ncopy_index\x12\x1d.summa.proto.CopyIndexRequest\x1a\x1e.summa.proto.CopyIndexResponse\"\x00\x12_\n\x10\x64\x65lete_documents\x12#.summa.proto.DeleteDocumentsRequest\x1a$.summa.proto.DeleteDocumentsResponse\"\x00\x12S\n\x0c\x64\x65lete_index\x12\x1f.summa.proto.DeleteIndexRequest\x1a .summa.proto.DeleteIndexResponse\"\x00\x12N\n\tdocuments\x12\x1d.summa.proto.DocumentsRequest\x1a\x1e.summa.proto.DocumentsResponse\"\x00\x30\x01\x12\x66\n\x13get_indices_aliases\x12%.summa.proto.GetIndicesAliasesRequest\x1a&.summa.proto.GetIndicesAliasesResponse\"\x00\x12J\n\tget_index\x12\x1c.summa.proto.GetIndexRequest\x1a\x1d.summa.proto.GetIndexResponse\"\x00\x12P\n\x0bget_indices\x12\x1e.summa.proto.GetIndicesRequest\x1a\x1f.summa.proto.GetIndicesResponse\"\x00\x12n\n\x15index_document_stream\x12\'.summa.proto.IndexDocumentStreamRequest\x1a(.summa.proto.IndexDocumentStreamResponse\"\x00(\x01\x12Y\n\x0eindex_document\x12!.summa.proto.IndexDocumentRequest\x1a\".summa.proto.IndexDocumentResponse\"\x00\x12Y\n\x0emerge_segments\x12!.summa.proto.MergeSegmentsRequest\x1a\".summa.proto.MergeSegmentsResponse\"\x00\x12Z\n\x0fset_index_alias\x12!.summa.proto.SetIndexAliasRequest\x1a\".summa.proto.SetIndexAliasResponse\"\x00\x12S\n\x0cvacuum_index\x12\x1f.summa.proto.VacuumIndexRequest\x1a .summa.proto.VacuumIndexResponse\"\x00\x12S\n\x0cwarmup_index\x12\x1f.summa.proto.WarmupIndexRequest\x1a .summa.proto.WarmupIndexResponse\"\x00\x62\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'index_service_pb2', _globals) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None - _GETINDICESALIASESRESPONSE_INDICESALIASESENTRY._options = None - _GETINDICESALIASESRESPONSE_INDICESALIASESENTRY._serialized_options = b'8\001' - _REMOTEENGINECONFIG_HEADERSTEMPLATEENTRY._options = None - _REMOTEENGINECONFIG_HEADERSTEMPLATEENTRY._serialized_options = b'8\001' - _globals['_CONFLICTSTRATEGY']._serialized_start=5042 - _globals['_CONFLICTSTRATEGY']._serialized_end=5124 - _globals['_COMPRESSION']._serialized_start=5126 - _globals['_COMPRESSION']._serialized_end=5217 + _globals['_GETINDICESALIASESRESPONSE_INDICESALIASESENTRY']._options = None + _globals['_GETINDICESALIASESRESPONSE_INDICESALIASESENTRY']._serialized_options = b'8\001' + _globals['_REMOTEENGINECONFIG_HEADERSTEMPLATEENTRY']._options = None + _globals['_REMOTEENGINECONFIG_HEADERSTEMPLATEENTRY']._serialized_options = b'8\001' + _globals['_CONFLICTSTRATEGY']._serialized_start=5088 + _globals['_CONFLICTSTRATEGY']._serialized_end=5170 + _globals['_COMPRESSION']._serialized_start=5172 + _globals['_COMPRESSION']._serialized_end=5263 _globals['_MERGEPOLICY']._serialized_start=62 _globals['_MERGEPOLICY']._serialized_end=189 _globals['_ATTACHFILEENGINEREQUEST']._serialized_start=191 @@ -61,83 +62,83 @@ _globals['_MAPPEDFIELD']._serialized_start=1438 _globals['_MAPPEDFIELD']._serialized_end=1495 _globals['_INDEXATTRIBUTES']._serialized_start=1498 - _globals['_INDEXATTRIBUTES']._serialized_end=1729 - _globals['_CREATEINDEXREQUEST']._serialized_start=1732 - _globals['_CREATEINDEXREQUEST']._serialized_end=2238 - _globals['_CREATEINDEXRESPONSE']._serialized_start=2240 - _globals['_CREATEINDEXRESPONSE']._serialized_end=2307 - _globals['_DELETEDOCUMENTSREQUEST']._serialized_start=2309 - _globals['_DELETEDOCUMENTSREQUEST']._serialized_end=2388 - _globals['_DELETEDOCUMENTSRESPONSE']._serialized_start=2390 - _globals['_DELETEDOCUMENTSRESPONSE']._serialized_end=2442 - _globals['_DELETEINDEXREQUEST']._serialized_start=2444 - _globals['_DELETEINDEXREQUEST']._serialized_end=2484 - _globals['_DELETEINDEXRESPONSE']._serialized_start=2486 - _globals['_DELETEINDEXRESPONSE']._serialized_end=2535 - _globals['_GETINDICESALIASESREQUEST']._serialized_start=2537 - _globals['_GETINDICESALIASESREQUEST']._serialized_end=2563 - _globals['_GETINDICESALIASESRESPONSE']._serialized_start=2566 - _globals['_GETINDICESALIASESRESPONSE']._serialized_end=2733 - _globals['_GETINDICESALIASESRESPONSE_INDICESALIASESENTRY']._serialized_start=2680 - _globals['_GETINDICESALIASESRESPONSE_INDICESALIASESENTRY']._serialized_end=2733 - _globals['_GETINDEXREQUEST']._serialized_start=2735 - _globals['_GETINDEXREQUEST']._serialized_end=2772 - _globals['_GETINDEXRESPONSE']._serialized_start=2774 - _globals['_GETINDEXRESPONSE']._serialized_end=2838 - _globals['_GETINDICESREQUEST']._serialized_start=2840 - _globals['_GETINDICESREQUEST']._serialized_end=2859 - _globals['_GETINDICESRESPONSE']._serialized_start=2861 - _globals['_GETINDICESRESPONSE']._serialized_end=2902 - _globals['_INDEXDOCUMENTSTREAMREQUEST']._serialized_start=2905 - _globals['_INDEXDOCUMENTSTREAMREQUEST']._serialized_end=3057 - _globals['_INDEXDOCUMENTSTREAMRESPONSE']._serialized_start=3059 - _globals['_INDEXDOCUMENTSTREAMRESPONSE']._serialized_end=3153 - _globals['_INDEXDOCUMENTREQUEST']._serialized_start=3155 - _globals['_INDEXDOCUMENTREQUEST']._serialized_end=3215 - _globals['_INDEXDOCUMENTRESPONSE']._serialized_start=3217 - _globals['_INDEXDOCUMENTRESPONSE']._serialized_end=3240 - _globals['_MERGESEGMENTSREQUEST']._serialized_start=3242 - _globals['_MERGESEGMENTSREQUEST']._serialized_end=3305 - _globals['_MERGESEGMENTSRESPONSE']._serialized_start=3307 - _globals['_MERGESEGMENTSRESPONSE']._serialized_end=3370 - _globals['_SETINDEXALIASREQUEST']._serialized_start=3372 - _globals['_SETINDEXALIASREQUEST']._serialized_end=3435 - _globals['_SETINDEXALIASRESPONSE']._serialized_start=3437 - _globals['_SETINDEXALIASRESPONSE']._serialized_end=3508 - _globals['_DOCUMENTSREQUEST']._serialized_start=3510 - _globals['_DOCUMENTSREQUEST']._serialized_end=3628 - _globals['_DOCUMENTSRESPONSE']._serialized_start=3630 - _globals['_DOCUMENTSRESPONSE']._serialized_end=3667 - _globals['_VACUUMINDEXREQUEST']._serialized_start=3669 - _globals['_VACUUMINDEXREQUEST']._serialized_end=3736 - _globals['_VACUUMINDEXRESPONSE']._serialized_start=3738 - _globals['_VACUUMINDEXRESPONSE']._serialized_end=3786 - _globals['_WARMUPINDEXREQUEST']._serialized_start=3788 - _globals['_WARMUPINDEXREQUEST']._serialized_end=3845 - _globals['_WARMUPINDEXRESPONSE']._serialized_start=3847 - _globals['_WARMUPINDEXRESPONSE']._serialized_end=3890 - _globals['_FILEENGINECONFIG']._serialized_start=3892 - _globals['_FILEENGINECONFIG']._serialized_end=3924 - _globals['_MEMORYENGINECONFIG']._serialized_start=3926 - _globals['_MEMORYENGINECONFIG']._serialized_end=3962 - _globals['_CACHECONFIG']._serialized_start=3964 - _globals['_CACHECONFIG']._serialized_end=3997 - _globals['_REMOTEENGINECONFIG']._serialized_start=4000 - _globals['_REMOTEENGINECONFIG']._serialized_end=4282 - _globals['_REMOTEENGINECONFIG_HEADERSTEMPLATEENTRY']._serialized_start=4213 - _globals['_REMOTEENGINECONFIG_HEADERSTEMPLATEENTRY']._serialized_end=4267 - _globals['_LOGMERGEPOLICY']._serialized_start=4284 - _globals['_LOGMERGEPOLICY']._serialized_end=4319 - _globals['_TEMPORALMERGEPOLICY']._serialized_start=4321 - _globals['_TEMPORALMERGEPOLICY']._serialized_end=4373 - _globals['_INDEXENGINECONFIG']._serialized_start=4376 - _globals['_INDEXENGINECONFIG']._serialized_end=4663 - _globals['_INDEXDESCRIPTION']._serialized_start=4666 - _globals['_INDEXDESCRIPTION']._serialized_end=4902 - _globals['_INDEXDOCUMENTOPERATION']._serialized_start=4904 - _globals['_INDEXDOCUMENTOPERATION']._serialized_end=4946 - _globals['_INDEXOPERATION']._serialized_start=4948 - _globals['_INDEXOPERATION']._serialized_end=5040 - _globals['_INDEXAPI']._serialized_start=5220 - _globals['_INDEXAPI']._serialized_end=6735 + _globals['_INDEXATTRIBUTES']._serialized_end=1775 + _globals['_CREATEINDEXREQUEST']._serialized_start=1778 + _globals['_CREATEINDEXREQUEST']._serialized_end=2284 + _globals['_CREATEINDEXRESPONSE']._serialized_start=2286 + _globals['_CREATEINDEXRESPONSE']._serialized_end=2353 + _globals['_DELETEDOCUMENTSREQUEST']._serialized_start=2355 + _globals['_DELETEDOCUMENTSREQUEST']._serialized_end=2434 + _globals['_DELETEDOCUMENTSRESPONSE']._serialized_start=2436 + _globals['_DELETEDOCUMENTSRESPONSE']._serialized_end=2488 + _globals['_DELETEINDEXREQUEST']._serialized_start=2490 + _globals['_DELETEINDEXREQUEST']._serialized_end=2530 + _globals['_DELETEINDEXRESPONSE']._serialized_start=2532 + _globals['_DELETEINDEXRESPONSE']._serialized_end=2581 + _globals['_GETINDICESALIASESREQUEST']._serialized_start=2583 + _globals['_GETINDICESALIASESREQUEST']._serialized_end=2609 + _globals['_GETINDICESALIASESRESPONSE']._serialized_start=2612 + _globals['_GETINDICESALIASESRESPONSE']._serialized_end=2779 + _globals['_GETINDICESALIASESRESPONSE_INDICESALIASESENTRY']._serialized_start=2726 + _globals['_GETINDICESALIASESRESPONSE_INDICESALIASESENTRY']._serialized_end=2779 + _globals['_GETINDEXREQUEST']._serialized_start=2781 + _globals['_GETINDEXREQUEST']._serialized_end=2818 + _globals['_GETINDEXRESPONSE']._serialized_start=2820 + _globals['_GETINDEXRESPONSE']._serialized_end=2884 + _globals['_GETINDICESREQUEST']._serialized_start=2886 + _globals['_GETINDICESREQUEST']._serialized_end=2905 + _globals['_GETINDICESRESPONSE']._serialized_start=2907 + _globals['_GETINDICESRESPONSE']._serialized_end=2948 + _globals['_INDEXDOCUMENTSTREAMREQUEST']._serialized_start=2951 + _globals['_INDEXDOCUMENTSTREAMREQUEST']._serialized_end=3103 + _globals['_INDEXDOCUMENTSTREAMRESPONSE']._serialized_start=3105 + _globals['_INDEXDOCUMENTSTREAMRESPONSE']._serialized_end=3199 + _globals['_INDEXDOCUMENTREQUEST']._serialized_start=3201 + _globals['_INDEXDOCUMENTREQUEST']._serialized_end=3261 + _globals['_INDEXDOCUMENTRESPONSE']._serialized_start=3263 + _globals['_INDEXDOCUMENTRESPONSE']._serialized_end=3286 + _globals['_MERGESEGMENTSREQUEST']._serialized_start=3288 + _globals['_MERGESEGMENTSREQUEST']._serialized_end=3351 + _globals['_MERGESEGMENTSRESPONSE']._serialized_start=3353 + _globals['_MERGESEGMENTSRESPONSE']._serialized_end=3416 + _globals['_SETINDEXALIASREQUEST']._serialized_start=3418 + _globals['_SETINDEXALIASREQUEST']._serialized_end=3481 + _globals['_SETINDEXALIASRESPONSE']._serialized_start=3483 + _globals['_SETINDEXALIASRESPONSE']._serialized_end=3554 + _globals['_DOCUMENTSREQUEST']._serialized_start=3556 + _globals['_DOCUMENTSREQUEST']._serialized_end=3674 + _globals['_DOCUMENTSRESPONSE']._serialized_start=3676 + _globals['_DOCUMENTSRESPONSE']._serialized_end=3713 + _globals['_VACUUMINDEXREQUEST']._serialized_start=3715 + _globals['_VACUUMINDEXREQUEST']._serialized_end=3782 + _globals['_VACUUMINDEXRESPONSE']._serialized_start=3784 + _globals['_VACUUMINDEXRESPONSE']._serialized_end=3832 + _globals['_WARMUPINDEXREQUEST']._serialized_start=3834 + _globals['_WARMUPINDEXREQUEST']._serialized_end=3891 + _globals['_WARMUPINDEXRESPONSE']._serialized_start=3893 + _globals['_WARMUPINDEXRESPONSE']._serialized_end=3936 + _globals['_FILEENGINECONFIG']._serialized_start=3938 + _globals['_FILEENGINECONFIG']._serialized_end=3970 + _globals['_MEMORYENGINECONFIG']._serialized_start=3972 + _globals['_MEMORYENGINECONFIG']._serialized_end=4008 + _globals['_CACHECONFIG']._serialized_start=4010 + _globals['_CACHECONFIG']._serialized_end=4043 + _globals['_REMOTEENGINECONFIG']._serialized_start=4046 + _globals['_REMOTEENGINECONFIG']._serialized_end=4328 + _globals['_REMOTEENGINECONFIG_HEADERSTEMPLATEENTRY']._serialized_start=4259 + _globals['_REMOTEENGINECONFIG_HEADERSTEMPLATEENTRY']._serialized_end=4313 + _globals['_LOGMERGEPOLICY']._serialized_start=4330 + _globals['_LOGMERGEPOLICY']._serialized_end=4365 + _globals['_TEMPORALMERGEPOLICY']._serialized_start=4367 + _globals['_TEMPORALMERGEPOLICY']._serialized_end=4419 + _globals['_INDEXENGINECONFIG']._serialized_start=4422 + _globals['_INDEXENGINECONFIG']._serialized_end=4709 + _globals['_INDEXDESCRIPTION']._serialized_start=4712 + _globals['_INDEXDESCRIPTION']._serialized_end=4948 + _globals['_INDEXDOCUMENTOPERATION']._serialized_start=4950 + _globals['_INDEXDOCUMENTOPERATION']._serialized_end=4992 + _globals['_INDEXOPERATION']._serialized_start=4994 + _globals['_INDEXOPERATION']._serialized_end=5086 + _globals['_INDEXAPI']._serialized_start=5266 + _globals['_INDEXAPI']._serialized_end=6781 # @@protoc_insertion_point(module_scope) diff --git a/aiosumma/aiosumma/proto/index_service_pb2.pyi b/aiosumma/aiosumma/proto/index_service_pb2.pyi index 0e7ff7b9..c4c165a9 100644 --- a/aiosumma/aiosumma/proto/index_service_pb2.pyi +++ b/aiosumma/aiosumma/proto/index_service_pb2.pyi @@ -9,14 +9,14 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map DESCRIPTOR: _descriptor.FileDescriptor class ConflictStrategy(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () DO_NOTHING: _ClassVar[ConflictStrategy] OVERWRITE_ALWAYS: _ClassVar[ConflictStrategy] OVERWRITE: _ClassVar[ConflictStrategy] MERGE: _ClassVar[ConflictStrategy] class Compression(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () None: _ClassVar[Compression] Zstd: _ClassVar[Compression] Zstd7: _ClassVar[Compression] @@ -37,7 +37,7 @@ Zstd19: Compression Zstd22: Compression class MergePolicy(_message.Message): - __slots__ = ["log", "temporal"] + __slots__ = ("log", "temporal") LOG_FIELD_NUMBER: _ClassVar[int] TEMPORAL_FIELD_NUMBER: _ClassVar[int] log: LogMergePolicy @@ -45,17 +45,17 @@ class MergePolicy(_message.Message): def __init__(self, log: _Optional[_Union[LogMergePolicy, _Mapping]] = ..., temporal: _Optional[_Union[TemporalMergePolicy, _Mapping]] = ...) -> None: ... class AttachFileEngineRequest(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class AttachRemoteEngineRequest(_message.Message): - __slots__ = ["config"] + __slots__ = ("config",) CONFIG_FIELD_NUMBER: _ClassVar[int] config: RemoteEngineConfig def __init__(self, config: _Optional[_Union[RemoteEngineConfig, _Mapping]] = ...) -> None: ... class AttachIndexRequest(_message.Message): - __slots__ = ["index_name", "file", "remote", "merge_policy", "query_parser_config"] + __slots__ = ("index_name", "file", "remote", "merge_policy", "query_parser_config") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] FILE_FIELD_NUMBER: _ClassVar[int] REMOTE_FIELD_NUMBER: _ClassVar[int] @@ -69,13 +69,13 @@ class AttachIndexRequest(_message.Message): def __init__(self, index_name: _Optional[str] = ..., file: _Optional[_Union[AttachFileEngineRequest, _Mapping]] = ..., remote: _Optional[_Union[AttachRemoteEngineRequest, _Mapping]] = ..., merge_policy: _Optional[_Union[MergePolicy, _Mapping]] = ..., query_parser_config: _Optional[_Union[_query_pb2.QueryParserConfig, _Mapping]] = ...) -> None: ... class AttachIndexResponse(_message.Message): - __slots__ = ["index"] + __slots__ = ("index",) INDEX_FIELD_NUMBER: _ClassVar[int] index: IndexDescription def __init__(self, index: _Optional[_Union[IndexDescription, _Mapping]] = ...) -> None: ... class CommitIndexRequest(_message.Message): - __slots__ = ["index_name", "with_hotcache"] + __slots__ = ("index_name", "with_hotcache") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] WITH_HOTCACHE_FIELD_NUMBER: _ClassVar[int] index_name: str @@ -83,13 +83,13 @@ class CommitIndexRequest(_message.Message): def __init__(self, index_name: _Optional[str] = ..., with_hotcache: bool = ...) -> None: ... class CommitIndexResponse(_message.Message): - __slots__ = ["elapsed_secs"] + __slots__ = ("elapsed_secs",) ELAPSED_SECS_FIELD_NUMBER: _ClassVar[int] elapsed_secs: float def __init__(self, elapsed_secs: _Optional[float] = ...) -> None: ... class CopyDocumentsRequest(_message.Message): - __slots__ = ["source_index_name", "target_index_name", "conflict_strategy"] + __slots__ = ("source_index_name", "target_index_name", "conflict_strategy") SOURCE_INDEX_NAME_FIELD_NUMBER: _ClassVar[int] TARGET_INDEX_NAME_FIELD_NUMBER: _ClassVar[int] CONFLICT_STRATEGY_FIELD_NUMBER: _ClassVar[int] @@ -99,7 +99,7 @@ class CopyDocumentsRequest(_message.Message): def __init__(self, source_index_name: _Optional[str] = ..., target_index_name: _Optional[str] = ..., conflict_strategy: _Optional[_Union[ConflictStrategy, str]] = ...) -> None: ... class CopyDocumentsResponse(_message.Message): - __slots__ = ["elapsed_secs", "copied_documents"] + __slots__ = ("elapsed_secs", "copied_documents") ELAPSED_SECS_FIELD_NUMBER: _ClassVar[int] COPIED_DOCUMENTS_FIELD_NUMBER: _ClassVar[int] elapsed_secs: float @@ -107,7 +107,7 @@ class CopyDocumentsResponse(_message.Message): def __init__(self, elapsed_secs: _Optional[float] = ..., copied_documents: _Optional[int] = ...) -> None: ... class CopyIndexRequest(_message.Message): - __slots__ = ["source_index_name", "target_index_name", "file", "memory", "merge_policy"] + __slots__ = ("source_index_name", "target_index_name", "file", "memory", "merge_policy") SOURCE_INDEX_NAME_FIELD_NUMBER: _ClassVar[int] TARGET_INDEX_NAME_FIELD_NUMBER: _ClassVar[int] FILE_FIELD_NUMBER: _ClassVar[int] @@ -121,13 +121,13 @@ class CopyIndexRequest(_message.Message): def __init__(self, source_index_name: _Optional[str] = ..., target_index_name: _Optional[str] = ..., file: _Optional[_Union[CreateFileEngineRequest, _Mapping]] = ..., memory: _Optional[_Union[CreateMemoryEngineRequest, _Mapping]] = ..., merge_policy: _Optional[_Union[MergePolicy, _Mapping]] = ...) -> None: ... class CopyIndexResponse(_message.Message): - __slots__ = ["index"] + __slots__ = ("index",) INDEX_FIELD_NUMBER: _ClassVar[int] index: IndexDescription def __init__(self, index: _Optional[_Union[IndexDescription, _Mapping]] = ...) -> None: ... class SortByField(_message.Message): - __slots__ = ["field", "order"] + __slots__ = ("field", "order") FIELD_FIELD_NUMBER: _ClassVar[int] ORDER_FIELD_NUMBER: _ClassVar[int] field: str @@ -135,15 +135,15 @@ class SortByField(_message.Message): def __init__(self, field: _Optional[str] = ..., order: _Optional[_Union[_utils_pb2.Order, str]] = ...) -> None: ... class CreateFileEngineRequest(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class CreateMemoryEngineRequest(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class MappedField(_message.Message): - __slots__ = ["source_field", "target_field"] + __slots__ = ("source_field", "target_field") SOURCE_FIELD_FIELD_NUMBER: _ClassVar[int] TARGET_FIELD_FIELD_NUMBER: _ClassVar[int] source_field: str @@ -151,23 +151,25 @@ class MappedField(_message.Message): def __init__(self, source_field: _Optional[str] = ..., target_field: _Optional[str] = ...) -> None: ... class IndexAttributes(_message.Message): - __slots__ = ["created_at", "unique_fields", "multi_fields", "description", "conflict_strategy", "mapped_fields"] + __slots__ = ("created_at", "unique_fields", "multi_fields", "description", "conflict_strategy", "mapped_fields", "auto_id_field") CREATED_AT_FIELD_NUMBER: _ClassVar[int] UNIQUE_FIELDS_FIELD_NUMBER: _ClassVar[int] MULTI_FIELDS_FIELD_NUMBER: _ClassVar[int] DESCRIPTION_FIELD_NUMBER: _ClassVar[int] CONFLICT_STRATEGY_FIELD_NUMBER: _ClassVar[int] MAPPED_FIELDS_FIELD_NUMBER: _ClassVar[int] + AUTO_ID_FIELD_FIELD_NUMBER: _ClassVar[int] created_at: int unique_fields: _containers.RepeatedScalarFieldContainer[str] multi_fields: _containers.RepeatedScalarFieldContainer[str] description: str conflict_strategy: ConflictStrategy mapped_fields: _containers.RepeatedCompositeFieldContainer[MappedField] - def __init__(self, created_at: _Optional[int] = ..., unique_fields: _Optional[_Iterable[str]] = ..., multi_fields: _Optional[_Iterable[str]] = ..., description: _Optional[str] = ..., conflict_strategy: _Optional[_Union[ConflictStrategy, str]] = ..., mapped_fields: _Optional[_Iterable[_Union[MappedField, _Mapping]]] = ...) -> None: ... + auto_id_field: str + def __init__(self, created_at: _Optional[int] = ..., unique_fields: _Optional[_Iterable[str]] = ..., multi_fields: _Optional[_Iterable[str]] = ..., description: _Optional[str] = ..., conflict_strategy: _Optional[_Union[ConflictStrategy, str]] = ..., mapped_fields: _Optional[_Iterable[_Union[MappedField, _Mapping]]] = ..., auto_id_field: _Optional[str] = ...) -> None: ... class CreateIndexRequest(_message.Message): - __slots__ = ["index_name", "file", "memory", "schema", "compression", "blocksize", "sort_by_field", "index_attributes", "merge_policy", "query_parser_config"] + __slots__ = ("index_name", "file", "memory", "schema", "compression", "blocksize", "sort_by_field", "index_attributes", "merge_policy", "query_parser_config") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] FILE_FIELD_NUMBER: _ClassVar[int] MEMORY_FIELD_NUMBER: _ClassVar[int] @@ -191,13 +193,13 @@ class CreateIndexRequest(_message.Message): def __init__(self, index_name: _Optional[str] = ..., file: _Optional[_Union[CreateFileEngineRequest, _Mapping]] = ..., memory: _Optional[_Union[CreateMemoryEngineRequest, _Mapping]] = ..., schema: _Optional[str] = ..., compression: _Optional[_Union[Compression, str]] = ..., blocksize: _Optional[int] = ..., sort_by_field: _Optional[_Union[SortByField, _Mapping]] = ..., index_attributes: _Optional[_Union[IndexAttributes, _Mapping]] = ..., merge_policy: _Optional[_Union[MergePolicy, _Mapping]] = ..., query_parser_config: _Optional[_Union[_query_pb2.QueryParserConfig, _Mapping]] = ...) -> None: ... class CreateIndexResponse(_message.Message): - __slots__ = ["index"] + __slots__ = ("index",) INDEX_FIELD_NUMBER: _ClassVar[int] index: IndexDescription def __init__(self, index: _Optional[_Union[IndexDescription, _Mapping]] = ...) -> None: ... class DeleteDocumentsRequest(_message.Message): - __slots__ = ["index_name", "query"] + __slots__ = ("index_name", "query") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] QUERY_FIELD_NUMBER: _ClassVar[int] index_name: str @@ -205,31 +207,31 @@ class DeleteDocumentsRequest(_message.Message): def __init__(self, index_name: _Optional[str] = ..., query: _Optional[_Union[_query_pb2.Query, _Mapping]] = ...) -> None: ... class DeleteDocumentsResponse(_message.Message): - __slots__ = ["deleted_documents"] + __slots__ = ("deleted_documents",) DELETED_DOCUMENTS_FIELD_NUMBER: _ClassVar[int] deleted_documents: int def __init__(self, deleted_documents: _Optional[int] = ...) -> None: ... class DeleteIndexRequest(_message.Message): - __slots__ = ["index_name"] + __slots__ = ("index_name",) INDEX_NAME_FIELD_NUMBER: _ClassVar[int] index_name: str def __init__(self, index_name: _Optional[str] = ...) -> None: ... class DeleteIndexResponse(_message.Message): - __slots__ = ["deleted_index_name"] + __slots__ = ("deleted_index_name",) DELETED_INDEX_NAME_FIELD_NUMBER: _ClassVar[int] deleted_index_name: str def __init__(self, deleted_index_name: _Optional[str] = ...) -> None: ... class GetIndicesAliasesRequest(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class GetIndicesAliasesResponse(_message.Message): - __slots__ = ["indices_aliases"] + __slots__ = ("indices_aliases",) class IndicesAliasesEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -240,29 +242,29 @@ class GetIndicesAliasesResponse(_message.Message): def __init__(self, indices_aliases: _Optional[_Mapping[str, str]] = ...) -> None: ... class GetIndexRequest(_message.Message): - __slots__ = ["index_name"] + __slots__ = ("index_name",) INDEX_NAME_FIELD_NUMBER: _ClassVar[int] index_name: str def __init__(self, index_name: _Optional[str] = ...) -> None: ... class GetIndexResponse(_message.Message): - __slots__ = ["index"] + __slots__ = ("index",) INDEX_FIELD_NUMBER: _ClassVar[int] index: IndexDescription def __init__(self, index: _Optional[_Union[IndexDescription, _Mapping]] = ...) -> None: ... class GetIndicesRequest(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class GetIndicesResponse(_message.Message): - __slots__ = ["index_names"] + __slots__ = ("index_names",) INDEX_NAMES_FIELD_NUMBER: _ClassVar[int] index_names: _containers.RepeatedScalarFieldContainer[str] def __init__(self, index_names: _Optional[_Iterable[str]] = ...) -> None: ... class IndexDocumentStreamRequest(_message.Message): - __slots__ = ["index_name", "documents", "conflict_strategy"] + __slots__ = ("index_name", "documents", "conflict_strategy") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] DOCUMENTS_FIELD_NUMBER: _ClassVar[int] CONFLICT_STRATEGY_FIELD_NUMBER: _ClassVar[int] @@ -272,7 +274,7 @@ class IndexDocumentStreamRequest(_message.Message): def __init__(self, index_name: _Optional[str] = ..., documents: _Optional[_Iterable[bytes]] = ..., conflict_strategy: _Optional[_Union[ConflictStrategy, str]] = ...) -> None: ... class IndexDocumentStreamResponse(_message.Message): - __slots__ = ["elapsed_secs", "success_docs", "failed_docs"] + __slots__ = ("elapsed_secs", "success_docs", "failed_docs") ELAPSED_SECS_FIELD_NUMBER: _ClassVar[int] SUCCESS_DOCS_FIELD_NUMBER: _ClassVar[int] FAILED_DOCS_FIELD_NUMBER: _ClassVar[int] @@ -282,7 +284,7 @@ class IndexDocumentStreamResponse(_message.Message): def __init__(self, elapsed_secs: _Optional[float] = ..., success_docs: _Optional[int] = ..., failed_docs: _Optional[int] = ...) -> None: ... class IndexDocumentRequest(_message.Message): - __slots__ = ["index_name", "document"] + __slots__ = ("index_name", "document") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] DOCUMENT_FIELD_NUMBER: _ClassVar[int] index_name: str @@ -290,11 +292,11 @@ class IndexDocumentRequest(_message.Message): def __init__(self, index_name: _Optional[str] = ..., document: _Optional[bytes] = ...) -> None: ... class IndexDocumentResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class MergeSegmentsRequest(_message.Message): - __slots__ = ["index_name", "segment_ids"] + __slots__ = ("index_name", "segment_ids") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] SEGMENT_IDS_FIELD_NUMBER: _ClassVar[int] index_name: str @@ -302,13 +304,13 @@ class MergeSegmentsRequest(_message.Message): def __init__(self, index_name: _Optional[str] = ..., segment_ids: _Optional[_Iterable[str]] = ...) -> None: ... class MergeSegmentsResponse(_message.Message): - __slots__ = ["segment_id"] + __slots__ = ("segment_id",) SEGMENT_ID_FIELD_NUMBER: _ClassVar[int] segment_id: str def __init__(self, segment_id: _Optional[str] = ...) -> None: ... class SetIndexAliasRequest(_message.Message): - __slots__ = ["index_alias", "index_name"] + __slots__ = ("index_alias", "index_name") INDEX_ALIAS_FIELD_NUMBER: _ClassVar[int] INDEX_NAME_FIELD_NUMBER: _ClassVar[int] index_alias: str @@ -316,13 +318,13 @@ class SetIndexAliasRequest(_message.Message): def __init__(self, index_alias: _Optional[str] = ..., index_name: _Optional[str] = ...) -> None: ... class SetIndexAliasResponse(_message.Message): - __slots__ = ["old_index_name"] + __slots__ = ("old_index_name",) OLD_INDEX_NAME_FIELD_NUMBER: _ClassVar[int] old_index_name: str def __init__(self, old_index_name: _Optional[str] = ...) -> None: ... class DocumentsRequest(_message.Message): - __slots__ = ["index_name", "fields", "query_filter"] + __slots__ = ("index_name", "fields", "query_filter") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] FIELDS_FIELD_NUMBER: _ClassVar[int] QUERY_FILTER_FIELD_NUMBER: _ClassVar[int] @@ -332,13 +334,13 @@ class DocumentsRequest(_message.Message): def __init__(self, index_name: _Optional[str] = ..., fields: _Optional[_Iterable[str]] = ..., query_filter: _Optional[_Union[_query_pb2.Query, _Mapping]] = ...) -> None: ... class DocumentsResponse(_message.Message): - __slots__ = ["document"] + __slots__ = ("document",) DOCUMENT_FIELD_NUMBER: _ClassVar[int] document: str def __init__(self, document: _Optional[str] = ...) -> None: ... class VacuumIndexRequest(_message.Message): - __slots__ = ["index_name", "excluded_segments"] + __slots__ = ("index_name", "excluded_segments") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] EXCLUDED_SEGMENTS_FIELD_NUMBER: _ClassVar[int] index_name: str @@ -346,13 +348,13 @@ class VacuumIndexRequest(_message.Message): def __init__(self, index_name: _Optional[str] = ..., excluded_segments: _Optional[_Iterable[str]] = ...) -> None: ... class VacuumIndexResponse(_message.Message): - __slots__ = ["freed_space_bytes"] + __slots__ = ("freed_space_bytes",) FREED_SPACE_BYTES_FIELD_NUMBER: _ClassVar[int] freed_space_bytes: int def __init__(self, freed_space_bytes: _Optional[int] = ...) -> None: ... class WarmupIndexRequest(_message.Message): - __slots__ = ["index_name", "is_full"] + __slots__ = ("index_name", "is_full") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] IS_FULL_FIELD_NUMBER: _ClassVar[int] index_name: str @@ -360,33 +362,33 @@ class WarmupIndexRequest(_message.Message): def __init__(self, index_name: _Optional[str] = ..., is_full: bool = ...) -> None: ... class WarmupIndexResponse(_message.Message): - __slots__ = ["elapsed_secs"] + __slots__ = ("elapsed_secs",) ELAPSED_SECS_FIELD_NUMBER: _ClassVar[int] elapsed_secs: float def __init__(self, elapsed_secs: _Optional[float] = ...) -> None: ... class FileEngineConfig(_message.Message): - __slots__ = ["path"] + __slots__ = ("path",) PATH_FIELD_NUMBER: _ClassVar[int] path: str def __init__(self, path: _Optional[str] = ...) -> None: ... class MemoryEngineConfig(_message.Message): - __slots__ = ["schema"] + __slots__ = ("schema",) SCHEMA_FIELD_NUMBER: _ClassVar[int] schema: str def __init__(self, schema: _Optional[str] = ...) -> None: ... class CacheConfig(_message.Message): - __slots__ = ["cache_size"] + __slots__ = ("cache_size",) CACHE_SIZE_FIELD_NUMBER: _ClassVar[int] cache_size: int def __init__(self, cache_size: _Optional[int] = ...) -> None: ... class RemoteEngineConfig(_message.Message): - __slots__ = ["method", "url_template", "headers_template", "cache_config", "timeout_ms"] + __slots__ = ("method", "url_template", "headers_template", "cache_config", "timeout_ms") class HeadersTemplateEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -405,19 +407,19 @@ class RemoteEngineConfig(_message.Message): def __init__(self, method: _Optional[str] = ..., url_template: _Optional[str] = ..., headers_template: _Optional[_Mapping[str, str]] = ..., cache_config: _Optional[_Union[CacheConfig, _Mapping]] = ..., timeout_ms: _Optional[int] = ...) -> None: ... class LogMergePolicy(_message.Message): - __slots__ = ["is_frozen"] + __slots__ = ("is_frozen",) IS_FROZEN_FIELD_NUMBER: _ClassVar[int] is_frozen: bool def __init__(self, is_frozen: bool = ...) -> None: ... class TemporalMergePolicy(_message.Message): - __slots__ = ["merge_older_then_secs"] + __slots__ = ("merge_older_then_secs",) MERGE_OLDER_THEN_SECS_FIELD_NUMBER: _ClassVar[int] merge_older_then_secs: int def __init__(self, merge_older_then_secs: _Optional[int] = ...) -> None: ... class IndexEngineConfig(_message.Message): - __slots__ = ["file", "memory", "remote", "merge_policy", "query_parser_config"] + __slots__ = ("file", "memory", "remote", "merge_policy", "query_parser_config") FILE_FIELD_NUMBER: _ClassVar[int] MEMORY_FIELD_NUMBER: _ClassVar[int] REMOTE_FIELD_NUMBER: _ClassVar[int] @@ -431,7 +433,7 @@ class IndexEngineConfig(_message.Message): def __init__(self, file: _Optional[_Union[FileEngineConfig, _Mapping]] = ..., memory: _Optional[_Union[MemoryEngineConfig, _Mapping]] = ..., remote: _Optional[_Union[RemoteEngineConfig, _Mapping]] = ..., merge_policy: _Optional[_Union[MergePolicy, _Mapping]] = ..., query_parser_config: _Optional[_Union[_query_pb2.QueryParserConfig, _Mapping]] = ...) -> None: ... class IndexDescription(_message.Message): - __slots__ = ["index_name", "index_aliases", "index_engine", "num_docs", "compression", "index_attributes"] + __slots__ = ("index_name", "index_aliases", "index_engine", "num_docs", "compression", "index_attributes") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] INDEX_ALIASES_FIELD_NUMBER: _ClassVar[int] INDEX_ENGINE_FIELD_NUMBER: _ClassVar[int] @@ -447,13 +449,13 @@ class IndexDescription(_message.Message): def __init__(self, index_name: _Optional[str] = ..., index_aliases: _Optional[_Iterable[str]] = ..., index_engine: _Optional[_Union[IndexEngineConfig, _Mapping]] = ..., num_docs: _Optional[int] = ..., compression: _Optional[_Union[Compression, str]] = ..., index_attributes: _Optional[_Union[IndexAttributes, _Mapping]] = ...) -> None: ... class IndexDocumentOperation(_message.Message): - __slots__ = ["document"] + __slots__ = ("document",) DOCUMENT_FIELD_NUMBER: _ClassVar[int] document: bytes def __init__(self, document: _Optional[bytes] = ...) -> None: ... class IndexOperation(_message.Message): - __slots__ = ["index_document"] + __slots__ = ("index_document",) INDEX_DOCUMENT_FIELD_NUMBER: _ClassVar[int] index_document: IndexDocumentOperation def __init__(self, index_document: _Optional[_Union[IndexDocumentOperation, _Mapping]] = ...) -> None: ... diff --git a/aiosumma/aiosumma/proto/public_service_pb2.py b/aiosumma/aiosumma/proto/public_service_pb2.py index 217da929..f59144f9 100644 --- a/aiosumma/aiosumma/proto/public_service_pb2.py +++ b/aiosumma/aiosumma/proto/public_service_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: public_service.proto +# Protobuf Python Version: 4.25.0 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/aiosumma/aiosumma/proto/query_pb2.py b/aiosumma/aiosumma/proto/query_pb2.py index 2dcabd12..2ae8b4da 100644 --- a/aiosumma/aiosumma/proto/query_pb2.py +++ b/aiosumma/aiosumma/proto/query_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: query.proto +# Protobuf Python Version: 4.25.0 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -20,20 +21,20 @@ _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'query_pb2', _globals) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None - _QUERYPARSERCONFIG_FIELDALIASESENTRY._options = None - _QUERYPARSERCONFIG_FIELDALIASESENTRY._serialized_options = b'8\001' - _QUERYPARSERCONFIG_FIELDBOOSTSENTRY._options = None - _QUERYPARSERCONFIG_FIELDBOOSTSENTRY._serialized_options = b'8\001' - _QUERYPARSERCONFIG_TERMFIELDMAPPERCONFIGSENTRY._options = None - _QUERYPARSERCONFIG_TERMFIELDMAPPERCONFIGSENTRY._serialized_options = b'8\001' - _QUERYPARSERCONFIG_MORPHOLOGYCONFIGSENTRY._options = None - _QUERYPARSERCONFIG_MORPHOLOGYCONFIGSENTRY._serialized_options = b'8\001' - _SCOREDDOCUMENT_SNIPPETSENTRY._options = None - _SCOREDDOCUMENT_SNIPPETSENTRY._serialized_options = b'8\001' - _FACETCOLLECTOROUTPUT_FACETCOUNTSENTRY._options = None - _FACETCOLLECTOROUTPUT_FACETCOUNTSENTRY._serialized_options = b'8\001' - _TOPDOCSCOLLECTOR_SNIPPETCONFIGSENTRY._options = None - _TOPDOCSCOLLECTOR_SNIPPETCONFIGSENTRY._serialized_options = b'8\001' + _globals['_QUERYPARSERCONFIG_FIELDALIASESENTRY']._options = None + _globals['_QUERYPARSERCONFIG_FIELDALIASESENTRY']._serialized_options = b'8\001' + _globals['_QUERYPARSERCONFIG_FIELDBOOSTSENTRY']._options = None + _globals['_QUERYPARSERCONFIG_FIELDBOOSTSENTRY']._serialized_options = b'8\001' + _globals['_QUERYPARSERCONFIG_TERMFIELDMAPPERCONFIGSENTRY']._options = None + _globals['_QUERYPARSERCONFIG_TERMFIELDMAPPERCONFIGSENTRY']._serialized_options = b'8\001' + _globals['_QUERYPARSERCONFIG_MORPHOLOGYCONFIGSENTRY']._options = None + _globals['_QUERYPARSERCONFIG_MORPHOLOGYCONFIGSENTRY']._serialized_options = b'8\001' + _globals['_SCOREDDOCUMENT_SNIPPETSENTRY']._options = None + _globals['_SCOREDDOCUMENT_SNIPPETSENTRY']._serialized_options = b'8\001' + _globals['_FACETCOLLECTOROUTPUT_FACETCOUNTSENTRY']._options = None + _globals['_FACETCOLLECTOROUTPUT_FACETCOUNTSENTRY']._serialized_options = b'8\001' + _globals['_TOPDOCSCOLLECTOR_SNIPPETCONFIGSENTRY']._options = None + _globals['_TOPDOCSCOLLECTOR_SNIPPETCONFIGSENTRY']._serialized_options = b'8\001' _globals['_OCCUR']._serialized_start=5566 _globals['_OCCUR']._serialized_end=5609 _globals['_TERMFIELDMAPPERCONFIG']._serialized_start=28 diff --git a/aiosumma/aiosumma/proto/query_pb2.pyi b/aiosumma/aiosumma/proto/query_pb2.pyi index d9f2cfd0..ef154b14 100644 --- a/aiosumma/aiosumma/proto/query_pb2.pyi +++ b/aiosumma/aiosumma/proto/query_pb2.pyi @@ -7,7 +7,7 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map DESCRIPTOR: _descriptor.FileDescriptor class Occur(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () should: _ClassVar[Occur] must: _ClassVar[Occur] must_not: _ClassVar[Occur] @@ -16,23 +16,23 @@ must: Occur must_not: Occur class TermFieldMapperConfig(_message.Message): - __slots__ = ["fields"] + __slots__ = ("fields",) FIELDS_FIELD_NUMBER: _ClassVar[int] fields: _containers.RepeatedScalarFieldContainer[str] def __init__(self, fields: _Optional[_Iterable[str]] = ...) -> None: ... class MatchQueryBooleanShouldMode(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class MatchQueryDisjuctionMaxMode(_message.Message): - __slots__ = ["tie_breaker"] + __slots__ = ("tie_breaker",) TIE_BREAKER_FIELD_NUMBER: _ClassVar[int] tie_breaker: float def __init__(self, tie_breaker: _Optional[float] = ...) -> None: ... class ExactMatchesPromoter(_message.Message): - __slots__ = ["slop", "boost", "fields"] + __slots__ = ("slop", "boost", "fields") SLOP_FIELD_NUMBER: _ClassVar[int] BOOST_FIELD_NUMBER: _ClassVar[int] FIELDS_FIELD_NUMBER: _ClassVar[int] @@ -42,7 +42,7 @@ class ExactMatchesPromoter(_message.Message): def __init__(self, slop: _Optional[int] = ..., boost: _Optional[float] = ..., fields: _Optional[_Iterable[str]] = ...) -> None: ... class NerMatchesPromoter(_message.Message): - __slots__ = ["boost", "fields"] + __slots__ = ("boost", "fields") BOOST_FIELD_NUMBER: _ClassVar[int] FIELDS_FIELD_NUMBER: _ClassVar[int] boost: float @@ -50,36 +50,36 @@ class NerMatchesPromoter(_message.Message): def __init__(self, boost: _Optional[float] = ..., fields: _Optional[_Iterable[str]] = ...) -> None: ... class MorphologyConfig(_message.Message): - __slots__ = ["derive_tenses_coefficient"] + __slots__ = ("derive_tenses_coefficient",) DERIVE_TENSES_COEFFICIENT_FIELD_NUMBER: _ClassVar[int] derive_tenses_coefficient: float def __init__(self, derive_tenses_coefficient: _Optional[float] = ...) -> None: ... class QueryParserConfig(_message.Message): - __slots__ = ["field_aliases", "field_boosts", "term_field_mapper_configs", "term_limit", "default_fields", "boolean_should_mode", "disjuction_max_mode", "exact_matches_promoter", "excluded_fields", "morphology_configs", "query_language"] + __slots__ = ("field_aliases", "field_boosts", "term_field_mapper_configs", "term_limit", "default_fields", "boolean_should_mode", "disjuction_max_mode", "exact_matches_promoter", "excluded_fields", "morphology_configs", "query_language") class FieldAliasesEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str value: str def __init__(self, key: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... class FieldBoostsEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str value: float def __init__(self, key: _Optional[str] = ..., value: _Optional[float] = ...) -> None: ... class TermFieldMapperConfigsEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str value: TermFieldMapperConfig def __init__(self, key: _Optional[str] = ..., value: _Optional[_Union[TermFieldMapperConfig, _Mapping]] = ...) -> None: ... class MorphologyConfigsEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -110,7 +110,7 @@ class QueryParserConfig(_message.Message): def __init__(self, field_aliases: _Optional[_Mapping[str, str]] = ..., field_boosts: _Optional[_Mapping[str, float]] = ..., term_field_mapper_configs: _Optional[_Mapping[str, TermFieldMapperConfig]] = ..., term_limit: _Optional[int] = ..., default_fields: _Optional[_Iterable[str]] = ..., boolean_should_mode: _Optional[_Union[MatchQueryBooleanShouldMode, _Mapping]] = ..., disjuction_max_mode: _Optional[_Union[MatchQueryDisjuctionMaxMode, _Mapping]] = ..., exact_matches_promoter: _Optional[_Union[ExactMatchesPromoter, _Mapping]] = ..., excluded_fields: _Optional[_Iterable[str]] = ..., morphology_configs: _Optional[_Mapping[str, MorphologyConfig]] = ..., query_language: _Optional[str] = ...) -> None: ... class SearchRequest(_message.Message): - __slots__ = ["index_alias", "query", "collectors", "is_fieldnorms_scoring_enabled", "load_cache", "store_cache"] + __slots__ = ("index_alias", "query", "collectors", "is_fieldnorms_scoring_enabled", "load_cache", "store_cache") INDEX_ALIAS_FIELD_NUMBER: _ClassVar[int] QUERY_FIELD_NUMBER: _ClassVar[int] COLLECTORS_FIELD_NUMBER: _ClassVar[int] @@ -126,7 +126,7 @@ class SearchRequest(_message.Message): def __init__(self, index_alias: _Optional[str] = ..., query: _Optional[_Union[Query, _Mapping]] = ..., collectors: _Optional[_Iterable[_Union[Collector, _Mapping]]] = ..., is_fieldnorms_scoring_enabled: bool = ..., load_cache: bool = ..., store_cache: bool = ...) -> None: ... class SearchResponse(_message.Message): - __slots__ = ["elapsed_secs", "collector_outputs"] + __slots__ = ("elapsed_secs", "collector_outputs") ELAPSED_SECS_FIELD_NUMBER: _ClassVar[int] COLLECTOR_OUTPUTS_FIELD_NUMBER: _ClassVar[int] elapsed_secs: float @@ -134,7 +134,7 @@ class SearchResponse(_message.Message): def __init__(self, elapsed_secs: _Optional[float] = ..., collector_outputs: _Optional[_Iterable[_Union[CollectorOutput, _Mapping]]] = ...) -> None: ... class Query(_message.Message): - __slots__ = ["boolean", "match", "regex", "term", "phrase", "range", "all", "more_like_this", "boost", "disjunction_max", "empty", "exists"] + __slots__ = ("boolean", "match", "regex", "term", "phrase", "range", "all", "more_like_this", "boost", "disjunction_max", "empty", "exists") BOOLEAN_FIELD_NUMBER: _ClassVar[int] MATCH_FIELD_NUMBER: _ClassVar[int] REGEX_FIELD_NUMBER: _ClassVar[int] @@ -162,15 +162,15 @@ class Query(_message.Message): def __init__(self, boolean: _Optional[_Union[BooleanQuery, _Mapping]] = ..., match: _Optional[_Union[MatchQuery, _Mapping]] = ..., regex: _Optional[_Union[RegexQuery, _Mapping]] = ..., term: _Optional[_Union[TermQuery, _Mapping]] = ..., phrase: _Optional[_Union[PhraseQuery, _Mapping]] = ..., range: _Optional[_Union[RangeQuery, _Mapping]] = ..., all: _Optional[_Union[AllQuery, _Mapping]] = ..., more_like_this: _Optional[_Union[MoreLikeThisQuery, _Mapping]] = ..., boost: _Optional[_Union[BoostQuery, _Mapping]] = ..., disjunction_max: _Optional[_Union[DisjunctionMaxQuery, _Mapping]] = ..., empty: _Optional[_Union[EmptyQuery, _Mapping]] = ..., exists: _Optional[_Union[ExistsQuery, _Mapping]] = ...) -> None: ... class AllQuery(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class EmptyQuery(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class BoostQuery(_message.Message): - __slots__ = ["query", "score"] + __slots__ = ("query", "score") QUERY_FIELD_NUMBER: _ClassVar[int] SCORE_FIELD_NUMBER: _ClassVar[int] query: Query @@ -178,7 +178,7 @@ class BoostQuery(_message.Message): def __init__(self, query: _Optional[_Union[Query, _Mapping]] = ..., score: _Optional[str] = ...) -> None: ... class DisjunctionMaxQuery(_message.Message): - __slots__ = ["disjuncts", "tie_breaker"] + __slots__ = ("disjuncts", "tie_breaker") DISJUNCTS_FIELD_NUMBER: _ClassVar[int] TIE_BREAKER_FIELD_NUMBER: _ClassVar[int] disjuncts: _containers.RepeatedCompositeFieldContainer[Query] @@ -186,7 +186,7 @@ class DisjunctionMaxQuery(_message.Message): def __init__(self, disjuncts: _Optional[_Iterable[_Union[Query, _Mapping]]] = ..., tie_breaker: _Optional[str] = ...) -> None: ... class MoreLikeThisQuery(_message.Message): - __slots__ = ["document", "min_doc_frequency", "max_doc_frequency", "min_term_frequency", "max_query_terms", "min_word_length", "max_word_length", "boost", "stop_words"] + __slots__ = ("document", "min_doc_frequency", "max_doc_frequency", "min_term_frequency", "max_query_terms", "min_word_length", "max_word_length", "boost", "stop_words") DOCUMENT_FIELD_NUMBER: _ClassVar[int] MIN_DOC_FREQUENCY_FIELD_NUMBER: _ClassVar[int] MAX_DOC_FREQUENCY_FIELD_NUMBER: _ClassVar[int] @@ -208,7 +208,7 @@ class MoreLikeThisQuery(_message.Message): def __init__(self, document: _Optional[str] = ..., min_doc_frequency: _Optional[int] = ..., max_doc_frequency: _Optional[int] = ..., min_term_frequency: _Optional[int] = ..., max_query_terms: _Optional[int] = ..., min_word_length: _Optional[int] = ..., max_word_length: _Optional[int] = ..., boost: _Optional[str] = ..., stop_words: _Optional[_Iterable[str]] = ...) -> None: ... class PhraseQuery(_message.Message): - __slots__ = ["field", "value", "slop"] + __slots__ = ("field", "value", "slop") FIELD_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] SLOP_FIELD_NUMBER: _ClassVar[int] @@ -218,7 +218,7 @@ class PhraseQuery(_message.Message): def __init__(self, field: _Optional[str] = ..., value: _Optional[str] = ..., slop: _Optional[int] = ...) -> None: ... class RangeQuery(_message.Message): - __slots__ = ["field", "value"] + __slots__ = ("field", "value") FIELD_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] field: str @@ -226,7 +226,7 @@ class RangeQuery(_message.Message): def __init__(self, field: _Optional[str] = ..., value: _Optional[_Union[Range, _Mapping]] = ...) -> None: ... class MatchQuery(_message.Message): - __slots__ = ["value", "query_parser_config"] + __slots__ = ("value", "query_parser_config") VALUE_FIELD_NUMBER: _ClassVar[int] QUERY_PARSER_CONFIG_FIELD_NUMBER: _ClassVar[int] value: str @@ -234,7 +234,7 @@ class MatchQuery(_message.Message): def __init__(self, value: _Optional[str] = ..., query_parser_config: _Optional[_Union[QueryParserConfig, _Mapping]] = ...) -> None: ... class BooleanSubquery(_message.Message): - __slots__ = ["occur", "query"] + __slots__ = ("occur", "query") OCCUR_FIELD_NUMBER: _ClassVar[int] QUERY_FIELD_NUMBER: _ClassVar[int] occur: Occur @@ -242,13 +242,13 @@ class BooleanSubquery(_message.Message): def __init__(self, occur: _Optional[_Union[Occur, str]] = ..., query: _Optional[_Union[Query, _Mapping]] = ...) -> None: ... class BooleanQuery(_message.Message): - __slots__ = ["subqueries"] + __slots__ = ("subqueries",) SUBQUERIES_FIELD_NUMBER: _ClassVar[int] subqueries: _containers.RepeatedCompositeFieldContainer[BooleanSubquery] def __init__(self, subqueries: _Optional[_Iterable[_Union[BooleanSubquery, _Mapping]]] = ...) -> None: ... class RegexQuery(_message.Message): - __slots__ = ["field", "value"] + __slots__ = ("field", "value") FIELD_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] field: str @@ -256,7 +256,7 @@ class RegexQuery(_message.Message): def __init__(self, field: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... class TermQuery(_message.Message): - __slots__ = ["field", "value"] + __slots__ = ("field", "value") FIELD_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] field: str @@ -264,13 +264,13 @@ class TermQuery(_message.Message): def __init__(self, field: _Optional[str] = ..., value: _Optional[str] = ...) -> None: ... class ExistsQuery(_message.Message): - __slots__ = ["field"] + __slots__ = ("field",) FIELD_FIELD_NUMBER: _ClassVar[int] field: str def __init__(self, field: _Optional[str] = ...) -> None: ... class Range(_message.Message): - __slots__ = ["left", "right", "including_left", "including_right"] + __slots__ = ("left", "right", "including_left", "including_right") LEFT_FIELD_NUMBER: _ClassVar[int] RIGHT_FIELD_NUMBER: _ClassVar[int] INCLUDING_LEFT_FIELD_NUMBER: _ClassVar[int] @@ -282,7 +282,7 @@ class Range(_message.Message): def __init__(self, left: _Optional[str] = ..., right: _Optional[str] = ..., including_left: bool = ..., including_right: bool = ...) -> None: ... class Score(_message.Message): - __slots__ = ["f64_score", "u64_score"] + __slots__ = ("f64_score", "u64_score") F64_SCORE_FIELD_NUMBER: _ClassVar[int] U64_SCORE_FIELD_NUMBER: _ClassVar[int] f64_score: float @@ -290,14 +290,14 @@ class Score(_message.Message): def __init__(self, f64_score: _Optional[float] = ..., u64_score: _Optional[int] = ...) -> None: ... class Highlight(_message.Message): - __slots__ = ["to"] + __slots__ = ("to",) FROM_FIELD_NUMBER: _ClassVar[int] TO_FIELD_NUMBER: _ClassVar[int] to: int def __init__(self, to: _Optional[int] = ..., **kwargs) -> None: ... class Snippet(_message.Message): - __slots__ = ["fragment", "highlights", "html"] + __slots__ = ("fragment", "highlights", "html") FRAGMENT_FIELD_NUMBER: _ClassVar[int] HIGHLIGHTS_FIELD_NUMBER: _ClassVar[int] HTML_FIELD_NUMBER: _ClassVar[int] @@ -307,9 +307,9 @@ class Snippet(_message.Message): def __init__(self, fragment: _Optional[bytes] = ..., highlights: _Optional[_Iterable[_Union[Highlight, _Mapping]]] = ..., html: _Optional[str] = ...) -> None: ... class ScoredDocument(_message.Message): - __slots__ = ["document", "score", "position", "snippets", "index_alias"] + __slots__ = ("document", "score", "position", "snippets", "index_alias") class SnippetsEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -328,7 +328,7 @@ class ScoredDocument(_message.Message): def __init__(self, document: _Optional[str] = ..., score: _Optional[_Union[Score, _Mapping]] = ..., position: _Optional[int] = ..., snippets: _Optional[_Mapping[str, Snippet]] = ..., index_alias: _Optional[str] = ...) -> None: ... class Scorer(_message.Message): - __slots__ = ["eval_expr", "order_by"] + __slots__ = ("eval_expr", "order_by") EVAL_EXPR_FIELD_NUMBER: _ClassVar[int] ORDER_BY_FIELD_NUMBER: _ClassVar[int] eval_expr: str @@ -336,7 +336,7 @@ class Scorer(_message.Message): def __init__(self, eval_expr: _Optional[str] = ..., order_by: _Optional[str] = ...) -> None: ... class Collector(_message.Message): - __slots__ = ["top_docs", "reservoir_sampling", "count", "facet", "aggregation"] + __slots__ = ("top_docs", "reservoir_sampling", "count", "facet", "aggregation") TOP_DOCS_FIELD_NUMBER: _ClassVar[int] RESERVOIR_SAMPLING_FIELD_NUMBER: _ClassVar[int] COUNT_FIELD_NUMBER: _ClassVar[int] @@ -350,7 +350,7 @@ class Collector(_message.Message): def __init__(self, top_docs: _Optional[_Union[TopDocsCollector, _Mapping]] = ..., reservoir_sampling: _Optional[_Union[ReservoirSamplingCollector, _Mapping]] = ..., count: _Optional[_Union[CountCollector, _Mapping]] = ..., facet: _Optional[_Union[FacetCollector, _Mapping]] = ..., aggregation: _Optional[_Union[AggregationCollector, _Mapping]] = ...) -> None: ... class CollectorOutput(_message.Message): - __slots__ = ["documents", "count", "facet", "aggregation"] + __slots__ = ("documents", "count", "facet", "aggregation") DOCUMENTS_FIELD_NUMBER: _ClassVar[int] COUNT_FIELD_NUMBER: _ClassVar[int] FACET_FIELD_NUMBER: _ClassVar[int] @@ -362,17 +362,17 @@ class CollectorOutput(_message.Message): def __init__(self, documents: _Optional[_Union[DocumentsCollectorOutput, _Mapping]] = ..., count: _Optional[_Union[CountCollectorOutput, _Mapping]] = ..., facet: _Optional[_Union[FacetCollectorOutput, _Mapping]] = ..., aggregation: _Optional[_Union[AggregationCollectorOutput, _Mapping]] = ...) -> None: ... class CountCollector(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class CountCollectorOutput(_message.Message): - __slots__ = ["count"] + __slots__ = ("count",) COUNT_FIELD_NUMBER: _ClassVar[int] count: int def __init__(self, count: _Optional[int] = ...) -> None: ... class FacetCollector(_message.Message): - __slots__ = ["field", "facets"] + __slots__ = ("field", "facets") FIELD_FIELD_NUMBER: _ClassVar[int] FACETS_FIELD_NUMBER: _ClassVar[int] field: str @@ -380,9 +380,9 @@ class FacetCollector(_message.Message): def __init__(self, field: _Optional[str] = ..., facets: _Optional[_Iterable[str]] = ...) -> None: ... class FacetCollectorOutput(_message.Message): - __slots__ = ["facet_counts"] + __slots__ = ("facet_counts",) class FacetCountsEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -393,7 +393,7 @@ class FacetCollectorOutput(_message.Message): def __init__(self, facet_counts: _Optional[_Mapping[str, int]] = ...) -> None: ... class ReservoirSamplingCollector(_message.Message): - __slots__ = ["limit", "fields", "excluded_fields"] + __slots__ = ("limit", "fields", "excluded_fields") LIMIT_FIELD_NUMBER: _ClassVar[int] FIELDS_FIELD_NUMBER: _ClassVar[int] EXCLUDED_FIELDS_FIELD_NUMBER: _ClassVar[int] @@ -403,7 +403,7 @@ class ReservoirSamplingCollector(_message.Message): def __init__(self, limit: _Optional[int] = ..., fields: _Optional[_Iterable[str]] = ..., excluded_fields: _Optional[_Iterable[str]] = ...) -> None: ... class RandomDocument(_message.Message): - __slots__ = ["document", "score", "index_alias"] + __slots__ = ("document", "score", "index_alias") DOCUMENT_FIELD_NUMBER: _ClassVar[int] SCORE_FIELD_NUMBER: _ClassVar[int] INDEX_ALIAS_FIELD_NUMBER: _ClassVar[int] @@ -413,15 +413,15 @@ class RandomDocument(_message.Message): def __init__(self, document: _Optional[str] = ..., score: _Optional[_Union[Score, _Mapping]] = ..., index_alias: _Optional[str] = ...) -> None: ... class ReservoirSamplingCollectorOutput(_message.Message): - __slots__ = ["documents"] + __slots__ = ("documents",) DOCUMENTS_FIELD_NUMBER: _ClassVar[int] documents: _containers.RepeatedCompositeFieldContainer[RandomDocument] def __init__(self, documents: _Optional[_Iterable[_Union[RandomDocument, _Mapping]]] = ...) -> None: ... class TopDocsCollector(_message.Message): - __slots__ = ["limit", "offset", "scorer", "snippet_configs", "explain", "fields", "excluded_fields"] + __slots__ = ("limit", "offset", "scorer", "snippet_configs", "explain", "fields", "excluded_fields") class SnippetConfigsEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -444,7 +444,7 @@ class TopDocsCollector(_message.Message): def __init__(self, limit: _Optional[int] = ..., offset: _Optional[int] = ..., scorer: _Optional[_Union[Scorer, _Mapping]] = ..., snippet_configs: _Optional[_Mapping[str, int]] = ..., explain: bool = ..., fields: _Optional[_Iterable[str]] = ..., excluded_fields: _Optional[_Iterable[str]] = ...) -> None: ... class DocumentsCollectorOutput(_message.Message): - __slots__ = ["scored_documents", "has_next"] + __slots__ = ("scored_documents", "has_next") SCORED_DOCUMENTS_FIELD_NUMBER: _ClassVar[int] HAS_NEXT_FIELD_NUMBER: _ClassVar[int] scored_documents: _containers.RepeatedCompositeFieldContainer[ScoredDocument] @@ -452,13 +452,13 @@ class DocumentsCollectorOutput(_message.Message): def __init__(self, scored_documents: _Optional[_Iterable[_Union[ScoredDocument, _Mapping]]] = ..., has_next: bool = ...) -> None: ... class AggregationCollector(_message.Message): - __slots__ = ["aggregations"] + __slots__ = ("aggregations",) AGGREGATIONS_FIELD_NUMBER: _ClassVar[int] aggregations: str def __init__(self, aggregations: _Optional[str] = ...) -> None: ... class AggregationCollectorOutput(_message.Message): - __slots__ = ["aggregation_results"] + __slots__ = ("aggregation_results",) AGGREGATION_RESULTS_FIELD_NUMBER: _ClassVar[int] aggregation_results: str def __init__(self, aggregation_results: _Optional[str] = ...) -> None: ... diff --git a/aiosumma/aiosumma/proto/reflection_service_pb2.py b/aiosumma/aiosumma/proto/reflection_service_pb2.py index e4fe73b2..d01ecde4 100644 --- a/aiosumma/aiosumma/proto/reflection_service_pb2.py +++ b/aiosumma/aiosumma/proto/reflection_service_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: reflection_service.proto +# Protobuf Python Version: 4.25.0 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -20,8 +21,8 @@ _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'reflection_service_pb2', _globals) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None - _GETTOPTERMSRESPONSE_PERSEGMENTENTRY._options = None - _GETTOPTERMSRESPONSE_PERSEGMENTENTRY._serialized_options = b'8\001' + _globals['_GETTOPTERMSRESPONSE_PERSEGMENTENTRY']._options = None + _globals['_GETTOPTERMSRESPONSE_PERSEGMENTENTRY']._serialized_options = b'8\001' _globals['_GETTOPTERMSREQUEST']._serialized_start=41 _globals['_GETTOPTERMSREQUEST']._serialized_end=116 _globals['_GETTOPTERMSRESPONSE']._serialized_start=119 diff --git a/aiosumma/aiosumma/proto/reflection_service_pb2.pyi b/aiosumma/aiosumma/proto/reflection_service_pb2.pyi index 4c6ab268..926e2ad8 100644 --- a/aiosumma/aiosumma/proto/reflection_service_pb2.pyi +++ b/aiosumma/aiosumma/proto/reflection_service_pb2.pyi @@ -6,7 +6,7 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map DESCRIPTOR: _descriptor.FileDescriptor class GetTopTermsRequest(_message.Message): - __slots__ = ["index_name", "field_name", "top_k"] + __slots__ = ("index_name", "field_name", "top_k") INDEX_NAME_FIELD_NUMBER: _ClassVar[int] FIELD_NAME_FIELD_NUMBER: _ClassVar[int] TOP_K_FIELD_NUMBER: _ClassVar[int] @@ -16,9 +16,9 @@ class GetTopTermsRequest(_message.Message): def __init__(self, index_name: _Optional[str] = ..., field_name: _Optional[str] = ..., top_k: _Optional[int] = ...) -> None: ... class GetTopTermsResponse(_message.Message): - __slots__ = ["per_segment"] + __slots__ = ("per_segment",) class PerSegmentEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -29,13 +29,13 @@ class GetTopTermsResponse(_message.Message): def __init__(self, per_segment: _Optional[_Mapping[str, SegmentTerms]] = ...) -> None: ... class SegmentTerms(_message.Message): - __slots__ = ["term_infos"] + __slots__ = ("term_infos",) TERM_INFOS_FIELD_NUMBER: _ClassVar[int] term_infos: _containers.RepeatedCompositeFieldContainer[TermInfo] def __init__(self, term_infos: _Optional[_Iterable[_Union[TermInfo, _Mapping]]] = ...) -> None: ... class TermInfo(_message.Message): - __slots__ = ["key", "doc_freq"] + __slots__ = ("key", "doc_freq") KEY_FIELD_NUMBER: _ClassVar[int] DOC_FREQ_FIELD_NUMBER: _ClassVar[int] key: bytes diff --git a/aiosumma/aiosumma/proto/search_service_pb2.py b/aiosumma/aiosumma/proto/search_service_pb2.py index 91e767cd..f611b372 100644 --- a/aiosumma/aiosumma/proto/search_service_pb2.py +++ b/aiosumma/aiosumma/proto/search_service_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: search_service.proto +# Protobuf Python Version: 4.25.0 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/aiosumma/aiosumma/proto/unixfs_pb2.py b/aiosumma/aiosumma/proto/unixfs_pb2.py index 2dec273c..f94e355c 100644 --- a/aiosumma/aiosumma/proto/unixfs_pb2.py +++ b/aiosumma/aiosumma/proto/unixfs_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: unixfs.proto +# Protobuf Python Version: 4.25.0 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/aiosumma/aiosumma/proto/unixfs_pb2.pyi b/aiosumma/aiosumma/proto/unixfs_pb2.pyi index 3aaf0925..0a11416f 100644 --- a/aiosumma/aiosumma/proto/unixfs_pb2.pyi +++ b/aiosumma/aiosumma/proto/unixfs_pb2.pyi @@ -7,9 +7,9 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Optional as _Op DESCRIPTOR: _descriptor.FileDescriptor class Data(_message.Message): - __slots__ = ["type", "data", "filesize", "blocksizes", "hashType", "fanout"] + __slots__ = ("type", "data", "filesize", "blocksizes", "hashType", "fanout") class DataType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () Raw: _ClassVar[Data.DataType] Directory: _ClassVar[Data.DataType] File: _ClassVar[Data.DataType] @@ -37,7 +37,7 @@ class Data(_message.Message): def __init__(self, type: _Optional[_Union[Data.DataType, str]] = ..., data: _Optional[bytes] = ..., filesize: _Optional[int] = ..., blocksizes: _Optional[_Iterable[int]] = ..., hashType: _Optional[int] = ..., fanout: _Optional[int] = ...) -> None: ... class Metadata(_message.Message): - __slots__ = ["MimeType"] + __slots__ = ("MimeType",) MIMETYPE_FIELD_NUMBER: _ClassVar[int] MimeType: str def __init__(self, MimeType: _Optional[str] = ...) -> None: ... diff --git a/aiosumma/aiosumma/proto/utils_pb2.py b/aiosumma/aiosumma/proto/utils_pb2.py index 56c15578..9a94f52c 100644 --- a/aiosumma/aiosumma/proto/utils_pb2.py +++ b/aiosumma/aiosumma/proto/utils_pb2.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: utils.proto +# Protobuf Python Version: 4.25.0 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool diff --git a/aiosumma/aiosumma/proto/utils_pb2.pyi b/aiosumma/aiosumma/proto/utils_pb2.pyi index cb5f953f..9b728fbc 100644 --- a/aiosumma/aiosumma/proto/utils_pb2.pyi +++ b/aiosumma/aiosumma/proto/utils_pb2.pyi @@ -6,12 +6,12 @@ from typing import ClassVar as _ClassVar DESCRIPTOR: _descriptor.FileDescriptor class Order(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () Asc: _ClassVar[Order] Desc: _ClassVar[Order] Asc: Order Desc: Order class Empty(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... diff --git a/aiosumma/build.sh b/aiosumma/build.sh index 8e982dc4..27f53ca6 100755 --- a/aiosumma/build.sh +++ b/aiosumma/build.sh @@ -1,4 +1,4 @@ -#!/usr/bin/env bash + #!/usr/bin/env bash pip3 install -U build grpcio-tools twine rm -rf aiosumma/proto/* diff --git a/aiosumma/pyproject.toml b/aiosumma/pyproject.toml index 59da06db..a1b1e67f 100644 --- a/aiosumma/pyproject.toml +++ b/aiosumma/pyproject.toml @@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta" [project] name = "aiosumma" -version = "2.47.3" +version = "2.47.4" authors = [{ name = "Pasha Podolsky", email = "ppodolsky@me.com" }] description = "Async client for Summa Search" readme = "README.md" diff --git a/summa-core/src/components/summa_document.rs b/summa-core/src/components/summa_document.rs index 40b5d93d..a0c3efeb 100644 --- a/summa-core/src/components/summa_document.rs +++ b/summa-core/src/components/summa_document.rs @@ -56,9 +56,6 @@ pub fn process_dynamic_fields(schema: &Schema, json_object: &mut serde_json::Map } } } - if schema.get_field("updated_at").is_ok() { - json_object.insert("updated_at".to_string(), json!(current_time())); - } } /// Parse single json value