veriservice

package
v0.0.33 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 13, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use DataInfo.ProtoReflect.Descriptor instead.

func (*DataInfo) GetAvg added in v0.0.22 

func (x *DataInfo) GetAvg() []float64

func (*DataInfo) GetEnforceReplicationOnInsert added in v0.0.25 

func (x *DataInfo) GetEnforceReplicationOnInsert() bool

func (*DataInfo) GetHist added in v0.0.22 

func (x *DataInfo) GetHist() []float64

func (*DataInfo) GetMaxDistance added in v0.0.22 

func (x *DataInfo) GetMaxDistance() float64

func (*DataInfo) GetN added in v0.0.22 

func (x *DataInfo) GetN() uint64

func (*DataInfo) GetName added in v0.0.22 

func (x *DataInfo) GetName() string

func (*DataInfo) GetNoTarget added in v0.0.22 

func (x *DataInfo) GetNoTarget() bool

func (*DataInfo) GetReplicationOnInsert added in v0.0.25 

func (x *DataInfo) GetReplicationOnInsert() uint32

func (*DataInfo) GetRetentation added in v0.0.25 

func (x *DataInfo) GetRetentation() uint64

func (*DataInfo) GetTargetN added in v0.0.22 

func (x *DataInfo) GetTargetN() uint64

func (*DataInfo) GetTargetUtilization added in v0.0.22 

func (x *DataInfo) GetTargetUtilization() float64

func (*DataInfo) GetTimestamp added in v0.0.22 

func (x *DataInfo) GetTimestamp() uint64

func (*DataInfo) GetVersion added in v0.0.22 

func (x *DataInfo) GetVersion() string

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

func (*DataInfo) Reset added in v0.0.22 

func (x *DataInfo) Reset()

func (*DataInfo) String added in v0.0.22 

func (x *DataInfo) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Datum.ProtoReflect.Descriptor instead.

func (*Datum) GetKey added in v0.0.22 

func (x *Datum) GetKey() *DatumKey

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

func (*Datum) Reset added in v0.0.22 

func (x *Datum) Reset()

func (*Datum) String added in v0.0.22 

func (x *Datum) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use DatumKey.ProtoReflect.Descriptor instead.

func (*DatumKey) GetDim1 added in v0.0.22 

func (x *DatumKey) GetDim1() uint32

func (*DatumKey) GetDim2 added in v0.0.22 

func (x *DatumKey) GetDim2() uint32

func (*DatumKey) GetFeature added in v0.0.22 

func (x *DatumKey) GetFeature() []float64

func (*DatumKey) GetGroupLabel added in v0.0.22 

func (x *DatumKey) GetGroupLabel() []byte

func (*DatumKey) GetSize1 added in v0.0.22 

func (x *DatumKey) GetSize1() uint32

func (*DatumKey) GetSize2 added in v0.0.22 

func (x *DatumKey) GetSize2() uint32

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

func (*DatumKey) Reset added in v0.0.22 

func (x *DatumKey) Reset()

func (*DatumKey) String added in v0.0.22 

func (x *DatumKey) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Peer.ProtoReflect.Descriptor instead.

func (*Peer) GetAddressList added in v0.0.22 

func (x *Peer) GetAddressList() []string

func (*Peer) GetDataList added in v0.0.22 

func (x *Peer) GetDataList() []*DataConfig

func (*Peer) GetPeerList added in v0.0.22 

func (x *Peer) GetPeerList() []*Peer

func (*Peer) GetServiceList added in v0.0.22 

func (x *Peer) GetServiceList() []string

func (*Peer) GetTimestamp 

func (x *Peer) GetTimestamp() uint64

func (*Peer) GetVersion 

func (x *Peer) GetVersion() string

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) ProtoReflect added in v0.0.22 

func (x *Peer) ProtoReflect() protoreflect.Message

func (*Peer) Reset 

func (x *Peer) Reset()

func (*Peer) String 

func (x *Peer) String() string

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.