pspb

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Apr 21, 2020 License: Apache-2.0, MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthApi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGrpc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGrpc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGrpc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var FieldOption_name = map[int32]string{
	0: "Null",
	1: "Index",
}
View Source 
var FieldOption_value = map[string]int32{
	"Null":  0,
	"Index": 1,
}
View Source 
var FieldType_name = map[int32]string{
	0: "NULL",
	1: "STRING",
	2: "INT",
	3: "FLOAT",
	4: "BOOL",
	5: "GEOPOINT",
	6: "DATE",
	7: "VECTOR",
}
View Source 
var FieldType_value = map[string]int32{
	"NULL":     0,
	"STRING":   1,
	"INT":      2,
	"FLOAT":    3,
	"BOOL":     4,
	"GEOPOINT": 5,
	"DATE":     6,
	"VECTOR":   7,
}
View Source 
var OpType_name = map[int32]string{
	0: "NOOP",
	1: "CREATE",
	2: "MERGE",
	3: "REPLACE",
	4: "DELETE",
}
View Source 
var OpType_value = map[string]int32{
	"NOOP":    0,
	"CREATE":  1,
	"MERGE":   2,
	"REPLACE": 3,
	"DELETE":  4,
}

Functions

func PutDocCmd 

func PutDocCmd(doc *DocCmd)

func RegisterRpcApiServer 

func RegisterRpcApiServer(s *grpc.Server, srv RpcApiServer)

Types

type Codec 

type Codec interface {
	Unmarshal(dAtA []byte) error
	Marshal() (dAtA []byte, err error)
}

type DocCmd 

