diff --git a/Makefile b/Makefile index 6ea08f4..8057f5a 100755 --- a/Makefile +++ b/Makefile @@ -49,6 +49,7 @@ PROTOS = \ v1/vald/filter.proto \ v1/vald/insert.proto \ v1/vald/object.proto \ + v1/vald/index.proto \ v1/vald/remove.proto \ v1/vald/search.proto \ v1/vald/update.proto \ diff --git a/VALD_SHA b/VALD_SHA index 9fdb6b7..5be43d6 100644 --- a/VALD_SHA +++ b/VALD_SHA @@ -1 +1 @@ -284fdb57b3afedecd330101968ba393381e58085 \ No newline at end of file +702e85153e90cdfea37c857e6f3a5cfd56755afa \ No newline at end of file diff --git a/src/tests/test_e2e.py b/src/tests/test_e2e.py index f73e659..bc44ca8 100644 --- a/src/tests/test_e2e.py +++ b/src/tests/test_e2e.py @@ -10,6 +10,7 @@ from vald.v1.vald import upsert_pb2_grpc from vald.v1.vald import remove_pb2_grpc from vald.v1.vald import object_pb2_grpc +from vald.v1.vald import index_pb2_grpc from vald.v1.payload import payload_pb2 @@ -79,7 +80,7 @@ def test_save_index(self): self.assertIsInstance(result, payload_pb2.Empty) def test_index_info(self): - stub = agent_pb2_grpc.AgentStub(self.channel) + stub = index_pb2_grpc.IndexStub(self.channel) result = stub.IndexInfo(payload_pb2.Empty()) self.assertIsInstance(result, payload_pb2.Info.Index.Count) self.assertEqual(result.stored, 99) diff --git a/src/vald/v1/agent/core/agent_pb2.py b/src/vald/v1/agent/core/agent_pb2.py index ddf6cac..3b8ba77 100644 --- a/src/vald/v1/agent/core/agent_pb2.py +++ b/src/vald/v1/agent/core/agent_pb2.py @@ -26,7 +26,7 @@ from vald.v1.payload import payload_pb2 as vald_dot_v1_dot_payload_dot_payload__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1evald/v1/agent/core/agent.proto\x12\x07\x63ore.v1\x1a\x1cgoogle/api/annotations.proto\x1a\x1dvald/v1/payload/payload.proto2\xde\x03\n\x05\x41gent\x12_\n\x0b\x43reateIndex\x12&.payload.v1.Control.CreateIndexRequest\x1a\x11.payload.v1.Empty\"\x15\x82\xd3\xe4\x93\x02\x0f\x12\r/index/create\x12\x46\n\tSaveIndex\x12\x11.payload.v1.Empty\x1a\x11.payload.v1.Empty\"\x13\x82\xd3\xe4\x93\x02\r\x12\x0b/index/save\x12m\n\x12\x43reateAndSaveIndex\x12&.payload.v1.Control.CreateIndexRequest\x1a\x11.payload.v1.Empty\"\x1c\x82\xd3\xe4\x93\x02\x16\x12\x14/index/createandsave\x12Q\n\tIndexInfo\x12\x11.payload.v1.Empty\x1a\x1c.payload.v1.Info.Index.Count\"\x13\x82\xd3\xe4\x93\x02\r\x12\x0b/index/info\x12j\n\x0cGetTimestamp\x12&.payload.v1.Object.GetTimestampRequest\x1a\x1c.payload.v1.Object.Timestamp\"\x14\x82\xd3\xe4\x93\x02\x0e\x12\x0c/object/metaBc\n org.vdaas.vald.api.v1.agent.coreB\tValdAgentP\x01Z2github.com/vdaas/vald/apis/grpc/v1/agent/core;coreb\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1evald/v1/agent/core/agent.proto\x12\x07\x63ore.v1\x1a\x1cgoogle/api/annotations.proto\x1a\x1dvald/v1/payload/payload.proto2\xb7\x02\n\x05\x41gent\x12k\n\x0b\x43reateIndex\x12&.payload.v1.Control.CreateIndexRequest\x1a\x11.payload.v1.Empty\"!\x82\xd3\xe4\x93\x02\x1b\x12\x19/index/create/{pool_size}\x12\x46\n\tSaveIndex\x12\x11.payload.v1.Empty\x1a\x11.payload.v1.Empty\"\x13\x82\xd3\xe4\x93\x02\r\x12\x0b/index/save\x12y\n\x12\x43reateAndSaveIndex\x12&.payload.v1.Control.CreateIndexRequest\x1a\x11.payload.v1.Empty\"(\x82\xd3\xe4\x93\x02\"\x12 /index/createandsave/{pool_size}Bc\n org.vdaas.vald.api.v1.agent.coreB\tValdAgentP\x01Z2github.com/vdaas/vald/apis/grpc/v1/agent/core;coreb\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -35,15 +35,11 @@ _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'\n org.vdaas.vald.api.v1.agent.coreB\tValdAgentP\001Z2github.com/vdaas/vald/apis/grpc/v1/agent/core;core' _globals['_AGENT'].methods_by_name['CreateIndex']._loaded_options = None - _globals['_AGENT'].methods_by_name['CreateIndex']._serialized_options = b'\202\323\344\223\002\017\022\r/index/create' + _globals['_AGENT'].methods_by_name['CreateIndex']._serialized_options = b'\202\323\344\223\002\033\022\031/index/create/{pool_size}' _globals['_AGENT'].methods_by_name['SaveIndex']._loaded_options = None _globals['_AGENT'].methods_by_name['SaveIndex']._serialized_options = b'\202\323\344\223\002\r\022\013/index/save' _globals['_AGENT'].methods_by_name['CreateAndSaveIndex']._loaded_options = None - _globals['_AGENT'].methods_by_name['CreateAndSaveIndex']._serialized_options = b'\202\323\344\223\002\026\022\024/index/createandsave' - _globals['_AGENT'].methods_by_name['IndexInfo']._loaded_options = None - _globals['_AGENT'].methods_by_name['IndexInfo']._serialized_options = b'\202\323\344\223\002\r\022\013/index/info' - _globals['_AGENT'].methods_by_name['GetTimestamp']._loaded_options = None - _globals['_AGENT'].methods_by_name['GetTimestamp']._serialized_options = b'\202\323\344\223\002\016\022\014/object/meta' + _globals['_AGENT'].methods_by_name['CreateAndSaveIndex']._serialized_options = b'\202\323\344\223\002\"\022 /index/createandsave/{pool_size}' _globals['_AGENT']._serialized_start=105 - _globals['_AGENT']._serialized_end=583 + _globals['_AGENT']._serialized_end=416 # @@protoc_insertion_point(module_scope) diff --git a/src/vald/v1/agent/core/agent_pb2_grpc.py b/src/vald/v1/agent/core/agent_pb2_grpc.py index 32ea0e0..9c780ab 100644 --- a/src/vald/v1/agent/core/agent_pb2_grpc.py +++ b/src/vald/v1/agent/core/agent_pb2_grpc.py @@ -30,16 +30,6 @@ def __init__(self, channel): request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Control.CreateIndexRequest.SerializeToString, response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.FromString, _registered_method=True) - self.IndexInfo = channel.unary_unary( - '/core.v1.Agent/IndexInfo', - request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString, - response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Info.Index.Count.FromString, - _registered_method=True) - self.GetTimestamp = channel.unary_unary( - '/core.v1.Agent/GetTimestamp', - request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.GetTimestampRequest.SerializeToString, - response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.Timestamp.FromString, - _registered_method=True) class AgentServicer(object): @@ -67,20 +57,6 @@ def CreateAndSaveIndex(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') - def IndexInfo(self, request, context): - """Represent the RPC to get the agent index information. - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def GetTimestamp(self, request, context): - """Represent the RPC to get the vector metadata. This RPC is mainly used for index correction process - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - def add_AgentServicer_to_server(servicer, server): rpc_method_handlers = { @@ -99,16 +75,6 @@ def add_AgentServicer_to_server(servicer, server): request_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Control.CreateIndexRequest.FromString, response_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString, ), - 'IndexInfo': grpc.unary_unary_rpc_method_handler( - servicer.IndexInfo, - request_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.FromString, - response_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Info.Index.Count.SerializeToString, - ), - 'GetTimestamp': grpc.unary_unary_rpc_method_handler( - servicer.GetTimestamp, - request_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.GetTimestampRequest.FromString, - response_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.Timestamp.SerializeToString, - ), } generic_handler = grpc.method_handlers_generic_handler( 'core.v1.Agent', rpc_method_handlers) @@ -201,57 +167,3 @@ def CreateAndSaveIndex(request, timeout, metadata, _registered_method=True) - - @staticmethod - def IndexInfo(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/core.v1.Agent/IndexInfo', - vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString, - vald_dot_v1_dot_payload_dot_payload__pb2.Info.Index.Count.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) - - @staticmethod - def GetTimestamp(request, - target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary( - request, - target, - '/core.v1.Agent/GetTimestamp', - vald_dot_v1_dot_payload_dot_payload__pb2.Object.GetTimestampRequest.SerializeToString, - vald_dot_v1_dot_payload_dot_payload__pb2.Object.Timestamp.FromString, - options, - channel_credentials, - insecure, - call_credentials, - compression, - wait_for_ready, - timeout, - metadata, - _registered_method=True) diff --git a/src/vald/v1/payload/payload_pb2.py b/src/vald/v1/payload/payload_pb2.py index 4d875cb..10ab0d7 100644 --- a/src/vald/v1/payload/payload_pb2.py +++ b/src/vald/v1/payload/payload_pb2.py @@ -27,7 +27,7 @@ from google.rpc import status_pb2 as google_dot_rpc_dot_status__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1dvald/v1/payload/payload.proto\x12\npayload.v1\x1a\x1b\x62uf/validate/validate.proto\x1a\x1egoogle/protobuf/wrappers.proto\x1a\x17google/rpc/status.proto\"\xa0\x0b\n\x06Search\x1a^\n\x07Request\x12 \n\x06vector\x18\x01 \x03(\x02\x42\x08\xbaH\x05\x92\x01\x02\x08\x02R\x06vector\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Search.ConfigR\x06\x63onfig\x1a\x46\n\x0cMultiRequest\x12\x36\n\x08requests\x18\x01 \x03(\x0b\x32\x1a.payload.v1.Search.RequestR\x08requests\x1aN\n\tIDRequest\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Search.ConfigR\x06\x63onfig\x1aJ\n\x0eMultiIDRequest\x12\x38\n\x08requests\x18\x01 \x03(\x0b\x32\x1c.payload.v1.Search.IDRequestR\x08requests\x1a\x95\x01\n\rObjectRequest\x12\x16\n\x06object\x18\x01 \x01(\x0cR\x06object\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Search.ConfigR\x06\x63onfig\x12\x39\n\nvectorizer\x18\x03 \x01(\x0b\x32\x19.payload.v1.Filter.TargetR\nvectorizer\x1aR\n\x12MultiObjectRequest\x12<\n\x08requests\x18\x01 \x03(\x0b\x32 .payload.v1.Search.ObjectRequestR\x08requests\x1a\xc7\x03\n\x06\x43onfig\x12\x1d\n\nrequest_id\x18\x01 \x01(\tR\trequestId\x12\x19\n\x03num\x18\x02 \x01(\rB\x07\xbaH\x04*\x02(\x01R\x03num\x12\x16\n\x06radius\x18\x03 \x01(\x02R\x06radius\x12\x18\n\x07\x65psilon\x18\x04 \x01(\x02R\x07\x65psilon\x12\x18\n\x07timeout\x18\x05 \x01(\x03R\x07timeout\x12\x42\n\x0fingress_filters\x18\x06 \x01(\x0b\x32\x19.payload.v1.Filter.ConfigR\x0eingressFilters\x12@\n\x0e\x65gress_filters\x18\x07 \x01(\x0b\x32\x19.payload.v1.Filter.ConfigR\regressFilters\x12 \n\x07min_num\x18\x08 \x01(\rB\x07\xbaH\x04*\x02(\x00R\x06minNum\x12\\\n\x15\x61ggregation_algorithm\x18\t \x01(\x0e\x32\'.payload.v1.Search.AggregationAlgorithmR\x14\x61ggregationAlgorithm\x12\x31\n\x05ratio\x18\n \x01(\x0b\x32\x1b.google.protobuf.FloatValueR\x05ratio\x1a`\n\x08Response\x12\x1d\n\nrequest_id\x18\x01 \x01(\tR\trequestId\x12\x35\n\x07results\x18\x02 \x03(\x0b\x32\x1b.payload.v1.Object.DistanceR\x07results\x1a\x46\n\tResponses\x12\x39\n\tresponses\x18\x01 \x03(\x0b\x32\x1b.payload.v1.Search.ResponseR\tresponses\x1a\x84\x01\n\x0eStreamResponse\x12\x39\n\x08response\x18\x01 \x01(\x0b\x32\x1b.payload.v1.Search.ResponseH\x00R\x08response\x12,\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.StatusH\x00R\x06statusB\t\n\x07payload\"k\n\x14\x41ggregationAlgorithm\x12\x0b\n\x07Unknown\x10\x00\x12\x13\n\x0f\x43oncurrentQueue\x10\x01\x12\r\n\tSortSlice\x10\x02\x12\x11\n\rSortPoolSlice\x10\x03\x12\x0f\n\x0bPairingHeap\x10\x04\"y\n\x06\x46ilter\x1a\x30\n\x06Target\x12\x12\n\x04host\x18\x01 \x01(\tR\x04host\x12\x12\n\x04port\x18\x02 \x01(\rR\x04port\x1a=\n\x06\x43onfig\x12\x33\n\x07targets\x18\x01 \x03(\x0b\x32\x19.payload.v1.Filter.TargetR\x07targets\"\xe5\x04\n\x06Insert\x1ay\n\x07Request\x12;\n\x06vector\x18\x01 \x01(\x0b\x32\x19.payload.v1.Object.VectorB\x08\xbaH\x05\x92\x01\x02\x08\x02R\x06vector\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Insert.ConfigR\x06\x63onfig\x1a\x46\n\x0cMultiRequest\x12\x36\n\x08requests\x18\x01 \x03(\x0b\x32\x1a.payload.v1.Insert.RequestR\x08requests\x1a\xae\x01\n\rObjectRequest\x12/\n\x06object\x18\x01 \x01(\x0b\x32\x17.payload.v1.Object.BlobR\x06object\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Insert.ConfigR\x06\x63onfig\x12\x39\n\nvectorizer\x18\x03 \x01(\x0b\x32\x19.payload.v1.Filter.TargetR\nvectorizer\x1aR\n\x12MultiObjectRequest\x12<\n\x08requests\x18\x01 \x03(\x0b\x32 .payload.v1.Insert.ObjectRequestR\x08requests\x1a\x92\x01\n\x06\x43onfig\x12\x35\n\x17skip_strict_exist_check\x18\x01 \x01(\x08R\x14skipStrictExistCheck\x12\x33\n\x07\x66ilters\x18\x02 \x01(\x0b\x32\x19.payload.v1.Filter.ConfigR\x07\x66ilters\x12\x1c\n\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\"\x9d\x05\n\x06Update\x1ay\n\x07Request\x12;\n\x06vector\x18\x01 \x01(\x0b\x32\x19.payload.v1.Object.VectorB\x08\xbaH\x05\x92\x01\x02\x08\x02R\x06vector\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Update.ConfigR\x06\x63onfig\x1a\x46\n\x0cMultiRequest\x12\x36\n\x08requests\x18\x01 \x03(\x0b\x32\x1a.payload.v1.Update.RequestR\x08requests\x1a\xae\x01\n\rObjectRequest\x12/\n\x06object\x18\x01 \x01(\x0b\x32\x17.payload.v1.Object.BlobR\x06object\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Update.ConfigR\x06\x63onfig\x12\x39\n\nvectorizer\x18\x03 \x01(\x0b\x32\x19.payload.v1.Filter.TargetR\nvectorizer\x1aR\n\x12MultiObjectRequest\x12<\n\x08requests\x18\x01 \x03(\x0b\x32 .payload.v1.Update.ObjectRequestR\x08requests\x1a\xca\x01\n\x06\x43onfig\x12\x35\n\x17skip_strict_exist_check\x18\x01 \x01(\x08R\x14skipStrictExistCheck\x12\x33\n\x07\x66ilters\x18\x02 \x01(\x0b\x32\x19.payload.v1.Filter.ConfigR\x07\x66ilters\x12\x1c\n\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x12\x36\n\x17\x64isable_balanced_update\x18\x04 \x01(\x08R\x15\x64isableBalancedUpdate\"\x9d\x05\n\x06Upsert\x1ay\n\x07Request\x12;\n\x06vector\x18\x01 \x01(\x0b\x32\x19.payload.v1.Object.VectorB\x08\xbaH\x05\x92\x01\x02\x08\x02R\x06vector\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Upsert.ConfigR\x06\x63onfig\x1a\x46\n\x0cMultiRequest\x12\x36\n\x08requests\x18\x01 \x03(\x0b\x32\x1a.payload.v1.Upsert.RequestR\x08requests\x1a\xae\x01\n\rObjectRequest\x12/\n\x06object\x18\x01 \x01(\x0b\x32\x17.payload.v1.Object.BlobR\x06object\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Upsert.ConfigR\x06\x63onfig\x12\x39\n\nvectorizer\x18\x03 \x01(\x0b\x32\x19.payload.v1.Filter.TargetR\nvectorizer\x1aR\n\x12MultiObjectRequest\x12<\n\x08requests\x18\x01 \x03(\x0b\x32 .payload.v1.Upsert.ObjectRequestR\x08requests\x1a\xca\x01\n\x06\x43onfig\x12\x35\n\x17skip_strict_exist_check\x18\x01 \x01(\x08R\x14skipStrictExistCheck\x12\x33\n\x07\x66ilters\x18\x02 \x01(\x0b\x32\x19.payload.v1.Filter.ConfigR\x07\x66ilters\x12\x1c\n\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x12\x36\n\x17\x64isable_balanced_update\x18\x04 \x01(\x08R\x15\x64isableBalancedUpdate\"\x91\x04\n\x06Remove\x1a\x63\n\x07Request\x12%\n\x02id\x18\x01 \x01(\x0b\x32\x15.payload.v1.Object.IDR\x02id\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Remove.ConfigR\x06\x63onfig\x1a\x46\n\x0cMultiRequest\x12\x36\n\x08requests\x18\x01 \x03(\x0b\x32\x1a.payload.v1.Remove.RequestR\x08requests\x1aP\n\x10TimestampRequest\x12<\n\ntimestamps\x18\x01 \x03(\x0b\x32\x1c.payload.v1.Remove.TimestampR\ntimestamps\x1a\xa8\x01\n\tTimestamp\x12\x1c\n\ttimestamp\x18\x01 \x01(\x03R\ttimestamp\x12\x41\n\x08operator\x18\x02 \x01(\x0e\x32%.payload.v1.Remove.Timestamp.OperatorR\x08operator\":\n\x08Operator\x12\x06\n\x02\x45q\x10\x00\x12\x06\n\x02Ne\x10\x01\x12\x06\n\x02Ge\x10\x02\x12\x06\n\x02Gt\x10\x03\x12\x06\n\x02Le\x10\x04\x12\x06\n\x02Lt\x10\x05\x1a]\n\x06\x43onfig\x12\x35\n\x17skip_strict_exist_check\x18\x01 \x01(\x08R\x14skipStrictExistCheck\x12\x1c\n\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\"\x12\n\x05\x46lush\x1a\t\n\x07Request\"\xb4\x0b\n\x06Object\x1au\n\rVectorRequest\x12/\n\x02id\x18\x01 \x01(\x0b\x32\x15.payload.v1.Object.IDB\x08\xbaH\x05\x92\x01\x02\x08\x02R\x02id\x12\x33\n\x07\x66ilters\x18\x02 \x01(\x0b\x32\x19.payload.v1.Filter.ConfigR\x07\x66ilters\x1a\x36\n\x08\x44istance\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id\x12\x1a\n\x08\x64istance\x18\x02 \x01(\x02R\x08\x64istance\x1a\x84\x01\n\x0eStreamDistance\x12\x39\n\x08\x64istance\x18\x01 \x01(\x0b\x32\x1b.payload.v1.Object.DistanceH\x00R\x08\x64istance\x12,\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.StatusH\x00R\x06statusB\t\n\x07payload\x1a\x1d\n\x02ID\x12\x17\n\x02id\x18\x01 \x01(\tB\x07\xbaH\x04r\x02\x10\x01R\x02id\x1a\x17\n\x03IDs\x12\x10\n\x03ids\x18\x01 \x03(\tR\x03ids\x1a\x61\n\x06Vector\x12\x17\n\x02id\x18\x01 \x01(\tB\x07\xbaH\x04r\x02\x10\x01R\x02id\x12 \n\x06vector\x18\x02 \x03(\x02\x42\x08\xbaH\x05\x92\x01\x02\x08\x02R\x06vector\x12\x1c\n\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x1a\x46\n\x13GetTimestampRequest\x12/\n\x02id\x18\x01 \x01(\x0b\x32\x15.payload.v1.Object.IDB\x08\xbaH\x05\x92\x01\x02\x08\x02R\x02id\x1a\x42\n\tTimestamp\x12\x17\n\x02id\x18\x01 \x01(\tB\x07\xbaH\x04r\x02\x10\x01R\x02id\x12\x1c\n\ttimestamp\x18\x02 \x01(\x03R\ttimestamp\x1a>\n\x07Vectors\x12\x33\n\x07vectors\x18\x01 \x03(\x0b\x32\x19.payload.v1.Object.VectorR\x07vectors\x1a|\n\x0cStreamVector\x12\x33\n\x06vector\x18\x01 \x01(\x0b\x32\x19.payload.v1.Object.VectorH\x00R\x06vector\x12,\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.StatusH\x00R\x06statusB\t\n\x07payload\x1a=\n\rReshapeVector\x12\x16\n\x06object\x18\x01 \x01(\x0cR\x06object\x12\x14\n\x05shape\x18\x02 \x03(\x05R\x05shape\x1a\x37\n\x04\x42lob\x12\x17\n\x02id\x18\x01 \x01(\tB\x07\xbaH\x04r\x02\x10\x01R\x02id\x12\x16\n\x06object\x18\x02 \x01(\x0cR\x06object\x1at\n\nStreamBlob\x12-\n\x04\x62lob\x18\x01 \x01(\x0b\x32\x17.payload.v1.Object.BlobH\x00R\x04\x62lob\x12,\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.StatusH\x00R\x06statusB\t\n\x07payload\x1a\x44\n\x08Location\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x12\n\x04uuid\x18\x02 \x01(\tR\x04uuid\x12\x10\n\x03ips\x18\x03 \x03(\tR\x03ips\x1a\x84\x01\n\x0eStreamLocation\x12\x39\n\x08location\x18\x01 \x01(\x0b\x32\x1b.payload.v1.Object.LocationH\x00R\x08location\x12,\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.StatusH\x00R\x06statusB\t\n\x07payload\x1a\x46\n\tLocations\x12\x39\n\tlocations\x18\x01 \x03(\x0b\x32\x1b.payload.v1.Object.LocationR\tlocations\x1a\x8b\x01\n\x04List\x1a\t\n\x07Request\x1ax\n\x08Response\x12\x33\n\x06vector\x18\x01 \x01(\x0b\x32\x19.payload.v1.Object.VectorH\x00R\x06vector\x12,\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.StatusH\x00R\x06statusB\t\n\x07payload\"E\n\x07\x43ontrol\x1a:\n\x12\x43reateIndexRequest\x12$\n\tpool_size\x18\x01 \x01(\rB\x07\xbaH\x04*\x02(\x00R\x08poolSize\"f\n\nDiscoverer\x1aX\n\x07Request\x12\x1b\n\x04name\x18\x01 \x01(\tB\x07\xbaH\x04r\x02\x10\x01R\x04name\x12\x1c\n\tnamespace\x18\x02 \x01(\tR\tnamespace\x12\x12\n\x04node\x18\x03 \x01(\tR\x04node\"\x8c\r\n\x04Info\x1a\xca\x01\n\x05Index\x1au\n\x05\x43ount\x12\x16\n\x06stored\x18\x01 \x01(\rR\x06stored\x12 \n\x0buncommitted\x18\x02 \x01(\rR\x0buncommitted\x12\x1a\n\x08indexing\x18\x03 \x01(\x08R\x08indexing\x12\x16\n\x06saving\x18\x04 \x01(\x08R\x06saving\x1aJ\n\x04UUID\x1a\x1f\n\tCommitted\x12\x12\n\x04uuid\x18\x01 \x01(\tR\x04uuid\x1a!\n\x0bUncommitted\x12\x12\n\x04uuid\x18\x01 \x01(\tR\x04uuid\x1a\xef\x01\n\x03Pod\x12\x19\n\x08\x61pp_name\x18\x01 \x01(\tR\x07\x61ppName\x12\x12\n\x04name\x18\x02 \x01(\tR\x04name\x12\x1c\n\tnamespace\x18\x03 \x01(\tR\tnamespace\x12\x17\n\x02ip\x18\x04 \x01(\tB\x07\xbaH\x04r\x02x\x01R\x02ip\x12&\n\x03\x63pu\x18\x05 \x01(\x0b\x32\x14.payload.v1.Info.CPUR\x03\x63pu\x12/\n\x06memory\x18\x06 \x01(\x0b\x32\x17.payload.v1.Info.MemoryR\x06memory\x12)\n\x04node\x18\x07 \x01(\x0b\x32\x15.payload.v1.Info.NodeR\x04node\x1a\xe8\x01\n\x04Node\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12#\n\rinternal_addr\x18\x02 \x01(\tR\x0cinternalAddr\x12#\n\rexternal_addr\x18\x03 \x01(\tR\x0c\x65xternalAddr\x12&\n\x03\x63pu\x18\x04 \x01(\x0b\x32\x14.payload.v1.Info.CPUR\x03\x63pu\x12/\n\x06memory\x18\x05 \x01(\x0b\x32\x17.payload.v1.Info.MemoryR\x06memory\x12)\n\x04Pods\x18\x06 \x01(\x0b\x32\x15.payload.v1.Info.PodsR\x04Pods\x1a\x82\x02\n\x07Service\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x1d\n\ncluster_ip\x18\x02 \x01(\tR\tclusterIp\x12\x1f\n\x0b\x63luster_ips\x18\x03 \x03(\tR\nclusterIps\x12\x32\n\x05ports\x18\x04 \x03(\x0b\x32\x1c.payload.v1.Info.ServicePortR\x05ports\x12/\n\x06labels\x18\x05 \x01(\x0b\x32\x17.payload.v1.Info.LabelsR\x06labels\x12>\n\x0b\x61nnotations\x18\x06 \x01(\x0b\x32\x1c.payload.v1.Info.AnnotationsR\x0b\x61nnotations\x1a\x35\n\x0bServicePort\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x12\n\x04port\x18\x02 \x01(\x05R\x04port\x1a\x80\x01\n\x06Labels\x12;\n\x06labels\x18\x01 \x03(\x0b\x32#.payload.v1.Info.Labels.LabelsEntryR\x06labels\x1a\x39\n\x0bLabelsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1a\x9e\x01\n\x0b\x41nnotations\x12O\n\x0b\x61nnotations\x18\x01 \x03(\x0b\x32-.payload.v1.Info.Annotations.AnnotationsEntryR\x0b\x61nnotations\x1a>\n\x10\x41nnotationsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1aK\n\x03\x43PU\x12\x14\n\x05limit\x18\x01 \x01(\x01R\x05limit\x12\x18\n\x07request\x18\x02 \x01(\x01R\x07request\x12\x14\n\x05usage\x18\x03 \x01(\x01R\x05usage\x1aN\n\x06Memory\x12\x14\n\x05limit\x18\x01 \x01(\x01R\x05limit\x12\x18\n\x07request\x18\x02 \x01(\x01R\x07request\x12\x14\n\x05usage\x18\x03 \x01(\x01R\x05usage\x1a:\n\x04Pods\x12\x32\n\x04pods\x18\x01 \x03(\x0b\x32\x14.payload.v1.Info.PodB\x08\xbaH\x05\x92\x01\x02\x08\x01R\x04pods\x1a>\n\x05Nodes\x12\x35\n\x05nodes\x18\x01 \x03(\x0b\x32\x15.payload.v1.Info.NodeB\x08\xbaH\x05\x92\x01\x02\x08\x01R\x05nodes\x1aJ\n\x08Services\x12>\n\x08services\x18\x01 \x03(\x0b\x32\x18.payload.v1.Info.ServiceB\x08\xbaH\x05\x92\x01\x02\x08\x01R\x08services\x1a\x15\n\x03IPs\x12\x0e\n\x02ip\x18\x01 \x03(\tR\x02ip\"z\n\x06Mirror\x1a\x30\n\x06Target\x12\x12\n\x04host\x18\x01 \x01(\tR\x04host\x12\x12\n\x04port\x18\x02 \x01(\rR\x04port\x1a>\n\x07Targets\x12\x33\n\x07targets\x18\x01 \x03(\x0b\x32\x19.payload.v1.Mirror.TargetR\x07targets\"\x07\n\x05\x45mptyBd\n\x1dorg.vdaas.vald.api.v1.payloadB\x0bValdPayloadP\x01Z*github.com/vdaas/vald/apis/grpc/v1/payload\xa2\x02\x07Payloadb\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1dvald/v1/payload/payload.proto\x12\npayload.v1\x1a\x1b\x62uf/validate/validate.proto\x1a\x1egoogle/protobuf/wrappers.proto\x1a\x17google/rpc/status.proto\"\xa0\x0b\n\x06Search\x1a^\n\x07Request\x12 \n\x06vector\x18\x01 \x03(\x02\x42\x08\xbaH\x05\x92\x01\x02\x08\x02R\x06vector\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Search.ConfigR\x06\x63onfig\x1a\x46\n\x0cMultiRequest\x12\x36\n\x08requests\x18\x01 \x03(\x0b\x32\x1a.payload.v1.Search.RequestR\x08requests\x1aN\n\tIDRequest\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Search.ConfigR\x06\x63onfig\x1aJ\n\x0eMultiIDRequest\x12\x38\n\x08requests\x18\x01 \x03(\x0b\x32\x1c.payload.v1.Search.IDRequestR\x08requests\x1a\x95\x01\n\rObjectRequest\x12\x16\n\x06object\x18\x01 \x01(\x0cR\x06object\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Search.ConfigR\x06\x63onfig\x12\x39\n\nvectorizer\x18\x03 \x01(\x0b\x32\x19.payload.v1.Filter.TargetR\nvectorizer\x1aR\n\x12MultiObjectRequest\x12<\n\x08requests\x18\x01 \x03(\x0b\x32 .payload.v1.Search.ObjectRequestR\x08requests\x1a\xc7\x03\n\x06\x43onfig\x12\x1d\n\nrequest_id\x18\x01 \x01(\tR\trequestId\x12\x19\n\x03num\x18\x02 \x01(\rB\x07\xbaH\x04*\x02(\x01R\x03num\x12\x16\n\x06radius\x18\x03 \x01(\x02R\x06radius\x12\x18\n\x07\x65psilon\x18\x04 \x01(\x02R\x07\x65psilon\x12\x18\n\x07timeout\x18\x05 \x01(\x03R\x07timeout\x12\x42\n\x0fingress_filters\x18\x06 \x01(\x0b\x32\x19.payload.v1.Filter.ConfigR\x0eingressFilters\x12@\n\x0e\x65gress_filters\x18\x07 \x01(\x0b\x32\x19.payload.v1.Filter.ConfigR\regressFilters\x12 \n\x07min_num\x18\x08 \x01(\rB\x07\xbaH\x04*\x02(\x00R\x06minNum\x12\\\n\x15\x61ggregation_algorithm\x18\t \x01(\x0e\x32\'.payload.v1.Search.AggregationAlgorithmR\x14\x61ggregationAlgorithm\x12\x31\n\x05ratio\x18\n \x01(\x0b\x32\x1b.google.protobuf.FloatValueR\x05ratio\x1a`\n\x08Response\x12\x1d\n\nrequest_id\x18\x01 \x01(\tR\trequestId\x12\x35\n\x07results\x18\x02 \x03(\x0b\x32\x1b.payload.v1.Object.DistanceR\x07results\x1a\x46\n\tResponses\x12\x39\n\tresponses\x18\x01 \x03(\x0b\x32\x1b.payload.v1.Search.ResponseR\tresponses\x1a\x84\x01\n\x0eStreamResponse\x12\x39\n\x08response\x18\x01 \x01(\x0b\x32\x1b.payload.v1.Search.ResponseH\x00R\x08response\x12,\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.StatusH\x00R\x06statusB\t\n\x07payload\"k\n\x14\x41ggregationAlgorithm\x12\x0b\n\x07Unknown\x10\x00\x12\x13\n\x0f\x43oncurrentQueue\x10\x01\x12\r\n\tSortSlice\x10\x02\x12\x11\n\rSortPoolSlice\x10\x03\x12\x0f\n\x0bPairingHeap\x10\x04\"y\n\x06\x46ilter\x1a\x30\n\x06Target\x12\x12\n\x04host\x18\x01 \x01(\tR\x04host\x12\x12\n\x04port\x18\x02 \x01(\rR\x04port\x1a=\n\x06\x43onfig\x12\x33\n\x07targets\x18\x01 \x03(\x0b\x32\x19.payload.v1.Filter.TargetR\x07targets\"\xe5\x04\n\x06Insert\x1ay\n\x07Request\x12;\n\x06vector\x18\x01 \x01(\x0b\x32\x19.payload.v1.Object.VectorB\x08\xbaH\x05\x92\x01\x02\x08\x02R\x06vector\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Insert.ConfigR\x06\x63onfig\x1a\x46\n\x0cMultiRequest\x12\x36\n\x08requests\x18\x01 \x03(\x0b\x32\x1a.payload.v1.Insert.RequestR\x08requests\x1a\xae\x01\n\rObjectRequest\x12/\n\x06object\x18\x01 \x01(\x0b\x32\x17.payload.v1.Object.BlobR\x06object\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Insert.ConfigR\x06\x63onfig\x12\x39\n\nvectorizer\x18\x03 \x01(\x0b\x32\x19.payload.v1.Filter.TargetR\nvectorizer\x1aR\n\x12MultiObjectRequest\x12<\n\x08requests\x18\x01 \x03(\x0b\x32 .payload.v1.Insert.ObjectRequestR\x08requests\x1a\x92\x01\n\x06\x43onfig\x12\x35\n\x17skip_strict_exist_check\x18\x01 \x01(\x08R\x14skipStrictExistCheck\x12\x33\n\x07\x66ilters\x18\x02 \x01(\x0b\x32\x19.payload.v1.Filter.ConfigR\x07\x66ilters\x12\x1c\n\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\"\x9d\x05\n\x06Update\x1ay\n\x07Request\x12;\n\x06vector\x18\x01 \x01(\x0b\x32\x19.payload.v1.Object.VectorB\x08\xbaH\x05\x92\x01\x02\x08\x02R\x06vector\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Update.ConfigR\x06\x63onfig\x1a\x46\n\x0cMultiRequest\x12\x36\n\x08requests\x18\x01 \x03(\x0b\x32\x1a.payload.v1.Update.RequestR\x08requests\x1a\xae\x01\n\rObjectRequest\x12/\n\x06object\x18\x01 \x01(\x0b\x32\x17.payload.v1.Object.BlobR\x06object\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Update.ConfigR\x06\x63onfig\x12\x39\n\nvectorizer\x18\x03 \x01(\x0b\x32\x19.payload.v1.Filter.TargetR\nvectorizer\x1aR\n\x12MultiObjectRequest\x12<\n\x08requests\x18\x01 \x03(\x0b\x32 .payload.v1.Update.ObjectRequestR\x08requests\x1a\xca\x01\n\x06\x43onfig\x12\x35\n\x17skip_strict_exist_check\x18\x01 \x01(\x08R\x14skipStrictExistCheck\x12\x33\n\x07\x66ilters\x18\x02 \x01(\x0b\x32\x19.payload.v1.Filter.ConfigR\x07\x66ilters\x12\x1c\n\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x12\x36\n\x17\x64isable_balanced_update\x18\x04 \x01(\x08R\x15\x64isableBalancedUpdate\"\x9d\x05\n\x06Upsert\x1ay\n\x07Request\x12;\n\x06vector\x18\x01 \x01(\x0b\x32\x19.payload.v1.Object.VectorB\x08\xbaH\x05\x92\x01\x02\x08\x02R\x06vector\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Upsert.ConfigR\x06\x63onfig\x1a\x46\n\x0cMultiRequest\x12\x36\n\x08requests\x18\x01 \x03(\x0b\x32\x1a.payload.v1.Upsert.RequestR\x08requests\x1a\xae\x01\n\rObjectRequest\x12/\n\x06object\x18\x01 \x01(\x0b\x32\x17.payload.v1.Object.BlobR\x06object\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Upsert.ConfigR\x06\x63onfig\x12\x39\n\nvectorizer\x18\x03 \x01(\x0b\x32\x19.payload.v1.Filter.TargetR\nvectorizer\x1aR\n\x12MultiObjectRequest\x12<\n\x08requests\x18\x01 \x03(\x0b\x32 .payload.v1.Upsert.ObjectRequestR\x08requests\x1a\xca\x01\n\x06\x43onfig\x12\x35\n\x17skip_strict_exist_check\x18\x01 \x01(\x08R\x14skipStrictExistCheck\x12\x33\n\x07\x66ilters\x18\x02 \x01(\x0b\x32\x19.payload.v1.Filter.ConfigR\x07\x66ilters\x12\x1c\n\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x12\x36\n\x17\x64isable_balanced_update\x18\x04 \x01(\x08R\x15\x64isableBalancedUpdate\"\x91\x04\n\x06Remove\x1a\x63\n\x07Request\x12%\n\x02id\x18\x01 \x01(\x0b\x32\x15.payload.v1.Object.IDR\x02id\x12\x31\n\x06\x63onfig\x18\x02 \x01(\x0b\x32\x19.payload.v1.Remove.ConfigR\x06\x63onfig\x1a\x46\n\x0cMultiRequest\x12\x36\n\x08requests\x18\x01 \x03(\x0b\x32\x1a.payload.v1.Remove.RequestR\x08requests\x1aP\n\x10TimestampRequest\x12<\n\ntimestamps\x18\x01 \x03(\x0b\x32\x1c.payload.v1.Remove.TimestampR\ntimestamps\x1a\xa8\x01\n\tTimestamp\x12\x1c\n\ttimestamp\x18\x01 \x01(\x03R\ttimestamp\x12\x41\n\x08operator\x18\x02 \x01(\x0e\x32%.payload.v1.Remove.Timestamp.OperatorR\x08operator\":\n\x08Operator\x12\x06\n\x02\x45q\x10\x00\x12\x06\n\x02Ne\x10\x01\x12\x06\n\x02Ge\x10\x02\x12\x06\n\x02Gt\x10\x03\x12\x06\n\x02Le\x10\x04\x12\x06\n\x02Lt\x10\x05\x1a]\n\x06\x43onfig\x12\x35\n\x17skip_strict_exist_check\x18\x01 \x01(\x08R\x14skipStrictExistCheck\x12\x1c\n\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\"\x12\n\x05\x46lush\x1a\t\n\x07Request\"\xb1\x0b\n\x06Object\x1au\n\rVectorRequest\x12/\n\x02id\x18\x01 \x01(\x0b\x32\x15.payload.v1.Object.IDB\x08\xbaH\x05\x92\x01\x02\x08\x02R\x02id\x12\x33\n\x07\x66ilters\x18\x02 \x01(\x0b\x32\x19.payload.v1.Filter.ConfigR\x07\x66ilters\x1a\x36\n\x08\x44istance\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id\x12\x1a\n\x08\x64istance\x18\x02 \x01(\x02R\x08\x64istance\x1a\x84\x01\n\x0eStreamDistance\x12\x39\n\x08\x64istance\x18\x01 \x01(\x0b\x32\x1b.payload.v1.Object.DistanceH\x00R\x08\x64istance\x12,\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.StatusH\x00R\x06statusB\t\n\x07payload\x1a\x1d\n\x02ID\x12\x17\n\x02id\x18\x01 \x01(\tB\x07\xbaH\x04r\x02\x10\x01R\x02id\x1a\x17\n\x03IDs\x12\x10\n\x03ids\x18\x01 \x03(\tR\x03ids\x1a\x61\n\x06Vector\x12\x17\n\x02id\x18\x01 \x01(\tB\x07\xbaH\x04r\x02\x10\x01R\x02id\x12 \n\x06vector\x18\x02 \x03(\x02\x42\x08\xbaH\x05\x92\x01\x02\x08\x02R\x06vector\x12\x1c\n\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x1a\x43\n\x10TimestampRequest\x12/\n\x02id\x18\x01 \x01(\x0b\x32\x15.payload.v1.Object.IDB\x08\xbaH\x05\x92\x01\x02\x08\x02R\x02id\x1a\x42\n\tTimestamp\x12\x17\n\x02id\x18\x01 \x01(\tB\x07\xbaH\x04r\x02\x10\x01R\x02id\x12\x1c\n\ttimestamp\x18\x02 \x01(\x03R\ttimestamp\x1a>\n\x07Vectors\x12\x33\n\x07vectors\x18\x01 \x03(\x0b\x32\x19.payload.v1.Object.VectorR\x07vectors\x1a|\n\x0cStreamVector\x12\x33\n\x06vector\x18\x01 \x01(\x0b\x32\x19.payload.v1.Object.VectorH\x00R\x06vector\x12,\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.StatusH\x00R\x06statusB\t\n\x07payload\x1a=\n\rReshapeVector\x12\x16\n\x06object\x18\x01 \x01(\x0cR\x06object\x12\x14\n\x05shape\x18\x02 \x03(\x05R\x05shape\x1a\x37\n\x04\x42lob\x12\x17\n\x02id\x18\x01 \x01(\tB\x07\xbaH\x04r\x02\x10\x01R\x02id\x12\x16\n\x06object\x18\x02 \x01(\x0cR\x06object\x1at\n\nStreamBlob\x12-\n\x04\x62lob\x18\x01 \x01(\x0b\x32\x17.payload.v1.Object.BlobH\x00R\x04\x62lob\x12,\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.StatusH\x00R\x06statusB\t\n\x07payload\x1a\x44\n\x08Location\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x12\n\x04uuid\x18\x02 \x01(\tR\x04uuid\x12\x10\n\x03ips\x18\x03 \x03(\tR\x03ips\x1a\x84\x01\n\x0eStreamLocation\x12\x39\n\x08location\x18\x01 \x01(\x0b\x32\x1b.payload.v1.Object.LocationH\x00R\x08location\x12,\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.StatusH\x00R\x06statusB\t\n\x07payload\x1a\x46\n\tLocations\x12\x39\n\tlocations\x18\x01 \x03(\x0b\x32\x1b.payload.v1.Object.LocationR\tlocations\x1a\x8b\x01\n\x04List\x1a\t\n\x07Request\x1ax\n\x08Response\x12\x33\n\x06vector\x18\x01 \x01(\x0b\x32\x19.payload.v1.Object.VectorH\x00R\x06vector\x12,\n\x06status\x18\x02 \x01(\x0b\x32\x12.google.rpc.StatusH\x00R\x06statusB\t\n\x07payload\"E\n\x07\x43ontrol\x1a:\n\x12\x43reateIndexRequest\x12$\n\tpool_size\x18\x01 \x01(\rB\x07\xbaH\x04*\x02(\x00R\x08poolSize\"f\n\nDiscoverer\x1aX\n\x07Request\x12\x1b\n\x04name\x18\x01 \x01(\tB\x07\xbaH\x04r\x02\x10\x01R\x04name\x12\x1c\n\tnamespace\x18\x02 \x01(\tR\tnamespace\x12\x12\n\x04node\x18\x03 \x01(\tR\x04node\"\xee\x0e\n\x04Info\x1a\xac\x03\n\x05Index\x1au\n\x05\x43ount\x12\x16\n\x06stored\x18\x01 \x01(\rR\x06stored\x12 \n\x0buncommitted\x18\x02 \x01(\rR\x0buncommitted\x12\x1a\n\x08indexing\x18\x03 \x01(\x08R\x08indexing\x12\x16\n\x06saving\x18\x04 \x01(\x08R\x06saving\x1a\xdf\x01\n\x06\x44\x65tail\x12\x41\n\x06\x63ounts\x18\x01 \x03(\x0b\x32).payload.v1.Info.Index.Detail.CountsEntryR\x06\x63ounts\x12\x18\n\x07replica\x18\x02 \x01(\rR\x07replica\x12\x1f\n\x0blive_agents\x18\x03 \x01(\rR\nliveAgents\x1aW\n\x0b\x43ountsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x32\n\x05value\x18\x02 \x01(\x0b\x32\x1c.payload.v1.Info.Index.CountR\x05value:\x02\x38\x01\x1aJ\n\x04UUID\x1a\x1f\n\tCommitted\x12\x12\n\x04uuid\x18\x01 \x01(\tR\x04uuid\x1a!\n\x0bUncommitted\x12\x12\n\x04uuid\x18\x01 \x01(\tR\x04uuid\x1a\xef\x01\n\x03Pod\x12\x19\n\x08\x61pp_name\x18\x01 \x01(\tR\x07\x61ppName\x12\x12\n\x04name\x18\x02 \x01(\tR\x04name\x12\x1c\n\tnamespace\x18\x03 \x01(\tR\tnamespace\x12\x17\n\x02ip\x18\x04 \x01(\tB\x07\xbaH\x04r\x02x\x01R\x02ip\x12&\n\x03\x63pu\x18\x05 \x01(\x0b\x32\x14.payload.v1.Info.CPUR\x03\x63pu\x12/\n\x06memory\x18\x06 \x01(\x0b\x32\x17.payload.v1.Info.MemoryR\x06memory\x12)\n\x04node\x18\x07 \x01(\x0b\x32\x15.payload.v1.Info.NodeR\x04node\x1a\xe8\x01\n\x04Node\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12#\n\rinternal_addr\x18\x02 \x01(\tR\x0cinternalAddr\x12#\n\rexternal_addr\x18\x03 \x01(\tR\x0c\x65xternalAddr\x12&\n\x03\x63pu\x18\x04 \x01(\x0b\x32\x14.payload.v1.Info.CPUR\x03\x63pu\x12/\n\x06memory\x18\x05 \x01(\x0b\x32\x17.payload.v1.Info.MemoryR\x06memory\x12)\n\x04Pods\x18\x06 \x01(\x0b\x32\x15.payload.v1.Info.PodsR\x04Pods\x1a\x82\x02\n\x07Service\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x1d\n\ncluster_ip\x18\x02 \x01(\tR\tclusterIp\x12\x1f\n\x0b\x63luster_ips\x18\x03 \x03(\tR\nclusterIps\x12\x32\n\x05ports\x18\x04 \x03(\x0b\x32\x1c.payload.v1.Info.ServicePortR\x05ports\x12/\n\x06labels\x18\x05 \x01(\x0b\x32\x17.payload.v1.Info.LabelsR\x06labels\x12>\n\x0b\x61nnotations\x18\x06 \x01(\x0b\x32\x1c.payload.v1.Info.AnnotationsR\x0b\x61nnotations\x1a\x35\n\x0bServicePort\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x12\n\x04port\x18\x02 \x01(\x05R\x04port\x1a\x80\x01\n\x06Labels\x12;\n\x06labels\x18\x01 \x03(\x0b\x32#.payload.v1.Info.Labels.LabelsEntryR\x06labels\x1a\x39\n\x0bLabelsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1a\x9e\x01\n\x0b\x41nnotations\x12O\n\x0b\x61nnotations\x18\x01 \x03(\x0b\x32-.payload.v1.Info.Annotations.AnnotationsEntryR\x0b\x61nnotations\x1a>\n\x10\x41nnotationsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1aK\n\x03\x43PU\x12\x14\n\x05limit\x18\x01 \x01(\x01R\x05limit\x12\x18\n\x07request\x18\x02 \x01(\x01R\x07request\x12\x14\n\x05usage\x18\x03 \x01(\x01R\x05usage\x1aN\n\x06Memory\x12\x14\n\x05limit\x18\x01 \x01(\x01R\x05limit\x12\x18\n\x07request\x18\x02 \x01(\x01R\x07request\x12\x14\n\x05usage\x18\x03 \x01(\x01R\x05usage\x1a:\n\x04Pods\x12\x32\n\x04pods\x18\x01 \x03(\x0b\x32\x14.payload.v1.Info.PodB\x08\xbaH\x05\x92\x01\x02\x08\x01R\x04pods\x1a>\n\x05Nodes\x12\x35\n\x05nodes\x18\x01 \x03(\x0b\x32\x15.payload.v1.Info.NodeB\x08\xbaH\x05\x92\x01\x02\x08\x01R\x05nodes\x1aJ\n\x08Services\x12>\n\x08services\x18\x01 \x03(\x0b\x32\x18.payload.v1.Info.ServiceB\x08\xbaH\x05\x92\x01\x02\x08\x01R\x08services\x1a\x15\n\x03IPs\x12\x0e\n\x02ip\x18\x01 \x03(\tR\x02ip\"z\n\x06Mirror\x1a\x30\n\x06Target\x12\x12\n\x04host\x18\x01 \x01(\tR\x04host\x12\x12\n\x04port\x18\x02 \x01(\rR\x04port\x1a>\n\x07Targets\x12\x33\n\x07targets\x18\x01 \x03(\x0b\x32\x19.payload.v1.Mirror.TargetR\x07targets\"\x07\n\x05\x45mptyBd\n\x1dorg.vdaas.vald.api.v1.payloadB\x0bValdPayloadP\x01Z*github.com/vdaas/vald/apis/grpc/v1/payload\xa2\x02\x07Payloadb\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -55,8 +55,8 @@ _globals['_OBJECT_VECTOR'].fields_by_name['id']._serialized_options = b'\272H\004r\002\020\001' _globals['_OBJECT_VECTOR'].fields_by_name['vector']._loaded_options = None _globals['_OBJECT_VECTOR'].fields_by_name['vector']._serialized_options = b'\272H\005\222\001\002\010\002' - _globals['_OBJECT_GETTIMESTAMPREQUEST'].fields_by_name['id']._loaded_options = None - _globals['_OBJECT_GETTIMESTAMPREQUEST'].fields_by_name['id']._serialized_options = b'\272H\005\222\001\002\010\002' + _globals['_OBJECT_TIMESTAMPREQUEST'].fields_by_name['id']._loaded_options = None + _globals['_OBJECT_TIMESTAMPREQUEST'].fields_by_name['id']._serialized_options = b'\272H\005\222\001\002\010\002' _globals['_OBJECT_TIMESTAMP'].fields_by_name['id']._loaded_options = None _globals['_OBJECT_TIMESTAMP'].fields_by_name['id']._serialized_options = b'\272H\004r\002\020\001' _globals['_OBJECT_BLOB'].fields_by_name['id']._loaded_options = None @@ -65,6 +65,8 @@ _globals['_CONTROL_CREATEINDEXREQUEST'].fields_by_name['pool_size']._serialized_options = b'\272H\004*\002(\000' _globals['_DISCOVERER_REQUEST'].fields_by_name['name']._loaded_options = None _globals['_DISCOVERER_REQUEST'].fields_by_name['name']._serialized_options = b'\272H\004r\002\020\001' + _globals['_INFO_INDEX_DETAIL_COUNTSENTRY']._loaded_options = None + _globals['_INFO_INDEX_DETAIL_COUNTSENTRY']._serialized_options = b'8\001' _globals['_INFO_POD'].fields_by_name['ip']._loaded_options = None _globals['_INFO_POD'].fields_by_name['ip']._serialized_options = b'\272H\004r\002x\001' _globals['_INFO_LABELS_LABELSENTRY']._loaded_options = None @@ -162,7 +164,7 @@ _globals['_FLUSH_REQUEST']._serialized_start=142 _globals['_FLUSH_REQUEST']._serialized_end=151 _globals['_OBJECT']._serialized_start=4210 - _globals['_OBJECT']._serialized_end=5670 + _globals['_OBJECT']._serialized_end=5667 _globals['_OBJECT_VECTORREQUEST']._serialized_start=4220 _globals['_OBJECT_VECTORREQUEST']._serialized_end=4337 _globals['_OBJECT_DISTANCE']._serialized_start=4339 @@ -175,86 +177,90 @@ _globals['_OBJECT_IDS']._serialized_end=4584 _globals['_OBJECT_VECTOR']._serialized_start=4586 _globals['_OBJECT_VECTOR']._serialized_end=4683 - _globals['_OBJECT_GETTIMESTAMPREQUEST']._serialized_start=4685 - _globals['_OBJECT_GETTIMESTAMPREQUEST']._serialized_end=4755 - _globals['_OBJECT_TIMESTAMP']._serialized_start=4757 - _globals['_OBJECT_TIMESTAMP']._serialized_end=4823 - _globals['_OBJECT_VECTORS']._serialized_start=4825 - _globals['_OBJECT_VECTORS']._serialized_end=4887 - _globals['_OBJECT_STREAMVECTOR']._serialized_start=4889 - _globals['_OBJECT_STREAMVECTOR']._serialized_end=5013 - _globals['_OBJECT_RESHAPEVECTOR']._serialized_start=5015 - _globals['_OBJECT_RESHAPEVECTOR']._serialized_end=5076 - _globals['_OBJECT_BLOB']._serialized_start=5078 - _globals['_OBJECT_BLOB']._serialized_end=5133 - _globals['_OBJECT_STREAMBLOB']._serialized_start=5135 - _globals['_OBJECT_STREAMBLOB']._serialized_end=5251 - _globals['_OBJECT_LOCATION']._serialized_start=5253 - _globals['_OBJECT_LOCATION']._serialized_end=5321 - _globals['_OBJECT_STREAMLOCATION']._serialized_start=5324 - _globals['_OBJECT_STREAMLOCATION']._serialized_end=5456 - _globals['_OBJECT_LOCATIONS']._serialized_start=5458 - _globals['_OBJECT_LOCATIONS']._serialized_end=5528 - _globals['_OBJECT_LIST']._serialized_start=5531 - _globals['_OBJECT_LIST']._serialized_end=5670 + _globals['_OBJECT_TIMESTAMPREQUEST']._serialized_start=4685 + _globals['_OBJECT_TIMESTAMPREQUEST']._serialized_end=4752 + _globals['_OBJECT_TIMESTAMP']._serialized_start=4754 + _globals['_OBJECT_TIMESTAMP']._serialized_end=4820 + _globals['_OBJECT_VECTORS']._serialized_start=4822 + _globals['_OBJECT_VECTORS']._serialized_end=4884 + _globals['_OBJECT_STREAMVECTOR']._serialized_start=4886 + _globals['_OBJECT_STREAMVECTOR']._serialized_end=5010 + _globals['_OBJECT_RESHAPEVECTOR']._serialized_start=5012 + _globals['_OBJECT_RESHAPEVECTOR']._serialized_end=5073 + _globals['_OBJECT_BLOB']._serialized_start=5075 + _globals['_OBJECT_BLOB']._serialized_end=5130 + _globals['_OBJECT_STREAMBLOB']._serialized_start=5132 + _globals['_OBJECT_STREAMBLOB']._serialized_end=5248 + _globals['_OBJECT_LOCATION']._serialized_start=5250 + _globals['_OBJECT_LOCATION']._serialized_end=5318 + _globals['_OBJECT_STREAMLOCATION']._serialized_start=5321 + _globals['_OBJECT_STREAMLOCATION']._serialized_end=5453 + _globals['_OBJECT_LOCATIONS']._serialized_start=5455 + _globals['_OBJECT_LOCATIONS']._serialized_end=5525 + _globals['_OBJECT_LIST']._serialized_start=5528 + _globals['_OBJECT_LIST']._serialized_end=5667 _globals['_OBJECT_LIST_REQUEST']._serialized_start=142 _globals['_OBJECT_LIST_REQUEST']._serialized_end=151 - _globals['_OBJECT_LIST_RESPONSE']._serialized_start=5550 - _globals['_OBJECT_LIST_RESPONSE']._serialized_end=5670 - _globals['_CONTROL']._serialized_start=5672 - _globals['_CONTROL']._serialized_end=5741 - _globals['_CONTROL_CREATEINDEXREQUEST']._serialized_start=5683 - _globals['_CONTROL_CREATEINDEXREQUEST']._serialized_end=5741 - _globals['_DISCOVERER']._serialized_start=5743 - _globals['_DISCOVERER']._serialized_end=5845 - _globals['_DISCOVERER_REQUEST']._serialized_start=5757 - _globals['_DISCOVERER_REQUEST']._serialized_end=5845 - _globals['_INFO']._serialized_start=5848 - _globals['_INFO']._serialized_end=7524 - _globals['_INFO_INDEX']._serialized_start=5857 - _globals['_INFO_INDEX']._serialized_end=6059 - _globals['_INFO_INDEX_COUNT']._serialized_start=5866 - _globals['_INFO_INDEX_COUNT']._serialized_end=5983 - _globals['_INFO_INDEX_UUID']._serialized_start=5985 - _globals['_INFO_INDEX_UUID']._serialized_end=6059 - _globals['_INFO_INDEX_UUID_COMMITTED']._serialized_start=5993 - _globals['_INFO_INDEX_UUID_COMMITTED']._serialized_end=6024 - _globals['_INFO_INDEX_UUID_UNCOMMITTED']._serialized_start=6026 - _globals['_INFO_INDEX_UUID_UNCOMMITTED']._serialized_end=6059 - _globals['_INFO_POD']._serialized_start=6062 - _globals['_INFO_POD']._serialized_end=6301 - _globals['_INFO_NODE']._serialized_start=6304 - _globals['_INFO_NODE']._serialized_end=6536 - _globals['_INFO_SERVICE']._serialized_start=6539 - _globals['_INFO_SERVICE']._serialized_end=6797 - _globals['_INFO_SERVICEPORT']._serialized_start=6799 - _globals['_INFO_SERVICEPORT']._serialized_end=6852 - _globals['_INFO_LABELS']._serialized_start=6855 - _globals['_INFO_LABELS']._serialized_end=6983 - _globals['_INFO_LABELS_LABELSENTRY']._serialized_start=6926 - _globals['_INFO_LABELS_LABELSENTRY']._serialized_end=6983 - _globals['_INFO_ANNOTATIONS']._serialized_start=6986 - _globals['_INFO_ANNOTATIONS']._serialized_end=7144 - _globals['_INFO_ANNOTATIONS_ANNOTATIONSENTRY']._serialized_start=7082 - _globals['_INFO_ANNOTATIONS_ANNOTATIONSENTRY']._serialized_end=7144 - _globals['_INFO_CPU']._serialized_start=7146 - _globals['_INFO_CPU']._serialized_end=7221 - _globals['_INFO_MEMORY']._serialized_start=7223 - _globals['_INFO_MEMORY']._serialized_end=7301 - _globals['_INFO_PODS']._serialized_start=7303 - _globals['_INFO_PODS']._serialized_end=7361 - _globals['_INFO_NODES']._serialized_start=7363 - _globals['_INFO_NODES']._serialized_end=7425 - _globals['_INFO_SERVICES']._serialized_start=7427 - _globals['_INFO_SERVICES']._serialized_end=7501 - _globals['_INFO_IPS']._serialized_start=7503 - _globals['_INFO_IPS']._serialized_end=7524 - _globals['_MIRROR']._serialized_start=7526 - _globals['_MIRROR']._serialized_end=7648 + _globals['_OBJECT_LIST_RESPONSE']._serialized_start=5547 + _globals['_OBJECT_LIST_RESPONSE']._serialized_end=5667 + _globals['_CONTROL']._serialized_start=5669 + _globals['_CONTROL']._serialized_end=5738 + _globals['_CONTROL_CREATEINDEXREQUEST']._serialized_start=5680 + _globals['_CONTROL_CREATEINDEXREQUEST']._serialized_end=5738 + _globals['_DISCOVERER']._serialized_start=5740 + _globals['_DISCOVERER']._serialized_end=5842 + _globals['_DISCOVERER_REQUEST']._serialized_start=5754 + _globals['_DISCOVERER_REQUEST']._serialized_end=5842 + _globals['_INFO']._serialized_start=5845 + _globals['_INFO']._serialized_end=7747 + _globals['_INFO_INDEX']._serialized_start=5854 + _globals['_INFO_INDEX']._serialized_end=6282 + _globals['_INFO_INDEX_COUNT']._serialized_start=5863 + _globals['_INFO_INDEX_COUNT']._serialized_end=5980 + _globals['_INFO_INDEX_DETAIL']._serialized_start=5983 + _globals['_INFO_INDEX_DETAIL']._serialized_end=6206 + _globals['_INFO_INDEX_DETAIL_COUNTSENTRY']._serialized_start=6119 + _globals['_INFO_INDEX_DETAIL_COUNTSENTRY']._serialized_end=6206 + _globals['_INFO_INDEX_UUID']._serialized_start=6208 + _globals['_INFO_INDEX_UUID']._serialized_end=6282 + _globals['_INFO_INDEX_UUID_COMMITTED']._serialized_start=6216 + _globals['_INFO_INDEX_UUID_COMMITTED']._serialized_end=6247 + _globals['_INFO_INDEX_UUID_UNCOMMITTED']._serialized_start=6249 + _globals['_INFO_INDEX_UUID_UNCOMMITTED']._serialized_end=6282 + _globals['_INFO_POD']._serialized_start=6285 + _globals['_INFO_POD']._serialized_end=6524 + _globals['_INFO_NODE']._serialized_start=6527 + _globals['_INFO_NODE']._serialized_end=6759 + _globals['_INFO_SERVICE']._serialized_start=6762 + _globals['_INFO_SERVICE']._serialized_end=7020 + _globals['_INFO_SERVICEPORT']._serialized_start=7022 + _globals['_INFO_SERVICEPORT']._serialized_end=7075 + _globals['_INFO_LABELS']._serialized_start=7078 + _globals['_INFO_LABELS']._serialized_end=7206 + _globals['_INFO_LABELS_LABELSENTRY']._serialized_start=7149 + _globals['_INFO_LABELS_LABELSENTRY']._serialized_end=7206 + _globals['_INFO_ANNOTATIONS']._serialized_start=7209 + _globals['_INFO_ANNOTATIONS']._serialized_end=7367 + _globals['_INFO_ANNOTATIONS_ANNOTATIONSENTRY']._serialized_start=7305 + _globals['_INFO_ANNOTATIONS_ANNOTATIONSENTRY']._serialized_end=7367 + _globals['_INFO_CPU']._serialized_start=7369 + _globals['_INFO_CPU']._serialized_end=7444 + _globals['_INFO_MEMORY']._serialized_start=7446 + _globals['_INFO_MEMORY']._serialized_end=7524 + _globals['_INFO_PODS']._serialized_start=7526 + _globals['_INFO_PODS']._serialized_end=7584 + _globals['_INFO_NODES']._serialized_start=7586 + _globals['_INFO_NODES']._serialized_end=7648 + _globals['_INFO_SERVICES']._serialized_start=7650 + _globals['_INFO_SERVICES']._serialized_end=7724 + _globals['_INFO_IPS']._serialized_start=7726 + _globals['_INFO_IPS']._serialized_end=7747 + _globals['_MIRROR']._serialized_start=7749 + _globals['_MIRROR']._serialized_end=7871 _globals['_MIRROR_TARGET']._serialized_start=1584 _globals['_MIRROR_TARGET']._serialized_end=1632 - _globals['_MIRROR_TARGETS']._serialized_start=7586 - _globals['_MIRROR_TARGETS']._serialized_end=7648 - _globals['_EMPTY']._serialized_start=7650 - _globals['_EMPTY']._serialized_end=7657 + _globals['_MIRROR_TARGETS']._serialized_start=7809 + _globals['_MIRROR_TARGETS']._serialized_end=7871 + _globals['_EMPTY']._serialized_start=7873 + _globals['_EMPTY']._serialized_end=7880 # @@protoc_insertion_point(module_scope) diff --git a/src/vald/v1/vald/index_pb2.py b/src/vald/v1/vald/index_pb2.py new file mode 100644 index 0000000..9560b08 --- /dev/null +++ b/src/vald/v1/vald/index_pb2.py @@ -0,0 +1,43 @@ +# -*- coding: utf-8 -*- +# Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE +# source: vald/v1/vald/index.proto +# Protobuf Python Version: 5.27.2 +"""Generated protocol buffer code.""" +from google.protobuf import descriptor as _descriptor +from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version +from google.protobuf import symbol_database as _symbol_database +from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'vald/v1/vald/index.proto' +) +# @@protoc_insertion_point(imports) + +_sym_db = _symbol_database.Default() + + +from google.api import annotations_pb2 as google_dot_api_dot_annotations__pb2 +from vald.v1.payload import payload_pb2 as vald_dot_v1_dot_payload_dot_payload__pb2 + + +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x18vald/v1/vald/index.proto\x12\x07vald.v1\x1a\x1cgoogle/api/annotations.proto\x1a\x1dvald/v1/payload/payload.proto2\xb2\x01\n\x05Index\x12Q\n\tIndexInfo\x12\x11.payload.v1.Empty\x1a\x1c.payload.v1.Info.Index.Count\"\x13\x82\xd3\xe4\x93\x02\r\x12\x0b/index/info\x12V\n\x0bIndexDetail\x12\x11.payload.v1.Empty\x1a\x1d.payload.v1.Info.Index.Detail\"\x15\x82\xd3\xe4\x93\x02\x0f\x12\r/index/detailBR\n\x1aorg.vdaas.vald.api.v1.valdB\tValdIndexP\x01Z\'github.com/vdaas/vald/apis/grpc/v1/valdb\x06proto3') + +_globals = globals() +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'vald.v1.vald.index_pb2', _globals) +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None + _globals['DESCRIPTOR']._serialized_options = b'\n\032org.vdaas.vald.api.v1.valdB\tValdIndexP\001Z\'github.com/vdaas/vald/apis/grpc/v1/vald' + _globals['_INDEX'].methods_by_name['IndexInfo']._loaded_options = None + _globals['_INDEX'].methods_by_name['IndexInfo']._serialized_options = b'\202\323\344\223\002\r\022\013/index/info' + _globals['_INDEX'].methods_by_name['IndexDetail']._loaded_options = None + _globals['_INDEX'].methods_by_name['IndexDetail']._serialized_options = b'\202\323\344\223\002\017\022\r/index/detail' + _globals['_INDEX']._serialized_start=99 + _globals['_INDEX']._serialized_end=277 +# @@protoc_insertion_point(module_scope) diff --git a/src/vald/v1/vald/index_pb2_grpc.py b/src/vald/v1/vald/index_pb2_grpc.py new file mode 100644 index 0000000..3845551 --- /dev/null +++ b/src/vald/v1/vald/index_pb2_grpc.py @@ -0,0 +1,125 @@ +# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! +"""Client and server classes corresponding to protobuf-defined services.""" +import grpc + +from vald.v1.payload import payload_pb2 as vald_dot_v1_dot_payload_dot_payload__pb2 + + +class IndexStub(object): + """Represent the index manager service. + """ + + def __init__(self, channel): + """Constructor. + + Args: + channel: A grpc.Channel. + """ + self.IndexInfo = channel.unary_unary( + '/vald.v1.Index/IndexInfo', + request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString, + response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Info.Index.Count.FromString, + _registered_method=True) + self.IndexDetail = channel.unary_unary( + '/vald.v1.Index/IndexDetail', + request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString, + response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Info.Index.Detail.FromString, + _registered_method=True) + + +class IndexServicer(object): + """Represent the index manager service. + """ + + def IndexInfo(self, request, context): + """Represent the RPC to get the index information. + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def IndexDetail(self, request, context): + """Represent the RPC to get the index information for each agents. + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + +def add_IndexServicer_to_server(servicer, server): + rpc_method_handlers = { + 'IndexInfo': grpc.unary_unary_rpc_method_handler( + servicer.IndexInfo, + request_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.FromString, + response_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Info.Index.Count.SerializeToString, + ), + 'IndexDetail': grpc.unary_unary_rpc_method_handler( + servicer.IndexDetail, + request_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.FromString, + response_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Info.Index.Detail.SerializeToString, + ), + } + generic_handler = grpc.method_handlers_generic_handler( + 'vald.v1.Index', rpc_method_handlers) + server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('vald.v1.Index', rpc_method_handlers) + + + # This class is part of an EXPERIMENTAL API. +class Index(object): + """Represent the index manager service. + """ + + @staticmethod + def IndexInfo(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/vald.v1.Index/IndexInfo', + vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString, + vald_dot_v1_dot_payload_dot_payload__pb2.Info.Index.Count.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) + + @staticmethod + def IndexDetail(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/vald.v1.Index/IndexDetail', + vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString, + vald_dot_v1_dot_payload_dot_payload__pb2.Info.Index.Detail.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/src/vald/v1/vald/object_pb2.py b/src/vald/v1/vald/object_pb2.py index 5eb5e16..61229fe 100644 --- a/src/vald/v1/vald/object_pb2.py +++ b/src/vald/v1/vald/object_pb2.py @@ -26,7 +26,7 @@ from vald.v1.payload import payload_pb2 as vald_dot_v1_dot_payload_dot_payload__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x19vald/v1/vald/object.proto\x12\x07vald.v1\x1a\x1cgoogle/api/annotations.proto\x1a\x1dvald/v1/payload/payload.proto2\x84\x03\n\x06Object\x12L\n\x06\x45xists\x12\x15.payload.v1.Object.ID\x1a\x15.payload.v1.Object.ID\"\x14\x82\xd3\xe4\x93\x02\x0e\x12\x0c/exists/{id}\x12\x61\n\tGetObject\x12 .payload.v1.Object.VectorRequest\x1a\x19.payload.v1.Object.Vector\"\x17\x82\xd3\xe4\x93\x02\x11\x12\x0f/object/{id.id}\x12Z\n\x0fStreamGetObject\x12 .payload.v1.Object.VectorRequest\x1a\x1f.payload.v1.Object.StreamVector\"\x00(\x01\x30\x01\x12m\n\x10StreamListObject\x12\x1f.payload.v1.Object.List.Request\x1a .payload.v1.Object.List.Response\"\x14\x82\xd3\xe4\x93\x02\x0e\x12\x0c/object/list0\x01\x42S\n\x1aorg.vdaas.vald.api.v1.valdB\nValdObjectP\x01Z\'github.com/vdaas/vald/apis/grpc/v1/valdb\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x19vald/v1/vald/object.proto\x12\x07vald.v1\x1a\x1cgoogle/api/annotations.proto\x1a\x1dvald/v1/payload/payload.proto2\xf5\x03\n\x06Object\x12L\n\x06\x45xists\x12\x15.payload.v1.Object.ID\x1a\x15.payload.v1.Object.ID\"\x14\x82\xd3\xe4\x93\x02\x0e\x12\x0c/exists/{id}\x12\x61\n\tGetObject\x12 .payload.v1.Object.VectorRequest\x1a\x19.payload.v1.Object.Vector\"\x17\x82\xd3\xe4\x93\x02\x11\x12\x0f/object/{id.id}\x12Z\n\x0fStreamGetObject\x12 .payload.v1.Object.VectorRequest\x1a\x1f.payload.v1.Object.StreamVector\"\x00(\x01\x30\x01\x12m\n\x10StreamListObject\x12\x1f.payload.v1.Object.List.Request\x1a .payload.v1.Object.List.Response\"\x14\x82\xd3\xe4\x93\x02\x0e\x12\x0c/object/list0\x01\x12o\n\x0cGetTimestamp\x12#.payload.v1.Object.TimestampRequest\x1a\x1c.payload.v1.Object.Timestamp\"\x1c\x82\xd3\xe4\x93\x02\x16\x12\x14/object/meta/{id.id}BS\n\x1aorg.vdaas.vald.api.v1.valdB\nValdObjectP\x01Z\'github.com/vdaas/vald/apis/grpc/v1/valdb\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -40,6 +40,8 @@ _globals['_OBJECT'].methods_by_name['GetObject']._serialized_options = b'\202\323\344\223\002\021\022\017/object/{id.id}' _globals['_OBJECT'].methods_by_name['StreamListObject']._loaded_options = None _globals['_OBJECT'].methods_by_name['StreamListObject']._serialized_options = b'\202\323\344\223\002\016\022\014/object/list' + _globals['_OBJECT'].methods_by_name['GetTimestamp']._loaded_options = None + _globals['_OBJECT'].methods_by_name['GetTimestamp']._serialized_options = b'\202\323\344\223\002\026\022\024/object/meta/{id.id}' _globals['_OBJECT']._serialized_start=100 - _globals['_OBJECT']._serialized_end=488 + _globals['_OBJECT']._serialized_end=601 # @@protoc_insertion_point(module_scope) diff --git a/src/vald/v1/vald/object_pb2_grpc.py b/src/vald/v1/vald/object_pb2_grpc.py index 675c315..4a6688c 100644 --- a/src/vald/v1/vald/object_pb2_grpc.py +++ b/src/vald/v1/vald/object_pb2_grpc.py @@ -35,6 +35,11 @@ def __init__(self, channel): request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.List.Request.SerializeToString, response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.List.Response.FromString, _registered_method=True) + self.GetTimestamp = channel.unary_unary( + '/vald.v1.Object/GetTimestamp', + request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.TimestampRequest.SerializeToString, + response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.Timestamp.FromString, + _registered_method=True) class ObjectServicer(object): @@ -69,6 +74,13 @@ def StreamListObject(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') + def GetTimestamp(self, request, context): + """Represent the RPC to get the vector metadata. This RPC is mainly used for index correction process + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + def add_ObjectServicer_to_server(servicer, server): rpc_method_handlers = { @@ -92,6 +104,11 @@ def add_ObjectServicer_to_server(servicer, server): request_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.List.Request.FromString, response_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.List.Response.SerializeToString, ), + 'GetTimestamp': grpc.unary_unary_rpc_method_handler( + servicer.GetTimestamp, + request_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.TimestampRequest.FromString, + response_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.Timestamp.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( 'vald.v1.Object', rpc_method_handlers) @@ -211,3 +228,30 @@ def StreamListObject(request, timeout, metadata, _registered_method=True) + + @staticmethod + def GetTimestamp(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.unary_unary( + request, + target, + '/vald.v1.Object/GetTimestamp', + vald_dot_v1_dot_payload_dot_payload__pb2.Object.TimestampRequest.SerializeToString, + vald_dot_v1_dot_payload_dot_payload__pb2.Object.Timestamp.FromString, + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True)