vearchpb

package
v3.2.7+incompatible Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2021 License: Apache-2.0, MIT Imports: 17 Imported by: 19

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDataModel        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDataModel          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDataModel = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthErrors        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowErrors          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupErrors = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRaftcmd        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaftcmd          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRaftcmd = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRouterGrpc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRouterGrpc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRouterGrpc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthSnapshot        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSnapshot          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSnapshot = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CmdType_name = map[int32]string{
	0: "WRITE",
	1: "UPDATESPACE",
	2: "FLUSH",
}
View Source 
var CmdType_value = map[string]int32{
	"WRITE":       0,
	"UPDATESPACE": 1,
	"FLUSH":       2,
}
View Source 
var ErrorEnum_name = map[int32]string{
	0:   "SUCCESS",
	1:   "INTERNAL_ERROR",
	2:   "NAME_OR_PASSWORD",
	3:   "SYSBUSY",
	4:   "PARAM_ERROR",
	5:   "INVALID_CFG",
	6:   "TIMEOUT",
	7:   "SERVICE_UNAVAILABLE",
	8:   "ZONE_NOT_EXISTS",
	9:   "LOCAL_ZONE_OPS_FAILED",
	10:  "DUP_ZONE",
	11:  "DUP_DB",
	12:  "INVALID_ENGINE",
	13:  "DB_NOTEXISTS",
	14:  "DB_Not_Empty",
	15:  "DUP_SPACE",
	16:  "SPACE_NOTEXISTS",
	17:  "PARTITION_HAS_TASK_NOW",
	18:  "REPLICA_NOT_EXISTS",
	19:  "DUP_REPLICA",
	20:  "PARTITION_REPLICA_LEADER_NOT_DELETE",
	21:  "PS_NOTEXISTS",
	22:  "PS_Already_Exists",
	23:  "LOCAL_SPACE_OPS_FAILED",
	24:  "Local_PS_Ops_Failed",
	25:  "GENID_FAILED",
	26:  "LOCALDB_OPTFAILED",
	27:  "SPACE_SCHEMA_INVALID",
	28:  "RPC_GET_CLIENT_FAILED",
	29:  "RPC_INVALID_RESP",
	30:  "RPC_INVOKE_FAILED",
	31:  "RPC_PARAM_ERROR",
	32:  "METHOD_NOT_IMPLEMENT",
	33:  "USER_NOT_EXISTS",
	34:  "DUP_USER",
	35:  "USER_OPS_FAILED",
	36:  "AUTHENTICATION_FAILED",
	37:  "REGION_NOT_EXISTS",
	38:  "MASTER_PS_CAN_NOT_SELECT",
	39:  "MASTER_PS_NOT_ENOUGH_SELECT",
	40:  "PARTITION_DUPLICATE",
	41:  "PARTITION_NOT_EXIST",
	42:  "PARTITION_NOT_LEADER",
	43:  "PARTITION_NO_LEADER",
	44:  "PARTITION_REQ_PARAM",
	45:  "PARTITON_ENGINENAME_INVALID",
	46:  "UNKNOWN_PARTITION_RAFT_CMD_TYPE",
	47:  "MASTER_SERVER_IS_NOT_RUNNING",
	48:  "PARTITION_IS_INVALID",
	49:  "PARTITION_IS_CLOSED",
	50:  "DOCUMENT_NOT_EXIST",
	51:  "DOCUMENT_EXIST",
	52:  "DOCUMENT_MUST_HAS_SOURCE",
	53:  "PULL_OUT_VERSION_NOT_MATCH",
	54:  "FUNC_CAN_NOT_INVOKE_IN_FROZEN_ENGINE",
	55:  "ROUTER_NO_PS_CLIENT",
	56:  "ROUTER_CALL_PS_RPC_ERR",
	57:  "GAMMA_SEARCH_QUERY_NUM_LESS_0",
	58:  "GAMMA_SEARCH_NO_CREATE_INDEX",
	59:  "GAMMA_SEARCH_INDEX_QUERY_ERR",
	60:  "GAMMA_SEARCH_OTHER_ERR",
	61:  "Primary_IS_INVALID",
	62:  "PARSING_RESULT_ERROR",
	63:  "FORCE_MERGE_BUILD_INDEX_ERR",
	64:  "DELETE_BY_QUERY_SERACH_ERR",
	65:  "DELETE_BY_QUERY_SEARCH_ID_IS_0",
	66:  "FLUSH_ERR",
	70:  "Create_RpcClient_Failed",
	71:  "Call_RpcClient_Failed",
	100: "RECOVER",
}
View Source 
var ErrorEnum_value = map[string]int32{
	"SUCCESS":                              0,
	"INTERNAL_ERROR":                       1,
	"NAME_OR_PASSWORD":                     2,
	"SYSBUSY":                              3,
	"PARAM_ERROR":                          4,
	"INVALID_CFG":                          5,
	"TIMEOUT":                              6,
	"SERVICE_UNAVAILABLE":                  7,
	"ZONE_NOT_EXISTS":                      8,
	"LOCAL_ZONE_OPS_FAILED":                9,
	"DUP_ZONE":                             10,
	"DUP_DB":                               11,
	"INVALID_ENGINE":                       12,
	"DB_NOTEXISTS":                         13,
	"DB_Not_Empty":                         14,
	"DUP_SPACE":                            15,
	"SPACE_NOTEXISTS":                      16,
	"PARTITION_HAS_TASK_NOW":               17,
	"REPLICA_NOT_EXISTS":                   18,
	"DUP_REPLICA":                          19,
	"PARTITION_REPLICA_LEADER_NOT_DELETE":  20,
	"PS_NOTEXISTS":                         21,
	"PS_Already_Exists":                    22,
	"LOCAL_SPACE_OPS_FAILED":               23,
	"Local_PS_Ops_Failed":                  24,
	"GENID_FAILED":                         25,
	"LOCALDB_OPTFAILED":                    26,
	"SPACE_SCHEMA_INVALID":                 27,
	"RPC_GET_CLIENT_FAILED":                28,
	"RPC_INVALID_RESP":                     29,
	"RPC_INVOKE_FAILED":                    30,
	"RPC_PARAM_ERROR":                      31,
	"METHOD_NOT_IMPLEMENT":                 32,
	"USER_NOT_EXISTS":                      33,
	"DUP_USER":                             34,
	"USER_OPS_FAILED":                      35,
	"AUTHENTICATION_FAILED":                36,
	"REGION_NOT_EXISTS":                    37,
	"MASTER_PS_CAN_NOT_SELECT":             38,
	"MASTER_PS_NOT_ENOUGH_SELECT":          39,
	"PARTITION_DUPLICATE":                  40,
	"PARTITION_NOT_EXIST":                  41,
	"PARTITION_NOT_LEADER":                 42,
	"PARTITION_NO_LEADER":                  43,
	"PARTITION_REQ_PARAM":                  44,
	"PARTITON_ENGINENAME_INVALID":          45,
	"UNKNOWN_PARTITION_RAFT_CMD_TYPE":      46,
	"MASTER_SERVER_IS_NOT_RUNNING":         47,
	"PARTITION_IS_INVALID":                 48,
	"PARTITION_IS_CLOSED":                  49,
	"DOCUMENT_NOT_EXIST":                   50,
	"DOCUMENT_EXIST":                       51,
	"DOCUMENT_MUST_HAS_SOURCE":             52,
	"PULL_OUT_VERSION_NOT_MATCH":           53,
	"FUNC_CAN_NOT_INVOKE_IN_FROZEN_ENGINE": 54,
	"ROUTER_NO_PS_CLIENT":                  55,
	"ROUTER_CALL_PS_RPC_ERR":               56,
	"GAMMA_SEARCH_QUERY_NUM_LESS_0":        57,
	"GAMMA_SEARCH_NO_CREATE_INDEX":         58,
	"GAMMA_SEARCH_INDEX_QUERY_ERR":         59,
	"GAMMA_SEARCH_OTHER_ERR":               60,
	"Primary_IS_INVALID":                   61,
	"PARSING_RESULT_ERROR":                 62,
	"FORCE_MERGE_BUILD_INDEX_ERR":          63,
	"DELETE_BY_QUERY_SERACH_ERR":           64,
	"DELETE_BY_QUERY_SEARCH_ID_IS_0":       65,
	"FLUSH_ERR":                            66,
	"Create_RpcClient_Failed":              70,
	"Call_RpcClient_Failed":                71,
	"RECOVER":                              100,
}
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: "INT",
	1: "LONG",
	2: "FLOAT",
	3: "DOUBLE",
	4: "STRING",
	5: "VECTOR",
	6: "BOOL",
	7: "GEOPOINT",
	8: "DATE",
}
View Source 
var FieldType_value = map[string]int32{
	"INT":      0,
	"LONG":     1,
	"FLOAT":    2,
	"DOUBLE":   3,
	"STRING":   4,
	"VECTOR":   5,
	"BOOL":     6,
	"GEOPOINT": 7,
	"DATE":     8,
}
View Source 
var OpType_name = map[int32]string{
	0: "CREATE",
	1: "DELETE",
	2: "REPLACE",
	3: "BULK",
	4: "GET",
	5: "SEARCH",
}
View Source 
var OpType_value = map[string]int32{
	"CREATE":  0,
	"DELETE":  1,
	"REPLACE": 2,
	"BULK":    3,
	"GET":     4,
	"SEARCH":  5,
}
View Source 
var RetrievalParameters_DistanceMetricType_name = map[int32]string{
	0: "InnerProduct",
	1: "L2",
}
View Source 
var RetrievalParameters_DistanceMetricType_value = map[string]int32{
	"InnerProduct": 0,
	"L2":           1,
}
View Source 
var SearchResultCode_name = map[int32]string{
	0: "SEARCH_SUCCESS",
	1: "INDEX_NOT_BUILDED",
	2: "SEARCH_ERROR",
}
View Source 
var SearchResultCode_value = map[string]int32{
	"SEARCH_SUCCESS":    0,
	"INDEX_NOT_BUILDED": 1,
	"SEARCH_ERROR":      2,
}
View Source 
var SnapshotStatus_name = map[int32]string{
	0: "UnUse",
	1: "Start",
	2: "Running",
	3: "Finish",
}
View Source 
var SnapshotStatus_value = map[string]int32{
	"UnUse":   0,
	"Start":   1,
	"Running": 2,
	"Finish":  3,
}
View Source 
var VectorMetaInfo_StoreType_name = map[int32]string{
	0: "MEMORYONLY",
	1: "ROCKSDB",
	2: "MMAP",
}
View Source 
var VectorMetaInfo_StoreType_value = map[string]int32{
	"MEMORYONLY": 0,
	"ROCKSDB":    1,
	"MMAP":       2,
}
View Source 
var VectorMetaInfo_ValueType_name = map[int32]string{
	0: "FLOAT",
	1: "UINT8",
}
View Source 
var VectorMetaInfo_ValueType_value = map[string]int32{
	"FLOAT": 0,
	"UINT8": 1,
}

Functions

func ErrCode 

func ErrCode(code ErrorEnum) (c int)

func ErrMsg 

func ErrMsg(code ErrorEnum) (s string)

func RegisterRouterGRPCServiceServer 

