Source code for needlestack.apis.servicers_pb2

# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: needlestack/apis/servicers.proto

import sys
_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
from google.protobuf import descriptor as _descriptor
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)

_sym_db = _symbol_database.Default()


from needlestack.apis import collections_pb2 as needlestack_dot_apis_dot_collections__pb2
from needlestack.apis import indices_pb2 as needlestack_dot_apis_dot_indices__pb2
from needlestack.apis import tensors_pb2 as needlestack_dot_apis_dot_tensors__pb2


DESCRIPTOR = _descriptor.FileDescriptor(
  name='needlestack/apis/servicers.proto',
  package='',
  syntax='proto3',
  serialized_options=None,
  serialized_pb=_b('\n needlestack/apis/servicers.proto\x1a\"needlestack/apis/collections.proto\x1a\x1eneedlestack/apis/indices.proto\x1a\x1eneedlestack/apis/tensors.proto\"f\n\rSearchRequest\x12\x18\n\x06vector\x18\x01 \x01(\x0b\x32\x08.NDArray\x12\r\n\x05\x63ount\x18\x02 \x01(\r\x12\x17\n\x0f\x63ollection_name\x18\x03 \x01(\t\x12\x13\n\x0bshard_names\x18\x04 \x03(\t\"2\n\x0eSearchResponse\x12 \n\x05items\x18\x01 \x03(\x0b\x32\x11.SearchResultItem\"K\n\x0fRetrieveRequest\x12\n\n\x02id\x18\x01 \x01(\t\x12\x17\n\x0f\x63ollection_name\x18\x02 \x01(\t\x12\x13\n\x0bshard_names\x18\x03 \x03(\t\"6\n\x10RetrieveResponse\x12\"\n\x04item\x18\x01 \x01(\x0b\x32\x14.RetrievalResultItem2\xb3\x03\n\x06Merger\x12)\n\x06Search\x12\x0e.SearchRequest\x1a\x0f.SearchResponse\x12\x33\n\x0cSearchStream\x12\x0e.SearchRequest\x1a\x11.SearchResultItem0\x01\x12/\n\x08Retrieve\x12\x10.RetrieveRequest\x1a\x11.RetrieveResponse\x12\x41\n\x0e\x43ollectionsAdd\x12\x16.CollectionsAddRequest\x1a\x17.CollectionsAddResponse\x12I\n\x11\x43ollectionsDelete\x12\x19.CollectionsDeleteRequest\x1a\x19.CollectionsDeleteRequest\x12\x44\n\x0f\x43ollectionsList\x12\x17.CollectionsListRequest\x1a\x18.CollectionsListResponse\x12\x44\n\x0f\x43ollectionsLoad\x12\x17.CollectionsLoadRequest\x1a\x18.CollectionsLoadResponse2\xe1\x01\n\x08Searcher\x12)\n\x06Search\x12\x0e.SearchRequest\x1a\x0f.SearchResponse\x12\x33\n\x0cSearchStream\x12\x0e.SearchRequest\x1a\x11.SearchResultItem0\x01\x12/\n\x08Retrieve\x12\x10.RetrieveRequest\x1a\x11.RetrieveResponse\x12\x44\n\x0f\x43ollectionsLoad\x12\x17.CollectionsLoadRequest\x1a\x18.CollectionsLoadResponseb\x06proto3')
  ,
  dependencies=[needlestack_dot_apis_dot_collections__pb2.DESCRIPTOR,needlestack_dot_apis_dot_indices__pb2.DESCRIPTOR,needlestack_dot_apis_dot_tensors__pb2.DESCRIPTOR,])




_SEARCHREQUEST = _descriptor.Descriptor(
  name='SearchRequest',
  full_name='SearchRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='vector', full_name='SearchRequest.vector', index=0,
      number=1, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='count', full_name='SearchRequest.count', index=1,
      number=2, type=13, cpp_type=3, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='collection_name', full_name='SearchRequest.collection_name', index=2,
      number=3, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='shard_names', full_name='SearchRequest.shard_names', index=3,
      number=4, type=9, cpp_type=9, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=136,
  serialized_end=238,
)


