Documentation ¶
Index ¶
- Variables
- func RegisterVeriServiceServer(s *grpc.Server, srv VeriServiceServer)
- type DataConfig
- func (*DataConfig) Descriptor() ([]byte, []int)deprecated
- func (x *DataConfig) GetEnforceReplicationOnInsert() bool
- func (x *DataConfig) GetName() string
- func (x *DataConfig) GetNoTarget() bool
- func (x *DataConfig) GetReplicationOnInsert() uint32
- func (x *DataConfig) GetRetentation() uint64
- func (x *DataConfig) GetTargetN() uint64
- func (x *DataConfig) GetTargetUtilization() float64
- func (x *DataConfig) GetVersion() string
- func (*DataConfig) ProtoMessage()
- func (x *DataConfig) ProtoReflect() protoreflect.Message
- func (x *DataConfig) Reset()
- func (x *DataConfig) String() string
- type DataInfo
- func (*DataInfo) Descriptor() ([]byte, []int)deprecated
- func (x *DataInfo) GetAvg() []float64
- func (x *DataInfo) GetEnforceReplicationOnInsert() bool
- func (x *DataInfo) GetHist() []float64
- func (x *DataInfo) GetMaxDistance() float64
- func (x *DataInfo) GetN() uint64
- func (x *DataInfo) GetName() string
- func (x *DataInfo) GetNoTarget() bool
- func (x *DataInfo) GetReplicationOnInsert() uint32
- func (x *DataInfo) GetRetentation() uint64
- func (x *DataInfo) GetTargetN() uint64
- func (x *DataInfo) GetTargetUtilization() float64
- func (x *DataInfo) GetTimestamp() uint64
- func (x *DataInfo) GetVersion() string
- func (*DataInfo) ProtoMessage()
- func (x *DataInfo) ProtoReflect() protoreflect.Message
- func (x *DataInfo) Reset()
- func (x *DataInfo) String() string
- type Datum
- type DatumKey
- func (*DatumKey) Descriptor() ([]byte, []int)deprecated
- func (x *DatumKey) GetDim1() uint32
- func (x *DatumKey) GetDim2() uint32
- func (x *DatumKey) GetFeature() []float64
- func (x *DatumKey) GetGroupLabel() []byte
- func (x *DatumKey) GetSize1() uint32
- func (x *DatumKey) GetSize2() uint32
- func (*DatumKey) ProtoMessage()
- func (x *DatumKey) ProtoReflect() protoreflect.Message
- func (x *DatumKey) Reset()
- func (x *DatumKey) String() string
- type DatumValue
- type GetDataRequest
- type InsertConfig
- type InsertDatumWithConfig
- func (*InsertDatumWithConfig) Descriptor() ([]byte, []int)deprecated
- func (x *InsertDatumWithConfig) GetConfig() *InsertConfig
- func (x *InsertDatumWithConfig) GetDatum() *Datum
- func (*InsertDatumWithConfig) ProtoMessage()
- func (x *InsertDatumWithConfig) ProtoReflect() protoreflect.Message
- func (x *InsertDatumWithConfig) Reset()
- func (x *InsertDatumWithConfig) String() string
- type InsertionRequest
- func (*InsertionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InsertionRequest) GetConfig() *InsertConfig
- func (x *InsertionRequest) GetDataName() string
- func (x *InsertionRequest) GetDatum() *Datum
- func (*InsertionRequest) ProtoMessage()
- func (x *InsertionRequest) ProtoReflect() protoreflect.Message
- func (x *InsertionRequest) Reset()
- func (x *InsertionRequest) String() string
- type InsertionResponse
- type JoinRequest
- type JoinResponse
- type Peer
- func (*Peer) Descriptor() ([]byte, []int)deprecated
- func (x *Peer) GetAddressList() []string
- func (x *Peer) GetDataList() []*DataConfig
- func (x *Peer) GetPeerList() []*Peer
- func (x *Peer) GetServiceList() []string
- func (x *Peer) GetTimestamp() uint64
- func (x *Peer) GetVersion() string
- func (*Peer) ProtoMessage()
- func (x *Peer) ProtoReflect() protoreflect.Message
- func (x *Peer) Reset()
- func (x *Peer) String() string
- type ScoredDatum
- func (*ScoredDatum) Descriptor() ([]byte, []int)deprecated
- func (x *ScoredDatum) GetDatum() *Datum
- func (x *ScoredDatum) GetScore() float64
- func (*ScoredDatum) ProtoMessage()
- func (x *ScoredDatum) ProtoReflect() protoreflect.Message
- func (x *ScoredDatum) Reset()
- func (x *ScoredDatum) String() string
- type SearchConfig
- func (*SearchConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SearchConfig) GetCacheDuration() uint64
- func (x *SearchConfig) GetDataName() string
- func (x *SearchConfig) GetFilters() []string
- func (x *SearchConfig) GetGroupFilters() []string
- func (x *SearchConfig) GetGroupLimit() uint32
- func (x *SearchConfig) GetGroupScoreFuncName() string
- func (x *SearchConfig) GetHigherIsBetter() bool
- func (x *SearchConfig) GetLimit() uint32
- func (x *SearchConfig) GetResultLimit() uint64
- func (x *SearchConfig) GetScoreFuncName() string
- func (x *SearchConfig) GetTimeout() uint64
- func (x *SearchConfig) GetTimestamp() uint64
- func (*SearchConfig) ProtoMessage()
- func (x *SearchConfig) ProtoReflect() protoreflect.Message
- func (x *SearchConfig) Reset()
- func (x *SearchConfig) String() string
- type SearchContext
- func (*SearchContext) Descriptor() ([]byte, []int)deprecated
- func (x *SearchContext) GetDatum() []*Datum
- func (x *SearchContext) GetPrioritize() bool
- func (*SearchContext) ProtoMessage()
- func (x *SearchContext) ProtoReflect() protoreflect.Message
- func (x *SearchContext) Reset()
- func (x *SearchContext) String() string
- type SearchRequest
- func (*SearchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchRequest) GetConfig() *SearchConfig
- func (x *SearchRequest) GetContext() *SearchContext
- func (x *SearchRequest) GetDatum() []*Datum
- func (*SearchRequest) ProtoMessage()
- func (x *SearchRequest) ProtoReflect() protoreflect.Message
- func (x *SearchRequest) Reset()
- func (x *SearchRequest) String() string
- type SearchResponse
- type UnimplementedVeriServiceServer
- func (*UnimplementedVeriServiceServer) CreateDataIfNotExists(context.Context, *DataConfig) (*DataInfo, error)
- func (*UnimplementedVeriServiceServer) DataStream(*GetDataRequest, VeriService_DataStreamServer) error
- func (*UnimplementedVeriServiceServer) GetDataInfo(context.Context, *GetDataRequest) (*DataInfo, error)
- func (*UnimplementedVeriServiceServer) Insert(context.Context, *InsertionRequest) (*InsertionResponse, error)
- func (*UnimplementedVeriServiceServer) Join(context.Context, *JoinRequest) (*JoinResponse, error)
- func (*UnimplementedVeriServiceServer) Search(context.Context, *SearchRequest) (*SearchResponse, error)
- func (*UnimplementedVeriServiceServer) SearchStream(*SearchRequest, VeriService_SearchStreamServer) error
- type VeriServiceClient
- type VeriServiceServer
- type VeriService_DataStreamClient
- type VeriService_DataStreamServer
- type VeriService_SearchStreamClient
- type VeriService_SearchStreamServer
Constants ¶
This section is empty.
Variables ¶
var File_veriservice_proto protoreflect.FileDescriptor
Functions ¶
func RegisterVeriServiceServer ¶
func RegisterVeriServiceServer(s *grpc.Server, srv VeriServiceServer)
Types ¶
type DataConfig ¶ added in v0.0.22
type DataConfig struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` TargetN uint64 `protobuf:"varint,3,opt,name=targetN,proto3" json:"targetN,omitempty"` TargetUtilization float64 `protobuf:"fixed64,4,opt,name=targetUtilization,proto3" json:"targetUtilization,omitempty"` NoTarget bool `protobuf:"varint,5,opt,name=noTarget,proto3" json:"noTarget,omitempty"` ReplicationOnInsert uint32 `protobuf:"varint,6,opt,name=replicationOnInsert,proto3" json:"replicationOnInsert,omitempty"` EnforceReplicationOnInsert bool `protobuf:"varint,7,opt,name=enforceReplicationOnInsert,proto3" json:"enforceReplicationOnInsert,omitempty"` Retentation uint64 `protobuf:"varint,8,opt,name=retentation,proto3" json:"retentation,omitempty"` // contains filtered or unexported fields }
func (*DataConfig) Descriptor
deprecated
added in
v0.0.22
func (*DataConfig) Descriptor() ([]byte, []int)
Deprecated: Use DataConfig.ProtoReflect.Descriptor instead.
func (*DataConfig) GetEnforceReplicationOnInsert ¶ added in v0.0.25
func (x *DataConfig) GetEnforceReplicationOnInsert() bool
func (*DataConfig) GetName ¶ added in v0.0.22
func (x *DataConfig) GetName() string
func (*DataConfig) GetNoTarget ¶ added in v0.0.22
func (x *DataConfig) GetNoTarget() bool
func (*DataConfig) GetReplicationOnInsert ¶ added in v0.0.25
func (x *DataConfig) GetReplicationOnInsert() uint32
func (*DataConfig) GetRetentation ¶ added in v0.0.25
func (x *DataConfig) GetRetentation() uint64
func (*DataConfig) GetTargetN ¶ added in v0.0.22
func (x *DataConfig) GetTargetN() uint64
func (*DataConfig) GetTargetUtilization ¶ added in v0.0.22
func (x *DataConfig) GetTargetUtilization() float64
func (*DataConfig) GetVersion ¶ added in v0.0.22
func (x *DataConfig) GetVersion() string
func (*DataConfig) ProtoMessage ¶ added in v0.0.22
func (*DataConfig) ProtoMessage()
func (*DataConfig) ProtoReflect ¶ added in v0.0.22
func (x *DataConfig) ProtoReflect() protoreflect.Message
func (*DataConfig) Reset ¶ added in v0.0.22
func (x *DataConfig) Reset()
func (*DataConfig) String ¶ added in v0.0.22
func (x *DataConfig) String() string
type DataInfo ¶ added in v0.0.22
type DataInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` Avg []float64 `protobuf:"fixed64,4,rep,packed,name=avg,proto3" json:"avg,omitempty"` Hist []float64 `protobuf:"fixed64,5,rep,packed,name=hist,proto3" json:"hist,omitempty"` N uint64 `protobuf:"varint,6,opt,name=n,proto3" json:"n,omitempty"` MaxDistance float64 `protobuf:"fixed64,7,opt,name=maxDistance,proto3" json:"maxDistance,omitempty"` TargetN uint64 `protobuf:"varint,8,opt,name=targetN,proto3" json:"targetN,omitempty"` TargetUtilization float64 `protobuf:"fixed64,9,opt,name=targetUtilization,proto3" json:"targetUtilization,omitempty"` NoTarget bool `protobuf:"varint,10,opt,name=noTarget,proto3" json:"noTarget,omitempty"` ReplicationOnInsert uint32 `protobuf:"varint,11,opt,name=replicationOnInsert,proto3" json:"replicationOnInsert,omitempty"` EnforceReplicationOnInsert bool `protobuf:"varint,12,opt,name=enforceReplicationOnInsert,proto3" json:"enforceReplicationOnInsert,omitempty"` Retentation uint64 `protobuf:"varint,13,opt,name=retentation,proto3" json:"retentation,omitempty"` // contains filtered or unexported fields }
func (*DataInfo) Descriptor
deprecated
added in
v0.0.22
func (*DataInfo) GetEnforceReplicationOnInsert ¶ added in v0.0.25
func (*DataInfo) GetMaxDistance ¶ added in v0.0.22
func (*DataInfo) GetNoTarget ¶ added in v0.0.22
func (*DataInfo) GetReplicationOnInsert ¶ added in v0.0.25
func (*DataInfo) GetRetentation ¶ added in v0.0.25
func (*DataInfo) GetTargetN ¶ added in v0.0.22
func (*DataInfo) GetTargetUtilization ¶ added in v0.0.22
func (*DataInfo) GetTimestamp ¶ added in v0.0.22
func (*DataInfo) GetVersion ¶ added in v0.0.22
func (*DataInfo) ProtoMessage ¶ added in v0.0.22
func (*DataInfo) ProtoMessage()
func (*DataInfo) ProtoReflect ¶ added in v0.0.22
func (x *DataInfo) ProtoReflect() protoreflect.Message
type Datum ¶ added in v0.0.22
type Datum struct { Key *DatumKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value *DatumValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Datum) Descriptor
deprecated
added in
v0.0.22
func (*Datum) GetValue ¶ added in v0.0.22
func (x *Datum) GetValue() *DatumValue
func (*Datum) ProtoMessage ¶ added in v0.0.22
func (*Datum) ProtoMessage()
func (*Datum) ProtoReflect ¶ added in v0.0.22
func (x *Datum) ProtoReflect() protoreflect.Message
type DatumKey ¶ added in v0.0.22
type DatumKey struct { Feature []float64 `protobuf:"fixed64,1,rep,packed,name=feature,proto3" json:"feature,omitempty"` GroupLabel []byte `protobuf:"bytes,2,opt,name=groupLabel,proto3" json:"groupLabel,omitempty"` Size1 uint32 `protobuf:"varint,3,opt,name=size1,proto3" json:"size1,omitempty"` Size2 uint32 `protobuf:"varint,4,opt,name=size2,proto3" json:"size2,omitempty"` Dim1 uint32 `protobuf:"varint,5,opt,name=dim1,proto3" json:"dim1,omitempty"` Dim2 uint32 `protobuf:"varint,6,opt,name=dim2,proto3" json:"dim2,omitempty"` // contains filtered or unexported fields }
func (*DatumKey) Descriptor
deprecated
added in
v0.0.22
func (*DatumKey) GetFeature ¶ added in v0.0.22
func (*DatumKey) GetGroupLabel ¶ added in v0.0.22
func (*DatumKey) ProtoMessage ¶ added in v0.0.22
func (*DatumKey) ProtoMessage()
func (*DatumKey) ProtoReflect ¶ added in v0.0.22
func (x *DatumKey) ProtoReflect() protoreflect.Message
type DatumValue ¶ added in v0.0.22
type DatumValue struct { Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` Label []byte `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"` // contains filtered or unexported fields }
func (*DatumValue) Descriptor
deprecated
added in
v0.0.22
func (*DatumValue) Descriptor() ([]byte, []int)
Deprecated: Use DatumValue.ProtoReflect.Descriptor instead.
func (*DatumValue) GetLabel ¶ added in v0.0.22
func (x *DatumValue) GetLabel() []byte
func (*DatumValue) GetVersion ¶ added in v0.0.22
func (x *DatumValue) GetVersion() uint64
func (*DatumValue) ProtoMessage ¶ added in v0.0.22
func (*DatumValue) ProtoMessage()
func (*DatumValue) ProtoReflect ¶ added in v0.0.22
func (x *DatumValue) ProtoReflect() protoreflect.Message
func (*DatumValue) Reset ¶ added in v0.0.22
func (x *DatumValue) Reset()
func (*DatumValue) String ¶ added in v0.0.22
func (x *DatumValue) String() string
type GetDataRequest ¶ added in v0.0.22
type GetDataRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetDataRequest) Descriptor
deprecated
added in
v0.0.22
func (*GetDataRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDataRequest.ProtoReflect.Descriptor instead.
func (*GetDataRequest) GetName ¶ added in v0.0.22
func (x *GetDataRequest) GetName() string
func (*GetDataRequest) ProtoMessage ¶ added in v0.0.22
func (*GetDataRequest) ProtoMessage()
func (*GetDataRequest) ProtoReflect ¶ added in v0.0.22
func (x *GetDataRequest) ProtoReflect() protoreflect.Message
func (*GetDataRequest) Reset ¶ added in v0.0.22
func (x *GetDataRequest) Reset()
func (*GetDataRequest) String ¶ added in v0.0.22
func (x *GetDataRequest) String() string
type InsertConfig ¶ added in v0.0.22
type InsertConfig struct { TTL uint64 `protobuf:"varint,1,opt,name=tTL,proto3" json:"tTL,omitempty"` // contains filtered or unexported fields }
func (*InsertConfig) Descriptor
deprecated
added in
v0.0.22
func (*InsertConfig) Descriptor() ([]byte, []int)
Deprecated: Use InsertConfig.ProtoReflect.Descriptor instead.
func (*InsertConfig) GetTTL ¶ added in v0.0.22
func (x *InsertConfig) GetTTL() uint64
func (*InsertConfig) ProtoMessage ¶ added in v0.0.22
func (*InsertConfig) ProtoMessage()
func (*InsertConfig) ProtoReflect ¶ added in v0.0.22
func (x *InsertConfig) ProtoReflect() protoreflect.Message
func (*InsertConfig) Reset ¶ added in v0.0.22
func (x *InsertConfig) Reset()
func (*InsertConfig) String ¶ added in v0.0.22
func (x *InsertConfig) String() string
type InsertDatumWithConfig ¶ added in v0.0.22
type InsertDatumWithConfig struct { Config *InsertConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` Datum *Datum `protobuf:"bytes,2,opt,name=datum,proto3" json:"datum,omitempty"` // contains filtered or unexported fields }
func (*InsertDatumWithConfig) Descriptor
deprecated
added in
v0.0.22
func (*InsertDatumWithConfig) Descriptor() ([]byte, []int)
Deprecated: Use InsertDatumWithConfig.ProtoReflect.Descriptor instead.
func (*InsertDatumWithConfig) GetConfig ¶ added in v0.0.22
func (x *InsertDatumWithConfig) GetConfig() *InsertConfig
func (*InsertDatumWithConfig) GetDatum ¶ added in v0.0.22
func (x *InsertDatumWithConfig) GetDatum() *Datum
func (*InsertDatumWithConfig) ProtoMessage ¶ added in v0.0.22
func (*InsertDatumWithConfig) ProtoMessage()
func (*InsertDatumWithConfig) ProtoReflect ¶ added in v0.0.22
func (x *InsertDatumWithConfig) ProtoReflect() protoreflect.Message
func (*InsertDatumWithConfig) Reset ¶ added in v0.0.22
func (x *InsertDatumWithConfig) Reset()
func (*InsertDatumWithConfig) String ¶ added in v0.0.22
func (x *InsertDatumWithConfig) String() string
type InsertionRequest ¶
type InsertionRequest struct { Config *InsertConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` Datum *Datum `protobuf:"bytes,2,opt,name=datum,proto3" json:"datum,omitempty"` DataName string `protobuf:"bytes,3,opt,name=dataName,proto3" json:"dataName,omitempty"` // contains filtered or unexported fields }
func (*InsertionRequest) Descriptor
deprecated
func (*InsertionRequest) Descriptor() ([]byte, []int)
Deprecated: Use InsertionRequest.ProtoReflect.Descriptor instead.
func (*InsertionRequest) GetConfig ¶ added in v0.0.22
func (x *InsertionRequest) GetConfig() *InsertConfig
func (*InsertionRequest) GetDataName ¶ added in v0.0.22
func (x *InsertionRequest) GetDataName() string
func (*InsertionRequest) GetDatum ¶ added in v0.0.22
func (x *InsertionRequest) GetDatum() *Datum
func (*InsertionRequest) ProtoMessage ¶
func (*InsertionRequest) ProtoMessage()
func (*InsertionRequest) ProtoReflect ¶ added in v0.0.22
func (x *InsertionRequest) ProtoReflect() protoreflect.Message
func (*InsertionRequest) Reset ¶
func (x *InsertionRequest) Reset()
func (*InsertionRequest) String ¶
func (x *InsertionRequest) String() string
type InsertionResponse ¶
type InsertionResponse struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` // contains filtered or unexported fields }
func (*InsertionResponse) Descriptor
deprecated
func (*InsertionResponse) Descriptor() ([]byte, []int)
Deprecated: Use InsertionResponse.ProtoReflect.Descriptor instead.
func (*InsertionResponse) GetCode ¶
func (x *InsertionResponse) GetCode() int32
func (*InsertionResponse) ProtoMessage ¶
func (*InsertionResponse) ProtoMessage()
func (*InsertionResponse) ProtoReflect ¶ added in v0.0.22
func (x *InsertionResponse) ProtoReflect() protoreflect.Message
func (*InsertionResponse) Reset ¶
func (x *InsertionResponse) Reset()
func (*InsertionResponse) String ¶
func (x *InsertionResponse) String() string
type JoinRequest ¶
type JoinRequest struct { Peer *Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"` // contains filtered or unexported fields }
func (*JoinRequest) Descriptor
deprecated
func (*JoinRequest) Descriptor() ([]byte, []int)
Deprecated: Use JoinRequest.ProtoReflect.Descriptor instead.
func (*JoinRequest) GetPeer ¶ added in v0.0.22
func (x *JoinRequest) GetPeer() *Peer
func (*JoinRequest) ProtoMessage ¶
func (*JoinRequest) ProtoMessage()
func (*JoinRequest) ProtoReflect ¶ added in v0.0.22
func (x *JoinRequest) ProtoReflect() protoreflect.Message
func (*JoinRequest) Reset ¶
func (x *JoinRequest) Reset()
func (*JoinRequest) String ¶
func (x *JoinRequest) String() string
type JoinResponse ¶
type JoinResponse struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // received address // contains filtered or unexported fields }
func (*JoinResponse) Descriptor
deprecated
func (*JoinResponse) Descriptor() ([]byte, []int)
Deprecated: Use JoinResponse.ProtoReflect.Descriptor instead.
func (*JoinResponse) GetAddress ¶
func (x *JoinResponse) GetAddress() string
func (*JoinResponse) ProtoMessage ¶
func (*JoinResponse) ProtoMessage()
func (*JoinResponse) ProtoReflect ¶ added in v0.0.22
func (x *JoinResponse) ProtoReflect() protoreflect.Message
func (*JoinResponse) Reset ¶
func (x *JoinResponse) Reset()
func (*JoinResponse) String ¶
func (x *JoinResponse) String() string
type Peer ¶
type Peer struct { AddressList []string `protobuf:"bytes,1,rep,name=addressList,proto3" json:"addressList,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` Timestamp uint64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` DataList []*DataConfig `protobuf:"bytes,4,rep,name=dataList,proto3" json:"dataList,omitempty"` ServiceList []string `protobuf:"bytes,5,rep,name=serviceList,proto3" json:"serviceList,omitempty"` PeerList []*Peer `protobuf:"bytes,6,rep,name=peerList,proto3" json:"peerList,omitempty"` // contains filtered or unexported fields }
func (*Peer) Descriptor
deprecated
func (*Peer) GetAddressList ¶ added in v0.0.22
func (*Peer) GetDataList ¶ added in v0.0.22
func (x *Peer) GetDataList() []*DataConfig
func (*Peer) GetPeerList ¶ added in v0.0.22
func (*Peer) GetServiceList ¶ added in v0.0.22
func (*Peer) GetTimestamp ¶
func (*Peer) GetVersion ¶
func (*Peer) ProtoMessage ¶
func (*Peer) ProtoMessage()
func (*Peer) ProtoReflect ¶ added in v0.0.22
func (x *Peer) ProtoReflect() protoreflect.Message
type ScoredDatum ¶ added in v0.0.22
type ScoredDatum struct { Score float64 `protobuf:"fixed64,1,opt,name=score,proto3" json:"score,omitempty"` Datum *Datum `protobuf:"bytes,2,opt,name=datum,proto3" json:"datum,omitempty"` // contains filtered or unexported fields }
func (*ScoredDatum) Descriptor
deprecated
added in
v0.0.22
func (*ScoredDatum) Descriptor() ([]byte, []int)
Deprecated: Use ScoredDatum.ProtoReflect.Descriptor instead.
func (*ScoredDatum) GetDatum ¶ added in v0.0.22
func (x *ScoredDatum) GetDatum() *Datum
func (*ScoredDatum) GetScore ¶ added in v0.0.22
func (x *ScoredDatum) GetScore() float64
func (*ScoredDatum) ProtoMessage ¶ added in v0.0.22
func (*ScoredDatum) ProtoMessage()
func (*ScoredDatum) ProtoReflect ¶ added in v0.0.22
func (x *ScoredDatum) ProtoReflect() protoreflect.Message
func (*ScoredDatum) Reset ¶ added in v0.0.22
func (x *ScoredDatum) Reset()
func (*ScoredDatum) String ¶ added in v0.0.22
func (x *ScoredDatum) String() string
type SearchConfig ¶ added in v0.0.22
type SearchConfig struct { ScoreFuncName string `protobuf:"bytes,1,opt,name=scoreFuncName,proto3" json:"scoreFuncName,omitempty"` HigherIsBetter bool `protobuf:"varint,2,opt,name=higherIsBetter,proto3" json:"higherIsBetter,omitempty"` Timestamp uint64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Timeout uint64 `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"` Limit uint32 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"` CacheDuration uint64 `protobuf:"varint,6,opt,name=cacheDuration,proto3" json:"cacheDuration,omitempty"` DataName string `protobuf:"bytes,7,opt,name=dataName,proto3" json:"dataName,omitempty"` GroupLimit uint32 `protobuf:"varint,8,opt,name=groupLimit,proto3" json:"groupLimit,omitempty"` GroupScoreFuncName string `protobuf:"bytes,9,opt,name=groupScoreFuncName,proto3" json:"groupScoreFuncName,omitempty"` Filters []string `protobuf:"bytes,10,rep,name=filters,proto3" json:"filters,omitempty"` ResultLimit uint64 `protobuf:"varint,11,opt,name=resultLimit,proto3" json:"resultLimit,omitempty"` GroupFilters []string `protobuf:"bytes,12,rep,name=groupFilters,proto3" json:"groupFilters,omitempty"` // contains filtered or unexported fields }
func (*SearchConfig) Descriptor
deprecated
added in
v0.0.22
func (*SearchConfig) Descriptor() ([]byte, []int)
Deprecated: Use SearchConfig.ProtoReflect.Descriptor instead.
func (*SearchConfig) GetCacheDuration ¶ added in v0.0.22
func (x *SearchConfig) GetCacheDuration() uint64
func (*SearchConfig) GetDataName ¶ added in v0.0.22
func (x *SearchConfig) GetDataName() string
func (*SearchConfig) GetFilters ¶ added in v0.0.23
func (x *SearchConfig) GetFilters() []string
func (*SearchConfig) GetGroupFilters ¶ added in v0.0.31
func (x *SearchConfig) GetGroupFilters() []string
func (*SearchConfig) GetGroupLimit ¶ added in v0.0.23
func (x *SearchConfig) GetGroupLimit() uint32
func (*SearchConfig) GetGroupScoreFuncName ¶ added in v0.0.23
func (x *SearchConfig) GetGroupScoreFuncName() string
func (*SearchConfig) GetHigherIsBetter ¶ added in v0.0.22
func (x *SearchConfig) GetHigherIsBetter() bool
func (*SearchConfig) GetLimit ¶ added in v0.0.22
func (x *SearchConfig) GetLimit() uint32
func (*SearchConfig) GetResultLimit ¶ added in v0.0.25
func (x *SearchConfig) GetResultLimit() uint64
func (*SearchConfig) GetScoreFuncName ¶ added in v0.0.22
func (x *SearchConfig) GetScoreFuncName() string
func (*SearchConfig) GetTimeout ¶ added in v0.0.22
func (x *SearchConfig) GetTimeout() uint64
func (*SearchConfig) GetTimestamp ¶ added in v0.0.22
func (x *SearchConfig) GetTimestamp() uint64
func (*SearchConfig) ProtoMessage ¶ added in v0.0.22
func (*SearchConfig) ProtoMessage()
func (*SearchConfig) ProtoReflect ¶ added in v0.0.22
func (x *SearchConfig) ProtoReflect() protoreflect.Message
func (*SearchConfig) Reset ¶ added in v0.0.22
func (x *SearchConfig) Reset()
func (*SearchConfig) String ¶ added in v0.0.22
func (x *SearchConfig) String() string
type SearchContext ¶ added in v0.0.23
type SearchContext struct { Datum []*Datum `protobuf:"bytes,1,rep,name=datum,proto3" json:"datum,omitempty"` Prioritize bool `protobuf:"varint,2,opt,name=prioritize,proto3" json:"prioritize,omitempty"` // contains filtered or unexported fields }
func (*SearchContext) Descriptor
deprecated
added in
v0.0.23
func (*SearchContext) Descriptor() ([]byte, []int)
Deprecated: Use SearchContext.ProtoReflect.Descriptor instead.
func (*SearchContext) GetDatum ¶ added in v0.0.23
func (x *SearchContext) GetDatum() []*Datum
func (*SearchContext) GetPrioritize ¶ added in v0.0.25
func (x *SearchContext) GetPrioritize() bool
func (*SearchContext) ProtoMessage ¶ added in v0.0.23
func (*SearchContext) ProtoMessage()
func (*SearchContext) ProtoReflect ¶ added in v0.0.23
func (x *SearchContext) ProtoReflect() protoreflect.Message
func (*SearchContext) Reset ¶ added in v0.0.23
func (x *SearchContext) Reset()
func (*SearchContext) String ¶ added in v0.0.23
func (x *SearchContext) String() string
type SearchRequest ¶ added in v0.0.22
type SearchRequest struct { Config *SearchConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` Datum []*Datum `protobuf:"bytes,2,rep,name=datum,proto3" json:"datum,omitempty"` Context *SearchContext `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"` // contains filtered or unexported fields }
Request message for creating a new customer
func (*SearchRequest) Descriptor
deprecated
added in
v0.0.22
func (*SearchRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.
func (*SearchRequest) GetConfig ¶ added in v0.0.22
func (x *SearchRequest) GetConfig() *SearchConfig
func (*SearchRequest) GetContext ¶ added in v0.0.23
func (x *SearchRequest) GetContext() *SearchContext
func (*SearchRequest) GetDatum ¶ added in v0.0.22
func (x *SearchRequest) GetDatum() []*Datum
func (*SearchRequest) ProtoMessage ¶ added in v0.0.22
func (*SearchRequest) ProtoMessage()
func (*SearchRequest) ProtoReflect ¶ added in v0.0.22
func (x *SearchRequest) ProtoReflect() protoreflect.Message
func (*SearchRequest) Reset ¶ added in v0.0.22
func (x *SearchRequest) Reset()
func (*SearchRequest) String ¶ added in v0.0.22
func (x *SearchRequest) String() string
type SearchResponse ¶ added in v0.0.22
type SearchResponse struct { Result []*ScoredDatum `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*SearchResponse) Descriptor
deprecated
added in
v0.0.22
func (*SearchResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.
func (*SearchResponse) GetResult ¶ added in v0.0.22
func (x *SearchResponse) GetResult() []*ScoredDatum
func (*SearchResponse) ProtoMessage ¶ added in v0.0.22
func (*SearchResponse) ProtoMessage()
func (*SearchResponse) ProtoReflect ¶ added in v0.0.22
func (x *SearchResponse) ProtoReflect() protoreflect.Message
func (*SearchResponse) Reset ¶ added in v0.0.22
func (x *SearchResponse) Reset()
func (*SearchResponse) String ¶ added in v0.0.22
func (x *SearchResponse) String() string
type UnimplementedVeriServiceServer ¶ added in v0.0.22
type UnimplementedVeriServiceServer struct { }
UnimplementedVeriServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedVeriServiceServer) CreateDataIfNotExists ¶ added in v0.0.22
func (*UnimplementedVeriServiceServer) CreateDataIfNotExists(context.Context, *DataConfig) (*DataInfo, error)
func (*UnimplementedVeriServiceServer) DataStream ¶ added in v0.0.22
func (*UnimplementedVeriServiceServer) DataStream(*GetDataRequest, VeriService_DataStreamServer) error
func (*UnimplementedVeriServiceServer) GetDataInfo ¶ added in v0.0.22
func (*UnimplementedVeriServiceServer) GetDataInfo(context.Context, *GetDataRequest) (*DataInfo, error)
func (*UnimplementedVeriServiceServer) Insert ¶ added in v0.0.22
func (*UnimplementedVeriServiceServer) Insert(context.Context, *InsertionRequest) (*InsertionResponse, error)
func (*UnimplementedVeriServiceServer) Join ¶ added in v0.0.22
func (*UnimplementedVeriServiceServer) Join(context.Context, *JoinRequest) (*JoinResponse, error)
func (*UnimplementedVeriServiceServer) Search ¶ added in v0.0.22
func (*UnimplementedVeriServiceServer) Search(context.Context, *SearchRequest) (*SearchResponse, error)
func (*UnimplementedVeriServiceServer) SearchStream ¶ added in v0.0.22
func (*UnimplementedVeriServiceServer) SearchStream(*SearchRequest, VeriService_SearchStreamServer) error
type VeriServiceClient ¶
type VeriServiceClient interface { Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error) Insert(ctx context.Context, in *InsertionRequest, opts ...grpc.CallOption) (*InsertionResponse, error) Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error) DataStream(ctx context.Context, in *GetDataRequest, opts ...grpc.CallOption) (VeriService_DataStreamClient, error) CreateDataIfNotExists(ctx context.Context, in *DataConfig, opts ...grpc.CallOption) (*DataInfo, error) GetDataInfo(ctx context.Context, in *GetDataRequest, opts ...grpc.CallOption) (*DataInfo, error) SearchStream(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (VeriService_SearchStreamClient, error) }
VeriServiceClient is the client API for VeriService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewVeriServiceClient ¶
func NewVeriServiceClient(cc grpc.ClientConnInterface) VeriServiceClient
type VeriServiceServer ¶
type VeriServiceServer interface { Search(context.Context, *SearchRequest) (*SearchResponse, error) Insert(context.Context, *InsertionRequest) (*InsertionResponse, error) Join(context.Context, *JoinRequest) (*JoinResponse, error) DataStream(*GetDataRequest, VeriService_DataStreamServer) error CreateDataIfNotExists(context.Context, *DataConfig) (*DataInfo, error) GetDataInfo(context.Context, *GetDataRequest) (*DataInfo, error) SearchStream(*SearchRequest, VeriService_SearchStreamServer) error }
VeriServiceServer is the server API for VeriService service.
type VeriService_DataStreamClient ¶ added in v0.0.22
type VeriService_DataStreamClient interface { Recv() (*Datum, error) grpc.ClientStream }
type VeriService_DataStreamServer ¶ added in v0.0.22
type VeriService_DataStreamServer interface { Send(*Datum) error grpc.ServerStream }
type VeriService_SearchStreamClient ¶ added in v0.0.22
type VeriService_SearchStreamClient interface { Recv() (*ScoredDatum, error) grpc.ClientStream }
type VeriService_SearchStreamServer ¶ added in v0.0.22
type VeriService_SearchStreamServer interface { Send(*ScoredDatum) error grpc.ServerStream }