type DocCmd struct {
	Type    OpType `protobuf:"varint,1,opt,name=type,proto3,enum=OpType" json:"type,omitempty"`
	DocId   string `protobuf:"bytes,2,opt,name=doc_id,json=docId,proto3" json:"doc_id,omitempty"`
	Version int64  `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	//PulloutVersion in docCmd specified version in DocCmd is pulled out
	//from engine or user specified
	PulloutVersion       bool     `protobuf:"varint,4,opt,name=pullout_version,json=pulloutVersion,proto3" json:"pullout_version,omitempty"`
	Slot                 uint32   `protobuf:"varint,5,opt,name=slot,proto3" json:"slot,omitempty"`
	Source               []byte   `protobuf:"bytes,6,opt,name=source,proto3" json:"source,omitempty"`
	Fields               []*Field `protobuf:"bytes,7,rep,name=fields,proto3" json:"fields,omitempty"`
	RetryOnConflict      int32    `protobuf:"varint,8,opt,name=retry_on_conflict,json=retryOnConflict,proto3" json:"retry_on_conflict,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func GetDocCmd 

func GetDocCmd() *DocCmd

func NewDocCmd 

func NewDocCmd(ot OpType, id string, slot uint32, source []byte, version int64) *DocCmd

func NewDocCreateWithSlot 

func NewDocCreateWithSlot(id string, slot uint32, source []byte) *DocCmd

func NewDocDeleteWithSlot 

func NewDocDeleteWithSlot(id string, slot uint32, version int64) *DocCmd

f version == 0 , delete not check version

func NewDocMergeWithSlot 

func NewDocMergeWithSlot(id string, slot uint32, source []byte, version int64) *DocCmd

if version is zero update version++

func NewDocReplaceWithSlot 

func NewDocReplaceWithSlot(id string, slot uint32, source []byte, version int64) *DocCmd

if version == -1 , over write and not check version , if version == 0 , update version++

func NewPopulatedDocCmd 

func NewPopulatedDocCmd(r randyApi, easy bool) *DocCmd

func (*DocCmd) Descriptor 

func (*DocCmd) Descriptor() ([]byte, []int)

func (*DocCmd) Equal 

func (this *DocCmd) Equal(that interface{}) bool

func (*DocCmd) Marshal 

func (m *DocCmd) Marshal() (dAtA []byte, err error)

func (*DocCmd) MarshalTo 

func (m *DocCmd) MarshalTo(dAtA []byte) (int, error)

func (*DocCmd) MarshalToSizedBuffer 

func (m *DocCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DocCmd) ProtoMessage 

func (*DocCmd) ProtoMessage()

func (*DocCmd) Reset 

func (m *DocCmd) Reset()

func (*DocCmd) Size 

func (m *DocCmd) Size() (n int)

func (*DocCmd) String 

func (this *DocCmd) String() string

func (*DocCmd) Unmarshal 

func (m *DocCmd) Unmarshal(dAtA []byte) error

func (*DocCmd) XXX_DiscardUnknown 

func (m *DocCmd) XXX_DiscardUnknown()

func (*DocCmd) XXX_Marshal 

func (m *DocCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DocCmd) XXX_Merge 

func (m *DocCmd) XXX_Merge(src proto.Message)

func (*DocCmd) XXX_Size 

func (m *DocCmd) XXX_Size() int

func (*DocCmd) XXX_Unmarshal 

func (m *DocCmd) XXX_Unmarshal(b []byte) error

type EngineFailure 

type EngineFailure struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Status               int64    `protobuf:"varint,3,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedEngineFailure 

func NewPopulatedEngineFailure(r randyApi, easy bool) *EngineFailure

func (*EngineFailure) Descriptor 

func (*EngineFailure) Descriptor() ([]byte, []int)

func (*EngineFailure) Equal 

func (this *EngineFailure) Equal(that interface{}) bool

func (*EngineFailure) Marshal 

func (m *EngineFailure) Marshal() (dAtA []byte, err error)

func (*EngineFailure) MarshalTo 

func (m *EngineFailure) MarshalTo(dAtA []byte) (int, error)

func (*EngineFailure) MarshalToSizedBuffer 

func (m *EngineFailure) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EngineFailure) ProtoMessage 

func (*EngineFailure) ProtoMessage()

func (*EngineFailure) Reset 

func (m *EngineFailure) Reset()

func (*EngineFailure) Size 

func (m *EngineFailure) Size() (n int)

func (*EngineFailure) String 

func (this *EngineFailure) String() string

func (*EngineFailure) Unmarshal 

func (m *EngineFailure) Unmarshal(dAtA []byte) error

func (*EngineFailure) XXX_DiscardUnknown 

func (m *EngineFailure) XXX_DiscardUnknown()

func (*EngineFailure) XXX_Marshal 

func (m *EngineFailure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EngineFailure) XXX_Merge 

func (m *EngineFailure) XXX_Merge(src proto.Message)

func (*EngineFailure) XXX_Size 

func (m *EngineFailure) XXX_Size() int

func (*EngineFailure) XXX_Unmarshal 

func (m *EngineFailure) XXX_Unmarshal(b []byte) error

type Failure 

type Failure struct {
	DocId                string   `protobuf:"bytes,1,opt,name=doc_id,json=docId,proto3" json:"doc_id,omitempty"`
	Cause                string   `protobuf:"bytes,2,opt,name=cause,proto3" json:"cause,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedFailure 

func NewPopulatedFailure(r randyApi, easy bool) *Failure

func (*Failure) Descriptor 

func (*Failure) Descriptor() ([]byte, []int)

func (*Failure) Equal 

func (this *Failure) Equal(that interface{}) bool

func (*Failure) Marshal 

func (m *Failure) Marshal() (dAtA []byte, err error)

func (*Failure) MarshalTo 

func (m *Failure) MarshalTo(dAtA []byte) (int, error)

func (*Failure) MarshalToSizedBuffer 

func (m *Failure) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Failure) ProtoMessage 

func (*Failure) ProtoMessage()

func (*Failure) Reset 

func (m *Failure) Reset()

func (*Failure) Size 

func (m *Failure) Size() (n int)

func (*Failure) String 

func (this *Failure) String() string