_SEARCHRESPONSE = _descriptor.Descriptor(
  name='SearchResponse',
  full_name='SearchResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='items', full_name='SearchResponse.items', index=0,
      number=1, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=240,
  serialized_end=290,
)


_RETRIEVEREQUEST = _descriptor.Descriptor(
  name='RetrieveRequest',
  full_name='RetrieveRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='id', full_name='RetrieveRequest.id', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='collection_name', full_name='RetrieveRequest.collection_name', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='shard_names', full_name='RetrieveRequest.shard_names', index=2,
      number=3, type=9, cpp_type=9, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=292,
  serialized_end=367,
)


_RETRIEVERESPONSE = _descriptor.Descriptor(
  name='RetrieveResponse',
  full_name='RetrieveResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='item', full_name='RetrieveResponse.item', index=0,
      number=1, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=369,
  serialized_end=423,
)

_SEARCHREQUEST.fields_by_name['vector'].message_type = needlestack_dot_apis_dot_tensors__pb2._NDARRAY
_SEARCHRESPONSE.fields_by_name['items'].message_type = needlestack_dot_apis_dot_indices__pb2._SEARCHRESULTITEM
_RETRIEVERESPONSE.fields_by_name['item'].message_type = needlestack_dot_apis_dot_indices__pb2._RETRIEVALRESULTITEM
DESCRIPTOR.message_types_by_name['SearchRequest'] = _SEARCHREQUEST
DESCRIPTOR.message_types_by_name['SearchResponse'] = _SEARCHRESPONSE
DESCRIPTOR.message_types_by_name['RetrieveRequest'] = _RETRIEVEREQUEST
DESCRIPTOR.message_types_by_name['RetrieveResponse'] = _RETRIEVERESPONSE
_sym_db.RegisterFileDescriptor(DESCRIPTOR)

SearchRequest = _reflection.GeneratedProtocolMessageType('SearchRequest', (_message.Message,), {
  'DESCRIPTOR' : _SEARCHREQUEST,
  '__module__' : 'needlestack.apis.servicers_pb2'
  # @@protoc_insertion_point(class_scope:SearchRequest)
  })
_sym_db.RegisterMessage(SearchRequest)

SearchResponse = _reflection.GeneratedProtocolMessageType('SearchResponse', (_message.Message,), {
  'DESCRIPTOR' : _SEARCHRESPONSE,
  '__module__' : 'needlestack.apis.servicers_pb2'
  # @@protoc_insertion_point(class_scope:SearchResponse)
  })
_sym_db.RegisterMessage(SearchResponse)

RetrieveRequest = _reflection.GeneratedProtocolMessageType('RetrieveRequest', (_message.Message,), {
  'DESCRIPTOR' : _RETRIEVEREQUEST,
  '__module__' : 'needlestack.apis.servicers_pb2'
  # @@protoc_insertion_point(class_scope:RetrieveRequest)
  })
_sym_db.RegisterMessage(RetrieveRequest)

RetrieveResponse = _reflection.GeneratedProtocolMessageType('RetrieveResponse', (_message.Message,), {
  'DESCRIPTOR' : _RETRIEVERESPONSE,
  '__module__' : 'needlestack.apis.servicers_pb2'
  # @@protoc_insertion_point(class_scope:RetrieveResponse)
  })
_sym_db.RegisterMessage(RetrieveResponse)



