Versions in this module Expand all Collapse all v0 v0.3.0 Apr 21, 2020 Changes in this version + var ErrIntOverflowApi = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowGrpc = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthGrpc = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupGrpc = fmt.Errorf("proto: unexpected end of group") + var FieldOption_name = map[int32]string + var FieldOption_value = map[string]int32 + var FieldType_name = map[int32]string + var FieldType_value = map[string]int32 + var OpType_name = map[int32]string + var OpType_value = map[string]int32 + func PutDocCmd(doc *DocCmd) + func RegisterRpcApiServer(s *grpc.Server, srv RpcApiServer) + type Codec interface + Marshal func() (dAtA []byte, err error) + Unmarshal func(dAtA []byte) error + type DocCmd struct + DocId string + Fields []*Field + PulloutVersion bool + RetryOnConflict int32 + Slot uint32 + Source []byte + Type OpType + Version int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func GetDocCmd() *DocCmd + func NewDocCmd(ot OpType, id string, slot uint32, source []byte, version int64) *DocCmd + func NewDocCreateWithSlot(id string, slot uint32, source []byte) *DocCmd + func NewDocDeleteWithSlot(id string, slot uint32, version int64) *DocCmd + func NewDocMergeWithSlot(id string, slot uint32, source []byte, version int64) *DocCmd + func NewDocReplaceWithSlot(id string, slot uint32, source []byte, version int64) *DocCmd + func NewPopulatedDocCmd(r randyApi, easy bool) *DocCmd + func (*DocCmd) Descriptor() ([]byte, []int) + func (*DocCmd) ProtoMessage() + func (m *DocCmd) Marshal() (dAtA []byte, err error) + func (m *DocCmd) MarshalTo(dAtA []byte) (int, error) + func (m *DocCmd) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DocCmd) Reset() + func (m *DocCmd) Size() (n int) + func (m *DocCmd) Unmarshal(dAtA []byte) error + func (m *DocCmd) XXX_DiscardUnknown() + func (m *DocCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DocCmd) XXX_Merge(src proto.Message) + func (m *DocCmd) XXX_Size() int + func (m *DocCmd) XXX_Unmarshal(b []byte) error + func (this *DocCmd) Equal(that interface{}) bool + func (this *DocCmd) String() string + type EngineFailure struct + Reason string + Status int64 + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedEngineFailure(r randyApi, easy bool) *EngineFailure + func (*EngineFailure) Descriptor() ([]byte, []int) + func (*EngineFailure) ProtoMessage() + func (m *EngineFailure) Marshal() (dAtA []byte, err error) + func (m *EngineFailure) MarshalTo(dAtA []byte) (int, error) + func (m *EngineFailure) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EngineFailure) Reset() + func (m *EngineFailure) Size() (n int) + func (m *EngineFailure) Unmarshal(dAtA []byte) error + func (m *EngineFailure) XXX_DiscardUnknown() + func (m *EngineFailure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EngineFailure) XXX_Merge(src proto.Message) + func (m *EngineFailure) XXX_Size() int + func (m *EngineFailure) XXX_Unmarshal(b []byte) error + func (this *EngineFailure) Equal(that interface{}) bool + func (this *EngineFailure) String() string + type Failure struct + Cause string + DocId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedFailure(r randyApi, easy bool) *Failure + func (*Failure) Descriptor() ([]byte, []int) + func (*Failure) ProtoMessage() + func (m *Failure) Marshal() (dAtA []byte, err error) + func (m *Failure) MarshalTo(dAtA []byte) (int, error) + func (m *Failure) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Failure) Reset() + func (m *Failure) Size() (n int) + func (m *Failure) Unmarshal(dAtA []byte) error + func (m *Failure) XXX_DiscardUnknown() + func (m *Failure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Failure) XXX_Merge(src proto.Message) + func (m *Failure) XXX_Size() int + func (m *Failure) XXX_Unmarshal(b []byte) error + func (this *Failure) Equal(that interface{}) bool + func (this *Failure) String() string + type Field struct + Name string + Option FieldOption + Type FieldType + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedField(r randyApi, easy bool) *Field + func (*Field) Descriptor() ([]byte, []int) + func (*Field) ProtoMessage() + func (m *Field) Marshal() (dAtA []byte, err error) + func (m *Field) MarshalTo(dAtA []byte) (int, error) + func (m *Field) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Field) Reset() + func (m *Field) Size() (n int) + func (m *Field) Unmarshal(dAtA []byte) error + func (m *Field) XXX_DiscardUnknown() + func (m *Field) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Field) XXX_Merge(src proto.Message) + func (m *Field) XXX_Size() int + func (m *Field) XXX_Unmarshal(b []byte) error + func (this *Field) Equal(that interface{}) bool + func (this *Field) String() string + type FieldOption int32 + const FieldOption_Index + const FieldOption_Null + func (FieldOption) EnumDescriptor() ([]byte, []int) + func (x FieldOption) String() string + type FieldType int32 + const FieldType_BOOL + const FieldType_DATE + const FieldType_FLOAT + const FieldType_GEOPOINT + const FieldType_INT + const FieldType_NULL + const FieldType_STRING + const FieldType_VECTOR + func (FieldType) EnumDescriptor() ([]byte, []int) + func (x FieldType) String() string + type Geo struct + Lat float64 + Lon float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedGeo(r randyApi, easy bool) *Geo + func (*Geo) Descriptor() ([]byte, []int) + func (*Geo) ProtoMessage() + func (m *Geo) Marshal() (dAtA []byte, err error) + func (m *Geo) MarshalTo(dAtA []byte) (int, error) + func (m *Geo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Geo) Reset() + func (m *Geo) Size() (n int) + func (m *Geo) Unmarshal(dAtA []byte) error + func (m *Geo) XXX_DiscardUnknown() + func (m *Geo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Geo) XXX_Merge(src proto.Message) + func (m *Geo) XXX_Size() int + func (m *Geo) XXX_Unmarshal(b []byte) error + func (this *Geo) Equal(that interface{}) bool + func (this *Geo) String() string + type OpType int32 + const OpType_CREATE + const OpType_DELETE + const OpType_MERGE + const OpType_NOOP + const OpType_REPLACE + func (OpType) EnumDescriptor() ([]byte, []int) + func (x OpType) String() string + type RpcApiClient interface + Search func(ctx context.Context, in *RpcSearchRequest, opts ...grpc.CallOption) (*RpcSearchResponse, error) + func NewRpcApiClient(cc *grpc.ClientConn) RpcApiClient + type RpcApiServer interface + Search func(context.Context, *RpcSearchRequest) (*RpcSearchResponse, error) + type RpcRequestHead struct + Password string + TimeOutMs int64 + UserName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedRpcRequestHead(r randyGrpc, easy bool) *RpcRequestHead + func (*RpcRequestHead) Descriptor() ([]byte, []int) + func (*RpcRequestHead) ProtoMessage() + func (m *RpcRequestHead) Marshal() (dAtA []byte, err error) + func (m *RpcRequestHead) MarshalTo(dAtA []byte) (int, error) + func (m *RpcRequestHead) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RpcRequestHead) Reset() + func (m *RpcRequestHead) Size() (n int) + func (m *RpcRequestHead) Unmarshal(dAtA []byte) error + func (m *RpcRequestHead) XXX_DiscardUnknown() + func (m *RpcRequestHead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RpcRequestHead) XXX_Merge(src proto.Message) + func (m *RpcRequestHead) XXX_Size() int + func (m *RpcRequestHead) XXX_Unmarshal(b []byte) error + func (this *RpcRequestHead) Equal(that interface{}) bool + func (this *RpcRequestHead) String() string + type RpcResponseHead struct + Code int64 + Error string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedRpcResponseHead(r randyGrpc, easy bool) *RpcResponseHead + func (*RpcResponseHead) Descriptor() ([]byte, []int) + func (*RpcResponseHead) ProtoMessage() + func (m *RpcResponseHead) Marshal() (dAtA []byte, err error) + func (m *RpcResponseHead) MarshalTo(dAtA []byte) (int, error) + func (m *RpcResponseHead) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RpcResponseHead) Reset() + func (m *RpcResponseHead) Size() (n int) + func (m *RpcResponseHead) Unmarshal(dAtA []byte) error + func (m *RpcResponseHead) XXX_DiscardUnknown() + func (m *RpcResponseHead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RpcResponseHead) XXX_Merge(src proto.Message) + func (m *RpcResponseHead) XXX_Size() int + func (m *RpcResponseHead) XXX_Unmarshal(b []byte) error + func (this *RpcResponseHead) Equal(that interface{}) bool + func (this *RpcResponseHead) String() string + type RpcSearchRequest struct + ClientType string + DbName string + Head *RpcRequestHead + Query string + SpaceName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedRpcSearchRequest(r randyGrpc, easy bool) *RpcSearchRequest + func (*RpcSearchRequest) Descriptor() ([]byte, []int) + func (*RpcSearchRequest) ProtoMessage() + func (m *RpcSearchRequest) Marshal() (dAtA []byte, err error) + func (m *RpcSearchRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RpcSearchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RpcSearchRequest) Reset() + func (m *RpcSearchRequest) Size() (n int) + func (m *RpcSearchRequest) Unmarshal(dAtA []byte) error + func (m *RpcSearchRequest) XXX_DiscardUnknown() + func (m *RpcSearchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RpcSearchRequest) XXX_Merge(src proto.Message) + func (m *RpcSearchRequest) XXX_Size() int + func (m *RpcSearchRequest) XXX_Unmarshal(b []byte) error + func (this *RpcSearchRequest) Equal(that interface{}) bool + func (this *RpcSearchRequest) String() string + type RpcSearchResponse struct + Body string + Head *RpcResponseHead + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedRpcSearchResponse(r randyGrpc, easy bool) *RpcSearchResponse + func (*RpcSearchResponse) Descriptor() ([]byte, []int) + func (*RpcSearchResponse) ProtoMessage() + func (m *RpcSearchResponse) Marshal() (dAtA []byte, err error) + func (m *RpcSearchResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RpcSearchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RpcSearchResponse) Reset() + func (m *RpcSearchResponse) Size() (n int) + func (m *RpcSearchResponse) Unmarshal(dAtA []byte) error + func (m *RpcSearchResponse) XXX_DiscardUnknown() + func (m *RpcSearchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RpcSearchResponse) XXX_Merge(src proto.Message) + func (m *RpcSearchResponse) XXX_Size() int + func (m *RpcSearchResponse) XXX_Unmarshal(b []byte) error + func (this *RpcSearchResponse) Equal(that interface{}) bool + func (this *RpcSearchResponse) String() string + type TimeStamp struct + Sec int64 + Usec int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedTimeStamp(r randyApi, easy bool) *TimeStamp + func (*TimeStamp) Descriptor() ([]byte, []int) + func (*TimeStamp) ProtoMessage() + func (m *TimeStamp) Marshal() (dAtA []byte, err error) + func (m *TimeStamp) MarshalTo(dAtA []byte) (int, error) + func (m *TimeStamp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TimeStamp) Reset() + func (m *TimeStamp) Size() (n int) + func (m *TimeStamp) Unmarshal(dAtA []byte) error + func (m *TimeStamp) XXX_DiscardUnknown() + func (m *TimeStamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TimeStamp) XXX_Merge(src proto.Message) + func (m *TimeStamp) XXX_Size() int + func (m *TimeStamp) XXX_Unmarshal(b []byte) error + func (this *TimeStamp) Equal(that interface{}) bool + func (this *TimeStamp) String() string + type UnimplementedRpcApiServer struct + func (*UnimplementedRpcApiServer) Search(ctx context.Context, req *RpcSearchRequest) (*RpcSearchResponse, error) + type UpdateSpace struct + Space []byte + Version uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedUpdateSpace(r randyApi, easy bool) *UpdateSpace + func (*UpdateSpace) Descriptor() ([]byte, []int) + func (*UpdateSpace) ProtoMessage() + func (m *UpdateSpace) Marshal() (dAtA []byte, err error) + func (m *UpdateSpace) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateSpace) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateSpace) Reset() + func (m *UpdateSpace) Size() (n int) + func (m *UpdateSpace) Unmarshal(dAtA []byte) error + func (m *UpdateSpace) XXX_DiscardUnknown() + func (m *UpdateSpace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateSpace) XXX_Merge(src proto.Message) + func (m *UpdateSpace) XXX_Size() int + func (m *UpdateSpace) XXX_Unmarshal(b []byte) error + func (this *UpdateSpace) Equal(that interface{}) bool + func (this *UpdateSpace) String() string + type Vector struct + Feature []float32 + Source string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewPopulatedVector(r randyApi, easy bool) *Vector + func (*Vector) Descriptor() ([]byte, []int) + func (*Vector) ProtoMessage() + func (m *Vector) Marshal() (dAtA []byte, err error) + func (m *Vector) MarshalTo(dAtA []byte) (int, error) + func (m *Vector) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Vector) Reset() + func (m *Vector) Size() (n int) + func (m *Vector) Unmarshal(dAtA []byte) error + 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 + func (this *Vector) Equal(that interface{}) bool + func (this *Vector) String() string Incompatible versions in this module v3.1.0+incompatible May 29, 2020
Go to main page