func (*Failure) Unmarshal 

func (m *Failure) Unmarshal(dAtA []byte) error

func (*Failure) XXX_DiscardUnknown 

func (m *Failure) XXX_DiscardUnknown()

func (*Failure) XXX_Marshal 

func (m *Failure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Failure) XXX_Merge 

func (m *Failure) XXX_Merge(src proto.Message)

func (*Failure) XXX_Size 

func (m *Failure) XXX_Size() int

func (*Failure) XXX_Unmarshal 

func (m *Failure) XXX_Unmarshal(b []byte) error

type Field 

type Field struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 FieldType   `protobuf:"varint,2,opt,name=type,proto3,enum=FieldType" json:"type,omitempty"`
	Value                []byte      `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Option               FieldOption `protobuf:"varint,4,opt,name=option,proto3,enum=FieldOption" json:"option,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func NewPopulatedField 

func NewPopulatedField(r randyApi, easy bool) *Field

func (*Field) Descriptor 

func (*Field) Descriptor() ([]byte, []int)

func (*Field) Equal 

func (this *Field) Equal(that interface{}) bool

func (*Field) Marshal 

func (m *Field) Marshal() (dAtA []byte, err error)

func (*Field) MarshalTo 

func (m *Field) MarshalTo(dAtA []byte) (int, error)

func (*Field) MarshalToSizedBuffer 

func (m *Field) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) Reset 

func (m *Field) Reset()

func (*Field) Size 

func (m *Field) Size() (n int)

func (*Field) String 

func (this *Field) String() string

func (*Field) Unmarshal 

func (m *Field) Unmarshal(dAtA []byte) error

func (*Field) XXX_DiscardUnknown 

func (m *Field) XXX_DiscardUnknown()

func (*Field) XXX_Marshal 

func (m *Field) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Field) XXX_Merge 

func (m *Field) XXX_Merge(src proto.Message)

func (*Field) XXX_Size 

func (m *Field) XXX_Size() int

func (*Field) XXX_Unmarshal 

func (m *Field) XXX_Unmarshal(b []byte) error

type FieldOption 

type FieldOption int32
const (
	FieldOption_Null  FieldOption = 0
	FieldOption_Index FieldOption = 1
)

func (FieldOption) EnumDescriptor 

func (FieldOption) EnumDescriptor() ([]byte, []int)

func (FieldOption) String 

func (x FieldOption) String() string

type FieldType 

type FieldType int32
const (
	FieldType_NULL     FieldType = 0
	FieldType_STRING   FieldType = 1
	FieldType_INT      FieldType = 2
	FieldType_FLOAT    FieldType = 3
	FieldType_BOOL     FieldType = 4
	FieldType_GEOPOINT FieldType = 5
	FieldType_DATE     FieldType = 6
	FieldType_VECTOR   FieldType = 7
)

func (FieldType) EnumDescriptor 

func (FieldType) EnumDescriptor() ([]byte, []int)

func (FieldType) String 

func (x FieldType) String() string

type Geo 

