Documentation ¶
Index ¶
- Variables
- func RegisterServerServer(s grpc.ServiceRegistrar, srv ServerServer)
- type CreateIndexRequest
- func (*CreateIndexRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateIndexRequest) GetAutoId() bool
- func (x *CreateIndexRequest) GetDim() int32
- func (x *CreateIndexRequest) GetEfConstruction() int32
- func (x *CreateIndexRequest) GetIndexName() string
- func (x *CreateIndexRequest) GetM() int32
- func (x *CreateIndexRequest) GetMaxElements() int32
- func (x *CreateIndexRequest) GetSeed() int32
- func (x *CreateIndexRequest) GetSpaceType() CreateIndexRequest_SpaceType
- func (*CreateIndexRequest) ProtoMessage()
- func (x *CreateIndexRequest) ProtoReflect() protoreflect.Message
- func (x *CreateIndexRequest) Reset()
- func (x *CreateIndexRequest) String() string
- type CreateIndexRequest_SpaceType
- func (CreateIndexRequest_SpaceType) Descriptor() protoreflect.EnumDescriptor
- func (x CreateIndexRequest_SpaceType) Enum() *CreateIndexRequest_SpaceType
- func (CreateIndexRequest_SpaceType) EnumDescriptor() ([]byte, []int)deprecated
- func (x CreateIndexRequest_SpaceType) Number() protoreflect.EnumNumber
- func (x CreateIndexRequest_SpaceType) String() string
- func (CreateIndexRequest_SpaceType) Type() protoreflect.EnumType
- type DeleteIndexRequest
- func (*DeleteIndexRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteIndexRequest) GetIndexName() string
- func (*DeleteIndexRequest) ProtoMessage()
- func (x *DeleteIndexRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteIndexRequest) Reset()
- func (x *DeleteIndexRequest) String() string
- type FlushRequest
- type Hit
- type IndicesReply
- type InsertVectorReply
- func (*InsertVectorReply) Descriptor() ([]byte, []int)deprecated
- func (x *InsertVectorReply) GetId() string
- func (x *InsertVectorReply) GetTook() int64
- func (*InsertVectorReply) ProtoMessage()
- func (x *InsertVectorReply) ProtoReflect() protoreflect.Message
- func (x *InsertVectorReply) Reset()
- func (x *InsertVectorReply) String() string
- type InsertVectorRequest
- func (*InsertVectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InsertVectorRequest) GetIndexName() string
- func (x *InsertVectorRequest) GetVector() *Vector
- func (*InsertVectorRequest) ProtoMessage()
- func (x *InsertVectorRequest) ProtoReflect() protoreflect.Message
- func (x *InsertVectorRequest) Reset()
- func (x *InsertVectorRequest) String() string
- type InsertVectorWithIdReply
- func (*InsertVectorWithIdReply) Descriptor() ([]byte, []int)deprecated
- func (x *InsertVectorWithIdReply) GetTook() int64
- func (*InsertVectorWithIdReply) ProtoMessage()
- func (x *InsertVectorWithIdReply) ProtoReflect() protoreflect.Message
- func (x *InsertVectorWithIdReply) Reset()
- func (x *InsertVectorWithIdReply) String() string
- type InsertVectorWithIdRequest
- func (*InsertVectorWithIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InsertVectorWithIdRequest) GetId() int32
- func (x *InsertVectorWithIdRequest) GetIndexName() string
- func (x *InsertVectorWithIdRequest) GetVector() *Vector
- func (*InsertVectorWithIdRequest) ProtoMessage()
- func (x *InsertVectorWithIdRequest) ProtoReflect() protoreflect.Message
- func (x *InsertVectorWithIdRequest) Reset()
- func (x *InsertVectorWithIdRequest) String() string
- type InsertVectorsReply
- func (*InsertVectorsReply) Descriptor() ([]byte, []int)deprecated
- func (x *InsertVectorsReply) GetIds() []string
- func (x *InsertVectorsReply) GetTook() int64
- func (*InsertVectorsReply) ProtoMessage()
- func (x *InsertVectorsReply) ProtoReflect() protoreflect.Message
- func (x *InsertVectorsReply) Reset()
- func (x *InsertVectorsReply) String() string
- type InsertVectorsWithIdsReply
- func (*InsertVectorsWithIdsReply) Descriptor() ([]byte, []int)deprecated
- func (x *InsertVectorsWithIdsReply) GetTook() int64
- func (*InsertVectorsWithIdsReply) ProtoMessage()
- func (x *InsertVectorsWithIdsReply) ProtoReflect() protoreflect.Message
- func (x *InsertVectorsWithIdsReply) Reset()
- func (x *InsertVectorsWithIdsReply) String() string
- type SearchKNNReply
- func (*SearchKNNReply) Descriptor() ([]byte, []int)deprecated
- func (x *SearchKNNReply) GetHits() []*Hit
- func (x *SearchKNNReply) GetTook() int64
- func (*SearchKNNReply) ProtoMessage()
- func (x *SearchKNNReply) ProtoReflect() protoreflect.Message
- func (x *SearchKNNReply) Reset()
- func (x *SearchKNNReply) String() string
- type SearchRequest
- func (*SearchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchRequest) GetIndexName() string
- func (x *SearchRequest) GetK() int32
- func (x *SearchRequest) GetVector() *Vector
- func (*SearchRequest) ProtoMessage()
- func (x *SearchRequest) ProtoReflect() protoreflect.Message
- func (x *SearchRequest) Reset()
- func (x *SearchRequest) String() string
- type ServerClient
- type ServerServer
- type Server_InsertVectorsClient
- type Server_InsertVectorsServer
- type Server_InsertVectorsWithIdsClient
- type Server_InsertVectorsWithIdsServer
- type SetEfRequest
- func (*SetEfRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetEfRequest) GetIndexName() string
- func (x *SetEfRequest) GetValue() int32
- func (*SetEfRequest) ProtoMessage()
- func (x *SetEfRequest) ProtoReflect() protoreflect.Message
- func (x *SetEfRequest) Reset()
- func (x *SetEfRequest) String() string
- type UnimplementedServerServer
- func (UnimplementedServerServer) CreateIndex(context.Context, *CreateIndexRequest) (*emptypb.Empty, error)
- func (UnimplementedServerServer) DeleteIndex(context.Context, *DeleteIndexRequest) (*emptypb.Empty, error)
- func (UnimplementedServerServer) FlushIndex(context.Context, *FlushRequest) (*emptypb.Empty, error)
- func (UnimplementedServerServer) Indices(context.Context, *emptypb.Empty) (*IndicesReply, error)
- func (UnimplementedServerServer) InsertVector(context.Context, *InsertVectorRequest) (*InsertVectorReply, error)
- func (UnimplementedServerServer) InsertVectorWithId(context.Context, *InsertVectorWithIdRequest) (*InsertVectorWithIdReply, error)
- func (UnimplementedServerServer) InsertVectors(Server_InsertVectorsServer) error
- func (UnimplementedServerServer) InsertVectorsWithIds(Server_InsertVectorsWithIdsServer) error
- func (UnimplementedServerServer) SearchKNN(context.Context, *SearchRequest) (*SearchKNNReply, error)
- func (UnimplementedServerServer) SetEf(context.Context, *SetEfRequest) (*emptypb.Empty, error)
- type UnsafeServerServer
- type Vector
Constants ¶
This section is empty.
Variables ¶
var ( CreateIndexRequest_SpaceType_name = map[int32]string{ 0: "L2", 1: "IP", 2: "COSINE", } CreateIndexRequest_SpaceType_value = map[string]int32{ "L2": 0, "IP": 1, "COSINE": 2, } )
Enum value maps for CreateIndexRequest_SpaceType.
var File_hnswservice_proto protoreflect.FileDescriptor
var Server_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpcapi.Server", HandlerType: (*ServerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateIndex", Handler: _Server_CreateIndex_Handler, }, { MethodName: "DeleteIndex", Handler: _Server_DeleteIndex_Handler, }, { MethodName: "InsertVector", Handler: _Server_InsertVector_Handler, }, { MethodName: "InsertVectorWithId", Handler: _Server_InsertVectorWithId_Handler, }, { MethodName: "SearchKNN", Handler: _Server_SearchKNN_Handler, }, { MethodName: "FlushIndex", Handler: _Server_FlushIndex_Handler, }, { MethodName: "Indices", Handler: _Server_Indices_Handler, }, { MethodName: "SetEf", Handler: _Server_SetEf_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "InsertVectors", Handler: _Server_InsertVectors_Handler, ClientStreams: true, }, { StreamName: "InsertVectorsWithIds", Handler: _Server_InsertVectorsWithIds_Handler, ClientStreams: true, }, }, Metadata: "hnswservice.proto", }
Server_ServiceDesc is the grpc.ServiceDesc for Server service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterServerServer ¶
func RegisterServerServer(s grpc.ServiceRegistrar, srv ServerServer)
Types ¶
type CreateIndexRequest ¶
type CreateIndexRequest struct { IndexName string `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"` Dim int32 `protobuf:"varint,2,opt,name=dim,proto3" json:"dim,omitempty"` EfConstruction int32 `protobuf:"varint,3,opt,name=efConstruction,proto3" json:"efConstruction,omitempty"` M int32 `protobuf:"varint,4,opt,name=m,proto3" json:"m,omitempty"` MaxElements int32 `protobuf:"varint,5,opt,name=max_elements,json=maxElements,proto3" json:"max_elements,omitempty"` Seed int32 `protobuf:"varint,6,opt,name=seed,proto3" json:"seed,omitempty"` SpaceType CreateIndexRequest_SpaceType `` /* 131-byte string literal not displayed */ AutoId bool `protobuf:"varint,8,opt,name=auto_id,json=autoId,proto3" json:"auto_id,omitempty"` // contains filtered or unexported fields }
func (*CreateIndexRequest) Descriptor
deprecated
func (*CreateIndexRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateIndexRequest.ProtoReflect.Descriptor instead.
func (*CreateIndexRequest) GetAutoId ¶
func (x *CreateIndexRequest) GetAutoId() bool
func (*CreateIndexRequest) GetDim ¶
func (x *CreateIndexRequest) GetDim() int32
func (*CreateIndexRequest) GetEfConstruction ¶
func (x *CreateIndexRequest) GetEfConstruction() int32
func (*CreateIndexRequest) GetIndexName ¶
func (x *CreateIndexRequest) GetIndexName() string
func (*CreateIndexRequest) GetM ¶
func (x *CreateIndexRequest) GetM() int32
func (*CreateIndexRequest) GetMaxElements ¶
func (x *CreateIndexRequest) GetMaxElements() int32
func (*CreateIndexRequest) GetSeed ¶
func (x *CreateIndexRequest) GetSeed() int32
func (*CreateIndexRequest) GetSpaceType ¶
func (x *CreateIndexRequest) GetSpaceType() CreateIndexRequest_SpaceType
func (*CreateIndexRequest) ProtoMessage ¶
func (*CreateIndexRequest) ProtoMessage()
func (*CreateIndexRequest) ProtoReflect ¶
func (x *CreateIndexRequest) ProtoReflect() protoreflect.Message
func (*CreateIndexRequest) Reset ¶
func (x *CreateIndexRequest) Reset()
func (*CreateIndexRequest) String ¶
func (x *CreateIndexRequest) String() string
type CreateIndexRequest_SpaceType ¶
type CreateIndexRequest_SpaceType int32
SpaceType is the vector space.
const ( CreateIndexRequest_L2 CreateIndexRequest_SpaceType = 0 CreateIndexRequest_IP CreateIndexRequest_SpaceType = 1 CreateIndexRequest_COSINE CreateIndexRequest_SpaceType = 2 )
func (CreateIndexRequest_SpaceType) Descriptor ¶
func (CreateIndexRequest_SpaceType) Descriptor() protoreflect.EnumDescriptor
func (CreateIndexRequest_SpaceType) Enum ¶
func (x CreateIndexRequest_SpaceType) Enum() *CreateIndexRequest_SpaceType
func (CreateIndexRequest_SpaceType) EnumDescriptor
deprecated
func (CreateIndexRequest_SpaceType) EnumDescriptor() ([]byte, []int)
Deprecated: Use CreateIndexRequest_SpaceType.Descriptor instead.
func (CreateIndexRequest_SpaceType) Number ¶
func (x CreateIndexRequest_SpaceType) Number() protoreflect.EnumNumber
func (CreateIndexRequest_SpaceType) String ¶
func (x CreateIndexRequest_SpaceType) String() string
func (CreateIndexRequest_SpaceType) Type ¶
func (CreateIndexRequest_SpaceType) Type() protoreflect.EnumType
type DeleteIndexRequest ¶
type DeleteIndexRequest struct { IndexName string `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"` // contains filtered or unexported fields }
func (*DeleteIndexRequest) Descriptor
deprecated
func (*DeleteIndexRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteIndexRequest.ProtoReflect.Descriptor instead.
func (*DeleteIndexRequest) GetIndexName ¶
func (x *DeleteIndexRequest) GetIndexName() string
func (*DeleteIndexRequest) ProtoMessage ¶
func (*DeleteIndexRequest) ProtoMessage()
func (*DeleteIndexRequest) ProtoReflect ¶
func (x *DeleteIndexRequest) ProtoReflect() protoreflect.Message
func (*DeleteIndexRequest) Reset ¶
func (x *DeleteIndexRequest) Reset()
func (*DeleteIndexRequest) String ¶
func (x *DeleteIndexRequest) String() string
type FlushRequest ¶
type FlushRequest struct { IndexName string `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"` // contains filtered or unexported fields }
func (*FlushRequest) Descriptor
deprecated
func (*FlushRequest) Descriptor() ([]byte, []int)
Deprecated: Use FlushRequest.ProtoReflect.Descriptor instead.
func (*FlushRequest) GetIndexName ¶
func (x *FlushRequest) GetIndexName() string
func (*FlushRequest) ProtoMessage ¶
func (*FlushRequest) ProtoMessage()
func (*FlushRequest) ProtoReflect ¶
func (x *FlushRequest) ProtoReflect() protoreflect.Message
func (*FlushRequest) Reset ¶
func (x *FlushRequest) Reset()
func (*FlushRequest) String ¶
func (x *FlushRequest) String() string
type Hit ¶
type Hit struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // the id of the stored vector Distance float32 `protobuf:"fixed32,2,opt,name=distance,proto3" json:"distance,omitempty"` // the distance between the stored vector and the query vector // contains filtered or unexported fields }
Hit represents a single result
func (*Hit) Descriptor
deprecated
func (*Hit) GetDistance ¶
func (*Hit) ProtoMessage ¶
func (*Hit) ProtoMessage()
func (*Hit) ProtoReflect ¶
func (x *Hit) ProtoReflect() protoreflect.Message
type IndicesReply ¶
type IndicesReply struct { Indices []string `protobuf:"bytes,1,rep,name=indices,proto3" json:"indices,omitempty"` // contains filtered or unexported fields }
func (*IndicesReply) Descriptor
deprecated
func (*IndicesReply) Descriptor() ([]byte, []int)
Deprecated: Use IndicesReply.ProtoReflect.Descriptor instead.
func (*IndicesReply) GetIndices ¶
func (x *IndicesReply) GetIndices() []string
func (*IndicesReply) ProtoMessage ¶
func (*IndicesReply) ProtoMessage()
func (*IndicesReply) ProtoReflect ¶
func (x *IndicesReply) ProtoReflect() protoreflect.Message
func (*IndicesReply) Reset ¶
func (x *IndicesReply) Reset()
func (*IndicesReply) String ¶
func (x *IndicesReply) String() string
type InsertVectorReply ¶
type InsertVectorReply struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Took is the number of milliseconds it took the server to execute the request. Took int64 `protobuf:"varint,2,opt,name=took,proto3" json:"took,omitempty"` // contains filtered or unexported fields }
func (*InsertVectorReply) Descriptor
deprecated
func (*InsertVectorReply) Descriptor() ([]byte, []int)
Deprecated: Use InsertVectorReply.ProtoReflect.Descriptor instead.
func (*InsertVectorReply) GetId ¶
func (x *InsertVectorReply) GetId() string
func (*InsertVectorReply) GetTook ¶
func (x *InsertVectorReply) GetTook() int64
func (*InsertVectorReply) ProtoMessage ¶
func (*InsertVectorReply) ProtoMessage()
func (*InsertVectorReply) ProtoReflect ¶
func (x *InsertVectorReply) ProtoReflect() protoreflect.Message
func (*InsertVectorReply) Reset ¶
func (x *InsertVectorReply) Reset()
func (*InsertVectorReply) String ¶
func (x *InsertVectorReply) String() string
type InsertVectorRequest ¶
type InsertVectorRequest struct { IndexName string `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"` Vector *Vector `protobuf:"bytes,2,opt,name=vector,proto3" json:"vector,omitempty"` // contains filtered or unexported fields }
func (*InsertVectorRequest) Descriptor
deprecated
func (*InsertVectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use InsertVectorRequest.ProtoReflect.Descriptor instead.
func (*InsertVectorRequest) GetIndexName ¶
func (x *InsertVectorRequest) GetIndexName() string
func (*InsertVectorRequest) GetVector ¶
func (x *InsertVectorRequest) GetVector() *Vector
func (*InsertVectorRequest) ProtoMessage ¶
func (*InsertVectorRequest) ProtoMessage()
func (*InsertVectorRequest) ProtoReflect ¶
func (x *InsertVectorRequest) ProtoReflect() protoreflect.Message
func (*InsertVectorRequest) Reset ¶
func (x *InsertVectorRequest) Reset()
func (*InsertVectorRequest) String ¶
func (x *InsertVectorRequest) String() string
type InsertVectorWithIdReply ¶
type InsertVectorWithIdReply struct { // Took is the number of milliseconds it took the server to execute the request. Took int64 `protobuf:"varint,2,opt,name=took,proto3" json:"took,omitempty"` // contains filtered or unexported fields }
func (*InsertVectorWithIdReply) Descriptor
deprecated
func (*InsertVectorWithIdReply) Descriptor() ([]byte, []int)
Deprecated: Use InsertVectorWithIdReply.ProtoReflect.Descriptor instead.
func (*InsertVectorWithIdReply) GetTook ¶
func (x *InsertVectorWithIdReply) GetTook() int64
func (*InsertVectorWithIdReply) ProtoMessage ¶
func (*InsertVectorWithIdReply) ProtoMessage()
func (*InsertVectorWithIdReply) ProtoReflect ¶
func (x *InsertVectorWithIdReply) ProtoReflect() protoreflect.Message
func (*InsertVectorWithIdReply) Reset ¶
func (x *InsertVectorWithIdReply) Reset()
func (*InsertVectorWithIdReply) String ¶
func (x *InsertVectorWithIdReply) String() string
type InsertVectorWithIdRequest ¶
type InsertVectorWithIdRequest struct { IndexName string `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"` Id int32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` Vector *Vector `protobuf:"bytes,3,opt,name=vector,proto3" json:"vector,omitempty"` // contains filtered or unexported fields }
func (*InsertVectorWithIdRequest) Descriptor
deprecated
func (*InsertVectorWithIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use InsertVectorWithIdRequest.ProtoReflect.Descriptor instead.
func (*InsertVectorWithIdRequest) GetId ¶
func (x *InsertVectorWithIdRequest) GetId() int32
func (*InsertVectorWithIdRequest) GetIndexName ¶
func (x *InsertVectorWithIdRequest) GetIndexName() string
func (*InsertVectorWithIdRequest) GetVector ¶
func (x *InsertVectorWithIdRequest) GetVector() *Vector
func (*InsertVectorWithIdRequest) ProtoMessage ¶
func (*InsertVectorWithIdRequest) ProtoMessage()
func (*InsertVectorWithIdRequest) ProtoReflect ¶
func (x *InsertVectorWithIdRequest) ProtoReflect() protoreflect.Message
func (*InsertVectorWithIdRequest) Reset ¶
func (x *InsertVectorWithIdRequest) Reset()
func (*InsertVectorWithIdRequest) String ¶
func (x *InsertVectorWithIdRequest) String() string
type InsertVectorsReply ¶
type InsertVectorsReply struct { Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"` // Took is the number of milliseconds it took the server to execute the request. Took int64 `protobuf:"varint,2,opt,name=took,proto3" json:"took,omitempty"` // contains filtered or unexported fields }
func (*InsertVectorsReply) Descriptor
deprecated
func (*InsertVectorsReply) Descriptor() ([]byte, []int)
Deprecated: Use InsertVectorsReply.ProtoReflect.Descriptor instead.
func (*InsertVectorsReply) GetIds ¶
func (x *InsertVectorsReply) GetIds() []string
func (*InsertVectorsReply) GetTook ¶
func (x *InsertVectorsReply) GetTook() int64
func (*InsertVectorsReply) ProtoMessage ¶
func (*InsertVectorsReply) ProtoMessage()
func (*InsertVectorsReply) ProtoReflect ¶
func (x *InsertVectorsReply) ProtoReflect() protoreflect.Message
func (*InsertVectorsReply) Reset ¶
func (x *InsertVectorsReply) Reset()
func (*InsertVectorsReply) String ¶
func (x *InsertVectorsReply) String() string
type InsertVectorsWithIdsReply ¶
type InsertVectorsWithIdsReply struct { // Took is the number of milliseconds it took the server to execute the request. Took int64 `protobuf:"varint,2,opt,name=took,proto3" json:"took,omitempty"` // contains filtered or unexported fields }
func (*InsertVectorsWithIdsReply) Descriptor
deprecated
func (*InsertVectorsWithIdsReply) Descriptor() ([]byte, []int)
Deprecated: Use InsertVectorsWithIdsReply.ProtoReflect.Descriptor instead.
func (*InsertVectorsWithIdsReply) GetTook ¶
func (x *InsertVectorsWithIdsReply) GetTook() int64
func (*InsertVectorsWithIdsReply) ProtoMessage ¶
func (*InsertVectorsWithIdsReply) ProtoMessage()
func (*InsertVectorsWithIdsReply) ProtoReflect ¶
func (x *InsertVectorsWithIdsReply) ProtoReflect() protoreflect.Message
func (*InsertVectorsWithIdsReply) Reset ¶
func (x *InsertVectorsWithIdsReply) Reset()
func (*InsertVectorsWithIdsReply) String ¶
func (x *InsertVectorsWithIdsReply) String() string
type SearchKNNReply ¶
type SearchKNNReply struct { Hits []*Hit `protobuf:"bytes,1,rep,name=hits,proto3" json:"hits,omitempty"` // Took is the number of milliseconds it took the server to execute the request. Took int64 `protobuf:"varint,2,opt,name=took,proto3" json:"took,omitempty"` // contains filtered or unexported fields }
Hit represents a the result of a search
func (*SearchKNNReply) Descriptor
deprecated
func (*SearchKNNReply) Descriptor() ([]byte, []int)
Deprecated: Use SearchKNNReply.ProtoReflect.Descriptor instead.
func (*SearchKNNReply) GetHits ¶
func (x *SearchKNNReply) GetHits() []*Hit
func (*SearchKNNReply) GetTook ¶
func (x *SearchKNNReply) GetTook() int64
func (*SearchKNNReply) ProtoMessage ¶
func (*SearchKNNReply) ProtoMessage()
func (*SearchKNNReply) ProtoReflect ¶
func (x *SearchKNNReply) ProtoReflect() protoreflect.Message
func (*SearchKNNReply) Reset ¶
func (x *SearchKNNReply) Reset()
func (*SearchKNNReply) String ¶
func (x *SearchKNNReply) String() string
type SearchRequest ¶
type SearchRequest struct { IndexName string `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"` Vector *Vector `protobuf:"bytes,2,opt,name=vector,proto3" json:"vector,omitempty"` K int32 `protobuf:"varint,3,opt,name=k,proto3" json:"k,omitempty"` // contains filtered or unexported fields }
func (*SearchRequest) Descriptor
deprecated
func (*SearchRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.
func (*SearchRequest) GetIndexName ¶
func (x *SearchRequest) GetIndexName() string
func (*SearchRequest) GetK ¶
func (x *SearchRequest) GetK() int32
func (*SearchRequest) GetVector ¶
func (x *SearchRequest) GetVector() *Vector
func (*SearchRequest) ProtoMessage ¶
func (*SearchRequest) ProtoMessage()
func (*SearchRequest) ProtoReflect ¶
func (x *SearchRequest) ProtoReflect() protoreflect.Message
func (*SearchRequest) Reset ¶
func (x *SearchRequest) Reset()
func (*SearchRequest) String ¶
func (x *SearchRequest) String() string
type ServerClient ¶
type ServerClient interface { // CreateIndex makes a new index. CreateIndex(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // DeleteIndex removes an index. DeleteIndex(ctx context.Context, in *DeleteIndexRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // InsertVector inserts a new vector in the given index. InsertVector(ctx context.Context, in *InsertVectorRequest, opts ...grpc.CallOption) (*InsertVectorReply, error) // InsertVectors inserts the new vectors in the given index. It flushes the index at each batch. InsertVectors(ctx context.Context, opts ...grpc.CallOption) (Server_InsertVectorsClient, error) // InsertVectorWithID inserts a new vector in the given index. InsertVectorWithId(ctx context.Context, in *InsertVectorWithIdRequest, opts ...grpc.CallOption) (*InsertVectorWithIdReply, error) // InsertVectorsWithIDs inserts the new vectors in the given index. It flushes the index at each batch. InsertVectorsWithIds(ctx context.Context, opts ...grpc.CallOption) (Server_InsertVectorsWithIdsClient, error) // SearchKNN returns the top k nearest neighbors to the query, searching on the given index. SearchKNN(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchKNNReply, error) // FlushIndex the index to file. FlushIndex(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Indices returns the list of indices. Indices(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*IndicesReply, error) // SetEf sets the `ef` parameter for the given index. SetEf(ctx context.Context, in *SetEfRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) }
ServerClient is the client API for Server service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewServerClient ¶
func NewServerClient(cc grpc.ClientConnInterface) ServerClient
type ServerServer ¶
type ServerServer interface { // CreateIndex makes a new index. CreateIndex(context.Context, *CreateIndexRequest) (*emptypb.Empty, error) // DeleteIndex removes an index. DeleteIndex(context.Context, *DeleteIndexRequest) (*emptypb.Empty, error) // InsertVector inserts a new vector in the given index. InsertVector(context.Context, *InsertVectorRequest) (*InsertVectorReply, error) // InsertVectors inserts the new vectors in the given index. It flushes the index at each batch. InsertVectors(Server_InsertVectorsServer) error // InsertVectorWithID inserts a new vector in the given index. InsertVectorWithId(context.Context, *InsertVectorWithIdRequest) (*InsertVectorWithIdReply, error) // InsertVectorsWithIDs inserts the new vectors in the given index. It flushes the index at each batch. InsertVectorsWithIds(Server_InsertVectorsWithIdsServer) error // SearchKNN returns the top k nearest neighbors to the query, searching on the given index. SearchKNN(context.Context, *SearchRequest) (*SearchKNNReply, error) // FlushIndex the index to file. FlushIndex(context.Context, *FlushRequest) (*emptypb.Empty, error) // Indices returns the list of indices. Indices(context.Context, *emptypb.Empty) (*IndicesReply, error) // SetEf sets the `ef` parameter for the given index. SetEf(context.Context, *SetEfRequest) (*emptypb.Empty, error) // contains filtered or unexported methods }
ServerServer is the server API for Server service. All implementations must embed UnimplementedServerServer for forward compatibility
type Server_InsertVectorsClient ¶
type Server_InsertVectorsClient interface { Send(*InsertVectorRequest) error CloseAndRecv() (*InsertVectorsReply, error) grpc.ClientStream }
type Server_InsertVectorsServer ¶
type Server_InsertVectorsServer interface { SendAndClose(*InsertVectorsReply) error Recv() (*InsertVectorRequest, error) grpc.ServerStream }
type Server_InsertVectorsWithIdsClient ¶
type Server_InsertVectorsWithIdsClient interface { Send(*InsertVectorWithIdRequest) error CloseAndRecv() (*InsertVectorsWithIdsReply, error) grpc.ClientStream }
type Server_InsertVectorsWithIdsServer ¶
type Server_InsertVectorsWithIdsServer interface { SendAndClose(*InsertVectorsWithIdsReply) error Recv() (*InsertVectorWithIdRequest, error) grpc.ServerStream }
type SetEfRequest ¶
type SetEfRequest struct { IndexName string `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"` Value int32 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*SetEfRequest) Descriptor
deprecated
func (*SetEfRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetEfRequest.ProtoReflect.Descriptor instead.
func (*SetEfRequest) GetIndexName ¶
func (x *SetEfRequest) GetIndexName() string
func (*SetEfRequest) GetValue ¶
func (x *SetEfRequest) GetValue() int32
func (*SetEfRequest) ProtoMessage ¶
func (*SetEfRequest) ProtoMessage()
func (*SetEfRequest) ProtoReflect ¶
func (x *SetEfRequest) ProtoReflect() protoreflect.Message
func (*SetEfRequest) Reset ¶
func (x *SetEfRequest) Reset()
func (*SetEfRequest) String ¶
func (x *SetEfRequest) String() string
type UnimplementedServerServer ¶
type UnimplementedServerServer struct { }
UnimplementedServerServer must be embedded to have forward compatible implementations.
func (UnimplementedServerServer) CreateIndex ¶
func (UnimplementedServerServer) CreateIndex(context.Context, *CreateIndexRequest) (*emptypb.Empty, error)
func (UnimplementedServerServer) DeleteIndex ¶
func (UnimplementedServerServer) DeleteIndex(context.Context, *DeleteIndexRequest) (*emptypb.Empty, error)
func (UnimplementedServerServer) FlushIndex ¶
func (UnimplementedServerServer) FlushIndex(context.Context, *FlushRequest) (*emptypb.Empty, error)
func (UnimplementedServerServer) Indices ¶
func (UnimplementedServerServer) Indices(context.Context, *emptypb.Empty) (*IndicesReply, error)
func (UnimplementedServerServer) InsertVector ¶
func (UnimplementedServerServer) InsertVector(context.Context, *InsertVectorRequest) (*InsertVectorReply, error)
func (UnimplementedServerServer) InsertVectorWithId ¶
func (UnimplementedServerServer) InsertVectorWithId(context.Context, *InsertVectorWithIdRequest) (*InsertVectorWithIdReply, error)
func (UnimplementedServerServer) InsertVectors ¶
func (UnimplementedServerServer) InsertVectors(Server_InsertVectorsServer) error
func (UnimplementedServerServer) InsertVectorsWithIds ¶
func (UnimplementedServerServer) InsertVectorsWithIds(Server_InsertVectorsWithIdsServer) error
func (UnimplementedServerServer) SearchKNN ¶
func (UnimplementedServerServer) SearchKNN(context.Context, *SearchRequest) (*SearchKNNReply, error)
func (UnimplementedServerServer) SetEf ¶
func (UnimplementedServerServer) SetEf(context.Context, *SetEfRequest) (*emptypb.Empty, error)
type UnsafeServerServer ¶
type UnsafeServerServer interface {
// contains filtered or unexported methods
}
UnsafeServerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServerServer will result in compilation errors.
type Vector ¶
type Vector struct { Value []float32 `protobuf:"fixed32,1,rep,packed,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Vector) Descriptor
deprecated
func (*Vector) ProtoMessage ¶
func (*Vector) ProtoMessage()
func (*Vector) ProtoReflect ¶
func (x *Vector) ProtoReflect() protoreflect.Message