func RegisterRouterGRPCServiceServer(s *grpc.Server, srv RouterGRPCServiceServer)

func Wrap 

func Wrap(err error, s string) error

Types

type AddRequest 

type AddRequest struct {
	Head                 *RequestHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Doc                  *Document    `protobuf:"bytes,4,opt,name=doc,proto3" json:"doc,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func NewPopulatedAddRequest 

func NewPopulatedAddRequest(r randyRouterGrpc, easy bool) *AddRequest

func (*AddRequest) Descriptor 

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

func (*AddRequest) Equal 

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

func (*AddRequest) GetDoc 

func (m *AddRequest) GetDoc() *Document

func (*AddRequest) GetHead 

func (m *AddRequest) GetHead() *RequestHead

func (*AddRequest) Marshal 

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

func (*AddRequest) MarshalTo 

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

func (*AddRequest) MarshalToSizedBuffer 

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

func (*AddRequest) ProtoMessage 

func (*AddRequest) ProtoMessage()

func (*AddRequest) Reset 

func (m *AddRequest) Reset()

func (*AddRequest) Size 

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

func (*AddRequest) String 

func (this *AddRequest) String() string

func (*AddRequest) Unmarshal 

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

func (*AddRequest) XXX_DiscardUnknown 

func (m *AddRequest) XXX_DiscardUnknown()

func (*AddRequest) XXX_Marshal 

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

func (*AddRequest) XXX_Merge 

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

func (*AddRequest) XXX_Size 

func (m *AddRequest) XXX_Size() int

func (*AddRequest) XXX_Unmarshal 

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

type AddResponse 

type AddResponse struct {
	Head                 *ResponseHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	PrimaryKey           string        `protobuf:"bytes,4,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewPopulatedAddResponse 

func NewPopulatedAddResponse(r randyRouterGrpc, easy bool) *AddResponse

func (*AddResponse) Descriptor 

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

func (*AddResponse) Equal 

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

func (*AddResponse) GetHead 

func (m *AddResponse) GetHead() *ResponseHead

func (*AddResponse) GetPrimaryKey 

func (m *AddResponse) GetPrimaryKey() string

func (*AddResponse) Marshal 

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

func (*AddResponse) MarshalTo 

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

func (*AddResponse) MarshalToSizedBuffer 

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

func (*AddResponse) ProtoMessage 

func (*AddResponse) ProtoMessage()

func (*AddResponse) Reset 

func (m *AddResponse) Reset()

func (*AddResponse) Size 

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

func (*AddResponse) String 

func (this *AddResponse) String() string

func (*AddResponse) Unmarshal 

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

func (*AddResponse) XXX_DiscardUnknown 

func (m *AddResponse) XXX_DiscardUnknown()

func (*AddResponse) XXX_Marshal 

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

func (*AddResponse) XXX_Merge 

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

func (*AddResponse) XXX_Size 

func (m *AddResponse) XXX_Size() int

func (*AddResponse) XXX_Unmarshal 

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

type BulkRequest 

type BulkRequest struct {
	Head                 *RequestHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Docs                 []*Document  `protobuf:"bytes,4,rep,name=docs,proto3" json:"docs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func NewPopulatedBulkRequest 

func NewPopulatedBulkRequest(r randyRouterGrpc, easy bool) *BulkRequest

func (*BulkRequest) Descriptor 

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

func (*BulkRequest) Equal 

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

func (*BulkRequest) GetDocs 

func (m *BulkRequest) GetDocs() []*Document

func (*BulkRequest) GetHead 

func (m *BulkRequest) GetHead() *RequestHead

func (*BulkRequest) Marshal 

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

func (*BulkRequest) MarshalTo 

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

func (*BulkRequest) MarshalToSizedBuffer 

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

func (*BulkRequest) ProtoMessage 

func (*BulkRequest) ProtoMessage()

func (*BulkRequest) Reset 

func (m *BulkRequest) Reset()

func (*BulkRequest) Size 

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

func (*BulkRequest) String 

func (this *BulkRequest) String() string

func (*BulkRequest) Unmarshal 

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

func (*BulkRequest) XXX_DiscardUnknown 

func (m *BulkRequest) XXX_DiscardUnknown()

func (*BulkRequest) XXX_Marshal 

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

func (*BulkRequest) XXX_Merge 

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

func (*BulkRequest) XXX_Size 

func (m *BulkRequest) XXX_Size() int

func (*BulkRequest) XXX_Unmarshal 

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

type BulkResponse 

type BulkResponse struct {
	Head                 *ResponseHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Items                []*Item       `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewPopulatedBulkResponse 

func NewPopulatedBulkResponse(r randyRouterGrpc, easy bool) *BulkResponse

func (*BulkResponse) Descriptor 

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

func (*BulkResponse) Equal 

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

func (*BulkResponse) GetHead 

func (m *BulkResponse) GetHead() *ResponseHead

func (*BulkResponse) GetItems 

func (m *BulkResponse) GetItems() []*Item

func (*BulkResponse) Marshal 

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

func (*BulkResponse) MarshalTo 

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

func (*BulkResponse) MarshalToSizedBuffer 

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

func (*BulkResponse) ProtoMessage 

func (*BulkResponse) ProtoMessage()

func (*BulkResponse) Reset 

func (m *BulkResponse) Reset()

func (*BulkResponse) Size 

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

func (*BulkResponse) String 

func (this *BulkResponse) String() string

func (*BulkResponse) Unmarshal 

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

func (*BulkResponse) XXX_DiscardUnknown 

func (m *BulkResponse) XXX_DiscardUnknown()

func (*BulkResponse) XXX_Marshal 

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

func (*BulkResponse) XXX_Merge 

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

func (*BulkResponse) XXX_Size 

func (m *BulkResponse) XXX_Size() int

func (*BulkResponse) XXX_Unmarshal 

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

type CmdType 

type CmdType int32
const (
	CmdType_WRITE       CmdType = 0
	CmdType_UPDATESPACE CmdType = 1
	CmdType_FLUSH       CmdType = 2
)

func (CmdType) EnumDescriptor 

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

func (CmdType) String 

func (x CmdType) String() string

type DB 

type DB struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tables               []*Table          `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"`
	UserPasswordPair     map[string]string `` /* 199-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func NewPopulatedDB 

func NewPopulatedDB(r randyDataModel, easy bool) *DB

func (*DB) Descriptor 

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

func (*DB) Equal 

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

func (*DB) Marshal 

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

func (*DB) MarshalTo 

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

func (*DB) MarshalToSizedBuffer 

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

func (*DB) ProtoMessage 

func (*DB) ProtoMessage()

func (*DB) Reset 

func (m *DB) Reset()

func (*DB) Size 

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

func (*DB) String 

func (this *DB) String() string

func (*DB) Unmarshal 

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

func (*DB) XXX_DiscardUnknown 

func (m *DB) XXX_DiscardUnknown()

func (*DB) XXX_Marshal 

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

func (*DB) XXX_Merge 

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

func (*DB) XXX_Size 

func (m *DB) XXX_Size() int

func (*DB) XXX_Unmarshal 

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

type DelByQueryeResponse 

type DelByQueryeResponse struct {
	Head                 *ResponseHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	DelNum               int32         `protobuf:"varint,2,opt,name=DelNum,proto3" json:"DelNum,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewPopulatedDelByQueryeResponse 

func NewPopulatedDelByQueryeResponse(r randyRouterGrpc, easy bool) *DelByQueryeResponse

func (*DelByQueryeResponse) Descriptor 

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

func (*DelByQueryeResponse) Equal 

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

func (*DelByQueryeResponse) GetDelNum 

func (m *DelByQueryeResponse) GetDelNum() int32

func (*DelByQueryeResponse) GetHead 

func (m *DelByQueryeResponse) GetHead() *ResponseHead

func (*DelByQueryeResponse) Marshal 

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

func (*DelByQueryeResponse) MarshalTo 

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

func (*DelByQueryeResponse) MarshalToSizedBuffer 

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

func (*DelByQueryeResponse) ProtoMessage 

func (*DelByQueryeResponse) ProtoMessage()

func (*DelByQueryeResponse) Reset 

func (m *DelByQueryeResponse) Reset()

func (*DelByQueryeResponse) Size 

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

func (*DelByQueryeResponse) String 

func (this *DelByQueryeResponse) String() string

func (*DelByQueryeResponse) Unmarshal 

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

func (*DelByQueryeResponse) XXX_DiscardUnknown 

func (m *DelByQueryeResponse) XXX_DiscardUnknown()

func (*DelByQueryeResponse) XXX_Marshal 

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

func (*DelByQueryeResponse) XXX_Merge 

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

func (*DelByQueryeResponse) XXX_Size 

func (m *DelByQueryeResponse) XXX_Size() int

func (*DelByQueryeResponse) XXX_Unmarshal 

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

type DeleteRequest 

type DeleteRequest struct {
	Head                 *RequestHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	PrimaryKeys          []string     `protobuf:"bytes,4,rep,name=primary_keys,json=primaryKeys,proto3" json:"primary_keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func NewPopulatedDeleteRequest 

func NewPopulatedDeleteRequest(r randyRouterGrpc, easy bool) *DeleteRequest

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) Equal 

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

func (*DeleteRequest) GetHead 

func (m *DeleteRequest) GetHead() *RequestHead

func (*DeleteRequest) GetPrimaryKeys 

func (m *DeleteRequest) GetPrimaryKeys() []string

func (*DeleteRequest) Marshal 

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

func (*DeleteRequest) MarshalTo 

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

func (*DeleteRequest) MarshalToSizedBuffer 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

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

func (*DeleteRequest) String 

func (this *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

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

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type DeleteResponse 

type DeleteResponse struct {
	Head                 *ResponseHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Items                []*Item       `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewPopulatedDeleteResponse 

func NewPopulatedDeleteResponse(r randyRouterGrpc, easy bool) *DeleteResponse

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) Equal 

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

func (*DeleteResponse) GetHead 

func (m *DeleteResponse) GetHead() *ResponseHead

func (*DeleteResponse) GetItems 

func (m *DeleteResponse) GetItems() []*Item

func (*DeleteResponse) Marshal 

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

func (*DeleteResponse) MarshalTo 

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

func (*DeleteResponse) MarshalToSizedBuffer 

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

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

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

func (*DeleteResponse) String 

func (this *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

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

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

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

func (*DeleteResponse) XXX_Merge 

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

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

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

type DocCmd 

type DocCmd struct {
	Type                 OpType   `protobuf:"varint,1,opt,name=type,proto3,enum=OpType" json:"type,omitempty"`
	Version              int64    `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	Slot                 uint32   `protobuf:"varint,5,opt,name=slot,proto3" json:"slot,omitempty"`
	Doc                  []byte   `protobuf:"bytes,7,opt,name=doc,proto3" json:"doc,omitempty"`
	Docs                 [][]byte `protobuf:"bytes,8,rep,name=docs,proto3" json:"docs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedDocCmd 

func NewPopulatedDocCmd(r randyRaftcmd, 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 Document 

type Document struct {
	PKey                 string   `protobuf:"bytes,1,opt,name=p_key,json=pKey,proto3" json:"p_key,omitempty"`
	Fields               []*Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedDocument 

func NewPopulatedDocument(r randyDataModel, easy bool) *Document

func (*Document) Descriptor 

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

func (*Document) Equal 

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

func (*Document) GetFields 

func (m *Document) GetFields() []*Field

func (*Document) GetPKey 

func (m *Document) GetPKey() string

func (*Document) Marshal 

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

func (*Document) MarshalTo 

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

func (*Document) MarshalToSizedBuffer 

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

func (*Document) ProtoMessage 

func (*Document) ProtoMessage()

func (*Document) Reset 

func (m *Document) Reset()

func (*Document) Size 

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

func (*Document) String 

func (this *Document) String() string

func (*Document) Unmarshal 

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

func (*Document) XXX_DiscardUnknown 

func (m *Document) XXX_DiscardUnknown()

func (*Document) XXX_Marshal 

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

func (*Document) XXX_Merge 

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

func (*Document) XXX_Size 

func (m *Document) XXX_Size() int

func (*Document) XXX_Unmarshal 

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

type Error 

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

func NewPopulatedError 

func NewPopulatedError(r randyErrors, easy bool) *Error

func (*Error) Descriptor 

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

func (*Error) Equal 

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

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) MarshalToSizedBuffer 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (this *Error) String() string

func (*Error) Unmarshal 

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

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type ErrorEnum 

type ErrorEnum int32
const (
	ErrorEnum_SUCCESS                              ErrorEnum = 0
	ErrorEnum_INTERNAL_ERROR                       ErrorEnum = 1
	ErrorEnum_NAME_OR_PASSWORD                     ErrorEnum = 2
	ErrorEnum_SYSBUSY                              ErrorEnum = 3
	ErrorEnum_PARAM_ERROR                          ErrorEnum = 4
	ErrorEnum_INVALID_CFG                          ErrorEnum = 5
	ErrorEnum_TIMEOUT                              ErrorEnum = 6
	ErrorEnum_SERVICE_UNAVAILABLE                  ErrorEnum = 7
	ErrorEnum_ZONE_NOT_EXISTS                      ErrorEnum = 8
	ErrorEnum_LOCAL_ZONE_OPS_FAILED                ErrorEnum = 9
	ErrorEnum_DUP_ZONE                             ErrorEnum = 10
	ErrorEnum_DUP_DB                               ErrorEnum = 11
	ErrorEnum_INVALID_ENGINE                       ErrorEnum = 12
	ErrorEnum_DB_NOTEXISTS                         ErrorEnum = 13
	ErrorEnum_DB_Not_Empty                         ErrorEnum = 14
	ErrorEnum_DUP_SPACE                            ErrorEnum = 15
	ErrorEnum_SPACE_NOTEXISTS                      ErrorEnum = 16
	ErrorEnum_PARTITION_HAS_TASK_NOW               ErrorEnum = 17
	ErrorEnum_REPLICA_NOT_EXISTS                   ErrorEnum = 18
	ErrorEnum_DUP_REPLICA                          ErrorEnum = 19
	ErrorEnum_PARTITION_REPLICA_LEADER_NOT_DELETE  ErrorEnum = 20
	ErrorEnum_PS_NOTEXISTS                         ErrorEnum = 21
	ErrorEnum_PS_Already_Exists                    ErrorEnum = 22
	ErrorEnum_LOCAL_SPACE_OPS_FAILED               ErrorEnum = 23
	ErrorEnum_Local_PS_Ops_Failed                  ErrorEnum = 24
	ErrorEnum_GENID_FAILED                         ErrorEnum = 25
	ErrorEnum_LOCALDB_OPTFAILED                    ErrorEnum = 26
	ErrorEnum_SPACE_SCHEMA_INVALID                 ErrorEnum = 27
	ErrorEnum_RPC_GET_CLIENT_FAILED                ErrorEnum = 28
	ErrorEnum_RPC_INVALID_RESP                     ErrorEnum = 29
	ErrorEnum_RPC_INVOKE_FAILED                    ErrorEnum = 30
	ErrorEnum_RPC_PARAM_ERROR                      ErrorEnum = 31
	ErrorEnum_METHOD_NOT_IMPLEMENT                 ErrorEnum = 32
	ErrorEnum_USER_NOT_EXISTS                      ErrorEnum = 33
	ErrorEnum_DUP_USER                             ErrorEnum = 34
	ErrorEnum_USER_OPS_FAILED                      ErrorEnum = 35
	ErrorEnum_AUTHENTICATION_FAILED                ErrorEnum = 36
	ErrorEnum_REGION_NOT_EXISTS                    ErrorEnum = 37
	ErrorEnum_MASTER_PS_CAN_NOT_SELECT             ErrorEnum = 38
	ErrorEnum_MASTER_PS_NOT_ENOUGH_SELECT          ErrorEnum = 39
	ErrorEnum_PARTITION_DUPLICATE                  ErrorEnum = 40
	ErrorEnum_PARTITION_NOT_EXIST                  ErrorEnum = 41
	ErrorEnum_PARTITION_NOT_LEADER                 ErrorEnum = 42
	ErrorEnum_PARTITION_NO_LEADER                  ErrorEnum = 43
	ErrorEnum_PARTITION_REQ_PARAM                  ErrorEnum = 44
	ErrorEnum_PARTITON_ENGINENAME_INVALID          ErrorEnum = 45
	ErrorEnum_UNKNOWN_PARTITION_RAFT_CMD_TYPE      ErrorEnum = 46
	ErrorEnum_MASTER_SERVER_IS_NOT_RUNNING         ErrorEnum = 47
	ErrorEnum_PARTITION_IS_INVALID                 ErrorEnum = 48
	ErrorEnum_PARTITION_IS_CLOSED                  ErrorEnum = 49
	ErrorEnum_DOCUMENT_NOT_EXIST                   ErrorEnum = 50
	ErrorEnum_DOCUMENT_EXIST                       ErrorEnum = 51
	ErrorEnum_DOCUMENT_MUST_HAS_SOURCE             ErrorEnum = 52
	ErrorEnum_PULL_OUT_VERSION_NOT_MATCH           ErrorEnum = 53
	ErrorEnum_FUNC_CAN_NOT_INVOKE_IN_FROZEN_ENGINE ErrorEnum = 54
	ErrorEnum_ROUTER_NO_PS_CLIENT                  ErrorEnum = 55
	ErrorEnum_ROUTER_CALL_PS_RPC_ERR               ErrorEnum = 56
	ErrorEnum_GAMMA_SEARCH_QUERY_NUM_LESS_0        ErrorEnum = 57
	ErrorEnum_GAMMA_SEARCH_NO_CREATE_INDEX         ErrorEnum = 58
	ErrorEnum_GAMMA_SEARCH_INDEX_QUERY_ERR         ErrorEnum = 59
	ErrorEnum_GAMMA_SEARCH_OTHER_ERR               ErrorEnum = 60
	ErrorEnum_Primary_IS_INVALID                   ErrorEnum = 61
	ErrorEnum_PARSING_RESULT_ERROR                 ErrorEnum = 62
	ErrorEnum_FORCE_MERGE_BUILD_INDEX_ERR          ErrorEnum = 63
	ErrorEnum_DELETE_BY_QUERY_SERACH_ERR           ErrorEnum = 64
	ErrorEnum_DELETE_BY_QUERY_SEARCH_ID_IS_0       ErrorEnum = 65
	ErrorEnum_FLUSH_ERR                            ErrorEnum = 66
	ErrorEnum_Create_RpcClient_Failed              ErrorEnum = 70
	ErrorEnum_Call_RpcClient_Failed                ErrorEnum = 71
	ErrorEnum_RECOVER                              ErrorEnum = 100
)

func (ErrorEnum) EnumDescriptor 

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

func (ErrorEnum) String 

func (x ErrorEnum) String() string

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"`
	Source               string      `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func NewPopulatedField 

func NewPopulatedField(r randyDataModel, 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 FieldMetaInfo 

type FieldMetaInfo struct {
	Name                 string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	DataType             FieldType       `protobuf:"varint,2,opt,name=data_type,json=dataType,proto3,enum=FieldType" json:"data_type,omitempty"`
	IsIndex              bool            `protobuf:"varint,3,opt,name=is_index,json=isIndex,proto3" json:"is_index,omitempty"`
	IsStore              bool            `protobuf:"varint,4,opt,name=is_store,json=isStore,proto3" json:"is_store,omitempty"`
	VectorMetaInfo       *VectorMetaInfo `protobuf:"bytes,5,opt,name=vector_meta_info,json=vectorMetaInfo,proto3" json:"vector_meta_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func NewPopulatedFieldMetaInfo 

func NewPopulatedFieldMetaInfo(r randyDataModel, easy bool) *FieldMetaInfo

func (*FieldMetaInfo) Descriptor 

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

func (*FieldMetaInfo) Equal 

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

func (*FieldMetaInfo) Marshal 

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

func (*FieldMetaInfo) MarshalTo 

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

func (*FieldMetaInfo) MarshalToSizedBuffer 

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

func (*FieldMetaInfo) ProtoMessage 

func (*FieldMetaInfo) ProtoMessage()

func (*FieldMetaInfo) Reset 

func (m *FieldMetaInfo) Reset()

func (*FieldMetaInfo) Size 

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

func (*FieldMetaInfo) String 

func (this *FieldMetaInfo) String() string

func (*FieldMetaInfo) Unmarshal 

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

func (*FieldMetaInfo) XXX_DiscardUnknown 

func (m *FieldMetaInfo) XXX_DiscardUnknown()

func (*FieldMetaInfo) XXX_Marshal 

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

func (*FieldMetaInfo) XXX_Merge 

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

func (*FieldMetaInfo) XXX_Size 

func (m *FieldMetaInfo) XXX_Size() int

func (*FieldMetaInfo) XXX_Unmarshal 

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

type FieldOption 

type FieldOption int32

Whether index this field 

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_INT      FieldType = 0
	FieldType_LONG     FieldType = 1
	FieldType_FLOAT    FieldType = 2
	FieldType_DOUBLE   FieldType = 3
	FieldType_STRING   FieldType = 4
	FieldType_VECTOR   FieldType = 5
	FieldType_BOOL     FieldType = 6
	FieldType_GEOPOINT FieldType = 7
	FieldType_DATE     FieldType = 8
)

func (FieldType) EnumDescriptor 

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

func (FieldType) String 

func (x FieldType) String() string

type FlushRequest 

type FlushRequest struct {
	Head                 *RequestHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func NewPopulatedFlushRequest 

func NewPopulatedFlushRequest(r randyRouterGrpc, easy bool) *FlushRequest

func (*FlushRequest) Descriptor 

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

func (*FlushRequest) Equal 

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

func (*FlushRequest) GetHead 

func (m *FlushRequest) GetHead() *RequestHead

func (*FlushRequest) Marshal 

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

func (*FlushRequest) MarshalTo 

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

func (*FlushRequest) MarshalToSizedBuffer 

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

func (*FlushRequest) ProtoMessage 

func (*FlushRequest) ProtoMessage()

func (*FlushRequest) Reset 

func (m *FlushRequest) Reset()

func (*FlushRequest) Size 

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

func (*FlushRequest) String 

func (this *FlushRequest) String() string

func (*FlushRequest) Unmarshal 

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

func (*FlushRequest) XXX_DiscardUnknown 

func (m *FlushRequest) XXX_DiscardUnknown()

func (*FlushRequest) XXX_Marshal 

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

func (*FlushRequest) XXX_Merge 

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

func (*FlushRequest) XXX_Size 

func (m *FlushRequest) XXX_Size() int

func (*FlushRequest) XXX_Unmarshal 

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

type FlushResponse 

type FlushResponse struct {
	Head                 *ResponseHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Shards               *SearchStatus `protobuf:"bytes,2,opt,name=shards,proto3" json:"shards,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewPopulatedFlushResponse 

func NewPopulatedFlushResponse(r randyRouterGrpc, easy bool) *FlushResponse

func (*FlushResponse) Descriptor 

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

func (*FlushResponse) Equal 

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

func (*FlushResponse) GetHead 

func (m *FlushResponse) GetHead() *ResponseHead

func (*FlushResponse) GetShards 

func (m *FlushResponse) GetShards() *SearchStatus

func (*FlushResponse) Marshal 

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

func (*FlushResponse) MarshalTo 

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

func (*FlushResponse) MarshalToSizedBuffer 

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

func (*FlushResponse) ProtoMessage 

func (*FlushResponse) ProtoMessage()

func (*FlushResponse) Reset 

func (m *FlushResponse) Reset()

func (*FlushResponse) Size 

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

func (*FlushResponse) String 

func (this *FlushResponse) String() string

func (*FlushResponse) Unmarshal 

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

func (*FlushResponse) XXX_DiscardUnknown 

func (m *FlushResponse) XXX_DiscardUnknown()

func (*FlushResponse) XXX_Marshal 

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

func (*FlushResponse) XXX_Merge 

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

func (*FlushResponse) XXX_Size 

func (m *FlushResponse) XXX_Size() int

func (*FlushResponse) XXX_Unmarshal 

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

type ForceMergeRequest 

type ForceMergeRequest struct {
	Head                 *RequestHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func NewPopulatedForceMergeRequest 

func NewPopulatedForceMergeRequest(r randyRouterGrpc, easy bool) *ForceMergeRequest

func (*ForceMergeRequest) Descriptor 

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

func (*ForceMergeRequest) Equal 

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

func (*ForceMergeRequest) GetHead 

func (m *ForceMergeRequest) GetHead() *RequestHead

func (*ForceMergeRequest) Marshal 

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

func (*ForceMergeRequest) MarshalTo 

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

func (*ForceMergeRequest) MarshalToSizedBuffer 

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

func (*ForceMergeRequest) ProtoMessage 

func (*ForceMergeRequest) ProtoMessage()

func (*ForceMergeRequest) Reset 

func (m *ForceMergeRequest) Reset()

func (*ForceMergeRequest) Size 

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

func (*ForceMergeRequest) String 

func (this *ForceMergeRequest) String() string

func (*ForceMergeRequest) Unmarshal 

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

func (*ForceMergeRequest) XXX_DiscardUnknown 

func (m *ForceMergeRequest) XXX_DiscardUnknown()

func (*ForceMergeRequest) XXX_Marshal 

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

func (*ForceMergeRequest) XXX_Merge 

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

func (*ForceMergeRequest) XXX_Size 

func (m *ForceMergeRequest) XXX_Size() int

func (*ForceMergeRequest) XXX_Unmarshal 

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

type ForceMergeResponse 

type ForceMergeResponse struct {
	Head                 *ResponseHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Shards               *SearchStatus `protobuf:"bytes,2,opt,name=shards,proto3" json:"shards,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewPopulatedForceMergeResponse 

func NewPopulatedForceMergeResponse(r randyRouterGrpc, easy bool) *ForceMergeResponse

func (*ForceMergeResponse) Descriptor 

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

func (*ForceMergeResponse) Equal 

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

func (*ForceMergeResponse) GetHead 

func (m *ForceMergeResponse) GetHead() *ResponseHead

func (*ForceMergeResponse) GetShards 

func (m *ForceMergeResponse) GetShards() *SearchStatus

func (*ForceMergeResponse) Marshal 

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

func (*ForceMergeResponse) MarshalTo 

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

func (*ForceMergeResponse) MarshalToSizedBuffer 

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

func (*ForceMergeResponse) ProtoMessage 

func (*ForceMergeResponse) ProtoMessage()

func (*ForceMergeResponse) Reset 

func (m *ForceMergeResponse) Reset()

func (*ForceMergeResponse) Size 

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

func (*ForceMergeResponse) String 

func (this *ForceMergeResponse) String() string

func (*ForceMergeResponse) Unmarshal 

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

func (*ForceMergeResponse) XXX_DiscardUnknown 

func (m *ForceMergeResponse) XXX_DiscardUnknown()

func (*ForceMergeResponse) XXX_Marshal 

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

func (*ForceMergeResponse) XXX_Merge 

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

func (*ForceMergeResponse) XXX_Size 

func (m *ForceMergeResponse) XXX_Size() int

func (*ForceMergeResponse) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Head                 *RequestHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	PrimaryKeys          []string     `protobuf:"bytes,4,rep,name=primary_keys,json=primaryKeys,proto3" json:"primary_keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func NewPopulatedGetRequest 

func NewPopulatedGetRequest(r randyRouterGrpc, easy bool) *GetRequest

func (*GetRequest) Descriptor 

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

func (*GetRequest) Equal 

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

func (*GetRequest) GetHead 

func (m *GetRequest) GetHead() *RequestHead

func (*GetRequest) GetPrimaryKeys 

func (m *GetRequest) GetPrimaryKeys() []string

func (*GetRequest) Marshal 

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

func (*GetRequest) MarshalTo 

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

func (*GetRequest) MarshalToSizedBuffer 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (this *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetResponse 

type GetResponse struct {
	Head                 *ResponseHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Items                []*Item       `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewPopulatedGetResponse 

func NewPopulatedGetResponse(r randyRouterGrpc, easy bool) *GetResponse

func (*GetResponse) Descriptor 

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

func (*GetResponse) Equal 

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

func (*GetResponse) GetHead 

func (m *GetResponse) GetHead() *ResponseHead

func (*GetResponse) GetItems 

func (m *GetResponse) GetItems() []*Item

func (*GetResponse) Marshal 

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

func (*GetResponse) MarshalTo 

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

func (*GetResponse) MarshalToSizedBuffer 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

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

func (*GetResponse) String 

func (this *GetResponse) String() string

func (*GetResponse) Unmarshal 

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type Item 

type Item struct {
	Err                  *Error    `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Doc                  *Document `protobuf:"bytes,2,opt,name=doc,proto3" json:"doc,omitempty"`
	Msg                  string    `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func NewPopulatedItem 

func NewPopulatedItem(r randyDataModel, easy bool) *Item

func (*Item) Descriptor 

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

func (*Item) Equal 

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

func (*Item) GetDoc 

func (m *Item) GetDoc() *Document

func (*Item) GetErr 

func (m *Item) GetErr() *Error

func (*Item) GetMsg 

func (m *Item) GetMsg() string

func (*Item) Marshal 

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

func (*Item) MarshalTo 

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

func (*Item) MarshalToSizedBuffer 

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

func (*Item) ProtoMessage 

func (*Item) ProtoMessage()

func (*Item) Reset 

func (m *Item) Reset()

func (*Item) Size 

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

func (*Item) String 

func (this *Item) String() string

func (*Item) Unmarshal 

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

func (*Item) XXX_DiscardUnknown 

func (m *Item) XXX_DiscardUnknown()

func (*Item) XXX_Marshal 

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

func (*Item) XXX_Merge 

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

func (*Item) XXX_Size 

func (m *Item) XXX_Size() int

func (*Item) XXX_Unmarshal 

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

type MSearchRequest 

type MSearchRequest struct {
	Head                 *RequestHead     `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	SearchRequests       []*SearchRequest `protobuf:"bytes,2,rep,name=search_requests,json=searchRequests,proto3" json:"search_requests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func NewPopulatedMSearchRequest 

func NewPopulatedMSearchRequest(r randyRouterGrpc, easy bool) *MSearchRequest

func (*MSearchRequest) Descriptor 

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

func (*MSearchRequest) Equal 

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

func (*MSearchRequest) GetHead 

func (m *MSearchRequest) GetHead() *RequestHead

func (*MSearchRequest) GetSearchRequests 

func (m *MSearchRequest) GetSearchRequests() []*SearchRequest

func (*MSearchRequest) Marshal 

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

func (*MSearchRequest) MarshalTo 

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

func (*MSearchRequest) MarshalToSizedBuffer 

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

func (*MSearchRequest) ProtoMessage 

func (*MSearchRequest) ProtoMessage()

func (*MSearchRequest) Reset 

func (m *MSearchRequest) Reset()

func (*MSearchRequest) Size 

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

func (*MSearchRequest) String 

func (this *MSearchRequest) String() string

func (*MSearchRequest) Unmarshal 

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

func (*MSearchRequest) XXX_DiscardUnknown 

func (m *MSearchRequest) XXX_DiscardUnknown()

func (*MSearchRequest) XXX_Marshal 

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

func (*MSearchRequest) XXX_Merge 

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

func (*MSearchRequest) XXX_Size 

func (m *MSearchRequest) XXX_Size() int

func (*MSearchRequest) XXX_Unmarshal 

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

type Model 

type Model struct {
	Name                 string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ModelParameters      *ModelParameters `protobuf:"bytes,2,opt,name=model_parameters,json=modelParameters,proto3" json:"model_parameters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func NewPopulatedModel 

func NewPopulatedModel(r randyDataModel, easy bool) *Model

func (*Model) Descriptor 

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

func (*Model) Equal 

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

func (*Model) Marshal 

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

func (*Model) MarshalTo 

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

func (*Model) MarshalToSizedBuffer 

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

func (*Model) ProtoMessage 

func (*Model) ProtoMessage()

func (*Model) Reset 

func (m *Model) Reset()

func (*Model) Size 

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

func (*Model) String 

func (this *Model) String() string

func (*Model) Unmarshal 

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

func (*Model) XXX_DiscardUnknown 

func (m *Model) XXX_DiscardUnknown()

func (*Model) XXX_Marshal 

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

func (*Model) XXX_Merge 

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

func (*Model) XXX_Size 

func (m *Model) XXX_Size() int

func (*Model) XXX_Unmarshal 

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

type ModelParameters 

type ModelParameters struct {
	JsonParametersStr    string            `protobuf:"bytes,1,opt,name=json_parameters_str,json=jsonParametersStr,proto3" json:"json_parameters_str,omitempty"`
	Parameters           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func NewPopulatedModelParameters 

func NewPopulatedModelParameters(r randyDataModel, easy bool) *ModelParameters

func (*ModelParameters) Descriptor 

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

func (*ModelParameters) Equal 

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

func (*ModelParameters) Marshal 

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

func (*ModelParameters) MarshalTo 

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

func (*ModelParameters) MarshalToSizedBuffer 

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

func (*ModelParameters) ProtoMessage 

func (*ModelParameters) ProtoMessage()

func (*ModelParameters) Reset 

func (m *ModelParameters) Reset()

func (*ModelParameters) Size 

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

func (*ModelParameters) String 

func (this *ModelParameters) String() string

func (*ModelParameters) Unmarshal 

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

func (*ModelParameters) XXX_DiscardUnknown 

func (m *ModelParameters) XXX_DiscardUnknown()

func (*ModelParameters) XXX_Marshal 

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

func (*ModelParameters) XXX_Merge 

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

func (*ModelParameters) XXX_Size 

func (m *ModelParameters) XXX_Size() int

func (*ModelParameters) XXX_Unmarshal 

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

type OpType 

type OpType int32
const (
	OpType_CREATE  OpType = 0
	OpType_DELETE  OpType = 1
	OpType_REPLACE OpType = 2
	OpType_BULK    OpType = 3
	OpType_GET     OpType = 4
	OpType_SEARCH  OpType = 5
)

func (OpType) EnumDescriptor 

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

func (OpType) String 

func (x OpType) String() string

type PartitionData 

type PartitionData struct {
	Type                 OpType               `protobuf:"varint,1,opt,name=type,proto3,enum=OpType" json:"type,omitempty"`
	PartitionID          uint32               `protobuf:"varint,2,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	MessageID            string               `protobuf:"bytes,3,opt,name=messageID,proto3" json:"messageID,omitempty"`
	Items                []*Item              `protobuf:"bytes,4,rep,name=items,proto3" json:"items,omitempty"`
	SearchRequest        *SearchRequest       `protobuf:"bytes,5,opt,name=search_request,json=searchRequest,proto3" json:"search_request,omitempty"`
	SearchResponse       *SearchResponse      `protobuf:"bytes,6,opt,name=search_response,json=searchResponse,proto3" json:"search_response,omitempty"`
	Data                 []byte               `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	Err                  *Error               `protobuf:"bytes,8,opt,name=err,proto3" json:"err,omitempty"`
	SearchRequests       []*SearchRequest     `protobuf:"bytes,9,rep,name=search_requests,json=searchRequests,proto3" json:"search_requests,omitempty"`
	SearchResponses      []*SearchResponse    `protobuf:"bytes,10,rep,name=search_responses,json=searchResponses,proto3" json:"search_responses,omitempty"`
	DelNum               int32                `protobuf:"varint,11,opt,name=del_num,json=delNum,proto3" json:"del_num,omitempty"`
	DelByQueryResponse   *DelByQueryeResponse `protobuf:"bytes,12,opt,name=del_by_query_response,json=delByQueryResponse,proto3" json:"del_by_query_response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func NewPopulatedPartitionData 

func NewPopulatedPartitionData(r randyRaftcmd, easy bool) *PartitionData

func (*PartitionData) Descriptor 

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

func (*PartitionData) Equal 

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

func (*PartitionData) Marshal 

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

func (*PartitionData) MarshalTo 

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

func (*PartitionData) MarshalToSizedBuffer 

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

func (*PartitionData) ProtoMessage 

func (*PartitionData) ProtoMessage()

func (*PartitionData) Reset 

func (m *PartitionData) Reset()

func (*PartitionData) Size 

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

func (*PartitionData) String 

func (this *PartitionData) String() string

func (*PartitionData) Unmarshal 

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

func (*PartitionData) XXX_DiscardUnknown 

func (m *PartitionData) XXX_DiscardUnknown()

func (*PartitionData) XXX_Marshal 

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

func (*PartitionData) XXX_Merge 

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

func (*PartitionData) XXX_Size 

func (m *PartitionData) XXX_Size() int

func (*PartitionData) XXX_Unmarshal 

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

type RaftCommand 

type RaftCommand struct {
	Type                 CmdType      `protobuf:"varint,1,opt,name=type,proto3,enum=CmdType" json:"type,omitempty"`
	WriteCommand         *DocCmd      `protobuf:"bytes,2,opt,name=write_command,json=writeCommand,proto3" json:"write_command,omitempty"`
	UpdateSpace          *UpdateSpace `protobuf:"bytes,3,opt,name=update_space,json=updateSpace,proto3" json:"update_space,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func CreateRaftCommand 

func CreateRaftCommand() *RaftCommand

CreateRaftCommand create a RaftCommand object

func NewPopulatedRaftCommand 

func NewPopulatedRaftCommand(r randyRaftcmd, easy bool) *RaftCommand

func (*RaftCommand) Close 

func (c *RaftCommand) Close() error

Close reset and put to pool

func (*RaftCommand) Descriptor 

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

func (*RaftCommand) Equal 

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

func (*RaftCommand) Marshal 

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

func (*RaftCommand) MarshalTo 

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

func (*RaftCommand) MarshalToSizedBuffer 

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

func (*RaftCommand) ProtoMessage 

func (*RaftCommand) ProtoMessage()

func (*RaftCommand) Reset 

func (m *RaftCommand) Reset()

func (*RaftCommand) Size 

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

func (*RaftCommand) String 

func (this *RaftCommand) String() string

func (*RaftCommand) Unmarshal 

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

func (*RaftCommand) XXX_DiscardUnknown 

func (m *RaftCommand) XXX_DiscardUnknown()

func (*RaftCommand) XXX_Marshal 

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

func (*RaftCommand) XXX_Merge 

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

func (*RaftCommand) XXX_Size 

func (m *RaftCommand) XXX_Size() int

func (*RaftCommand) XXX_Unmarshal 

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

type RangeFilter 

type RangeFilter struct {
	Field                string   `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	LowerValue           []byte   `protobuf:"bytes,2,opt,name=lower_value,json=lowerValue,proto3" json:"lower_value,omitempty"`
	UpperValue           []byte   `protobuf:"bytes,3,opt,name=upper_value,json=upperValue,proto3" json:"upper_value,omitempty"`
	IncludeLower         bool     `protobuf:"varint,4,opt,name=include_lower,json=includeLower,proto3" json:"include_lower,omitempty"`
	IncludeUpper         bool     `protobuf:"varint,5,opt,name=include_upper,json=includeUpper,proto3" json:"include_upper,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedRangeFilter 

func NewPopulatedRangeFilter(r randyRouterGrpc, easy bool) *RangeFilter

func (*RangeFilter) Descriptor 

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

func (*RangeFilter) Equal 

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

func (*RangeFilter) Marshal 

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

func (*RangeFilter) MarshalTo 

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

func (*RangeFilter) MarshalToSizedBuffer 

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

func (*RangeFilter) ProtoMessage 

func (*RangeFilter) ProtoMessage()

func (*RangeFilter) Reset 

func (m *RangeFilter) Reset()

func (*RangeFilter) Size 

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

func (*RangeFilter) String 

func (this *RangeFilter) String() string

func (*RangeFilter) Unmarshal 

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

func (*RangeFilter) XXX_DiscardUnknown 

func (m *RangeFilter) XXX_DiscardUnknown()

func (*RangeFilter) XXX_Marshal 

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

func (*RangeFilter) XXX_Merge 

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

func (*RangeFilter) XXX_Size 

func (m *RangeFilter) XXX_Size() int

func (*RangeFilter) XXX_Unmarshal 

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

type RequestHead 

type RequestHead 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"`
	DbName     string `protobuf:"bytes,4,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	SpaceName  string `protobuf:"bytes,5,opt,name=space_name,json=spaceName,proto3" json:"space_name,omitempty"`
	ClientType string `protobuf:"bytes,6,opt,name=client_type,json=clientType,proto3" json:"client_type,omitempty"`
	// from, sort, request_id, partition_id
	Params               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func NewPopulatedRequestHead 

func NewPopulatedRequestHead(r randyRouterGrpc, easy bool) *RequestHead

func (*RequestHead) Descriptor 

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

func (*RequestHead) Equal 

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

func (*RequestHead) Marshal 

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

func (*RequestHead) MarshalTo 

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

func (*RequestHead) MarshalToSizedBuffer 

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

func (*RequestHead) ProtoMessage 

func (*RequestHead) ProtoMessage()

func (*RequestHead) Reset 

func (m *RequestHead) Reset()

func (*RequestHead) Size 

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

func (*RequestHead) String 

func (this *RequestHead) String() string

func (*RequestHead) Unmarshal 

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

func (*RequestHead) XXX_DiscardUnknown 

func (m *RequestHead) XXX_DiscardUnknown()

func (*RequestHead) XXX_Marshal 

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

func (*RequestHead) XXX_Merge 

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

func (*RequestHead) XXX_Size 

func (m *RequestHead) XXX_Size() int

func (*RequestHead) XXX_Unmarshal 

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

type ResponseHead 

type ResponseHead struct {
	Err                  *Error            `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Params               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func NewPopulatedResponseHead 

func NewPopulatedResponseHead(r randyRouterGrpc, easy bool) *ResponseHead

func (*ResponseHead) Descriptor 

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

func (*ResponseHead) Equal 

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

func (*ResponseHead) Marshal 

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

func (*ResponseHead) MarshalTo 

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

func (*ResponseHead) MarshalToSizedBuffer 

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

func (*ResponseHead) ProtoMessage 

func (*ResponseHead) ProtoMessage()

func (*ResponseHead) Reset 

func (m *ResponseHead) Reset()

func (*ResponseHead) Size 

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

func (*ResponseHead) String 

func (this *ResponseHead) String() string

func (*ResponseHead) Unmarshal 

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

func (*ResponseHead) XXX_DiscardUnknown 

func (m *ResponseHead) XXX_DiscardUnknown()

func (*ResponseHead) XXX_Marshal 

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

func (*ResponseHead) XXX_Merge 

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

func (*ResponseHead) XXX_Size 

func (m *ResponseHead) XXX_Size() int

func (*ResponseHead) XXX_Unmarshal 

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

type ResultItem 

type ResultItem struct {
	Score                float64  `protobuf:"fixed64,1,opt,name=score,proto3" json:"score,omitempty"`
	Fields               []*Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	Extra                string   `protobuf:"bytes,3,opt,name=extra,proto3" json:"extra,omitempty"`
	PKey                 string   `protobuf:"bytes,4,opt,name=p_key,json=pKey,proto3" json:"p_key,omitempty"`
	Source               []byte   `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedResultItem 

func NewPopulatedResultItem(r randyRouterGrpc, easy bool) *ResultItem

func (*ResultItem) Descriptor 

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

func (*ResultItem) Equal 

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

func (*ResultItem) Marshal 

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

func (*ResultItem) MarshalTo 

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

func (*ResultItem) MarshalToSizedBuffer 

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

func (*ResultItem) ProtoMessage 

func (*ResultItem) ProtoMessage()

func (*ResultItem) Reset 

func (m *ResultItem) Reset()

func (*ResultItem) Size 

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

func (*ResultItem) String 

func (this *ResultItem) String() string

func (*ResultItem) Unmarshal 

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

func (*ResultItem) XXX_DiscardUnknown 

func (m *ResultItem) XXX_DiscardUnknown()

func (*ResultItem) XXX_Marshal 

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

func (*ResultItem) XXX_Merge 

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

func (*ResultItem) XXX_Size 

func (m *ResultItem) XXX_Size() int

func (*ResultItem) XXX_Unmarshal 

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

type RetrievalParameters 

type RetrievalParameters struct {
	MetricType           RetrievalParameters_DistanceMetricType `` /* 136-byte string literal not displayed */
	Nprobe               int32                                  `protobuf:"varint,2,opt,name=nprobe,proto3" json:"nprobe,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                               `json:"-"`
	XXX_unrecognized     []byte                                 `json:"-"`
	XXX_sizecache        int32                                  `json:"-"`
}

func NewPopulatedRetrievalParameters 

func NewPopulatedRetrievalParameters(r randyRouterGrpc, easy bool) *RetrievalParameters

func (*RetrievalParameters) Descriptor 

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

func (*RetrievalParameters) Equal 

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

func (*RetrievalParameters) Marshal 

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

func (*RetrievalParameters) MarshalTo 

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

func (*RetrievalParameters) MarshalToSizedBuffer 

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

func (*RetrievalParameters) ProtoMessage 

func (*RetrievalParameters) ProtoMessage()

func (*RetrievalParameters) Reset 

func (m *RetrievalParameters) Reset()

func (*RetrievalParameters) Size 

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

func (*RetrievalParameters) String 

func (this *RetrievalParameters) String() string

func (*RetrievalParameters) Unmarshal 

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

func (*RetrievalParameters) XXX_DiscardUnknown 

func (m *RetrievalParameters) XXX_DiscardUnknown()

func (*RetrievalParameters) XXX_Marshal 

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

func (*RetrievalParameters) XXX_Merge 

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

func (*RetrievalParameters) XXX_Size 

func (m *RetrievalParameters) XXX_Size() int

func (*RetrievalParameters) XXX_Unmarshal 

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

type RetrievalParameters_DistanceMetricType 

type RetrievalParameters_DistanceMetricType int32
const (
	RetrievalParameters_InnerProduct RetrievalParameters_DistanceMetricType = 0
	RetrievalParameters_L2           RetrievalParameters_DistanceMetricType = 1
)

func (RetrievalParameters_DistanceMetricType) EnumDescriptor 

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

func (RetrievalParameters_DistanceMetricType) String 

func (x RetrievalParameters_DistanceMetricType) String() string

type RouterGRPCServiceClient 

type RouterGRPCServiceClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	Bulk(ctx context.Context, in *BulkRequest, opts ...grpc.CallOption) (*BulkResponse, error)
	MSearch(ctx context.Context, in *MSearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	Space(ctx context.Context, in *RequestHead, opts ...grpc.CallOption) (*Table, error)
	SearchByID(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
}

RouterGRPCServiceClient is the client API for RouterGRPCService service.

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

func NewRouterGRPCServiceClient 

func NewRouterGRPCServiceClient(cc *grpc.ClientConn) RouterGRPCServiceClient

type RouterGRPCServiceServer 

type RouterGRPCServiceServer interface {
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Add(context.Context, *AddRequest) (*AddResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	Search(context.Context, *SearchRequest) (*SearchResponse, error)
	Bulk(context.Context, *BulkRequest) (*BulkResponse, error)
	MSearch(context.Context, *MSearchRequest) (*SearchResponse, error)
	Space(context.Context, *RequestHead) (*Table, error)
	SearchByID(context.Context, *SearchRequest) (*SearchResponse, error)
}

RouterGRPCServiceServer is the server API for RouterGRPCService service.

type SearchRequest 

type SearchRequest struct {
	Head                 *RequestHead      `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	ReqNum               int32             `protobuf:"varint,2,opt,name=req_num,json=reqNum,proto3" json:"req_num,omitempty"`
	TopN                 int32             `protobuf:"varint,3,opt,name=topN,proto3" json:"topN,omitempty"`
	IsBruteSearch        int32             `protobuf:"varint,4,opt,name=is_brute_search,json=isBruteSearch,proto3" json:"is_brute_search,omitempty"`
	VecFields            []*VectorQuery    `protobuf:"bytes,5,rep,name=vec_fields,json=vecFields,proto3" json:"vec_fields,omitempty"`
	Fields               []string          `protobuf:"bytes,6,rep,name=fields,proto3" json:"fields,omitempty"`
	RangeFilters         []*RangeFilter    `protobuf:"bytes,7,rep,name=range_filters,json=rangeFilters,proto3" json:"range_filters,omitempty"`
	TermFilters          []*TermFilter     `protobuf:"bytes,8,rep,name=term_filters,json=termFilters,proto3" json:"term_filters,omitempty"`
	OnlineLogLevel       string            `protobuf:"bytes,9,opt,name=online_log_level,json=onlineLogLevel,proto3" json:"online_log_level,omitempty"`
	RetrievalParams      string            `protobuf:"bytes,10,opt,name=retrieval_params,json=retrievalParams,proto3" json:"retrieval_params,omitempty"`
	HasRank              bool              `protobuf:"varint,11,opt,name=has_rank,json=hasRank,proto3" json:"has_rank,omitempty"`
	MultiVectorRank      int32             `protobuf:"varint,12,opt,name=multi_vector_rank,json=multiVectorRank,proto3" json:"multi_vector_rank,omitempty"`
	ParallelBasedOnQuery bool              `` /* 127-byte string literal not displayed */
	L2Sqrt               bool              `protobuf:"varint,14,opt,name=l2_sqrt,json=l2Sqrt,proto3" json:"l2_sqrt,omitempty"`
	IvfFlat              bool              `protobuf:"varint,15,opt,name=ivf_flat,json=ivfFlat,proto3" json:"ivf_flat,omitempty"`
	IsVectorValue        bool              `protobuf:"varint,16,opt,name=is_vector_value,json=isVectorValue,proto3" json:"is_vector_value,omitempty"`
	SortFieldMap         map[string]string `` /* 188-byte string literal not displayed */
	SortFields           []*SortField      `protobuf:"bytes,18,rep,name=sort_fields,json=sortFields,proto3" json:"sort_fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func NewPopulatedSearchRequest 

func NewPopulatedSearchRequest(r randyRouterGrpc, easy bool) *SearchRequest

func (*SearchRequest) Descriptor 

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

func (*SearchRequest) Equal 

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

func (*SearchRequest) GetFields 

func (m *SearchRequest) GetFields() []string

func (*SearchRequest) GetHasRank 

func (m *SearchRequest) GetHasRank() bool

func (*SearchRequest) GetHead 

func (m *SearchRequest) GetHead() *RequestHead

func (*SearchRequest) GetIsBruteSearch 

func (m *SearchRequest) GetIsBruteSearch() int32

func (*SearchRequest) GetIsVectorValue 

func (m *SearchRequest) GetIsVectorValue() bool

func (*SearchRequest) GetIvfFlat 

func (m *SearchRequest) GetIvfFlat() bool

func (*SearchRequest) GetL2Sqrt 

func (m *SearchRequest) GetL2Sqrt() bool

func (*SearchRequest) GetMultiVectorRank 

func (m *SearchRequest) GetMultiVectorRank() int32

func (*SearchRequest) GetOnlineLogLevel 

func (m *SearchRequest) GetOnlineLogLevel() string

func (*SearchRequest) GetParallelBasedOnQuery 

func (m *SearchRequest) GetParallelBasedOnQuery() bool

func (*SearchRequest) GetRangeFilters 

func (m *SearchRequest) GetRangeFilters() []*RangeFilter

func (*SearchRequest) GetReqNum 

func (m *SearchRequest) GetReqNum() int32

func (*SearchRequest) GetRetrievalParams 

func (m *SearchRequest) GetRetrievalParams() string

func (*SearchRequest) GetSortFieldMap 

func (m *SearchRequest) GetSortFieldMap() map[string]string

func (*SearchRequest) GetSortFields 

func (m *SearchRequest) GetSortFields() []*SortField

func (*SearchRequest) GetTermFilters 

func (m *SearchRequest) GetTermFilters() []*TermFilter

func (*SearchRequest) GetTopN 

func (m *SearchRequest) GetTopN() int32

func (*SearchRequest) GetVecFields 

func (m *SearchRequest) GetVecFields() []*VectorQuery

func (*SearchRequest) Marshal 

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

func (*SearchRequest) MarshalTo 

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

func (*SearchRequest) MarshalToSizedBuffer 

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

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset 

func (m *SearchRequest) Reset()

func (*SearchRequest) Size 

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

func (*SearchRequest) String 

func (this *SearchRequest) String() string

func (*SearchRequest) Unmarshal 

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

func (*SearchRequest) XXX_DiscardUnknown 

func (m *SearchRequest) XXX_DiscardUnknown()

func (*SearchRequest) XXX_Marshal 

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

func (*SearchRequest) XXX_Merge 

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

func (*SearchRequest) XXX_Size 

func (m *SearchRequest) XXX_Size() int

func (*SearchRequest) XXX_Unmarshal 

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

type SearchResponse 

type SearchResponse struct {
	Head                 *ResponseHead     `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Results              []*SearchResult   `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	OnlineLogMessage     string            `protobuf:"bytes,3,opt,name=online_log_message,json=onlineLogMessage,proto3" json:"online_log_message,omitempty"`
	Timeout              bool              `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	FlatBytes            []byte            `protobuf:"bytes,5,opt,name=FlatBytes,proto3" json:"FlatBytes,omitempty"`
	SortFieldMap         map[string]string `` /* 187-byte string literal not displayed */
	TopSize              int32             `protobuf:"varint,7,opt,name=top_size,json=topSize,proto3" json:"top_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func NewPopulatedSearchResponse 

func NewPopulatedSearchResponse(r randyRouterGrpc, easy bool) *SearchResponse

func (*SearchResponse) Descriptor 

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

func (*SearchResponse) Equal 

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

func (*SearchResponse) GetFlatBytes 

func (m *SearchResponse) GetFlatBytes() []byte

func (*SearchResponse) GetHead 

func (m *SearchResponse) GetHead() *ResponseHead

func (*SearchResponse) GetOnlineLogMessage 

func (m *SearchResponse) GetOnlineLogMessage() string

func (*SearchResponse) GetResults 

func (m *SearchResponse) GetResults() []*SearchResult

func (*SearchResponse) GetSortFieldMap 

func (m *SearchResponse) GetSortFieldMap() map[string]string

func (*SearchResponse) GetTimeout 

func (m *SearchResponse) GetTimeout() bool

func (*SearchResponse) GetTopSize 

func (m *SearchResponse) GetTopSize() int32

func (*SearchResponse) Marshal 

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

func (*SearchResponse) MarshalTo 

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

func (*SearchResponse) MarshalToSizedBuffer 

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

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset 

func (m *SearchResponse) Reset()

func (*SearchResponse) Size 

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

func (*SearchResponse) String 

func (this *SearchResponse) String() string

func (*SearchResponse) Unmarshal 

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

func (*SearchResponse) XXX_DiscardUnknown 

func (m *SearchResponse) XXX_DiscardUnknown()

func (*SearchResponse) XXX_Marshal 

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

func (*SearchResponse) XXX_Merge 

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

func (*SearchResponse) XXX_Size 

func (m *SearchResponse) XXX_Size() int

func (*SearchResponse) XXX_Unmarshal 

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

type SearchResult 

type SearchResult struct {
	TotalHits            int32             `protobuf:"varint,1,opt,name=total_hits,json=totalHits,proto3" json:"total_hits,omitempty"`
	MaxScore             float64           `protobuf:"fixed64,2,opt,name=max_score,json=maxScore,proto3" json:"max_score,omitempty"`
	MaxTook              int64             `protobuf:"varint,3,opt,name=max_took,json=maxTook,proto3" json:"max_took,omitempty"`
	MaxTookId            uint32            `protobuf:"varint,4,opt,name=max_took_id,json=maxTookId,proto3" json:"max_took_id,omitempty"`
	Status               *SearchStatus     `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	Msg                  string            `protobuf:"bytes,6,opt,name=msg,proto3" json:"msg,omitempty"`
	ResultItems          []*ResultItem     `protobuf:"bytes,7,rep,name=result_items,json=resultItems,proto3" json:"result_items,omitempty"`
	PID                  uint32            `protobuf:"varint,8,opt,name=pID,proto3" json:"pID,omitempty"`
	Explain              map[uint32]string `` /* 156-byte string literal not displayed */
	Timeout              bool              `protobuf:"varint,10,opt,name=timeout,proto3" json:"timeout,omitempty"`
	TopN                 int32             `protobuf:"varint,11,opt,name=topN,proto3" json:"topN,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func NewPopulatedSearchResult 

func NewPopulatedSearchResult(r randyRouterGrpc, easy bool) *SearchResult

func (*SearchResult) Descriptor 

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

func (*SearchResult) Equal 

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

func (*SearchResult) Marshal 

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

func (*SearchResult) MarshalTo 

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

func (*SearchResult) MarshalToSizedBuffer 

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

func (*SearchResult) ProtoMessage 

func (*SearchResult) ProtoMessage()

func (*SearchResult) Reset 

func (m *SearchResult) Reset()

func (*SearchResult) Size 

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

func (*SearchResult) String 

func (this *SearchResult) String() string

func (*SearchResult) Unmarshal 

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

func (*SearchResult) XXX_DiscardUnknown 

func (m *SearchResult) XXX_DiscardUnknown()

func (*SearchResult) XXX_Marshal 

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

func (*SearchResult) XXX_Merge 

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

func (*SearchResult) XXX_Size 

func (m *SearchResult) XXX_Size() int

func (*SearchResult) XXX_Unmarshal 

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

type SearchResultCode 

type SearchResultCode int32
const (
	SearchResultCode_SEARCH_SUCCESS    SearchResultCode = 0
	SearchResultCode_INDEX_NOT_BUILDED SearchResultCode = 1
	SearchResultCode_SEARCH_ERROR      SearchResultCode = 2
)

func (SearchResultCode) EnumDescriptor 

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

func (SearchResultCode) String 

func (x SearchResultCode) String() string

type SearchStatus 

type SearchStatus struct {
	Total                int32    `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Failed               int32    `protobuf:"varint,2,opt,name=failed,proto3" json:"failed,omitempty"`
	Successful           int32    `protobuf:"varint,3,opt,name=successful,proto3" json:"successful,omitempty"`
	Msg                  string   `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedSearchStatus 

func NewPopulatedSearchStatus(r randyRouterGrpc, easy bool) *SearchStatus

func (*SearchStatus) Descriptor 

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

func (*SearchStatus) Equal 

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

func (*SearchStatus) Marshal 

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

func (*SearchStatus) MarshalTo 

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

func (*SearchStatus) MarshalToSizedBuffer 

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

func (*SearchStatus) ProtoMessage 

func (*SearchStatus) ProtoMessage()

func (*SearchStatus) Reset 

func (m *SearchStatus) Reset()

func (*SearchStatus) Size 

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

func (*SearchStatus) String 

func (this *SearchStatus) String() string

func (*SearchStatus) Unmarshal 

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

func (*SearchStatus) XXX_DiscardUnknown 

func (m *SearchStatus) XXX_DiscardUnknown()

func (*SearchStatus) XXX_Marshal 

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

func (*SearchStatus) XXX_Merge 

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

func (*SearchStatus) XXX_Size 

func (m *SearchStatus) XXX_Size() int

func (*SearchStatus) XXX_Unmarshal 

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

type SnapData 

type SnapData struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedSnapData 

func NewPopulatedSnapData(r randyRaftcmd, easy bool) *SnapData

func (*SnapData) Descriptor 

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

func (*SnapData) Equal 

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

func (*SnapData) Marshal 

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

func (*SnapData) MarshalTo 

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

func (*SnapData) MarshalToSizedBuffer 

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

func (*SnapData) ProtoMessage 

func (*SnapData) ProtoMessage()

func (*SnapData) Reset 

func (m *SnapData) Reset()

func (*SnapData) Size 

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

func (*SnapData) String 

func (this *SnapData) String() string

func (*SnapData) Unmarshal 

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

func (*SnapData) XXX_DiscardUnknown 

func (m *SnapData) XXX_DiscardUnknown()

func (*SnapData) XXX_Marshal 

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

func (*SnapData) XXX_Merge 

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

func (*SnapData) XXX_Size 

func (m *SnapData) XXX_Size() int

func (*SnapData) XXX_Unmarshal 

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

type SnapshotMsg 

type SnapshotMsg struct {
	// 文件带路径全名称
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// 文件内容
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// 处理状态
	Status               SnapshotStatus `protobuf:"varint,3,opt,name=status,proto3,enum=SnapshotStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

snapshot消息体

func NewPopulatedSnapshotMsg 

func NewPopulatedSnapshotMsg(r randySnapshot, easy bool) *SnapshotMsg

func (*SnapshotMsg) Descriptor 

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

func (*SnapshotMsg) Equal 

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

func (*SnapshotMsg) Marshal 

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

func (*SnapshotMsg) MarshalTo 

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

func (*SnapshotMsg) MarshalToSizedBuffer 

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

func (*SnapshotMsg) ProtoMessage 

func (*SnapshotMsg) ProtoMessage()

func (*SnapshotMsg) Reset 

func (m *SnapshotMsg) Reset()

func (*SnapshotMsg) Size 

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

func (*SnapshotMsg) String 

func (this *SnapshotMsg) String() string

func (*SnapshotMsg) Unmarshal 

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

func (*SnapshotMsg) XXX_DiscardUnknown 

func (m *SnapshotMsg) XXX_DiscardUnknown()

func (*SnapshotMsg) XXX_Marshal 

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

func (*SnapshotMsg) XXX_Merge 

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

func (*SnapshotMsg) XXX_Size 

func (m *SnapshotMsg) XXX_Size() int

func (*SnapshotMsg) XXX_Unmarshal 

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

type SnapshotStatus 

type SnapshotStatus int32

snapshot状态 

const (
	SnapshotStatus_UnUse   SnapshotStatus = 0
	SnapshotStatus_Start   SnapshotStatus = 1
	SnapshotStatus_Running SnapshotStatus = 2
	SnapshotStatus_Finish  SnapshotStatus = 3
)

func (SnapshotStatus) EnumDescriptor 

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

func (SnapshotStatus) String 

func (x SnapshotStatus) String() string

type SortField 

type SortField struct {
	Field                string   `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Type                 bool     `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedSortField 

func NewPopulatedSortField(r randyRouterGrpc, easy bool) *SortField

func (*SortField) Descriptor 

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

func (*SortField) Equal 

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

func (*SortField) Marshal 

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

func (*SortField) MarshalTo 

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

func (*SortField) MarshalToSizedBuffer 

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

func (*SortField) ProtoMessage 

func (*SortField) ProtoMessage()

func (*SortField) Reset 

func (m *SortField) Reset()

func (*SortField) Size 

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

func (*SortField) String 

func (this *SortField) String() string

func (*SortField) Unmarshal 

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

func (*SortField) XXX_DiscardUnknown 

func (m *SortField) XXX_DiscardUnknown()

func (*SortField) XXX_Marshal 

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

func (*SortField) XXX_Merge 

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

func (*SortField) XXX_Size 

func (m *SortField) XXX_Size() int

func (*SortField) XXX_Unmarshal 

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

type Table 

type Table struct {
	Name                 string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	TableMetaInfo        *TableMetaInfo `protobuf:"bytes,2,opt,name=table_meta_info,json=tableMetaInfo,proto3" json:"table_meta_info,omitempty"`
	StartIndexingSize    int32          `protobuf:"varint,3,opt,name=start_indexing_size,json=startIndexingSize,proto3" json:"start_indexing_size,omitempty"`
	Model                *Model         `protobuf:"bytes,4,opt,name=model,proto3" json:"model,omitempty"`
	TotalDocsSize        int64          `protobuf:"varint,5,opt,name=total_docs_size,json=totalDocsSize,proto3" json:"total_docs_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func NewPopulatedTable 

func NewPopulatedTable(r randyDataModel, easy bool) *Table

func (*Table) Descriptor 

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

func (*Table) Equal 

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

func (*Table) Marshal 

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

func (*Table) MarshalTo 

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

func (*Table) MarshalToSizedBuffer 

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

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) Reset 

func (m *Table) Reset()

func (*Table) Size 

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

func (*Table) String 

func (this *Table) String() string

func (*Table) Unmarshal 

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

func (*Table) XXX_DiscardUnknown 

func (m *Table) XXX_DiscardUnknown()

func (*Table) XXX_Marshal 

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

func (*Table) XXX_Merge 

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

func (*Table) XXX_Size 

func (m *Table) XXX_Size() int

func (*Table) XXX_Unmarshal 

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

type TableMetaInfo 

type TableMetaInfo struct {
	PrimaryKeyName       string           `protobuf:"bytes,1,opt,name=primary_key_name,json=primaryKeyName,proto3" json:"primary_key_name,omitempty"`
	PrimaryKeyType       FieldType        `protobuf:"varint,2,opt,name=primary_key_type,json=primaryKeyType,proto3,enum=FieldType" json:"primary_key_type,omitempty"`
	PartitionsNum        int32            `protobuf:"varint,3,opt,name=partitions_num,json=partitionsNum,proto3" json:"partitions_num,omitempty"`
	ReplicasNum          int32            `protobuf:"varint,4,opt,name=replicas_num,json=replicasNum,proto3" json:"replicas_num,omitempty"`
	FieldMetaInfo        []*FieldMetaInfo `protobuf:"bytes,5,rep,name=field_meta_info,json=fieldMetaInfo,proto3" json:"field_meta_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func NewPopulatedTableMetaInfo 

func NewPopulatedTableMetaInfo(r randyDataModel, easy bool) *TableMetaInfo

func (*TableMetaInfo) Descriptor 

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

func (*TableMetaInfo) Equal 

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

func (*TableMetaInfo) Marshal 

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

func (*TableMetaInfo) MarshalTo 

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

func (*TableMetaInfo) MarshalToSizedBuffer 

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

func (*TableMetaInfo) ProtoMessage 

func (*TableMetaInfo) ProtoMessage()

func (*TableMetaInfo) Reset 

func (m *TableMetaInfo) Reset()

func (*TableMetaInfo) Size 

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

func (*TableMetaInfo) String 

func (this *TableMetaInfo) String() string

func (*TableMetaInfo) Unmarshal 

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

func (*TableMetaInfo) XXX_DiscardUnknown 

func (m *TableMetaInfo) XXX_DiscardUnknown()

func (*TableMetaInfo) XXX_Marshal 

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

func (*TableMetaInfo) XXX_Merge 

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

func (*TableMetaInfo) XXX_Size 

func (m *TableMetaInfo) XXX_Size() int

func (*TableMetaInfo) XXX_Unmarshal 

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

type TermFilter 

type TermFilter struct {
	Field                string   `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	IsUnion              int32    `protobuf:"varint,3,opt,name=is_union,json=isUnion,proto3" json:"is_union,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedTermFilter 

func NewPopulatedTermFilter(r randyRouterGrpc, easy bool) *TermFilter

func (*TermFilter) Descriptor 

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

func (*TermFilter) Equal 

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

func (*TermFilter) Marshal 

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

func (*TermFilter) MarshalTo 

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

func (*TermFilter) MarshalToSizedBuffer 

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

func (*TermFilter) ProtoMessage 

func (*TermFilter) ProtoMessage()

func (*TermFilter) Reset 

func (m *TermFilter) Reset()

func (*TermFilter) Size 

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

func (*TermFilter) String 

func (this *TermFilter) String() string

func (*TermFilter) Unmarshal 

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

func (*TermFilter) XXX_DiscardUnknown 

func (m *TermFilter) XXX_DiscardUnknown()

func (*TermFilter) XXX_Marshal 

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

func (*TermFilter) XXX_Merge 

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

func (*TermFilter) XXX_Size 

func (m *TermFilter) XXX_Size() int

func (*TermFilter) XXX_Unmarshal 

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

type UnimplementedRouterGRPCServiceServer 

type UnimplementedRouterGRPCServiceServer struct {
}

UnimplementedRouterGRPCServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRouterGRPCServiceServer) Add 

func (*UnimplementedRouterGRPCServiceServer) Add(ctx context.Context, req *AddRequest) (*AddResponse, error)

func (*UnimplementedRouterGRPCServiceServer) Bulk 

func (*UnimplementedRouterGRPCServiceServer) Bulk(ctx context.Context, req *BulkRequest) (*BulkResponse, error)

func (*UnimplementedRouterGRPCServiceServer) Delete 

func (*UnimplementedRouterGRPCServiceServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

func (*UnimplementedRouterGRPCServiceServer) Get 

func (*UnimplementedRouterGRPCServiceServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedRouterGRPCServiceServer) MSearch 

func (*UnimplementedRouterGRPCServiceServer) MSearch(ctx context.Context, req *MSearchRequest) (*SearchResponse, error)

func (*UnimplementedRouterGRPCServiceServer) Search 

func (*UnimplementedRouterGRPCServiceServer) Search(ctx context.Context, req *SearchRequest) (*SearchResponse, error)

func (*UnimplementedRouterGRPCServiceServer) SearchByID 

func (*UnimplementedRouterGRPCServiceServer) SearchByID(ctx context.Context, req *SearchRequest) (*SearchResponse, error)

func (*UnimplementedRouterGRPCServiceServer) Space 

func (*UnimplementedRouterGRPCServiceServer) Space(ctx context.Context, req *RequestHead) (*Table, error)

func (*UnimplementedRouterGRPCServiceServer) Update 

func (*UnimplementedRouterGRPCServiceServer) Update(ctx context.Context, req *UpdateRequest) (*UpdateResponse, error)

type UpdateRequest 

type UpdateRequest struct {
	Head                 *RequestHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Doc                  *Document    `protobuf:"bytes,4,opt,name=doc,proto3" json:"doc,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func NewPopulatedUpdateRequest 

func NewPopulatedUpdateRequest(r randyRouterGrpc, easy bool) *UpdateRequest

func (*UpdateRequest) Descriptor 

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

func (*UpdateRequest) Equal 

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

func (*UpdateRequest) GetDoc 

func (m *UpdateRequest) GetDoc() *Document

func (*UpdateRequest) GetHead 

func (m *UpdateRequest) GetHead() *RequestHead

func (*UpdateRequest) Marshal 

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

func (*UpdateRequest) MarshalTo 

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

func (*UpdateRequest) MarshalToSizedBuffer 

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

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) Reset 

func (m *UpdateRequest) Reset()

func (*UpdateRequest) Size 

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

func (*UpdateRequest) String 

func (this *UpdateRequest) String() string

func (*UpdateRequest) Unmarshal 

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

func (*UpdateRequest) XXX_DiscardUnknown 

func (m *UpdateRequest) XXX_DiscardUnknown()

func (*UpdateRequest) XXX_Marshal 

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

func (*UpdateRequest) XXX_Merge 

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

func (*UpdateRequest) XXX_Size 

func (m *UpdateRequest) XXX_Size() int

func (*UpdateRequest) XXX_Unmarshal 

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

type UpdateResponse 

type UpdateResponse struct {
	Head                 *ResponseHead `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewPopulatedUpdateResponse 

func NewPopulatedUpdateResponse(r randyRouterGrpc, easy bool) *UpdateResponse

func (*UpdateResponse) Descriptor 

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

func (*UpdateResponse) Equal 

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

func (*UpdateResponse) GetHead 

func (m *UpdateResponse) GetHead() *ResponseHead

func (*UpdateResponse) Marshal 

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

func (*UpdateResponse) MarshalTo 

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

func (*UpdateResponse) MarshalToSizedBuffer 

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

func (*UpdateResponse) ProtoMessage 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) Reset 

func (m *UpdateResponse) Reset()

func (*UpdateResponse) Size 

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

func (*UpdateResponse) String 

func (this *UpdateResponse) String() string

func (*UpdateResponse) Unmarshal 

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

func (*UpdateResponse) XXX_DiscardUnknown 

func (m *UpdateResponse) XXX_DiscardUnknown()

func (*UpdateResponse) XXX_Marshal 

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

func (*UpdateResponse) XXX_Merge 

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

func (*UpdateResponse) XXX_Size 

func (m *UpdateResponse) XXX_Size() int

func (*UpdateResponse) XXX_Unmarshal 

func (m *UpdateResponse) XXX_Unmarshal(b []byte) 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:"-"`
}

*********************** Raft *********************** //

func NewPopulatedUpdateSpace 

func NewPopulatedUpdateSpace(r randyRaftcmd, 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 VearchErr 

type VearchErr struct {
	// contains filtered or unexported fields
}

func NewError 

func NewError(code ErrorEnum, err error) (vErr *VearchErr)

func NewErrorInfo 

func NewErrorInfo(code ErrorEnum, msg string) (vErr *VearchErr)

func (*VearchErr) Error 

func (v *VearchErr) Error() string

func (*VearchErr) GetError 

func (v *VearchErr) GetError() *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 randyDataModel, 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

type VectorMetaInfo 

type VectorMetaInfo struct {
	Dimension            int32                    `protobuf:"varint,1,opt,name=dimension,proto3" json:"dimension,omitempty"`
	ValueType            VectorMetaInfo_ValueType `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=VectorMetaInfo_ValueType" json:"value_type,omitempty"`
	StoreType            VectorMetaInfo_StoreType `protobuf:"varint,3,opt,name=store_type,json=storeType,proto3,enum=VectorMetaInfo_StoreType" json:"store_type,omitempty"`
	StoreParam           string                   `protobuf:"bytes,4,opt,name=store_param,json=storeParam,proto3" json:"store_param,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func NewPopulatedVectorMetaInfo 

func NewPopulatedVectorMetaInfo(r randyDataModel, easy bool) *VectorMetaInfo

func (*VectorMetaInfo) Descriptor 

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

func (*VectorMetaInfo) Equal 

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

func (*VectorMetaInfo) Marshal 

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

func (*VectorMetaInfo) MarshalTo 

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

func (*VectorMetaInfo) MarshalToSizedBuffer 

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

func (*VectorMetaInfo) ProtoMessage 

func (*VectorMetaInfo) ProtoMessage()

func (*VectorMetaInfo) Reset 

func (m *VectorMetaInfo) Reset()

func (*VectorMetaInfo) Size 

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

func (*VectorMetaInfo) String 

func (this *VectorMetaInfo) String() string

func (*VectorMetaInfo) Unmarshal 

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

func (*VectorMetaInfo) XXX_DiscardUnknown 

func (m *VectorMetaInfo) XXX_DiscardUnknown()

func (*VectorMetaInfo) XXX_Marshal 

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

func (*VectorMetaInfo) XXX_Merge 

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

func (*VectorMetaInfo) XXX_Size 

func (m *VectorMetaInfo) XXX_Size() int

func (*VectorMetaInfo) XXX_Unmarshal 

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

type VectorMetaInfo_StoreType 

type VectorMetaInfo_StoreType int32
const (
	VectorMetaInfo_MEMORYONLY VectorMetaInfo_StoreType = 0
	VectorMetaInfo_ROCKSDB    VectorMetaInfo_StoreType = 1
	VectorMetaInfo_MMAP       VectorMetaInfo_StoreType = 2
)

func (VectorMetaInfo_StoreType) EnumDescriptor 

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

func (VectorMetaInfo_StoreType) String 

func (x VectorMetaInfo_StoreType) String() string

type VectorMetaInfo_ValueType 

type VectorMetaInfo_ValueType int32
const (
	VectorMetaInfo_FLOAT VectorMetaInfo_ValueType = 0
	VectorMetaInfo_UINT8 VectorMetaInfo_ValueType = 1
)

func (VectorMetaInfo_ValueType) EnumDescriptor 

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

func (VectorMetaInfo_ValueType) String 

func (x VectorMetaInfo_ValueType) String() string

type VectorQuery 

type VectorQuery struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	MinScore             float64  `protobuf:"fixed64,3,opt,name=min_score,json=minScore,proto3" json:"min_score,omitempty"`
	MaxScore             float64  `protobuf:"fixed64,4,opt,name=max_score,json=maxScore,proto3" json:"max_score,omitempty"`
	Boost                float64  `protobuf:"fixed64,5,opt,name=boost,proto3" json:"boost,omitempty"`
	HasBoost             int32    `protobuf:"varint,6,opt,name=has_boost,json=hasBoost,proto3" json:"has_boost,omitempty"`
	Format               string   `protobuf:"bytes,7,opt,name=format,proto3" json:"format,omitempty"`
	RetrievalType        string   `protobuf:"bytes,8,opt,name=retrieval_type,json=retrievalType,proto3" json:"retrieval_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedVectorQuery 

func NewPopulatedVectorQuery(r randyRouterGrpc, easy bool) *VectorQuery

func (*VectorQuery) Descriptor 

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

func (*VectorQuery) Equal 

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

func (*VectorQuery) Marshal 

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

func (*VectorQuery) MarshalTo 

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

func (*VectorQuery) MarshalToSizedBuffer 

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

func (*VectorQuery) ProtoMessage 

func (*VectorQuery) ProtoMessage()

func (*VectorQuery) Reset 

func (m *VectorQuery) Reset()

func (*VectorQuery) Size 

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

func (*VectorQuery) String 

func (this *VectorQuery) String() string

func (*VectorQuery) Unmarshal 

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

func (*VectorQuery) XXX_DiscardUnknown 

func (m *VectorQuery) XXX_DiscardUnknown()

func (*VectorQuery) XXX_Marshal 

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

func (*VectorQuery) XXX_Merge 

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

func (*VectorQuery) XXX_Size 

func (m *VectorQuery) XXX_Size() int

func (*VectorQuery) XXX_Unmarshal 

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

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.