type Geo struct {
	Lon                  float64  `protobuf:"fixed64,1,opt,name=lon,proto3" json:"lon,omitempty"`
	Lat                  float64  `protobuf:"fixed64,2,opt,name=lat,proto3" json:"lat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedGeo 

func NewPopulatedGeo(r randyApi, easy bool) *Geo

func (*Geo) Descriptor 

func (*Geo) Descriptor() ([]byte, []int)

func (*Geo) Equal 

func (this *Geo) Equal(that interface{}) bool

func (*Geo) Marshal 

func (m *Geo) Marshal() (dAtA []byte, err error)

func (*Geo) MarshalTo 

func (m *Geo) MarshalTo(dAtA []byte) (int, error)

func (*Geo) MarshalToSizedBuffer 

func (m *Geo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Geo) ProtoMessage 

func (*Geo) ProtoMessage()

func (*Geo) Reset 

func (m *Geo) Reset()

func (*Geo) Size 

func (m *Geo) Size() (n int)

func (*Geo) String 

func (this *Geo) String() string

func (*Geo) Unmarshal 

func (m *Geo) Unmarshal(dAtA []byte) error

func (*Geo) XXX_DiscardUnknown 

func (m *Geo) XXX_DiscardUnknown()

func (*Geo) XXX_Marshal 

func (m *Geo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Geo) XXX_Merge 

func (m *Geo) XXX_Merge(src proto.Message)

func (*Geo) XXX_Size 

func (m *Geo) XXX_Size() int

func (*Geo) XXX_Unmarshal 

func (m *Geo) XXX_Unmarshal(b []byte) error

type OpType 

type OpType int32
const (
	OpType_NOOP OpType = 0
	// Creates the resource. If there is an existing document with the id, then it won't be removed.
	OpType_CREATE OpType = 1
	// Updates  document. If there an existing document with the id, it will be replaced.
	OpType_MERGE OpType = 2
	//create document if exits it will overy write but version not ++
	OpType_REPLACE OpType = 3
	// Deletes a document
	OpType_DELETE OpType = 4
)

func (OpType) EnumDescriptor 

func (OpType) EnumDescriptor() ([]byte, []int)

func (OpType) String 

func (x OpType) String() string

type RpcApiClient 

type RpcApiClient interface {
	// Sends a greeting
	Search(ctx context.Context, in *RpcSearchRequest, opts ...grpc.CallOption) (*RpcSearchResponse, error)
}

RpcApiClient is the client API for RpcApi service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRpcApiClient 

func NewRpcApiClient(cc *grpc.ClientConn) RpcApiClient

type RpcApiServer 

type RpcApiServer interface {
	// Sends a greeting
	Search(context.Context, *RpcSearchRequest) (*RpcSearchResponse, error)
}

RpcApiServer is the server API for RpcApi service.

type RpcRequestHead 

type RpcRequestHead struct {
	TimeOutMs            int64    `protobuf:"varint,1,opt,name=time_out_ms,json=timeOutMs,proto3" json:"time_out_ms,omitempty"`
	UserName             string   `protobuf:"bytes,2,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	Password             string   `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedRpcRequestHead 

func NewPopulatedRpcRequestHead(r randyGrpc, easy bool) *RpcRequestHead

func (*RpcRequestHead) Descriptor 

func (*RpcRequestHead) Descriptor() ([]byte, []int)

func (*RpcRequestHead) Equal 

func (this *RpcRequestHead) Equal(that interface{}) bool

func (*RpcRequestHead) Marshal 

func (m *RpcRequestHead) Marshal() (dAtA []byte, err error)

func (*RpcRequestHead) MarshalTo 

func (m *RpcRequestHead) MarshalTo(dAtA []byte) (int, error)

func (*RpcRequestHead) MarshalToSizedBuffer 

func (m *RpcRequestHead) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RpcRequestHead) ProtoMessage 

func (*RpcRequestHead) ProtoMessage()

func (*RpcRequestHead) Reset 

func (m *RpcRequestHead) Reset()

func (*RpcRequestHead) Size 

func (m *RpcRequestHead) Size() (n int)

func (*RpcRequestHead) String 

func (this *RpcRequestHead) String() string

func (*RpcRequestHead) Unmarshal 

func (m *RpcRequestHead) Unmarshal(dAtA []byte) error

func (*RpcRequestHead) XXX_DiscardUnknown 

func (m *RpcRequestHead) XXX_DiscardUnknown()

func (*RpcRequestHead) XXX_Marshal 

func (m *RpcRequestHead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpcRequestHead) XXX_Merge 

func (m *RpcRequestHead) XXX_Merge(src proto.Message)

func (*RpcRequestHead) XXX_Size 

func (m *RpcRequestHead) XXX_Size() int

func (*RpcRequestHead) XXX_Unmarshal 

func (m *RpcRequestHead) XXX_Unmarshal(b []byte) error

