anndb_pb

package
v0.0.2-0...-6735cf7 Latest Latest
Warning

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

 Go to latest Published: May 2, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DatasetManagerChangeType_name = map[int32]string{
	0: "DatasetManagerCreateDataset",
	1: "DatasetManagerDeleteDataset",
	2: "DatasetManagerUpdatePartitionNodes",
}
View Source 
var DatasetManagerChangeType_value = map[string]int32{
	"DatasetManagerCreateDataset":        0,
	"DatasetManagerDeleteDataset":        1,
	"DatasetManagerUpdatePartitionNodes": 2,
}
View Source 
var DatasetPartitionNodesChangeType_name = map[int32]string{
	0: "DatasetPartitionNodesChangeAddNode",
	1: "DatasetPartitionNodesChangeRemoveNode",
}
View Source 
var DatasetPartitionNodesChangeType_value = map[string]int32{
	"DatasetPartitionNodesChangeAddNode":    0,
	"DatasetPartitionNodesChangeRemoveNode": 1,
}
View Source 
var PartitionChangeType_name = map[int32]string{
	0: "PartitionChangeInsertValue",
	1: "PartitionChangeUpdateValue",
	2: "PartitionChangeDeleteValue",
	3: "PartitionChangeBatchInsertValue",
	4: "PartitionChangeBatchUpdateValue",
	5: "PartitionChangeBatchDeleteValue",
}
View Source 
var PartitionChangeType_value = map[string]int32{
	"PartitionChangeInsertValue":      0,
	"PartitionChangeUpdateValue":      1,
	"PartitionChangeDeleteValue":      2,
	"PartitionChangeBatchInsertValue": 3,
	"PartitionChangeBatchUpdateValue": 4,
	"PartitionChangeBatchDeleteValue": 5,
}
View Source 
var Space_name = map[int32]string{
	0: "Euclidean",
	1: "Manhattan",
	2: "Cosine",
}
View Source 
var Space_value = map[string]int32{
	"Euclidean": 0,
	"Manhattan": 1,
	"Cosine":    2,
}

Functions

func RegisterDataManagerServer 

func RegisterDataManagerServer(s *grpc.Server, srv DataManagerServer)

func RegisterDatasetManagerServer 

func RegisterDatasetManagerServer(s *grpc.Server, srv DatasetManagerServer)

func RegisterNodesManagerServer 

func RegisterNodesManagerServer(s *grpc.Server, srv NodesManagerServer)

func RegisterRaftTransportServer 

func RegisterRaftTransportServer(s *grpc.Server, srv RaftTransportServer)

func RegisterSearchServer 

func RegisterSearchServer(s *grpc.Server, srv SearchServer)

Types

type BatchItem 

