Documentation ¶
Index ¶
- func NewFaissClient(addr string, port int) (uc.Ann, error)
- func RegisterFaissServiceServer(s *grpc.Server, srv FaissServiceServer)
- type Faiss
- type FaissServiceClient
- type FaissServiceServer
- type HeartbeatResponse
- func (*HeartbeatResponse) Descriptor() ([]byte, []int)
- func (m *HeartbeatResponse) GetMessage() string
- func (*HeartbeatResponse) ProtoMessage()
- func (m *HeartbeatResponse) Reset()
- func (m *HeartbeatResponse) String() string
- func (m *HeartbeatResponse) XXX_DiscardUnknown()
- func (m *HeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartbeatResponse) XXX_Merge(src proto.Message)
- func (m *HeartbeatResponse) XXX_Size() int
- func (m *HeartbeatResponse) XXX_Unmarshal(b []byte) error
- type Neighbor
- func (*Neighbor) Descriptor() ([]byte, []int)
- func (m *Neighbor) GetId() uint64
- func (m *Neighbor) GetScore() float32
- func (*Neighbor) ProtoMessage()
- func (m *Neighbor) Reset()
- func (m *Neighbor) String() string
- func (m *Neighbor) XXX_DiscardUnknown()
- func (m *Neighbor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Neighbor) XXX_Merge(src proto.Message)
- func (m *Neighbor) XXX_Size() int
- func (m *Neighbor) XXX_Unmarshal(b []byte) error
- type SearchByIdRequest
- func (*SearchByIdRequest) Descriptor() ([]byte, []int)
- func (m *SearchByIdRequest) GetId() uint64
- func (m *SearchByIdRequest) GetTopK() uint64
- func (*SearchByIdRequest) ProtoMessage()
- func (m *SearchByIdRequest) Reset()
- func (m *SearchByIdRequest) String() string
- func (m *SearchByIdRequest) XXX_DiscardUnknown()
- func (m *SearchByIdRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SearchByIdRequest) XXX_Merge(src proto.Message)
- func (m *SearchByIdRequest) XXX_Size() int
- func (m *SearchByIdRequest) XXX_Unmarshal(b []byte) error
- type SearchByIdResponse
- func (*SearchByIdResponse) Descriptor() ([]byte, []int)
- func (m *SearchByIdResponse) GetNeighbors() []*Neighbor
- func (m *SearchByIdResponse) GetRequestId() uint64
- func (*SearchByIdResponse) ProtoMessage()
- func (m *SearchByIdResponse) Reset()
- func (m *SearchByIdResponse) String() string
- func (m *SearchByIdResponse) XXX_DiscardUnknown()
- func (m *SearchByIdResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SearchByIdResponse) XXX_Merge(src proto.Message)
- func (m *SearchByIdResponse) XXX_Size() int
- func (m *SearchByIdResponse) XXX_Unmarshal(b []byte) error
- type SearchRequest
- func (*SearchRequest) Descriptor() ([]byte, []int)
- func (m *SearchRequest) GetTopK() uint64
- func (m *SearchRequest) GetVector() *Vector
- func (*SearchRequest) ProtoMessage()
- func (m *SearchRequest) Reset()
- func (m *SearchRequest) String() string
- func (m *SearchRequest) XXX_DiscardUnknown()
- func (m *SearchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SearchRequest) XXX_Merge(src proto.Message)
- func (m *SearchRequest) XXX_Size() int
- func (m *SearchRequest) XXX_Unmarshal(b []byte) error
- type SearchResponse
- func (*SearchResponse) Descriptor() ([]byte, []int)
- func (m *SearchResponse) GetNeighbors() []*Neighbor
- func (*SearchResponse) ProtoMessage()
- func (m *SearchResponse) Reset()
- func (m *SearchResponse) String() string
- func (m *SearchResponse) XXX_DiscardUnknown()
- func (m *SearchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SearchResponse) XXX_Merge(src proto.Message)
- func (m *SearchResponse) XXX_Size() int
- func (m *SearchResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedFaissServiceServer
- func (*UnimplementedFaissServiceServer) Heartbeat(ctx context.Context, req *empty.Empty) (*HeartbeatResponse, error)
- func (*UnimplementedFaissServiceServer) Search(ctx context.Context, req *SearchRequest) (*SearchResponse, error)
- func (*UnimplementedFaissServiceServer) SearchById(ctx context.Context, req *SearchByIdRequest) (*SearchByIdResponse, error)
- type Vector
- func (*Vector) Descriptor() ([]byte, []int)
- func (m *Vector) GetFloatVal() []float32
- func (*Vector) ProtoMessage()
- func (m *Vector) Reset()
- func (m *Vector) String() string
- func (m *Vector) XXX_DiscardUnknown()
- func (m *Vector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Vector) XXX_Merge(src proto.Message)
- func (m *Vector) XXX_Size() int
- func (m *Vector) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFaissClient ¶
NewFaissClient creates a new gRPC client
func RegisterFaissServiceServer ¶
func RegisterFaissServiceServer(s *grpc.Server, srv FaissServiceServer)
Types ¶
type FaissServiceClient ¶
type FaissServiceClient interface { Heartbeat(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*HeartbeatResponse, error) Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error) SearchById(ctx context.Context, in *SearchByIdRequest, opts ...grpc.CallOption) (*SearchByIdResponse, error) }
FaissServiceClient is the client API for FaissService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewFaissServiceClient ¶
func NewFaissServiceClient(cc *grpc.ClientConn) FaissServiceClient
type FaissServiceServer ¶
type FaissServiceServer interface { Heartbeat(context.Context, *empty.Empty) (*HeartbeatResponse, error) Search(context.Context, *SearchRequest) (*SearchResponse, error) SearchById(context.Context, *SearchByIdRequest) (*SearchByIdResponse, error) }
FaissServiceServer is the server API for FaissService service.
type HeartbeatResponse ¶
type HeartbeatResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HeartbeatResponse) Descriptor ¶
func (*HeartbeatResponse) Descriptor() ([]byte, []int)
func (*HeartbeatResponse) GetMessage ¶
func (m *HeartbeatResponse) GetMessage() string
func (*HeartbeatResponse) ProtoMessage ¶
func (*HeartbeatResponse) ProtoMessage()
func (*HeartbeatResponse) Reset ¶
func (m *HeartbeatResponse) Reset()
func (*HeartbeatResponse) String ¶
func (m *HeartbeatResponse) String() string
func (*HeartbeatResponse) XXX_DiscardUnknown ¶
func (m *HeartbeatResponse) XXX_DiscardUnknown()
func (*HeartbeatResponse) XXX_Marshal ¶
func (m *HeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HeartbeatResponse) XXX_Merge ¶
func (m *HeartbeatResponse) XXX_Merge(src proto.Message)
func (*HeartbeatResponse) XXX_Size ¶
func (m *HeartbeatResponse) XXX_Size() int
func (*HeartbeatResponse) XXX_Unmarshal ¶
func (m *HeartbeatResponse) XXX_Unmarshal(b []byte) error
type Neighbor ¶
type Neighbor struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Score float32 `protobuf:"fixed32,2,opt,name=score,proto3" json:"score,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Neighbor) Descriptor ¶
func (*Neighbor) ProtoMessage ¶
func (*Neighbor) ProtoMessage()
func (*Neighbor) XXX_DiscardUnknown ¶
func (m *Neighbor) XXX_DiscardUnknown()
func (*Neighbor) XXX_Marshal ¶
func (*Neighbor) XXX_Unmarshal ¶
type SearchByIdRequest ¶
type SearchByIdRequest struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` TopK uint64 `protobuf:"varint,2,opt,name=top_k,json=topK,proto3" json:"top_k,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SearchByIdRequest) Descriptor ¶
func (*SearchByIdRequest) Descriptor() ([]byte, []int)
func (*SearchByIdRequest) GetId ¶
func (m *SearchByIdRequest) GetId() uint64
func (*SearchByIdRequest) GetTopK ¶
func (m *SearchByIdRequest) GetTopK() uint64
func (*SearchByIdRequest) ProtoMessage ¶
func (*SearchByIdRequest) ProtoMessage()
func (*SearchByIdRequest) Reset ¶
func (m *SearchByIdRequest) Reset()
func (*SearchByIdRequest) String ¶
func (m *SearchByIdRequest) String() string
func (*SearchByIdRequest) XXX_DiscardUnknown ¶
func (m *SearchByIdRequest) XXX_DiscardUnknown()
func (*SearchByIdRequest) XXX_Marshal ¶
func (m *SearchByIdRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SearchByIdRequest) XXX_Merge ¶
func (m *SearchByIdRequest) XXX_Merge(src proto.Message)
func (*SearchByIdRequest) XXX_Size ¶
func (m *SearchByIdRequest) XXX_Size() int
func (*SearchByIdRequest) XXX_Unmarshal ¶
func (m *SearchByIdRequest) XXX_Unmarshal(b []byte) error
type SearchByIdResponse ¶
type SearchByIdResponse struct { RequestId uint64 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Neighbors []*Neighbor `protobuf:"bytes,2,rep,name=neighbors,proto3" json:"neighbors,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SearchByIdResponse) Descriptor ¶
func (*SearchByIdResponse) Descriptor() ([]byte, []int)
func (*SearchByIdResponse) GetNeighbors ¶
func (m *SearchByIdResponse) GetNeighbors() []*Neighbor
func (*SearchByIdResponse) GetRequestId ¶
func (m *SearchByIdResponse) GetRequestId() uint64
func (*SearchByIdResponse) ProtoMessage ¶
func (*SearchByIdResponse) ProtoMessage()
func (*SearchByIdResponse) Reset ¶
func (m *SearchByIdResponse) Reset()
func (*SearchByIdResponse) String ¶
func (m *SearchByIdResponse) String() string
func (*SearchByIdResponse) XXX_DiscardUnknown ¶
func (m *SearchByIdResponse) XXX_DiscardUnknown()
func (*SearchByIdResponse) XXX_Marshal ¶
func (m *SearchByIdResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SearchByIdResponse) XXX_Merge ¶
func (m *SearchByIdResponse) XXX_Merge(src proto.Message)
func (*SearchByIdResponse) XXX_Size ¶
func (m *SearchByIdResponse) XXX_Size() int
func (*SearchByIdResponse) XXX_Unmarshal ¶
func (m *SearchByIdResponse) XXX_Unmarshal(b []byte) error
type SearchRequest ¶
type SearchRequest struct { Vector *Vector `protobuf:"bytes,1,opt,name=vector,proto3" json:"vector,omitempty"` TopK uint64 `protobuf:"varint,2,opt,name=top_k,json=topK,proto3" json:"top_k,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SearchRequest) Descriptor ¶
func (*SearchRequest) Descriptor() ([]byte, []int)
func (*SearchRequest) GetTopK ¶
func (m *SearchRequest) GetTopK() uint64
func (*SearchRequest) GetVector ¶
func (m *SearchRequest) GetVector() *Vector
func (*SearchRequest) ProtoMessage ¶
func (*SearchRequest) ProtoMessage()
func (*SearchRequest) Reset ¶
func (m *SearchRequest) Reset()
func (*SearchRequest) String ¶
func (m *SearchRequest) String() string
func (*SearchRequest) XXX_DiscardUnknown ¶
func (m *SearchRequest) XXX_DiscardUnknown()
func (*SearchRequest) XXX_Marshal ¶
func (m *SearchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SearchRequest) XXX_Merge ¶
func (m *SearchRequest) XXX_Merge(src proto.Message)
func (*SearchRequest) XXX_Size ¶
func (m *SearchRequest) XXX_Size() int
func (*SearchRequest) XXX_Unmarshal ¶
func (m *SearchRequest) XXX_Unmarshal(b []byte) error
type SearchResponse ¶
type SearchResponse struct { Neighbors []*Neighbor `protobuf:"bytes,2,rep,name=neighbors,proto3" json:"neighbors,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SearchResponse) Descriptor ¶
func (*SearchResponse) Descriptor() ([]byte, []int)
func (*SearchResponse) GetNeighbors ¶
func (m *SearchResponse) GetNeighbors() []*Neighbor
func (*SearchResponse) ProtoMessage ¶
func (*SearchResponse) ProtoMessage()
func (*SearchResponse) Reset ¶
func (m *SearchResponse) Reset()
func (*SearchResponse) String ¶
func (m *SearchResponse) String() string
func (*SearchResponse) XXX_DiscardUnknown ¶
func (m *SearchResponse) XXX_DiscardUnknown()
func (*SearchResponse) XXX_Marshal ¶
func (m *SearchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SearchResponse) XXX_Merge ¶
func (m *SearchResponse) XXX_Merge(src proto.Message)
func (*SearchResponse) XXX_Size ¶
func (m *SearchResponse) XXX_Size() int
func (*SearchResponse) XXX_Unmarshal ¶
func (m *SearchResponse) XXX_Unmarshal(b []byte) error
type UnimplementedFaissServiceServer ¶
type UnimplementedFaissServiceServer struct { }
UnimplementedFaissServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedFaissServiceServer) Heartbeat ¶
func (*UnimplementedFaissServiceServer) Heartbeat(ctx context.Context, req *empty.Empty) (*HeartbeatResponse, error)
func (*UnimplementedFaissServiceServer) Search ¶
func (*UnimplementedFaissServiceServer) Search(ctx context.Context, req *SearchRequest) (*SearchResponse, error)
func (*UnimplementedFaissServiceServer) SearchById ¶
func (*UnimplementedFaissServiceServer) SearchById(ctx context.Context, req *SearchByIdRequest) (*SearchByIdResponse, error)
type Vector ¶
type Vector struct { FloatVal []float32 `protobuf:"fixed32,5,rep,packed,name=float_val,json=floatVal,proto3" json:"float_val,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Vector) Descriptor ¶
func (*Vector) GetFloatVal ¶
func (*Vector) ProtoMessage ¶
func (*Vector) ProtoMessage()
func (*Vector) XXX_DiscardUnknown ¶
func (m *Vector) XXX_DiscardUnknown()
func (*Vector) XXX_Marshal ¶
func (*Vector) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.