_MERGER = _descriptor.ServiceDescriptor(
  name='Merger',
  full_name='Merger',
  file=DESCRIPTOR,
  index=0,
  serialized_options=None,
  serialized_start=426,
  serialized_end=861,
  methods=[
  _descriptor.MethodDescriptor(
    name='Search',
    full_name='Merger.Search',
    index=0,
    containing_service=None,
    input_type=_SEARCHREQUEST,
    output_type=_SEARCHRESPONSE,
    serialized_options=None,
  ),
  _descriptor.MethodDescriptor(
    name='SearchStream',
    full_name='Merger.SearchStream',
    index=1,
    containing_service=None,
    input_type=_SEARCHREQUEST,
    output_type=needlestack_dot_apis_dot_indices__pb2._SEARCHRESULTITEM,
    serialized_options=None,
  ),
  _descriptor.MethodDescriptor(
    name='Retrieve',
    full_name='Merger.Retrieve',
    index=2,
    containing_service=None,
    input_type=_RETRIEVEREQUEST,
    output_type=_RETRIEVERESPONSE,
    serialized_options=None,
  ),
  _descriptor.MethodDescriptor(
    name='CollectionsAdd',
    full_name='Merger.CollectionsAdd',
    index=3,
    containing_service=None,
    input_type=needlestack_dot_apis_dot_collections__pb2._COLLECTIONSADDREQUEST,
    output_type=needlestack_dot_apis_dot_collections__pb2._COLLECTIONSADDRESPONSE,
    serialized_options=None,
  ),
  _descriptor.MethodDescriptor(
    name='CollectionsDelete',
    full_name='Merger.CollectionsDelete',
    index=4,
    containing_service=None,
    input_type=needlestack_dot_apis_dot_collections__pb2._COLLECTIONSDELETEREQUEST,
    output_type=needlestack_dot_apis_dot_collections__pb2._COLLECTIONSDELETEREQUEST,
    serialized_options=None,
  ),
  _descriptor.MethodDescriptor(
    name='CollectionsList',
    full_name='Merger.CollectionsList',
    index=5,
    containing_service=None,
    input_type=needlestack_dot_apis_dot_collections__pb2._COLLECTIONSLISTREQUEST,
    output_type=needlestack_dot_apis_dot_collections__pb2._COLLECTIONSLISTRESPONSE,
    serialized_options=None,
  ),
  _descriptor.MethodDescriptor(
    name='CollectionsLoad',
    full_name='Merger.CollectionsLoad',
    index=6,
    containing_service=None,
    input_type=needlestack_dot_apis_dot_collections__pb2._COLLECTIONSLOADREQUEST,
    output_type=needlestack_dot_apis_dot_collections__pb2._COLLECTIONSLOADRESPONSE,
    serialized_options=None,
  ),
])
_sym_db.RegisterServiceDescriptor(_MERGER)

DESCRIPTOR.services_by_name['Merger'] = _MERGER


_SEARCHER = _descriptor.ServiceDescriptor(
  name='Searcher',
  full_name='Searcher',
  file=DESCRIPTOR,
  index=1,
  serialized_options=None,
  serialized_start=864,
  serialized_end=1089,
  methods=[
  _descriptor.MethodDescriptor(
    name='Search',
    full_name='Searcher.Search',
    index=0,
    containing_service=None,
    input_type=_SEARCHREQUEST,
    output_type=_SEARCHRESPONSE,
    serialized_options=None,
  ),
  _descriptor.MethodDescriptor(
    name='SearchStream',
    full_name='Searcher.SearchStream',
    index=1,
    containing_service=None,
    input_type=_SEARCHREQUEST,
    output_type=needlestack_dot_apis_dot_indices__pb2._SEARCHRESULTITEM,
    serialized_options=None,
  ),
  _descriptor.MethodDescriptor(
    name='Retrieve',
    full_name='Searcher.Retrieve',
    index=2,
    containing_service=None,
    input_type=_RETRIEVEREQUEST,
    output_type=_RETRIEVERESPONSE,
    serialized_options=None,
  ),
  _descriptor.MethodDescriptor(
    name='CollectionsLoad',
    full_name='Searcher.CollectionsLoad',
    index=3,
    containing_service=None,
    input_type=needlestack_dot_apis_dot_collections__pb2._COLLECTIONSLOADREQUEST,
    output_type=needlestack_dot_apis_dot_collections__pb2._COLLECTIONSLOADRESPONSE,
    serialized_options=None,
  ),
])
_sym_db.RegisterServiceDescriptor(_SEARCHER)

DESCRIPTOR.services_by_name['Searcher'] = _SEARCHER

# @@protoc_insertion_point(module_scope)