type BatchItem struct {
	Id                   []byte            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Value                []float32         `protobuf:"fixed32,2,rep,packed,name=value,proto3" json:"value,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	Level                int32             `protobuf:"varint,4,opt,name=level,proto3" json:"level,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*BatchItem) Descriptor 

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

func (*BatchItem) GetId 

func (m *BatchItem) GetId() []byte

func (*BatchItem) GetLevel 

func (m *BatchItem) GetLevel() int32

func (*BatchItem) GetMetadata 

func (m *BatchItem) GetMetadata() map[string]string

func (*BatchItem) GetValue 

func (m *BatchItem) GetValue() []float32

func (*BatchItem) ProtoMessage 

func (*BatchItem) ProtoMessage()

func (*BatchItem) Reset 

func (m *BatchItem) Reset()

func (*BatchItem) String 

func (m *BatchItem) String() string

func (*BatchItem) XXX_DiscardUnknown 

func (m *BatchItem) XXX_DiscardUnknown()

func (*BatchItem) XXX_Marshal 

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

func (*BatchItem) XXX_Merge 

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

func (*BatchItem) XXX_Size 

func (m *BatchItem) XXX_Size() int

func (*BatchItem) XXX_Unmarshal 

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

type BatchRequest 

type BatchRequest struct {
	DatasetId            []byte       `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	Items                []*BatchItem `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*BatchRequest) Descriptor 

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

func (*BatchRequest) GetDatasetId 

func (m *BatchRequest) GetDatasetId() []byte

func (*BatchRequest) GetItems 

func (m *BatchRequest) GetItems() []*BatchItem

func (*BatchRequest) ProtoMessage 

func (*BatchRequest) ProtoMessage()

func (*BatchRequest) Reset 

func (m *BatchRequest) Reset()

func (*BatchRequest) String 

func (m *BatchRequest) String() string

func (*BatchRequest) XXX_DiscardUnknown 

func (m *BatchRequest) XXX_DiscardUnknown()

func (*BatchRequest) XXX_Marshal 

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

func (*BatchRequest) XXX_Merge 

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

func (*BatchRequest) XXX_Size 

func (m *BatchRequest) XXX_Size() int

func (*BatchRequest) XXX_Unmarshal 

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

type BatchResponse 

type BatchResponse struct {
	Errors               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*BatchResponse) Descriptor 

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

func (*BatchResponse) GetErrors 

func (m *BatchResponse) GetErrors() map[string]string

func (*BatchResponse) ProtoMessage 

func (*BatchResponse) ProtoMessage()

func (*BatchResponse) Reset 

func (m *BatchResponse) Reset()

func (*BatchResponse) String 

func (m *BatchResponse) String() string

func (*BatchResponse) XXX_DiscardUnknown 

func (m *BatchResponse) XXX_DiscardUnknown()

func (*BatchResponse) XXX_Marshal 

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

func (*BatchResponse) XXX_Merge 

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

func (*BatchResponse) XXX_Size 

func (m *BatchResponse) XXX_Size() int

func (*BatchResponse) XXX_Unmarshal 

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

type DataManagerClient 

type DataManagerClient interface {
	Insert(ctx context.Context, in *InsertRequest, opts ...grpc.CallOption) (*EmptyMessage, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*EmptyMessage, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*EmptyMessage, error)
	BatchInsert(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
	BatchUpdate(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
	BatchRemove(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
	PartitionBatchInsert(ctx context.Context, in *PartitionBatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
	PartitionBatchUpdate(ctx context.Context, in *PartitionBatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
	PartitionBatchRemove(ctx context.Context, in *PartitionBatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
	PartitionInfo(ctx context.Context, in *PartitionInfoRequest, opts ...grpc.CallOption) (*PartitionInfoResponse, error)
}

DataManagerClient is the client API for DataManager service.

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

func NewDataManagerClient 

func NewDataManagerClient(cc grpc.ClientConnInterface) DataManagerClient

type DataManagerServer 

type DataManagerServer interface {
	Insert(context.Context, *InsertRequest) (*EmptyMessage, error)
	Update(context.Context, *UpdateRequest) (*EmptyMessage, error)
	Remove(context.Context, *RemoveRequest) (*EmptyMessage, error)
	BatchInsert(context.Context, *BatchRequest) (*BatchResponse, error)
	BatchUpdate(context.Context, *BatchRequest) (*BatchResponse, error)
	BatchRemove(context.Context, *BatchRequest) (*BatchResponse, error)
	PartitionBatchInsert(context.Context, *PartitionBatchRequest) (*BatchResponse, error)
	PartitionBatchUpdate(context.Context, *PartitionBatchRequest) (*BatchResponse, error)
	PartitionBatchRemove(context.Context, *PartitionBatchRequest) (*BatchResponse, error)
	PartitionInfo(context.Context, *PartitionInfoRequest) (*PartitionInfoResponse, error)
}

DataManagerServer is the server API for DataManager service.

type Dataset 

type Dataset struct {
	Id                   []byte       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Dimension            uint32       `protobuf:"varint,2,opt,name=dimension,proto3" json:"dimension,omitempty"`
	Space                Space        `protobuf:"varint,3,opt,name=space,proto3,enum=anndb_pb.Space" json:"space,omitempty"`
	PartitionCount       uint32       `protobuf:"varint,4,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	ReplicationFactor    uint32       `protobuf:"varint,5,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`
	Partitions           []*Partition `protobuf:"bytes,6,rep,name=partitions,proto3" json:"partitions,omitempty"`
	Size                 uint64       `protobuf:"varint,7,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Dataset) Descriptor 

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

func (*Dataset) GetDimension 

func (m *Dataset) GetDimension() uint32

func (*Dataset) GetId 

func (m *Dataset) GetId() []byte

func (*Dataset) GetPartitionCount 

func (m *Dataset) GetPartitionCount() uint32

func (*Dataset) GetPartitions 

func (m *Dataset) GetPartitions() []*Partition

func (*Dataset) GetReplicationFactor 

func (m *Dataset) GetReplicationFactor() uint32

func (*Dataset) GetSize 

func (m *Dataset) GetSize() uint64

func (*Dataset) GetSpace 

func (m *Dataset) GetSpace() Space

func (*Dataset) ProtoMessage 

func (*Dataset) ProtoMessage()

func (*Dataset) Reset 

func (m *Dataset) Reset()

func (*Dataset) String 

func (m *Dataset) String() string

func (*Dataset) XXX_DiscardUnknown 

func (m *Dataset) XXX_DiscardUnknown()

func (*Dataset) XXX_Marshal 

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

func (*Dataset) XXX_Merge 

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

func (*Dataset) XXX_Size 

func (m *Dataset) XXX_Size() int

func (*Dataset) XXX_Unmarshal 

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

type DatasetManagerChange 

type DatasetManagerChange struct {
	Type                 DatasetManagerChangeType `protobuf:"varint,1,opt,name=type,proto3,enum=anndb_pb.DatasetManagerChangeType" json:"type,omitempty"`
	NotificationId       []byte                   `protobuf:"bytes,2,opt,name=notification_id,json=notificationId,proto3" json:"notification_id,omitempty"`
	Data                 []byte                   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*DatasetManagerChange) Descriptor 

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

func (*DatasetManagerChange) GetData 

func (m *DatasetManagerChange) GetData() []byte

func (*DatasetManagerChange) GetNotificationId 

func (m *DatasetManagerChange) GetNotificationId() []byte

func (*DatasetManagerChange) GetType 

func (m *DatasetManagerChange) GetType() DatasetManagerChangeType

func (*DatasetManagerChange) ProtoMessage 

func (*DatasetManagerChange) ProtoMessage()

func (*DatasetManagerChange) Reset 

func (m *DatasetManagerChange) Reset()

func (*DatasetManagerChange) String 

func (m *DatasetManagerChange) String() string

func (*DatasetManagerChange) XXX_DiscardUnknown 

func (m *DatasetManagerChange) XXX_DiscardUnknown()

func (*DatasetManagerChange) XXX_Marshal 

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

func (*DatasetManagerChange) XXX_Merge 

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

func (*DatasetManagerChange) XXX_Size 

func (m *DatasetManagerChange) XXX_Size() int

func (*DatasetManagerChange) XXX_Unmarshal 

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

type DatasetManagerChangeType 

type DatasetManagerChangeType int32
const (
	DatasetManagerChangeType_DatasetManagerCreateDataset        DatasetManagerChangeType = 0
	DatasetManagerChangeType_DatasetManagerDeleteDataset        DatasetManagerChangeType = 1
	DatasetManagerChangeType_DatasetManagerUpdatePartitionNodes DatasetManagerChangeType = 2
)

func (DatasetManagerChangeType) EnumDescriptor 

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

func (DatasetManagerChangeType) String 

func (x DatasetManagerChangeType) String() string

type DatasetManagerClient 

type DatasetManagerClient interface {
	List(ctx context.Context, in *ListDatasetsRequest, opts ...grpc.CallOption) (DatasetManager_ListClient, error)
	Get(ctx context.Context, in *GetDatasetRequest, opts ...grpc.CallOption) (*Dataset, error)
	Create(ctx context.Context, in *Dataset, opts ...grpc.CallOption) (*Dataset, error)
	Delete(ctx context.Context, in *UUIDRequest, opts ...grpc.CallOption) (*EmptyMessage, error)
	GetDatasetSize(ctx context.Context, in *GetDatasetRequest, opts ...grpc.CallOption) (*DatasetSize, error)
}

DatasetManagerClient is the client API for DatasetManager service.

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

func NewDatasetManagerClient 

func NewDatasetManagerClient(cc grpc.ClientConnInterface) DatasetManagerClient

type DatasetManagerServer 

type DatasetManagerServer interface {
	List(*ListDatasetsRequest, DatasetManager_ListServer) error
	Get(context.Context, *GetDatasetRequest) (*Dataset, error)
	Create(context.Context, *Dataset) (*Dataset, error)
	Delete(context.Context, *UUIDRequest) (*EmptyMessage, error)
	GetDatasetSize(context.Context, *GetDatasetRequest) (*DatasetSize, error)
}

DatasetManagerServer is the server API for DatasetManager service.

type DatasetManagerSnapshot 

type DatasetManagerSnapshot struct {
	Datasets             []*Dataset `protobuf:"bytes,1,rep,name=datasets,proto3" json:"datasets,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*DatasetManagerSnapshot) Descriptor 

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

func (*DatasetManagerSnapshot) GetDatasets 

func (m *DatasetManagerSnapshot) GetDatasets() []*Dataset

func (*DatasetManagerSnapshot) ProtoMessage 

func (*DatasetManagerSnapshot) ProtoMessage()

func (*DatasetManagerSnapshot) Reset 

func (m *DatasetManagerSnapshot) Reset()

func (*DatasetManagerSnapshot) String 

func (m *DatasetManagerSnapshot) String() string

func (*DatasetManagerSnapshot) XXX_DiscardUnknown 

func (m *DatasetManagerSnapshot) XXX_DiscardUnknown()

func (*DatasetManagerSnapshot) XXX_Marshal 

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

func (*DatasetManagerSnapshot) XXX_Merge 

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

func (*DatasetManagerSnapshot) XXX_Size 

func (m *DatasetManagerSnapshot) XXX_Size() int

func (*DatasetManagerSnapshot) XXX_Unmarshal 

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

type DatasetManager_ListClient 

type DatasetManager_ListClient interface {
	Recv() (*Dataset, error)
	grpc.ClientStream
}

type DatasetManager_ListServer 

type DatasetManager_ListServer interface {
	Send(*Dataset) error
	grpc.ServerStream
}

type DatasetPartitionNodesChange 

type DatasetPartitionNodesChange struct {
	Type                 DatasetPartitionNodesChangeType `protobuf:"varint,1,opt,name=type,proto3,enum=anndb_pb.DatasetPartitionNodesChangeType" json:"type,omitempty"`
	DatasetId            []byte                          `protobuf:"bytes,2,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	PartitionId          []byte                          `protobuf:"bytes,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	NodeId               uint64                          `protobuf:"varint,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*DatasetPartitionNodesChange) Descriptor 

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

func (*DatasetPartitionNodesChange) GetDatasetId 

func (m *DatasetPartitionNodesChange) GetDatasetId() []byte

func (*DatasetPartitionNodesChange) GetNodeId 

func (m *DatasetPartitionNodesChange) GetNodeId() uint64

func (*DatasetPartitionNodesChange) GetPartitionId 

func (m *DatasetPartitionNodesChange) GetPartitionId() []byte

func (*DatasetPartitionNodesChange) GetType 

func (m *DatasetPartitionNodesChange) GetType() DatasetPartitionNodesChangeType

func (*DatasetPartitionNodesChange) ProtoMessage 

func (*DatasetPartitionNodesChange) ProtoMessage()

func (*DatasetPartitionNodesChange) Reset 

func (m *DatasetPartitionNodesChange) Reset()

func (*DatasetPartitionNodesChange) String 

func (m *DatasetPartitionNodesChange) String() string

func (*DatasetPartitionNodesChange) XXX_DiscardUnknown 

func (m *DatasetPartitionNodesChange) XXX_DiscardUnknown()

func (*DatasetPartitionNodesChange) XXX_Marshal 

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

func (*DatasetPartitionNodesChange) XXX_Merge 

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

func (*DatasetPartitionNodesChange) XXX_Size 

func (m *DatasetPartitionNodesChange) XXX_Size() int

func (*DatasetPartitionNodesChange) XXX_Unmarshal 

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

type DatasetPartitionNodesChangeType 

type DatasetPartitionNodesChangeType int32
const (
	DatasetPartitionNodesChangeType_DatasetPartitionNodesChangeAddNode    DatasetPartitionNodesChangeType = 0
	DatasetPartitionNodesChangeType_DatasetPartitionNodesChangeRemoveNode DatasetPartitionNodesChangeType = 1
)

func (DatasetPartitionNodesChangeType) EnumDescriptor 

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

func (DatasetPartitionNodesChangeType) String 

func (x DatasetPartitionNodesChangeType) String() string

type DatasetSize 

type DatasetSize struct {
	Len                  uint64   `protobuf:"varint,1,opt,name=len,proto3" json:"len,omitempty"`
	BytesSize            uint64   `protobuf:"varint,2,opt,name=bytes_size,json=bytesSize,proto3" json:"bytes_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatasetSize) Descriptor 

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

func (*DatasetSize) GetBytesSize 

func (m *DatasetSize) GetBytesSize() uint64

func (*DatasetSize) GetLen 

func (m *DatasetSize) GetLen() uint64

func (*DatasetSize) ProtoMessage 

func (*DatasetSize) ProtoMessage()

func (*DatasetSize) Reset 

func (m *DatasetSize) Reset()

func (*DatasetSize) String 

func (m *DatasetSize) String() string

func (*DatasetSize) XXX_DiscardUnknown 

func (m *DatasetSize) XXX_DiscardUnknown()

func (*DatasetSize) XXX_Marshal 

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

func (*DatasetSize) XXX_Merge 

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

func (*DatasetSize) XXX_Size 

func (m *DatasetSize) XXX_Size() int

func (*DatasetSize) XXX_Unmarshal 

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

type EmptyMessage 

type EmptyMessage struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EmptyMessage) Descriptor 

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

func (*EmptyMessage) ProtoMessage 

func (*EmptyMessage) ProtoMessage()

func (*EmptyMessage) Reset 

func (m *EmptyMessage) Reset()

func (*EmptyMessage) String 

func (m *EmptyMessage) String() string

func (*EmptyMessage) XXX_DiscardUnknown 

func (m *EmptyMessage) XXX_DiscardUnknown()

func (*EmptyMessage) XXX_Marshal 

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

func (*EmptyMessage) XXX_Merge 

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

func (*EmptyMessage) XXX_Size 

func (m *EmptyMessage) XXX_Size() int

func (*EmptyMessage) XXX_Unmarshal 

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

type GetDatasetRequest 

type GetDatasetRequest struct {
	DatasetId            []byte   `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	WithSize             bool     `protobuf:"varint,2,opt,name=with_size,json=withSize,proto3" json:"with_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDatasetRequest) Descriptor 

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

func (*GetDatasetRequest) GetDatasetId 

func (m *GetDatasetRequest) GetDatasetId() []byte

func (*GetDatasetRequest) GetWithSize 

func (m *GetDatasetRequest) GetWithSize() bool

func (*GetDatasetRequest) ProtoMessage 

func (*GetDatasetRequest) ProtoMessage()

func (*GetDatasetRequest) Reset 

func (m *GetDatasetRequest) Reset()

func (*GetDatasetRequest) String 

func (m *GetDatasetRequest) String() string

func (*GetDatasetRequest) XXX_DiscardUnknown 

func (m *GetDatasetRequest) XXX_DiscardUnknown()

func (*GetDatasetRequest) XXX_Marshal 

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

func (*GetDatasetRequest) XXX_Merge 

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

func (*GetDatasetRequest) XXX_Size 

func (m *GetDatasetRequest) XXX_Size() int

func (*GetDatasetRequest) XXX_Unmarshal 

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

type InsertRequest 

type InsertRequest struct {
	DatasetId            []byte            `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	Id                   []byte            `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Value                []float32         `protobuf:"fixed32,3,rep,packed,name=value,proto3" json:"value,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*InsertRequest) Descriptor 

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

func (*InsertRequest) GetDatasetId 

func (m *InsertRequest) GetDatasetId() []byte

func (*InsertRequest) GetId 

func (m *InsertRequest) GetId() []byte

func (*InsertRequest) GetMetadata 

func (m *InsertRequest) GetMetadata() map[string]string

func (*InsertRequest) GetValue 

func (m *InsertRequest) GetValue() []float32

func (*InsertRequest) ProtoMessage 

func (*InsertRequest) ProtoMessage()

func (*InsertRequest) Reset 

func (m *InsertRequest) Reset()

func (*InsertRequest) String 

func (m *InsertRequest) String() string

func (*InsertRequest) XXX_DiscardUnknown 

func (m *InsertRequest) XXX_DiscardUnknown()

func (*InsertRequest) XXX_Marshal 

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

func (*InsertRequest) XXX_Merge 

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

func (*InsertRequest) XXX_Size 

func (m *InsertRequest) XXX_Size() int

func (*InsertRequest) XXX_Unmarshal 

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

type ListDatasetsRequest 

type ListDatasetsRequest struct {
	WithSize             bool     `protobuf:"varint,1,opt,name=with_size,json=withSize,proto3" json:"with_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListDatasetsRequest) Descriptor 

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

func (*ListDatasetsRequest) GetWithSize 

func (m *ListDatasetsRequest) GetWithSize() bool

func (*ListDatasetsRequest) ProtoMessage 

func (*ListDatasetsRequest) ProtoMessage()

func (*ListDatasetsRequest) Reset 

func (m *ListDatasetsRequest) Reset()

func (*ListDatasetsRequest) String 

func (m *ListDatasetsRequest) String() string

func (*ListDatasetsRequest) XXX_DiscardUnknown 

func (m *ListDatasetsRequest) XXX_DiscardUnknown()

func (*ListDatasetsRequest) XXX_Marshal 

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

func (*ListDatasetsRequest) XXX_Merge 

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

func (*ListDatasetsRequest) XXX_Size 

func (m *ListDatasetsRequest) XXX_Size() int

func (*ListDatasetsRequest) XXX_Unmarshal 

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

type Node 

type Node struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Address              string   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Node) Descriptor 

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

func (*Node) GetAddress 

func (m *Node) GetAddress() string

func (*Node) GetId 

func (m *Node) GetId() uint64

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

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

func (*Node) XXX_Merge 

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

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

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

type NodeLoadInfo 

type NodeLoadInfo struct {
	Uptime               uint64   `protobuf:"varint,1,opt,name=uptime,proto3" json:"uptime,omitempty"`
	CpuLoad1             float64  `protobuf:"fixed64,2,opt,name=cpu_load1,json=cpuLoad1,proto3" json:"cpu_load1,omitempty"`
	CpuLoad5             float64  `protobuf:"fixed64,3,opt,name=cpu_load5,json=cpuLoad5,proto3" json:"cpu_load5,omitempty"`
	CpuLoad15            float64  `protobuf:"fixed64,4,opt,name=cpu_load15,json=cpuLoad15,proto3" json:"cpu_load15,omitempty"`
	MemTotal             uint64   `protobuf:"varint,5,opt,name=mem_total,json=memTotal,proto3" json:"mem_total,omitempty"`
	MemAvailable         uint64   `protobuf:"varint,6,opt,name=mem_available,json=memAvailable,proto3" json:"mem_available,omitempty"`
	MemUsed              uint64   `protobuf:"varint,7,opt,name=mem_used,json=memUsed,proto3" json:"mem_used,omitempty"`
	MemFree              uint64   `protobuf:"varint,8,opt,name=mem_free,json=memFree,proto3" json:"mem_free,omitempty"`
	MemUsedPercent       float64  `protobuf:"fixed64,9,opt,name=mem_used_percent,json=memUsedPercent,proto3" json:"mem_used_percent,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeLoadInfo) Descriptor 

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

func (*NodeLoadInfo) GetCpuLoad1 

func (m *NodeLoadInfo) GetCpuLoad1() float64

func (*NodeLoadInfo) GetCpuLoad15 

func (m *NodeLoadInfo) GetCpuLoad15() float64

func (*NodeLoadInfo) GetCpuLoad5 

func (m *NodeLoadInfo) GetCpuLoad5() float64

func (*NodeLoadInfo) GetMemAvailable 

func (m *NodeLoadInfo) GetMemAvailable() uint64

func (*NodeLoadInfo) GetMemFree 

func (m *NodeLoadInfo) GetMemFree() uint64

func (*NodeLoadInfo) GetMemTotal 

func (m *NodeLoadInfo) GetMemTotal() uint64

func (*NodeLoadInfo) GetMemUsed 

func (m *NodeLoadInfo) GetMemUsed() uint64

func (*NodeLoadInfo) GetMemUsedPercent 

func (m *NodeLoadInfo) GetMemUsedPercent() float64

func (*NodeLoadInfo) GetUptime 

func (m *NodeLoadInfo) GetUptime() uint64

func (*NodeLoadInfo) ProtoMessage 

func (*NodeLoadInfo) ProtoMessage()

func (*NodeLoadInfo) Reset 

func (m *NodeLoadInfo) Reset()

func (*NodeLoadInfo) String 

func (m *NodeLoadInfo) String() string

func (*NodeLoadInfo) XXX_DiscardUnknown 

func (m *NodeLoadInfo) XXX_DiscardUnknown()

func (*NodeLoadInfo) XXX_Marshal 

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

func (*NodeLoadInfo) XXX_Merge 

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

func (*NodeLoadInfo) XXX_Size 

func (m *NodeLoadInfo) XXX_Size() int

func (*NodeLoadInfo) XXX_Unmarshal 

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

type NodesManagerClient 

type NodesManagerClient interface {
	ListNodes(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (NodesManager_ListNodesClient, error)
	AddNode(ctx context.Context, in *Node, opts ...grpc.CallOption) (NodesManager_AddNodeClient, error)
	RemoveNode(ctx context.Context, in *Node, opts ...grpc.CallOption) (*EmptyMessage, error)
	LoadInfo(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (*NodeLoadInfo, error)
}

NodesManagerClient is the client API for NodesManager service.

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

func NewNodesManagerClient 

func NewNodesManagerClient(cc grpc.ClientConnInterface) NodesManagerClient

type NodesManagerServer 

type NodesManagerServer interface {
	ListNodes(*EmptyMessage, NodesManager_ListNodesServer) error
	AddNode(*Node, NodesManager_AddNodeServer) error
	RemoveNode(context.Context, *Node) (*EmptyMessage, error)
	LoadInfo(context.Context, *EmptyMessage) (*NodeLoadInfo, error)
}

NodesManagerServer is the server API for NodesManager service.

type NodesManager_AddNodeClient 

type NodesManager_AddNodeClient interface {
	Recv() (*Node, error)
	grpc.ClientStream
}

type NodesManager_AddNodeServer 

type NodesManager_AddNodeServer interface {
	Send(*Node) error
	grpc.ServerStream
}

type NodesManager_ListNodesClient 

type NodesManager_ListNodesClient interface {
	Recv() (*Node, error)
	grpc.ClientStream
}

type NodesManager_ListNodesServer 

type NodesManager_ListNodesServer interface {
	Send(*Node) error
	grpc.ServerStream
}

type Partition 

type Partition struct {
	Id                   []byte   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	NodeIds              []uint64 `protobuf:"varint,2,rep,packed,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Partition) Descriptor 

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

func (*Partition) GetId 

func (m *Partition) GetId() []byte

func (*Partition) GetNodeIds 

func (m *Partition) GetNodeIds() []uint64

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) Reset 

func (m *Partition) Reset()

func (*Partition) String 

func (m *Partition) String() string

func (*Partition) XXX_DiscardUnknown 

func (m *Partition) XXX_DiscardUnknown()

func (*Partition) XXX_Marshal 

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

func (*Partition) XXX_Merge 

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

func (*Partition) XXX_Size 

func (m *Partition) XXX_Size() int

func (*Partition) XXX_Unmarshal 

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

type PartitionBatchRequest 

type PartitionBatchRequest struct {
	DatasetId            []byte       `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	PartitionId          []byte       `protobuf:"bytes,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	Items                []*BatchItem `protobuf:"bytes,3,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PartitionBatchRequest) Descriptor 

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

func (*PartitionBatchRequest) GetDatasetId 

func (m *PartitionBatchRequest) GetDatasetId() []byte

func (*PartitionBatchRequest) GetItems 

func (m *PartitionBatchRequest) GetItems() []*BatchItem

func (*PartitionBatchRequest) GetPartitionId 

func (m *PartitionBatchRequest) GetPartitionId() []byte

func (*PartitionBatchRequest) ProtoMessage 

func (*PartitionBatchRequest) ProtoMessage()

func (*PartitionBatchRequest) Reset 

func (m *PartitionBatchRequest) Reset()

func (*PartitionBatchRequest) String 

func (m *PartitionBatchRequest) String() string

func (*PartitionBatchRequest) XXX_DiscardUnknown 

func (m *PartitionBatchRequest) XXX_DiscardUnknown()

func (*PartitionBatchRequest) XXX_Marshal 

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

func (*PartitionBatchRequest) XXX_Merge 

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

func (*PartitionBatchRequest) XXX_Size 

func (m *PartitionBatchRequest) XXX_Size() int

func (*PartitionBatchRequest) XXX_Unmarshal 

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

type PartitionChange 

type PartitionChange struct {
	Type                 PartitionChangeType `protobuf:"varint,1,opt,name=type,proto3,enum=anndb_pb.PartitionChangeType" json:"type,omitempty"`
	NotificationId       []byte              `protobuf:"bytes,2,opt,name=notification_id,json=notificationId,proto3" json:"notification_id,omitempty"`
	Id                   []byte              `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Value                []float32           `protobuf:"fixed32,4,rep,packed,name=value,proto3" json:"value,omitempty"`
	Metadata             map[string]string   `` /* 157-byte string literal not displayed */
	Level                int32               `protobuf:"varint,6,opt,name=level,proto3" json:"level,omitempty"`
	BatchItems           []*BatchItem        `protobuf:"bytes,7,rep,name=batch_items,json=batchItems,proto3" json:"batch_items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*PartitionChange) Descriptor 

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

func (*PartitionChange) GetBatchItems 

func (m *PartitionChange) GetBatchItems() []*BatchItem

func (*PartitionChange) GetId 

func (m *PartitionChange) GetId() []byte

func (*PartitionChange) GetLevel 

func (m *PartitionChange) GetLevel() int32

func (*PartitionChange) GetMetadata 

func (m *PartitionChange) GetMetadata() map[string]string

func (*PartitionChange) GetNotificationId 

func (m *PartitionChange) GetNotificationId() []byte

func (*PartitionChange) GetType 

func (m *PartitionChange) GetType() PartitionChangeType

func (*PartitionChange) GetValue 

func (m *PartitionChange) GetValue() []float32

func (*PartitionChange) ProtoMessage 

func (*PartitionChange) ProtoMessage()

func (*PartitionChange) Reset 

func (m *PartitionChange) Reset()

func (*PartitionChange) String 

func (m *PartitionChange) String() string

func (*PartitionChange) XXX_DiscardUnknown 

func (m *PartitionChange) XXX_DiscardUnknown()

func (*PartitionChange) XXX_Marshal 

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

func (*PartitionChange) XXX_Merge 

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

func (*PartitionChange) XXX_Size 

func (m *PartitionChange) XXX_Size() int

func (*PartitionChange) XXX_Unmarshal 

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

type PartitionChangeType 

type PartitionChangeType int32
const (
	PartitionChangeType_PartitionChangeInsertValue      PartitionChangeType = 0
	PartitionChangeType_PartitionChangeUpdateValue      PartitionChangeType = 1
	PartitionChangeType_PartitionChangeDeleteValue      PartitionChangeType = 2
	PartitionChangeType_PartitionChangeBatchInsertValue PartitionChangeType = 3
	PartitionChangeType_PartitionChangeBatchUpdateValue PartitionChangeType = 4
	PartitionChangeType_PartitionChangeBatchDeleteValue PartitionChangeType = 5
)

func (PartitionChangeType) EnumDescriptor 

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

func (PartitionChangeType) String 

func (x PartitionChangeType) String() string

type PartitionInfoRequest 

type PartitionInfoRequest struct {
	DatasetId            []byte   `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	PartitionId          []byte   `protobuf:"bytes,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PartitionInfoRequest) Descriptor 

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

func (*PartitionInfoRequest) GetDatasetId 

func (m *PartitionInfoRequest) GetDatasetId() []byte

func (*PartitionInfoRequest) GetPartitionId 

func (m *PartitionInfoRequest) GetPartitionId() []byte

func (*PartitionInfoRequest) ProtoMessage 

func (*PartitionInfoRequest) ProtoMessage()

func (*PartitionInfoRequest) Reset 

func (m *PartitionInfoRequest) Reset()

func (*PartitionInfoRequest) String 

func (m *PartitionInfoRequest) String() string

func (*PartitionInfoRequest) XXX_DiscardUnknown 

func (m *PartitionInfoRequest) XXX_DiscardUnknown()

func (*PartitionInfoRequest) XXX_Marshal 

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

func (*PartitionInfoRequest) XXX_Merge 

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

func (*PartitionInfoRequest) XXX_Size 

func (m *PartitionInfoRequest) XXX_Size() int

func (*PartitionInfoRequest) XXX_Unmarshal 

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

type PartitionInfoResponse 

type PartitionInfoResponse struct {
	Len                  uint64   `protobuf:"varint,1,opt,name=len,proto3" json:"len,omitempty"`
	BytesSize            uint64   `protobuf:"varint,2,opt,name=bytes_size,json=bytesSize,proto3" json:"bytes_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PartitionInfoResponse) Descriptor 

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

func (*PartitionInfoResponse) GetBytesSize 

func (m *PartitionInfoResponse) GetBytesSize() uint64

func (*PartitionInfoResponse) GetLen 

func (m *PartitionInfoResponse) GetLen() uint64

func (*PartitionInfoResponse) ProtoMessage 

func (*PartitionInfoResponse) ProtoMessage()

func (*PartitionInfoResponse) Reset 

func (m *PartitionInfoResponse) Reset()

func (*PartitionInfoResponse) String 

func (m *PartitionInfoResponse) String() string

func (*PartitionInfoResponse) XXX_DiscardUnknown 

func (m *PartitionInfoResponse) XXX_DiscardUnknown()

func (*PartitionInfoResponse) XXX_Marshal 

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

func (*PartitionInfoResponse) XXX_Merge 

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

func (*PartitionInfoResponse) XXX_Size 

func (m *PartitionInfoResponse) XXX_Size() int

func (*PartitionInfoResponse) XXX_Unmarshal 

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

type RaftMessage 

type RaftMessage struct {
	GroupId              []byte   `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Message              []byte   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RaftMessage) Descriptor 

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

func (*RaftMessage) GetGroupId 

func (m *RaftMessage) GetGroupId() []byte

func (*RaftMessage) GetMessage 

func (m *RaftMessage) GetMessage() []byte

func (*RaftMessage) ProtoMessage 

func (*RaftMessage) ProtoMessage()

func (*RaftMessage) Reset 

func (m *RaftMessage) Reset()

func (*RaftMessage) String 

func (m *RaftMessage) String() string

func (*RaftMessage) XXX_DiscardUnknown 

func (m *RaftMessage) XXX_DiscardUnknown()

func (*RaftMessage) XXX_Marshal 

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

func (*RaftMessage) XXX_Merge 

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

func (*RaftMessage) XXX_Size 

func (m *RaftMessage) XXX_Size() int

func (*RaftMessage) XXX_Unmarshal 

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

type RaftTransportClient 

type RaftTransportClient interface {
	Receive(ctx context.Context, in *RaftMessage, opts ...grpc.CallOption) (*EmptyMessage, error)
}

RaftTransportClient is the client API for RaftTransport service.

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

func NewRaftTransportClient 

func NewRaftTransportClient(cc grpc.ClientConnInterface) RaftTransportClient

type RaftTransportServer 

type RaftTransportServer interface {
	Receive(context.Context, *RaftMessage) (*EmptyMessage, error)
}

RaftTransportServer is the server API for RaftTransport service.

type RemoveRequest 

type RemoveRequest struct {
	DatasetId            []byte   `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	Id                   []byte   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetDatasetId 

func (m *RemoveRequest) GetDatasetId() []byte

func (*RemoveRequest) GetId 

func (m *RemoveRequest) GetId() []byte

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) Reset 

func (m *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (m *RemoveRequest) String() string

func (*RemoveRequest) XXX_DiscardUnknown 

func (m *RemoveRequest) XXX_DiscardUnknown()

func (*RemoveRequest) XXX_Marshal 

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

func (*RemoveRequest) XXX_Merge 

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

func (*RemoveRequest) XXX_Size 

func (m *RemoveRequest) XXX_Size() int

func (*RemoveRequest) XXX_Unmarshal 

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

type SearchClient 

type SearchClient interface {
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (Search_SearchClient, error)
	SearchPartitions(ctx context.Context, in *SearchPartitionsRequest, opts ...grpc.CallOption) (Search_SearchPartitionsClient, error)
}

SearchClient is the client API for Search service.

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

func NewSearchClient 

func NewSearchClient(cc grpc.ClientConnInterface) SearchClient

type SearchPartitionsRequest 

type SearchPartitionsRequest struct {
	DatasetId            []byte    `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	PartitionIds         [][]byte  `protobuf:"bytes,2,rep,name=partition_ids,json=partitionIds,proto3" json:"partition_ids,omitempty"`
	Query                []float32 `protobuf:"fixed32,3,rep,packed,name=query,proto3" json:"query,omitempty"`
	K                    uint32    `protobuf:"varint,4,opt,name=k,proto3" json:"k,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*SearchPartitionsRequest) Descriptor 

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

func (*SearchPartitionsRequest) GetDatasetId 

func (m *SearchPartitionsRequest) GetDatasetId() []byte

func (*SearchPartitionsRequest) GetK 

func (m *SearchPartitionsRequest) GetK() uint32

func (*SearchPartitionsRequest) GetPartitionIds 

func (m *SearchPartitionsRequest) GetPartitionIds() [][]byte

func (*SearchPartitionsRequest) GetQuery 

func (m *SearchPartitionsRequest) GetQuery() []float32

func (*SearchPartitionsRequest) ProtoMessage 

func (*SearchPartitionsRequest) ProtoMessage()

func (*SearchPartitionsRequest) Reset 

func (m *SearchPartitionsRequest) Reset()

func (*SearchPartitionsRequest) String 

func (m *SearchPartitionsRequest) String() string

func (*SearchPartitionsRequest) XXX_DiscardUnknown 

func (m *SearchPartitionsRequest) XXX_DiscardUnknown()

func (*SearchPartitionsRequest) XXX_Marshal 

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

func (*SearchPartitionsRequest) XXX_Merge 

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

func (*SearchPartitionsRequest) XXX_Size 

func (m *SearchPartitionsRequest) XXX_Size() int

func (*SearchPartitionsRequest) XXX_Unmarshal 

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

type SearchRequest 

type SearchRequest struct {
	DatasetId            []byte    `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	Query                []float32 `protobuf:"fixed32,2,rep,packed,name=query,proto3" json:"query,omitempty"`
	K                    uint32    `protobuf:"varint,3,opt,name=k,proto3" json:"k,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*SearchRequest) Descriptor 

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

func (*SearchRequest) GetDatasetId 

func (m *SearchRequest) GetDatasetId() []byte

func (*SearchRequest) GetK 

func (m *SearchRequest) GetK() uint32

func (*SearchRequest) GetQuery 

func (m *SearchRequest) GetQuery() []float32

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset 

func (m *SearchRequest) Reset()

func (*SearchRequest) String 

func (m *SearchRequest) String() string

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 SearchResultItem 

type SearchResultItem struct {
	Id                   []byte            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	Score                float32           `protobuf:"fixed32,3,opt,name=score,proto3" json:"score,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SearchResultItem) Descriptor 

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

func (*SearchResultItem) GetId 

func (m *SearchResultItem) GetId() []byte

func (*SearchResultItem) GetMetadata 

func (m *SearchResultItem) GetMetadata() map[string]string

func (*SearchResultItem) GetScore 

func (m *SearchResultItem) GetScore() float32

func (*SearchResultItem) ProtoMessage 

func (*SearchResultItem) ProtoMessage()

func (*SearchResultItem) Reset 

func (m *SearchResultItem) Reset()

func (*SearchResultItem) String 

func (m *SearchResultItem) String() string

func (*SearchResultItem) XXX_DiscardUnknown 

func (m *SearchResultItem) XXX_DiscardUnknown()

func (*SearchResultItem) XXX_Marshal 

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

func (*SearchResultItem) XXX_Merge 

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

func (*SearchResultItem) XXX_Size 

func (m *SearchResultItem) XXX_Size() int

func (*SearchResultItem) XXX_Unmarshal 

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

type SearchServer 

type SearchServer interface {
	Search(*SearchRequest, Search_SearchServer) error
	SearchPartitions(*SearchPartitionsRequest, Search_SearchPartitionsServer) error
}

SearchServer is the server API for Search service.

type Search_SearchClient 

type Search_SearchClient interface {
	Recv() (*SearchResultItem, error)
	grpc.ClientStream
}

type Search_SearchPartitionsClient 

type Search_SearchPartitionsClient interface {
	Recv() (*SearchResultItem, error)
	grpc.ClientStream
}

type Search_SearchPartitionsServer 

type Search_SearchPartitionsServer interface {
	Send(*SearchResultItem) error
	grpc.ServerStream
}

type Search_SearchServer 

type Search_SearchServer interface {
	Send(*SearchResultItem) error
	grpc.ServerStream
}

type SharedGroupProposal 

type SharedGroupProposal struct {
	ProxyName            string   `protobuf:"bytes,1,opt,name=proxy_name,json=proxyName,proto3" json:"proxy_name,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SharedGroupProposal) Descriptor 

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

func (*SharedGroupProposal) GetData 

func (m *SharedGroupProposal) GetData() []byte

func (*SharedGroupProposal) GetProxyName 

func (m *SharedGroupProposal) GetProxyName() string

func (*SharedGroupProposal) ProtoMessage 

func (*SharedGroupProposal) ProtoMessage()

func (*SharedGroupProposal) Reset 

func (m *SharedGroupProposal) Reset()

func (*SharedGroupProposal) String 

func (m *SharedGroupProposal) String() string

func (*SharedGroupProposal) XXX_DiscardUnknown 

func (m *SharedGroupProposal) XXX_DiscardUnknown()

func (*SharedGroupProposal) XXX_Marshal 

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

func (*SharedGroupProposal) XXX_Merge 

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

func (*SharedGroupProposal) XXX_Size 

func (m *SharedGroupProposal) XXX_Size() int

func (*SharedGroupProposal) XXX_Unmarshal 

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

type SharedGroupSnapshot 

type SharedGroupSnapshot struct {
	ProxySnapshots       map[string][]byte `` /* 191-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SharedGroupSnapshot) Descriptor 

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

func (*SharedGroupSnapshot) GetProxySnapshots 

func (m *SharedGroupSnapshot) GetProxySnapshots() map[string][]byte

func (*SharedGroupSnapshot) ProtoMessage 

func (*SharedGroupSnapshot) ProtoMessage()

func (*SharedGroupSnapshot) Reset 

func (m *SharedGroupSnapshot) Reset()

func (*SharedGroupSnapshot) String 

func (m *SharedGroupSnapshot) String() string

func (*SharedGroupSnapshot) XXX_DiscardUnknown 

func (m *SharedGroupSnapshot) XXX_DiscardUnknown()

func (*SharedGroupSnapshot) XXX_Marshal 

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

func (*SharedGroupSnapshot) XXX_Merge 

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

func (*SharedGroupSnapshot) XXX_Size 

func (m *SharedGroupSnapshot) XXX_Size() int

func (*SharedGroupSnapshot) XXX_Unmarshal 

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

type Space 

type Space int32
const (
	Space_Euclidean Space = 0
	Space_Manhattan Space = 1
	Space_Cosine    Space = 2
)

func (Space) EnumDescriptor 

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

func (Space) String 

func (x Space) String() string

type UUIDRequest 

type UUIDRequest struct {
	Id                   []byte   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UUIDRequest) Descriptor 

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

func (*UUIDRequest) GetId 

func (m *UUIDRequest) GetId() []byte

func (*UUIDRequest) ProtoMessage 

func (*UUIDRequest) ProtoMessage()

func (*UUIDRequest) Reset 

func (m *UUIDRequest) Reset()

func (*UUIDRequest) String 

func (m *UUIDRequest) String() string

func (*UUIDRequest) XXX_DiscardUnknown 

func (m *UUIDRequest) XXX_DiscardUnknown()

func (*UUIDRequest) XXX_Marshal 

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

func (*UUIDRequest) XXX_Merge 

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

func (*UUIDRequest) XXX_Size 

func (m *UUIDRequest) XXX_Size() int

func (*UUIDRequest) XXX_Unmarshal 

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

type UnimplementedDataManagerServer 

type UnimplementedDataManagerServer struct {
}

UnimplementedDataManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataManagerServer) BatchInsert 

func (*UnimplementedDataManagerServer) BatchInsert(ctx context.Context, req *BatchRequest) (*BatchResponse, error)

func (*UnimplementedDataManagerServer) BatchRemove 

func (*UnimplementedDataManagerServer) BatchRemove(ctx context.Context, req *BatchRequest) (*BatchResponse, error)

func (*UnimplementedDataManagerServer) BatchUpdate 

func (*UnimplementedDataManagerServer) BatchUpdate(ctx context.Context, req *BatchRequest) (*BatchResponse, error)

func (*UnimplementedDataManagerServer) Insert 

func (*UnimplementedDataManagerServer) Insert(ctx context.Context, req *InsertRequest) (*EmptyMessage, error)

func (*UnimplementedDataManagerServer) PartitionBatchInsert 

func (*UnimplementedDataManagerServer) PartitionBatchInsert(ctx context.Context, req *PartitionBatchRequest) (*BatchResponse, error)

func (*UnimplementedDataManagerServer) PartitionBatchRemove 

func (*UnimplementedDataManagerServer) PartitionBatchRemove(ctx context.Context, req *PartitionBatchRequest) (*BatchResponse, error)

func (*UnimplementedDataManagerServer) PartitionBatchUpdate 

func (*UnimplementedDataManagerServer) PartitionBatchUpdate(ctx context.Context, req *PartitionBatchRequest) (*BatchResponse, error)

func (*UnimplementedDataManagerServer) PartitionInfo 

func (*UnimplementedDataManagerServer) PartitionInfo(ctx context.Context, req *PartitionInfoRequest) (*PartitionInfoResponse, error)

func (*UnimplementedDataManagerServer) Remove 

func (*UnimplementedDataManagerServer) Remove(ctx context.Context, req *RemoveRequest) (*EmptyMessage, error)

func (*UnimplementedDataManagerServer) Update 

func (*UnimplementedDataManagerServer) Update(ctx context.Context, req *UpdateRequest) (*EmptyMessage, error)

type UnimplementedDatasetManagerServer 

type UnimplementedDatasetManagerServer struct {
}

UnimplementedDatasetManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedDatasetManagerServer) Create 

func (*UnimplementedDatasetManagerServer) Create(ctx context.Context, req *Dataset) (*Dataset, error)

func (*UnimplementedDatasetManagerServer) Delete 

func (*UnimplementedDatasetManagerServer) Delete(ctx context.Context, req *UUIDRequest) (*EmptyMessage, error)

func (*UnimplementedDatasetManagerServer) Get 

func (*UnimplementedDatasetManagerServer) Get(ctx context.Context, req *GetDatasetRequest) (*Dataset, error)

func (*UnimplementedDatasetManagerServer) GetDatasetSize 

func (*UnimplementedDatasetManagerServer) GetDatasetSize(ctx context.Context, req *GetDatasetRequest) (*DatasetSize, error)

func (*UnimplementedDatasetManagerServer) List 

func (*UnimplementedDatasetManagerServer) List(req *ListDatasetsRequest, srv DatasetManager_ListServer) error

type UnimplementedNodesManagerServer 

type UnimplementedNodesManagerServer struct {
}

UnimplementedNodesManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodesManagerServer) AddNode 

func (*UnimplementedNodesManagerServer) AddNode(req *Node, srv NodesManager_AddNodeServer) error

func (*UnimplementedNodesManagerServer) ListNodes 

func (*UnimplementedNodesManagerServer) ListNodes(req *EmptyMessage, srv NodesManager_ListNodesServer) error

func (*UnimplementedNodesManagerServer) LoadInfo 

func (*UnimplementedNodesManagerServer) LoadInfo(ctx context.Context, req *EmptyMessage) (*NodeLoadInfo, error)

func (*UnimplementedNodesManagerServer) RemoveNode 

func (*UnimplementedNodesManagerServer) RemoveNode(ctx context.Context, req *Node) (*EmptyMessage, error)

type UnimplementedRaftTransportServer 

type UnimplementedRaftTransportServer struct {
}

UnimplementedRaftTransportServer can be embedded to have forward compatible implementations.

func (*UnimplementedRaftTransportServer) Receive 

func (*UnimplementedRaftTransportServer) Receive(ctx context.Context, req *RaftMessage) (*EmptyMessage, error)

type UnimplementedSearchServer 

type UnimplementedSearchServer struct {
}

UnimplementedSearchServer can be embedded to have forward compatible implementations.

func (*UnimplementedSearchServer) Search 

func (*UnimplementedSearchServer) Search(req *SearchRequest, srv Search_SearchServer) error

func (*UnimplementedSearchServer) SearchPartitions 

func (*UnimplementedSearchServer) SearchPartitions(req *SearchPartitionsRequest, srv Search_SearchPartitionsServer) error

type UpdateRequest 

type UpdateRequest struct {
	DatasetId            []byte            `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	Id                   []byte            `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Value                []float32         `protobuf:"fixed32,3,rep,packed,name=value,proto3" json:"value,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*UpdateRequest) Descriptor 

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

func (*UpdateRequest) GetDatasetId 

func (m *UpdateRequest) GetDatasetId() []byte

func (*UpdateRequest) GetId 

func (m *UpdateRequest) GetId() []byte

func (*UpdateRequest) GetMetadata 

func (m *UpdateRequest) GetMetadata() map[string]string

func (*UpdateRequest) GetValue 

func (m *UpdateRequest) GetValue() []float32

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) Reset 

func (m *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (m *UpdateRequest) String() string

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

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.