type RpcResponseHead 

type RpcResponseHead struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Code                 int64    `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedRpcResponseHead 

func NewPopulatedRpcResponseHead(r randyGrpc, easy bool) *RpcResponseHead

func (*RpcResponseHead) Descriptor 

func (*RpcResponseHead) Descriptor() ([]byte, []int)

func (*RpcResponseHead) Equal 

func (this *RpcResponseHead) Equal(that interface{}) bool

func (*RpcResponseHead) Marshal 

func (m *RpcResponseHead) Marshal() (dAtA []byte, err error)

func (*RpcResponseHead) MarshalTo 

func (m *RpcResponseHead) MarshalTo(dAtA []byte) (int, error)

func (*RpcResponseHead) MarshalToSizedBuffer 

func (m *RpcResponseHead) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RpcResponseHead) ProtoMessage 

func (*RpcResponseHead) ProtoMessage()

func (*RpcResponseHead) Reset 

func (m *RpcResponseHead) Reset()

func (*RpcResponseHead) Size 

func (m *RpcResponseHead) Size() (n int)

func (*RpcResponseHead) String 

func (this *RpcResponseHead) String() string

func (*RpcResponseHead) Unmarshal 

func (m *RpcResponseHead) Unmarshal(dAtA []byte) error

func (*RpcResponseHead) XXX_DiscardUnknown 

func (m *RpcResponseHead) XXX_DiscardUnknown()

func (*RpcResponseHead) XXX_Marshal 

func (m *RpcResponseHead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpcResponseHead) XXX_Merge 

func (m *RpcResponseHead) XXX_Merge(src proto.Message)

func (*RpcResponseHead) XXX_Size 

func (m *RpcResponseHead) XXX_Size() int

func (*RpcResponseHead) XXX_Unmarshal 

func (m *RpcResponseHead) XXX_Unmarshal(b []byte) error

type RpcSearchRequest 

type RpcSearchRequest struct {
	Head                 *RpcRequestHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	DbName               string          `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	SpaceName            string          `protobuf:"bytes,3,opt,name=space_name,json=spaceName,proto3" json:"space_name,omitempty"`
	Query                string          `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	ClientType           string          `protobuf:"bytes,5,opt,name=client_type,json=clientType,proto3" json:"client_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func NewPopulatedRpcSearchRequest 

func NewPopulatedRpcSearchRequest(r randyGrpc, easy bool) *RpcSearchRequest

func (*RpcSearchRequest) Descriptor 

func (*RpcSearchRequest) Descriptor() ([]byte, []int)

func (*RpcSearchRequest) Equal 

func (this *RpcSearchRequest) Equal(that interface{}) bool

func (*RpcSearchRequest) Marshal 

func (m *RpcSearchRequest) Marshal() (dAtA []byte, err error)

func (*RpcSearchRequest) MarshalTo 

func (m *RpcSearchRequest) MarshalTo(dAtA []byte) (int, error)

func (*RpcSearchRequest) MarshalToSizedBuffer 

func (m *RpcSearchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RpcSearchRequest) ProtoMessage 

func (*RpcSearchRequest) ProtoMessage()

func (*RpcSearchRequest) Reset 

func (m *RpcSearchRequest) Reset()

func (*RpcSearchRequest) Size 

func (m *RpcSearchRequest) Size() (n int)

func (*RpcSearchRequest) String 

func (this *RpcSearchRequest) String() string

func (*RpcSearchRequest) Unmarshal 

func (m *RpcSearchRequest) Unmarshal(dAtA []byte) error

func (*RpcSearchRequest) XXX_DiscardUnknown 

func (m *RpcSearchRequest) XXX_DiscardUnknown()

func (*RpcSearchRequest) XXX_Marshal 

func (m *RpcSearchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpcSearchRequest) XXX_Merge 

func (m *RpcSearchRequest) XXX_Merge(src proto.Message)

func (*RpcSearchRequest) XXX_Size 

func (m *RpcSearchRequest) XXX_Size() int

func (*RpcSearchRequest) XXX_Unmarshal 

func (m *RpcSearchRequest) XXX_Unmarshal(b []byte) error

type RpcSearchResponse 

type RpcSearchResponse struct {
	Head                 *RpcResponseHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Body                 string           `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func NewPopulatedRpcSearchResponse 

func NewPopulatedRpcSearchResponse(r randyGrpc, easy bool) *RpcSearchResponse

func (*RpcSearchResponse) Descriptor 

func (*RpcSearchResponse) Descriptor() ([]byte, []int)

func (*RpcSearchResponse) Equal 

func (this *RpcSearchResponse) Equal(that interface{}) bool

func (*RpcSearchResponse) Marshal 

func (m *RpcSearchResponse) Marshal() (dAtA []byte, err error)

func (*RpcSearchResponse) MarshalTo 

func (m *RpcSearchResponse) MarshalTo(dAtA []byte) (int, error)

func (*RpcSearchResponse) MarshalToSizedBuffer 

func (m *RpcSearchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RpcSearchResponse) ProtoMessage 

func (*RpcSearchResponse) ProtoMessage()

func (*RpcSearchResponse) Reset 

func (m *RpcSearchResponse) Reset()

func (*RpcSearchResponse) Size 

func (m *RpcSearchResponse) Size() (n int)

func (*RpcSearchResponse) String 

func (this *RpcSearchResponse) String() string

func (*RpcSearchResponse) Unmarshal 

func (m *RpcSearchResponse) Unmarshal(dAtA []byte) error

func (*RpcSearchResponse) XXX_DiscardUnknown 

func (m *RpcSearchResponse) XXX_DiscardUnknown()

func (*RpcSearchResponse) XXX_Marshal 

func (m *RpcSearchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpcSearchResponse) XXX_Merge 

func (m *RpcSearchResponse) XXX_Merge(src proto.Message)

func (*RpcSearchResponse) XXX_Size 

func (m *RpcSearchResponse) XXX_Size() int

func (*RpcSearchResponse) XXX_Unmarshal 

func (m *RpcSearchResponse) XXX_Unmarshal(b []byte) error

type TimeStamp 

type TimeStamp struct {
	Sec                  int64    `protobuf:"varint,1,opt,name=sec,proto3" json:"sec,omitempty"`
	Usec                 int64    `protobuf:"varint,2,opt,name=usec,proto3" json:"usec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedTimeStamp 

func NewPopulatedTimeStamp(r randyApi, easy bool) *TimeStamp

func (*TimeStamp) Descriptor 

func (*TimeStamp) Descriptor() ([]byte, []int)

func (*TimeStamp) Equal 

func (this *TimeStamp) Equal(that interface{}) bool

func (*TimeStamp) Marshal 

func (m *TimeStamp) Marshal() (dAtA []byte, err error)

func (*TimeStamp) MarshalTo 

func (m *TimeStamp) MarshalTo(dAtA []byte) (int, error)

func (*TimeStamp) MarshalToSizedBuffer 

func (m *TimeStamp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TimeStamp) ProtoMessage 

func (*TimeStamp) ProtoMessage()

func (*TimeStamp) Reset 

func (m *TimeStamp) Reset()

func (*TimeStamp) Size 

func (m *TimeStamp) Size() (n int)

func (*TimeStamp) String 

func (this *TimeStamp) String() string

func (*TimeStamp) Unmarshal 

func (m *TimeStamp) Unmarshal(dAtA []byte) error

func (*TimeStamp) XXX_DiscardUnknown 

func (m *TimeStamp) XXX_DiscardUnknown()

func (*TimeStamp) XXX_Marshal 

func (m *TimeStamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeStamp) XXX_Merge 

func (m *TimeStamp) XXX_Merge(src proto.Message)

func (*TimeStamp) XXX_Size 

func (m *TimeStamp) XXX_Size() int

func (*TimeStamp) XXX_Unmarshal 

func (m *TimeStamp) XXX_Unmarshal(b []byte) error

type UnimplementedRpcApiServer 

type UnimplementedRpcApiServer struct {
}

UnimplementedRpcApiServer can be embedded to have forward compatible implementations.

func (*UnimplementedRpcApiServer) Search 

func (*UnimplementedRpcApiServer) Search(ctx context.Context, req *RpcSearchRequest) (*RpcSearchResponse, error)

type UpdateSpace 

type UpdateSpace struct {
	Space                []byte   `protobuf:"bytes,1,opt,name=Space,proto3" json:"Space,omitempty"`
	Version              uint64   `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedUpdateSpace 

func NewPopulatedUpdateSpace(r randyApi, easy bool) *UpdateSpace

func (*UpdateSpace) Descriptor 

func (*UpdateSpace) Descriptor() ([]byte, []int)

func (*UpdateSpace) Equal 

func (this *UpdateSpace) Equal(that interface{}) bool

func (*UpdateSpace) Marshal 

func (m *UpdateSpace) Marshal() (dAtA []byte, err error)

func (*UpdateSpace) MarshalTo 

func (m *UpdateSpace) MarshalTo(dAtA []byte) (int, error)

func (*UpdateSpace) MarshalToSizedBuffer 

func (m *UpdateSpace) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateSpace) ProtoMessage 

func (*UpdateSpace) ProtoMessage()

func (*UpdateSpace) Reset 

func (m *UpdateSpace) Reset()

func (*UpdateSpace) Size 

func (m *UpdateSpace) Size() (n int)

func (*UpdateSpace) String 

func (this *UpdateSpace) String() string

func (*UpdateSpace) Unmarshal 

func (m *UpdateSpace) Unmarshal(dAtA []byte) error

func (*UpdateSpace) XXX_DiscardUnknown 

func (m *UpdateSpace) XXX_DiscardUnknown()

func (*UpdateSpace) XXX_Marshal 

func (m *UpdateSpace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateSpace) XXX_Merge 

func (m *UpdateSpace) XXX_Merge(src proto.Message)

func (*UpdateSpace) XXX_Size 

func (m *UpdateSpace) XXX_Size() int

func (*UpdateSpace) XXX_Unmarshal 

func (m *UpdateSpace) XXX_Unmarshal(b []byte) error

type Vector 

type Vector struct {
	Feature              []float32 `protobuf:"fixed32,1,rep,packed,name=feature,proto3" json:"feature,omitempty"`
	Source               string    `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func NewPopulatedVector 

func NewPopulatedVector(r randyApi, easy bool) *Vector

func (*Vector) Descriptor 

func (*Vector) Descriptor() ([]byte, []int)

func (*Vector) Equal 

func (this *Vector) Equal(that interface{}) bool

func (*Vector) Marshal 

func (m *Vector) Marshal() (dAtA []byte, err error)

func (*Vector) MarshalTo 

func (m *Vector) MarshalTo(dAtA []byte) (int, error)

func (*Vector) MarshalToSizedBuffer 

func (m *Vector) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Vector) ProtoMessage 

func (*Vector) ProtoMessage()

func (*Vector) Reset 

func (m *Vector) Reset()

func (*Vector) Size 

func (m *Vector) Size() (n int)

func (*Vector) String 

func (this *Vector) String() string

func (*Vector) Unmarshal 

func (m *Vector) Unmarshal(dAtA []byte) error

func (*Vector) XXX_DiscardUnknown 

func (m *Vector) XXX_DiscardUnknown()

func (*Vector) XXX_Marshal 

func (m *Vector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Vector) XXX_Merge 

func (m *Vector) XXX_Merge(src proto.Message)

func (*Vector) XXX_Size 

func (m *Vector) XXX_Size() int

func (*Vector) XXX_Unmarshal 

func (m *Vector) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis

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.