Documentation ¶
Overview ¶
Package internal is a generated protocol buffer package.
It is generated from these files:
private.proto
It has these top-level messages:
IndexMeta FieldOptions ImportResponse BlockDataRequest BlockDataResponse Cache MaxShards CreateShardMessage DeleteIndexMessage CreateIndexMessage CreateFieldMessage DeleteFieldMessage DeleteAvailableShardMessage Field Schema Index URI Node NodeStateMessage NodeEventMessage NodeStatus IndexStatus FieldStatus ClusterStatus BSIGroup CreateViewMessage DeleteViewMessage ResizeInstruction ResizeSource ResizeInstructionComplete SetCoordinatorMessage UpdateCoordinatorMessage Topology RecalculateCaches
Package internal is a generated protocol buffer package.
It is generated from these files:
public.proto
It has these top-level messages:
Row RowIdentifiers Pair FieldRow GroupCount ValCount ColumnAttrSet Attr AttrMap QueryRequest QueryResponse QueryResult ImportRequest ImportValueRequest TranslateKeysRequest TranslateKeysResponse ImportRoaringRequestView ImportRoaringRequest
Index ¶
- Variables
- type Attr
- func (*Attr) Descriptor() ([]byte, []int)
- func (m *Attr) GetBoolValue() bool
- func (m *Attr) GetFloatValue() float64
- func (m *Attr) GetIntValue() int64
- func (m *Attr) GetKey() string
- func (m *Attr) GetStringValue() string
- func (m *Attr) GetType() uint64
- func (m *Attr) Marshal() (dAtA []byte, err error)
- func (m *Attr) MarshalTo(dAtA []byte) (int, error)
- func (*Attr) ProtoMessage()
- func (m *Attr) Reset()
- func (m *Attr) Size() (n int)
- func (m *Attr) String() string
- func (m *Attr) Unmarshal(dAtA []byte) error
- type AttrMap
- func (*AttrMap) Descriptor() ([]byte, []int)
- func (m *AttrMap) GetAttrs() []*Attr
- func (m *AttrMap) Marshal() (dAtA []byte, err error)
- func (m *AttrMap) MarshalTo(dAtA []byte) (int, error)
- func (*AttrMap) ProtoMessage()
- func (m *AttrMap) Reset()
- func (m *AttrMap) Size() (n int)
- func (m *AttrMap) String() string
- func (m *AttrMap) Unmarshal(dAtA []byte) error
- type BSIGroup
- func (*BSIGroup) Descriptor() ([]byte, []int)
- func (m *BSIGroup) GetMax() int64
- func (m *BSIGroup) GetMin() int64
- func (m *BSIGroup) GetName() string
- func (m *BSIGroup) GetType() string
- func (m *BSIGroup) Marshal() (dAtA []byte, err error)
- func (m *BSIGroup) MarshalTo(dAtA []byte) (int, error)
- func (*BSIGroup) ProtoMessage()
- func (m *BSIGroup) Reset()
- func (m *BSIGroup) Size() (n int)
- func (m *BSIGroup) String() string
- func (m *BSIGroup) Unmarshal(dAtA []byte) error
- type BlockDataRequest
- func (*BlockDataRequest) Descriptor() ([]byte, []int)
- func (m *BlockDataRequest) GetBlock() uint64
- func (m *BlockDataRequest) GetField() string
- func (m *BlockDataRequest) GetIndex() string
- func (m *BlockDataRequest) GetShard() uint64
- func (m *BlockDataRequest) GetView() string
- func (m *BlockDataRequest) Marshal() (dAtA []byte, err error)
- func (m *BlockDataRequest) MarshalTo(dAtA []byte) (int, error)
- func (*BlockDataRequest) ProtoMessage()
- func (m *BlockDataRequest) Reset()
- func (m *BlockDataRequest) Size() (n int)
- func (m *BlockDataRequest) String() string
- func (m *BlockDataRequest) Unmarshal(dAtA []byte) error
- type BlockDataResponse
- func (*BlockDataResponse) Descriptor() ([]byte, []int)
- func (m *BlockDataResponse) GetColumnIDs() []uint64
- func (m *BlockDataResponse) GetRowIDs() []uint64
- func (m *BlockDataResponse) Marshal() (dAtA []byte, err error)
- func (m *BlockDataResponse) MarshalTo(dAtA []byte) (int, error)
- func (*BlockDataResponse) ProtoMessage()
- func (m *BlockDataResponse) Reset()
- func (m *BlockDataResponse) Size() (n int)
- func (m *BlockDataResponse) String() string
- func (m *BlockDataResponse) Unmarshal(dAtA []byte) error
- type Cache
- func (*Cache) Descriptor() ([]byte, []int)
- func (m *Cache) GetIDs() []uint64
- func (m *Cache) Marshal() (dAtA []byte, err error)
- func (m *Cache) MarshalTo(dAtA []byte) (int, error)
- func (*Cache) ProtoMessage()
- func (m *Cache) Reset()
- func (m *Cache) Size() (n int)
- func (m *Cache) String() string
- func (m *Cache) Unmarshal(dAtA []byte) error
- type ClusterStatus
- func (*ClusterStatus) Descriptor() ([]byte, []int)
- func (m *ClusterStatus) GetClusterID() string
- func (m *ClusterStatus) GetNodes() []*Node
- func (m *ClusterStatus) GetState() string
- func (m *ClusterStatus) Marshal() (dAtA []byte, err error)
- func (m *ClusterStatus) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterStatus) ProtoMessage()
- func (m *ClusterStatus) Reset()
- func (m *ClusterStatus) Size() (n int)
- func (m *ClusterStatus) String() string
- func (m *ClusterStatus) Unmarshal(dAtA []byte) error
- type ColumnAttrSet
- func (*ColumnAttrSet) Descriptor() ([]byte, []int)
- func (m *ColumnAttrSet) GetAttrs() []*Attr
- func (m *ColumnAttrSet) GetID() uint64
- func (m *ColumnAttrSet) GetKey() string
- func (m *ColumnAttrSet) Marshal() (dAtA []byte, err error)
- func (m *ColumnAttrSet) MarshalTo(dAtA []byte) (int, error)
- func (*ColumnAttrSet) ProtoMessage()
- func (m *ColumnAttrSet) Reset()
- func (m *ColumnAttrSet) Size() (n int)
- func (m *ColumnAttrSet) String() string
- func (m *ColumnAttrSet) Unmarshal(dAtA []byte) error
- type CreateFieldMessage
- func (*CreateFieldMessage) Descriptor() ([]byte, []int)
- func (m *CreateFieldMessage) GetField() string
- func (m *CreateFieldMessage) GetIndex() string
- func (m *CreateFieldMessage) GetMeta() *FieldOptions
- func (m *CreateFieldMessage) Marshal() (dAtA []byte, err error)
- func (m *CreateFieldMessage) MarshalTo(dAtA []byte) (int, error)
- func (*CreateFieldMessage) ProtoMessage()
- func (m *CreateFieldMessage) Reset()
- func (m *CreateFieldMessage) Size() (n int)
- func (m *CreateFieldMessage) String() string
- func (m *CreateFieldMessage) Unmarshal(dAtA []byte) error
- type CreateIndexMessage
- func (*CreateIndexMessage) Descriptor() ([]byte, []int)
- func (m *CreateIndexMessage) GetIndex() string
- func (m *CreateIndexMessage) GetMeta() *IndexMeta
- func (m *CreateIndexMessage) Marshal() (dAtA []byte, err error)
- func (m *CreateIndexMessage) MarshalTo(dAtA []byte) (int, error)
- func (*CreateIndexMessage) ProtoMessage()
- func (m *CreateIndexMessage) Reset()
- func (m *CreateIndexMessage) Size() (n int)
- func (m *CreateIndexMessage) String() string
- func (m *CreateIndexMessage) Unmarshal(dAtA []byte) error
- type CreateShardMessage
- func (*CreateShardMessage) Descriptor() ([]byte, []int)
- func (m *CreateShardMessage) GetField() string
- func (m *CreateShardMessage) GetIndex() string
- func (m *CreateShardMessage) GetShard() uint64
- func (m *CreateShardMessage) Marshal() (dAtA []byte, err error)
- func (m *CreateShardMessage) MarshalTo(dAtA []byte) (int, error)
- func (*CreateShardMessage) ProtoMessage()
- func (m *CreateShardMessage) Reset()
- func (m *CreateShardMessage) Size() (n int)
- func (m *CreateShardMessage) String() string
- func (m *CreateShardMessage) Unmarshal(dAtA []byte) error
- type CreateViewMessage
- func (*CreateViewMessage) Descriptor() ([]byte, []int)
- func (m *CreateViewMessage) GetField() string
- func (m *CreateViewMessage) GetIndex() string
- func (m *CreateViewMessage) GetView() string
- func (m *CreateViewMessage) Marshal() (dAtA []byte, err error)
- func (m *CreateViewMessage) MarshalTo(dAtA []byte) (int, error)
- func (*CreateViewMessage) ProtoMessage()
- func (m *CreateViewMessage) Reset()
- func (m *CreateViewMessage) Size() (n int)
- func (m *CreateViewMessage) String() string
- func (m *CreateViewMessage) Unmarshal(dAtA []byte) error
- type Decoder
- type DeleteAvailableShardMessage
- func (*DeleteAvailableShardMessage) Descriptor() ([]byte, []int)
- func (m *DeleteAvailableShardMessage) GetField() string
- func (m *DeleteAvailableShardMessage) GetIndex() string
- func (m *DeleteAvailableShardMessage) GetShardID() uint64
- func (m *DeleteAvailableShardMessage) Marshal() (dAtA []byte, err error)
- func (m *DeleteAvailableShardMessage) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteAvailableShardMessage) ProtoMessage()
- func (m *DeleteAvailableShardMessage) Reset()
- func (m *DeleteAvailableShardMessage) Size() (n int)
- func (m *DeleteAvailableShardMessage) String() string
- func (m *DeleteAvailableShardMessage) Unmarshal(dAtA []byte) error
- type DeleteFieldMessage
- func (*DeleteFieldMessage) Descriptor() ([]byte, []int)
- func (m *DeleteFieldMessage) GetField() string
- func (m *DeleteFieldMessage) GetIndex() string
- func (m *DeleteFieldMessage) Marshal() (dAtA []byte, err error)
- func (m *DeleteFieldMessage) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteFieldMessage) ProtoMessage()
- func (m *DeleteFieldMessage) Reset()
- func (m *DeleteFieldMessage) Size() (n int)
- func (m *DeleteFieldMessage) String() string
- func (m *DeleteFieldMessage) Unmarshal(dAtA []byte) error
- type DeleteIndexMessage
- func (*DeleteIndexMessage) Descriptor() ([]byte, []int)
- func (m *DeleteIndexMessage) GetIndex() string
- func (m *DeleteIndexMessage) Marshal() (dAtA []byte, err error)
- func (m *DeleteIndexMessage) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteIndexMessage) ProtoMessage()
- func (m *DeleteIndexMessage) Reset()
- func (m *DeleteIndexMessage) Size() (n int)
- func (m *DeleteIndexMessage) String() string
- func (m *DeleteIndexMessage) Unmarshal(dAtA []byte) error
- type DeleteViewMessage
- func (*DeleteViewMessage) Descriptor() ([]byte, []int)
- func (m *DeleteViewMessage) GetField() string
- func (m *DeleteViewMessage) GetIndex() string
- func (m *DeleteViewMessage) GetView() string
- func (m *DeleteViewMessage) Marshal() (dAtA []byte, err error)
- func (m *DeleteViewMessage) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteViewMessage) ProtoMessage()
- func (m *DeleteViewMessage) Reset()
- func (m *DeleteViewMessage) Size() (n int)
- func (m *DeleteViewMessage) String() string
- func (m *DeleteViewMessage) Unmarshal(dAtA []byte) error
- type Encoder
- type Field
- func (*Field) Descriptor() ([]byte, []int)
- func (m *Field) GetMeta() *FieldOptions
- func (m *Field) GetName() string
- func (m *Field) GetViews() []string
- func (m *Field) Marshal() (dAtA []byte, err error)
- func (m *Field) MarshalTo(dAtA []byte) (int, error)
- func (*Field) ProtoMessage()
- func (m *Field) Reset()
- func (m *Field) Size() (n int)
- func (m *Field) String() string
- func (m *Field) Unmarshal(dAtA []byte) error
- type FieldOptions
- func (*FieldOptions) Descriptor() ([]byte, []int)
- func (m *FieldOptions) GetBase() int64
- func (m *FieldOptions) GetBitDepth() uint64
- func (m *FieldOptions) GetCacheSize() uint32
- func (m *FieldOptions) GetCacheType() string
- func (m *FieldOptions) GetKeys() bool
- func (m *FieldOptions) GetMax() int64
- func (m *FieldOptions) GetMin() int64
- func (m *FieldOptions) GetNoStandardView() bool
- func (m *FieldOptions) GetTimeQuantum() string
- func (m *FieldOptions) GetType() string
- func (m *FieldOptions) Marshal() (dAtA []byte, err error)
- func (m *FieldOptions) MarshalTo(dAtA []byte) (int, error)
- func (*FieldOptions) ProtoMessage()
- func (m *FieldOptions) Reset()
- func (m *FieldOptions) Size() (n int)
- func (m *FieldOptions) String() string
- func (m *FieldOptions) Unmarshal(dAtA []byte) error
- type FieldRow
- func (*FieldRow) Descriptor() ([]byte, []int)
- func (m *FieldRow) GetField() string
- func (m *FieldRow) GetRowID() uint64
- func (m *FieldRow) GetRowKey() string
- func (m *FieldRow) Marshal() (dAtA []byte, err error)
- func (m *FieldRow) MarshalTo(dAtA []byte) (int, error)
- func (*FieldRow) ProtoMessage()
- func (m *FieldRow) Reset()
- func (m *FieldRow) Size() (n int)
- func (m *FieldRow) String() string
- func (m *FieldRow) Unmarshal(dAtA []byte) error
- type FieldStatus
- func (*FieldStatus) Descriptor() ([]byte, []int)
- func (m *FieldStatus) GetAvailableShards() []uint64
- func (m *FieldStatus) GetName() string
- func (m *FieldStatus) Marshal() (dAtA []byte, err error)
- func (m *FieldStatus) MarshalTo(dAtA []byte) (int, error)
- func (*FieldStatus) ProtoMessage()
- func (m *FieldStatus) Reset()
- func (m *FieldStatus) Size() (n int)
- func (m *FieldStatus) String() string
- func (m *FieldStatus) Unmarshal(dAtA []byte) error
- type GroupCount
- func (*GroupCount) Descriptor() ([]byte, []int)
- func (m *GroupCount) GetCount() uint64
- func (m *GroupCount) GetGroup() []*FieldRow
- func (m *GroupCount) Marshal() (dAtA []byte, err error)
- func (m *GroupCount) MarshalTo(dAtA []byte) (int, error)
- func (*GroupCount) ProtoMessage()
- func (m *GroupCount) Reset()
- func (m *GroupCount) Size() (n int)
- func (m *GroupCount) String() string
- func (m *GroupCount) Unmarshal(dAtA []byte) error
- type ImportRequest
- func (*ImportRequest) Descriptor() ([]byte, []int)
- func (m *ImportRequest) GetColumnIDs() []uint64
- func (m *ImportRequest) GetColumnKeys() []string
- func (m *ImportRequest) GetField() string
- func (m *ImportRequest) GetIndex() string
- func (m *ImportRequest) GetRowIDs() []uint64
- func (m *ImportRequest) GetRowKeys() []string
- func (m *ImportRequest) GetShard() uint64
- func (m *ImportRequest) GetTimestamps() []int64
- func (m *ImportRequest) Marshal() (dAtA []byte, err error)
- func (m *ImportRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ImportRequest) ProtoMessage()
- func (m *ImportRequest) Reset()
- func (m *ImportRequest) Size() (n int)
- func (m *ImportRequest) String() string
- func (m *ImportRequest) Unmarshal(dAtA []byte) error
- type ImportResponse
- func (*ImportResponse) Descriptor() ([]byte, []int)
- func (m *ImportResponse) GetErr() string
- func (m *ImportResponse) Marshal() (dAtA []byte, err error)
- func (m *ImportResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ImportResponse) ProtoMessage()
- func (m *ImportResponse) Reset()
- func (m *ImportResponse) Size() (n int)
- func (m *ImportResponse) String() string
- func (m *ImportResponse) Unmarshal(dAtA []byte) error
- type ImportRoaringRequest
- func (*ImportRoaringRequest) Descriptor() ([]byte, []int)
- func (m *ImportRoaringRequest) GetClear() bool
- func (m *ImportRoaringRequest) GetViews() []*ImportRoaringRequestView
- func (m *ImportRoaringRequest) Marshal() (dAtA []byte, err error)
- func (m *ImportRoaringRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ImportRoaringRequest) ProtoMessage()
- func (m *ImportRoaringRequest) Reset()
- func (m *ImportRoaringRequest) Size() (n int)
- func (m *ImportRoaringRequest) String() string
- func (m *ImportRoaringRequest) Unmarshal(dAtA []byte) error
- type ImportRoaringRequestView
- func (*ImportRoaringRequestView) Descriptor() ([]byte, []int)
- func (m *ImportRoaringRequestView) GetData() []byte
- func (m *ImportRoaringRequestView) GetName() string
- func (m *ImportRoaringRequestView) Marshal() (dAtA []byte, err error)
- func (m *ImportRoaringRequestView) MarshalTo(dAtA []byte) (int, error)
- func (*ImportRoaringRequestView) ProtoMessage()
- func (m *ImportRoaringRequestView) Reset()
- func (m *ImportRoaringRequestView) Size() (n int)
- func (m *ImportRoaringRequestView) String() string
- func (m *ImportRoaringRequestView) Unmarshal(dAtA []byte) error
- type ImportValueRequest
- func (*ImportValueRequest) Descriptor() ([]byte, []int)
- func (m *ImportValueRequest) GetColumnIDs() []uint64
- func (m *ImportValueRequest) GetColumnKeys() []string
- func (m *ImportValueRequest) GetField() string
- func (m *ImportValueRequest) GetIndex() string
- func (m *ImportValueRequest) GetShard() uint64
- func (m *ImportValueRequest) GetValues() []int64
- func (m *ImportValueRequest) Marshal() (dAtA []byte, err error)
- func (m *ImportValueRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ImportValueRequest) ProtoMessage()
- func (m *ImportValueRequest) Reset()
- func (m *ImportValueRequest) Size() (n int)
- func (m *ImportValueRequest) String() string
- func (m *ImportValueRequest) Unmarshal(dAtA []byte) error
- type Index
- func (*Index) Descriptor() ([]byte, []int)
- func (m *Index) GetFields() []*Field
- func (m *Index) GetName() string
- func (m *Index) Marshal() (dAtA []byte, err error)
- func (m *Index) MarshalTo(dAtA []byte) (int, error)
- func (*Index) ProtoMessage()
- func (m *Index) Reset()
- func (m *Index) Size() (n int)
- func (m *Index) String() string
- func (m *Index) Unmarshal(dAtA []byte) error
- type IndexMeta
- func (*IndexMeta) Descriptor() ([]byte, []int)
- func (m *IndexMeta) GetKeys() bool
- func (m *IndexMeta) GetTrackExistence() bool
- func (m *IndexMeta) Marshal() (dAtA []byte, err error)
- func (m *IndexMeta) MarshalTo(dAtA []byte) (int, error)
- func (*IndexMeta) ProtoMessage()
- func (m *IndexMeta) Reset()
- func (m *IndexMeta) Size() (n int)
- func (m *IndexMeta) String() string
- func (m *IndexMeta) Unmarshal(dAtA []byte) error
- type IndexStatus
- func (*IndexStatus) Descriptor() ([]byte, []int)
- func (m *IndexStatus) GetFields() []*FieldStatus
- func (m *IndexStatus) GetName() string
- func (m *IndexStatus) Marshal() (dAtA []byte, err error)
- func (m *IndexStatus) MarshalTo(dAtA []byte) (int, error)
- func (*IndexStatus) ProtoMessage()
- func (m *IndexStatus) Reset()
- func (m *IndexStatus) Size() (n int)
- func (m *IndexStatus) String() string
- func (m *IndexStatus) Unmarshal(dAtA []byte) error
- type MaxShards
- func (*MaxShards) Descriptor() ([]byte, []int)
- func (m *MaxShards) GetStandard() map[string]uint64
- func (m *MaxShards) Marshal() (dAtA []byte, err error)
- func (m *MaxShards) MarshalTo(dAtA []byte) (int, error)
- func (*MaxShards) ProtoMessage()
- func (m *MaxShards) Reset()
- func (m *MaxShards) Size() (n int)
- func (m *MaxShards) String() string
- func (m *MaxShards) Unmarshal(dAtA []byte) error
- type Node
- func (*Node) Descriptor() ([]byte, []int)
- func (m *Node) GetID() string
- func (m *Node) GetIsCoordinator() bool
- func (m *Node) GetState() string
- func (m *Node) GetURI() *URI
- func (m *Node) Marshal() (dAtA []byte, err error)
- func (m *Node) MarshalTo(dAtA []byte) (int, error)
- func (*Node) ProtoMessage()
- func (m *Node) Reset()
- func (m *Node) Size() (n int)
- func (m *Node) String() string
- func (m *Node) Unmarshal(dAtA []byte) error
- type NodeEventMessage
- func (*NodeEventMessage) Descriptor() ([]byte, []int)
- func (m *NodeEventMessage) GetEvent() uint32
- func (m *NodeEventMessage) GetNode() *Node
- func (m *NodeEventMessage) Marshal() (dAtA []byte, err error)
- func (m *NodeEventMessage) MarshalTo(dAtA []byte) (int, error)
- func (*NodeEventMessage) ProtoMessage()
- func (m *NodeEventMessage) Reset()
- func (m *NodeEventMessage) Size() (n int)
- func (m *NodeEventMessage) String() string
- func (m *NodeEventMessage) Unmarshal(dAtA []byte) error
- type NodeStateMessage
- func (*NodeStateMessage) Descriptor() ([]byte, []int)
- func (m *NodeStateMessage) GetNodeID() string
- func (m *NodeStateMessage) GetState() string
- func (m *NodeStateMessage) Marshal() (dAtA []byte, err error)
- func (m *NodeStateMessage) MarshalTo(dAtA []byte) (int, error)
- func (*NodeStateMessage) ProtoMessage()
- func (m *NodeStateMessage) Reset()
- func (m *NodeStateMessage) Size() (n int)
- func (m *NodeStateMessage) String() string
- func (m *NodeStateMessage) Unmarshal(dAtA []byte) error
- type NodeStatus
- func (*NodeStatus) Descriptor() ([]byte, []int)
- func (m *NodeStatus) GetIndexes() []*IndexStatus
- func (m *NodeStatus) GetNode() *Node
- func (m *NodeStatus) GetSchema() *Schema
- func (m *NodeStatus) Marshal() (dAtA []byte, err error)
- func (m *NodeStatus) MarshalTo(dAtA []byte) (int, error)
- func (*NodeStatus) ProtoMessage()
- func (m *NodeStatus) Reset()
- func (m *NodeStatus) Size() (n int)
- func (m *NodeStatus) String() string
- func (m *NodeStatus) Unmarshal(dAtA []byte) error
- type Pair
- func (*Pair) Descriptor() ([]byte, []int)
- func (m *Pair) GetCount() uint64
- func (m *Pair) GetID() uint64
- func (m *Pair) GetKey() string
- func (m *Pair) Marshal() (dAtA []byte, err error)
- func (m *Pair) MarshalTo(dAtA []byte) (int, error)
- func (*Pair) ProtoMessage()
- func (m *Pair) Reset()
- func (m *Pair) Size() (n int)
- func (m *Pair) String() string
- func (m *Pair) Unmarshal(dAtA []byte) error
- type QueryRequest
- func (*QueryRequest) Descriptor() ([]byte, []int)
- func (m *QueryRequest) GetColumnAttrs() bool
- func (m *QueryRequest) GetExcludeColumns() bool
- func (m *QueryRequest) GetExcludeRowAttrs() bool
- func (m *QueryRequest) GetQuery() string
- func (m *QueryRequest) GetRemote() bool
- func (m *QueryRequest) GetShards() []uint64
- func (m *QueryRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (*QueryRequest) ProtoMessage()
- func (m *QueryRequest) Reset()
- func (m *QueryRequest) Size() (n int)
- func (m *QueryRequest) String() string
- func (m *QueryRequest) Unmarshal(dAtA []byte) error
- type QueryResponse
- func (*QueryResponse) Descriptor() ([]byte, []int)
- func (m *QueryResponse) GetColumnAttrSets() []*ColumnAttrSet
- func (m *QueryResponse) GetErr() string
- func (m *QueryResponse) GetResults() []*QueryResult
- func (m *QueryResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryResponse) MarshalTo(dAtA []byte) (int, error)
- func (*QueryResponse) ProtoMessage()
- func (m *QueryResponse) Reset()
- func (m *QueryResponse) Size() (n int)
- func (m *QueryResponse) String() string
- func (m *QueryResponse) Unmarshal(dAtA []byte) error
- type QueryResult
- func (*QueryResult) Descriptor() ([]byte, []int)
- func (m *QueryResult) GetChanged() bool
- func (m *QueryResult) GetGroupCounts() []*GroupCount
- func (m *QueryResult) GetN() uint64
- func (m *QueryResult) GetPairs() []*Pair
- func (m *QueryResult) GetRow() *Row
- func (m *QueryResult) GetRowIDs() []uint64
- func (m *QueryResult) GetRowIdentifiers() *RowIdentifiers
- func (m *QueryResult) GetType() uint32
- func (m *QueryResult) GetValCount() *ValCount
- func (m *QueryResult) Marshal() (dAtA []byte, err error)
- func (m *QueryResult) MarshalTo(dAtA []byte) (int, error)
- func (*QueryResult) ProtoMessage()
- func (m *QueryResult) Reset()
- func (m *QueryResult) Size() (n int)
- func (m *QueryResult) String() string
- func (m *QueryResult) Unmarshal(dAtA []byte) error
- type RecalculateCaches
- func (*RecalculateCaches) Descriptor() ([]byte, []int)
- func (m *RecalculateCaches) Marshal() (dAtA []byte, err error)
- func (m *RecalculateCaches) MarshalTo(dAtA []byte) (int, error)
- func (*RecalculateCaches) ProtoMessage()
- func (m *RecalculateCaches) Reset()
- func (m *RecalculateCaches) Size() (n int)
- func (m *RecalculateCaches) String() string
- func (m *RecalculateCaches) Unmarshal(dAtA []byte) error
- type Request
- type ResizeInstruction
- func (*ResizeInstruction) Descriptor() ([]byte, []int)
- func (m *ResizeInstruction) GetClusterStatus() *ClusterStatus
- func (m *ResizeInstruction) GetCoordinator() *Node
- func (m *ResizeInstruction) GetJobID() int64
- func (m *ResizeInstruction) GetNode() *Node
- func (m *ResizeInstruction) GetNodeStatus() *NodeStatus
- func (m *ResizeInstruction) GetSources() []*ResizeSource
- func (m *ResizeInstruction) Marshal() (dAtA []byte, err error)
- func (m *ResizeInstruction) MarshalTo(dAtA []byte) (int, error)
- func (*ResizeInstruction) ProtoMessage()
- func (m *ResizeInstruction) Reset()
- func (m *ResizeInstruction) Size() (n int)
- func (m *ResizeInstruction) String() string
- func (m *ResizeInstruction) Unmarshal(dAtA []byte) error
- type ResizeInstructionComplete
- func (*ResizeInstructionComplete) Descriptor() ([]byte, []int)
- func (m *ResizeInstructionComplete) GetError() string
- func (m *ResizeInstructionComplete) GetJobID() int64
- func (m *ResizeInstructionComplete) GetNode() *Node
- func (m *ResizeInstructionComplete) Marshal() (dAtA []byte, err error)
- func (m *ResizeInstructionComplete) MarshalTo(dAtA []byte) (int, error)
- func (*ResizeInstructionComplete) ProtoMessage()
- func (m *ResizeInstructionComplete) Reset()
- func (m *ResizeInstructionComplete) Size() (n int)
- func (m *ResizeInstructionComplete) String() string
- func (m *ResizeInstructionComplete) Unmarshal(dAtA []byte) error
- type ResizeSource
- func (*ResizeSource) Descriptor() ([]byte, []int)
- func (m *ResizeSource) GetField() string
- func (m *ResizeSource) GetIndex() string
- func (m *ResizeSource) GetNode() *Node
- func (m *ResizeSource) GetShard() uint64
- func (m *ResizeSource) GetView() string
- func (m *ResizeSource) Marshal() (dAtA []byte, err error)
- func (m *ResizeSource) MarshalTo(dAtA []byte) (int, error)
- func (*ResizeSource) ProtoMessage()
- func (m *ResizeSource) Reset()
- func (m *ResizeSource) Size() (n int)
- func (m *ResizeSource) String() string
- func (m *ResizeSource) Unmarshal(dAtA []byte) error
- type Response
- type Row
- func (*Row) Descriptor() ([]byte, []int)
- func (m *Row) GetAttrs() []*Attr
- func (m *Row) GetColumns() []uint64
- func (m *Row) GetKeys() []string
- func (m *Row) Marshal() (dAtA []byte, err error)
- func (m *Row) MarshalTo(dAtA []byte) (int, error)
- func (*Row) ProtoMessage()
- func (m *Row) Reset()
- func (m *Row) Size() (n int)
- func (m *Row) String() string
- func (m *Row) Unmarshal(dAtA []byte) error
- type RowIdentifiers
- func (*RowIdentifiers) Descriptor() ([]byte, []int)
- func (m *RowIdentifiers) GetKeys() []string
- func (m *RowIdentifiers) GetRows() []uint64
- func (m *RowIdentifiers) Marshal() (dAtA []byte, err error)
- func (m *RowIdentifiers) MarshalTo(dAtA []byte) (int, error)
- func (*RowIdentifiers) ProtoMessage()
- func (m *RowIdentifiers) Reset()
- func (m *RowIdentifiers) Size() (n int)
- func (m *RowIdentifiers) String() string
- func (m *RowIdentifiers) Unmarshal(dAtA []byte) error
- type Schema
- func (*Schema) Descriptor() ([]byte, []int)
- func (m *Schema) GetIndexes() []*Index
- func (m *Schema) Marshal() (dAtA []byte, err error)
- func (m *Schema) MarshalTo(dAtA []byte) (int, error)
- func (*Schema) ProtoMessage()
- func (m *Schema) Reset()
- func (m *Schema) Size() (n int)
- func (m *Schema) String() string
- func (m *Schema) Unmarshal(dAtA []byte) error
- type SetCoordinatorMessage
- func (*SetCoordinatorMessage) Descriptor() ([]byte, []int)
- func (m *SetCoordinatorMessage) GetNew() *Node
- func (m *SetCoordinatorMessage) Marshal() (dAtA []byte, err error)
- func (m *SetCoordinatorMessage) MarshalTo(dAtA []byte) (int, error)
- func (*SetCoordinatorMessage) ProtoMessage()
- func (m *SetCoordinatorMessage) Reset()
- func (m *SetCoordinatorMessage) Size() (n int)
- func (m *SetCoordinatorMessage) String() string
- func (m *SetCoordinatorMessage) Unmarshal(dAtA []byte) error
- type Topology
- func (*Topology) Descriptor() ([]byte, []int)
- func (m *Topology) GetClusterID() string
- func (m *Topology) GetNodeIDs() []string
- func (m *Topology) Marshal() (dAtA []byte, err error)
- func (m *Topology) MarshalTo(dAtA []byte) (int, error)
- func (*Topology) ProtoMessage()
- func (m *Topology) Reset()
- func (m *Topology) Size() (n int)
- func (m *Topology) String() string
- func (m *Topology) Unmarshal(dAtA []byte) error
- type TranslateKeysRequest
- func (*TranslateKeysRequest) Descriptor() ([]byte, []int)
- func (m *TranslateKeysRequest) GetField() string
- func (m *TranslateKeysRequest) GetIndex() string
- func (m *TranslateKeysRequest) GetKeys() []string
- func (m *TranslateKeysRequest) Marshal() (dAtA []byte, err error)
- func (m *TranslateKeysRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TranslateKeysRequest) ProtoMessage()
- func (m *TranslateKeysRequest) Reset()
- func (m *TranslateKeysRequest) Size() (n int)
- func (m *TranslateKeysRequest) String() string
- func (m *TranslateKeysRequest) Unmarshal(dAtA []byte) error
- type TranslateKeysResponse
- func (*TranslateKeysResponse) Descriptor() ([]byte, []int)
- func (m *TranslateKeysResponse) GetIDs() []uint64
- func (m *TranslateKeysResponse) Marshal() (dAtA []byte, err error)
- func (m *TranslateKeysResponse) MarshalTo(dAtA []byte) (int, error)
- func (*TranslateKeysResponse) ProtoMessage()
- func (m *TranslateKeysResponse) Reset()
- func (m *TranslateKeysResponse) Size() (n int)
- func (m *TranslateKeysResponse) String() string
- func (m *TranslateKeysResponse) Unmarshal(dAtA []byte) error
- type URI
- func (*URI) Descriptor() ([]byte, []int)
- func (m *URI) GetHost() string
- func (m *URI) GetPort() uint32
- func (m *URI) GetScheme() string
- func (m *URI) Marshal() (dAtA []byte, err error)
- func (m *URI) MarshalTo(dAtA []byte) (int, error)
- func (*URI) ProtoMessage()
- func (m *URI) Reset()
- func (m *URI) Size() (n int)
- func (m *URI) String() string
- func (m *URI) Unmarshal(dAtA []byte) error
- type UpdateCoordinatorMessage
- func (*UpdateCoordinatorMessage) Descriptor() ([]byte, []int)
- func (m *UpdateCoordinatorMessage) GetNew() *Node
- func (m *UpdateCoordinatorMessage) Marshal() (dAtA []byte, err error)
- func (m *UpdateCoordinatorMessage) MarshalTo(dAtA []byte) (int, error)
- func (*UpdateCoordinatorMessage) ProtoMessage()
- func (m *UpdateCoordinatorMessage) Reset()
- func (m *UpdateCoordinatorMessage) Size() (n int)
- func (m *UpdateCoordinatorMessage) String() string
- func (m *UpdateCoordinatorMessage) Unmarshal(dAtA []byte) error
- type ValCount
- func (*ValCount) Descriptor() ([]byte, []int)
- func (m *ValCount) GetCount() int64
- func (m *ValCount) GetVal() int64
- func (m *ValCount) Marshal() (dAtA []byte, err error)
- func (m *ValCount) MarshalTo(dAtA []byte) (int, error)
- func (*ValCount) ProtoMessage()
- func (m *ValCount) Reset()
- func (m *ValCount) Size() (n int)
- func (m *ValCount) String() string
- func (m *ValCount) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthPrivate = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPrivate = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthPublic = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPublic = fmt.Errorf("proto: integer overflow") )
Functions ¶
This section is empty.
Types ¶
type Attr ¶
type Attr struct { Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"` Type uint64 `protobuf:"varint,2,opt,name=Type,proto3" json:"Type,omitempty"` StringValue string `protobuf:"bytes,3,opt,name=StringValue,proto3" json:"StringValue,omitempty"` IntValue int64 `protobuf:"varint,4,opt,name=IntValue,proto3" json:"IntValue,omitempty"` BoolValue bool `protobuf:"varint,5,opt,name=BoolValue,proto3" json:"BoolValue,omitempty"` FloatValue float64 `protobuf:"fixed64,6,opt,name=FloatValue,proto3" json:"FloatValue,omitempty"` }
func (*Attr) Descriptor ¶
func (*Attr) GetBoolValue ¶ added in v0.8.0
func (*Attr) GetFloatValue ¶ added in v0.8.0
func (*Attr) GetIntValue ¶ added in v0.8.0
func (*Attr) GetStringValue ¶ added in v0.8.0
func (*Attr) ProtoMessage ¶
func (*Attr) ProtoMessage()
type AttrMap ¶
type AttrMap struct {
Attrs []*Attr `protobuf:"bytes,1,rep,name=Attrs" json:"Attrs,omitempty"`
}
func (*AttrMap) Descriptor ¶
func (*AttrMap) ProtoMessage ¶
func (*AttrMap) ProtoMessage()
type BSIGroup ¶ added in v1.0.0
type BSIGroup struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Type string `protobuf:"bytes,2,opt,name=Type,proto3" json:"Type,omitempty"` Min int64 `protobuf:"varint,3,opt,name=Min,proto3" json:"Min,omitempty"` Max int64 `protobuf:"varint,4,opt,name=Max,proto3" json:"Max,omitempty"` }
func (*BSIGroup) Descriptor ¶ added in v1.0.0
func (*BSIGroup) ProtoMessage ¶ added in v1.0.0
func (*BSIGroup) ProtoMessage()
type BlockDataRequest ¶
type BlockDataRequest struct { Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"` View string `protobuf:"bytes,5,opt,name=View,proto3" json:"View,omitempty"` Shard uint64 `protobuf:"varint,4,opt,name=Shard,proto3" json:"Shard,omitempty"` Block uint64 `protobuf:"varint,3,opt,name=Block,proto3" json:"Block,omitempty"` }
func (*BlockDataRequest) Descriptor ¶
func (*BlockDataRequest) Descriptor() ([]byte, []int)
func (*BlockDataRequest) GetBlock ¶ added in v0.8.0
func (m *BlockDataRequest) GetBlock() uint64
func (*BlockDataRequest) GetField ¶ added in v1.0.0
func (m *BlockDataRequest) GetField() string
func (*BlockDataRequest) GetIndex ¶ added in v0.8.0
func (m *BlockDataRequest) GetIndex() string
func (*BlockDataRequest) GetShard ¶ added in v1.0.0
func (m *BlockDataRequest) GetShard() uint64
func (*BlockDataRequest) GetView ¶ added in v0.8.0
func (m *BlockDataRequest) GetView() string
func (*BlockDataRequest) Marshal ¶
func (m *BlockDataRequest) Marshal() (dAtA []byte, err error)
func (*BlockDataRequest) ProtoMessage ¶
func (*BlockDataRequest) ProtoMessage()
func (*BlockDataRequest) Reset ¶
func (m *BlockDataRequest) Reset()
func (*BlockDataRequest) Size ¶
func (m *BlockDataRequest) Size() (n int)
func (*BlockDataRequest) String ¶
func (m *BlockDataRequest) String() string
func (*BlockDataRequest) Unmarshal ¶
func (m *BlockDataRequest) Unmarshal(dAtA []byte) error
type BlockDataResponse ¶
type BlockDataResponse struct { RowIDs []uint64 `protobuf:"varint,1,rep,packed,name=RowIDs" json:"RowIDs,omitempty"` ColumnIDs []uint64 `protobuf:"varint,2,rep,packed,name=ColumnIDs" json:"ColumnIDs,omitempty"` }
func (*BlockDataResponse) Descriptor ¶
func (*BlockDataResponse) Descriptor() ([]byte, []int)
func (*BlockDataResponse) GetColumnIDs ¶ added in v0.8.0
func (m *BlockDataResponse) GetColumnIDs() []uint64
func (*BlockDataResponse) GetRowIDs ¶ added in v0.8.0
func (m *BlockDataResponse) GetRowIDs() []uint64
func (*BlockDataResponse) Marshal ¶
func (m *BlockDataResponse) Marshal() (dAtA []byte, err error)
func (*BlockDataResponse) MarshalTo ¶
func (m *BlockDataResponse) MarshalTo(dAtA []byte) (int, error)
func (*BlockDataResponse) ProtoMessage ¶
func (*BlockDataResponse) ProtoMessage()
func (*BlockDataResponse) Reset ¶
func (m *BlockDataResponse) Reset()
func (*BlockDataResponse) Size ¶
func (m *BlockDataResponse) Size() (n int)
func (*BlockDataResponse) String ¶
func (m *BlockDataResponse) String() string
func (*BlockDataResponse) Unmarshal ¶
func (m *BlockDataResponse) Unmarshal(dAtA []byte) error
type Cache ¶
type Cache struct {
IDs []uint64 `protobuf:"varint,1,rep,packed,name=IDs" json:"IDs,omitempty"`
}
func (*Cache) Descriptor ¶
func (*Cache) ProtoMessage ¶
func (*Cache) ProtoMessage()
type ClusterStatus ¶
type ClusterStatus struct { ClusterID string `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"` State string `protobuf:"bytes,2,opt,name=State,proto3" json:"State,omitempty"` Nodes []*Node `protobuf:"bytes,3,rep,name=Nodes" json:"Nodes,omitempty"` }
func (*ClusterStatus) Descriptor ¶
func (*ClusterStatus) Descriptor() ([]byte, []int)
func (*ClusterStatus) GetClusterID ¶ added in v0.9.0
func (m *ClusterStatus) GetClusterID() string
func (*ClusterStatus) GetNodes ¶
func (m *ClusterStatus) GetNodes() []*Node
func (*ClusterStatus) GetState ¶ added in v0.9.0
func (m *ClusterStatus) GetState() string
func (*ClusterStatus) Marshal ¶
func (m *ClusterStatus) Marshal() (dAtA []byte, err error)
func (*ClusterStatus) ProtoMessage ¶
func (*ClusterStatus) ProtoMessage()
func (*ClusterStatus) Reset ¶
func (m *ClusterStatus) Reset()
func (*ClusterStatus) Size ¶
func (m *ClusterStatus) Size() (n int)
func (*ClusterStatus) String ¶
func (m *ClusterStatus) String() string
func (*ClusterStatus) Unmarshal ¶
func (m *ClusterStatus) Unmarshal(dAtA []byte) error
type ColumnAttrSet ¶
type ColumnAttrSet struct { ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` Key string `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"` Attrs []*Attr `protobuf:"bytes,2,rep,name=Attrs" json:"Attrs,omitempty"` }
func (*ColumnAttrSet) Descriptor ¶
func (*ColumnAttrSet) Descriptor() ([]byte, []int)
func (*ColumnAttrSet) GetAttrs ¶
func (m *ColumnAttrSet) GetAttrs() []*Attr
func (*ColumnAttrSet) GetID ¶ added in v0.8.0
func (m *ColumnAttrSet) GetID() uint64
func (*ColumnAttrSet) GetKey ¶ added in v0.9.0
func (m *ColumnAttrSet) GetKey() string
func (*ColumnAttrSet) Marshal ¶
func (m *ColumnAttrSet) Marshal() (dAtA []byte, err error)
func (*ColumnAttrSet) ProtoMessage ¶
func (*ColumnAttrSet) ProtoMessage()
func (*ColumnAttrSet) Reset ¶
func (m *ColumnAttrSet) Reset()
func (*ColumnAttrSet) Size ¶
func (m *ColumnAttrSet) Size() (n int)
func (*ColumnAttrSet) String ¶
func (m *ColumnAttrSet) String() string
func (*ColumnAttrSet) Unmarshal ¶
func (m *ColumnAttrSet) Unmarshal(dAtA []byte) error
type CreateFieldMessage ¶ added in v0.9.0
type CreateFieldMessage struct { Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"` Meta *FieldOptions `protobuf:"bytes,3,opt,name=Meta" json:"Meta,omitempty"` }
func (*CreateFieldMessage) Descriptor ¶ added in v0.9.0
func (*CreateFieldMessage) Descriptor() ([]byte, []int)
func (*CreateFieldMessage) GetField ¶ added in v0.9.0
func (m *CreateFieldMessage) GetField() string
func (*CreateFieldMessage) GetIndex ¶ added in v0.9.0
func (m *CreateFieldMessage) GetIndex() string
func (*CreateFieldMessage) GetMeta ¶ added in v1.0.0
func (m *CreateFieldMessage) GetMeta() *FieldOptions
func (*CreateFieldMessage) Marshal ¶ added in v0.9.0
func (m *CreateFieldMessage) Marshal() (dAtA []byte, err error)
func (*CreateFieldMessage) MarshalTo ¶ added in v0.9.0
func (m *CreateFieldMessage) MarshalTo(dAtA []byte) (int, error)
func (*CreateFieldMessage) ProtoMessage ¶ added in v0.9.0
func (*CreateFieldMessage) ProtoMessage()
func (*CreateFieldMessage) Reset ¶ added in v0.9.0
func (m *CreateFieldMessage) Reset()
func (*CreateFieldMessage) Size ¶ added in v0.9.0
func (m *CreateFieldMessage) Size() (n int)
func (*CreateFieldMessage) String ¶ added in v0.9.0
func (m *CreateFieldMessage) String() string
func (*CreateFieldMessage) Unmarshal ¶ added in v0.9.0
func (m *CreateFieldMessage) Unmarshal(dAtA []byte) error
type CreateIndexMessage ¶
type CreateIndexMessage struct { Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` Meta *IndexMeta `protobuf:"bytes,2,opt,name=Meta" json:"Meta,omitempty"` }
func (*CreateIndexMessage) Descriptor ¶
func (*CreateIndexMessage) Descriptor() ([]byte, []int)
func (*CreateIndexMessage) GetIndex ¶ added in v0.8.0
func (m *CreateIndexMessage) GetIndex() string
func (*CreateIndexMessage) GetMeta ¶
func (m *CreateIndexMessage) GetMeta() *IndexMeta
func (*CreateIndexMessage) Marshal ¶
func (m *CreateIndexMessage) Marshal() (dAtA []byte, err error)
func (*CreateIndexMessage) MarshalTo ¶
func (m *CreateIndexMessage) MarshalTo(dAtA []byte) (int, error)
func (*CreateIndexMessage) ProtoMessage ¶
func (*CreateIndexMessage) ProtoMessage()
func (*CreateIndexMessage) Reset ¶
func (m *CreateIndexMessage) Reset()
func (*CreateIndexMessage) Size ¶
func (m *CreateIndexMessage) Size() (n int)
func (*CreateIndexMessage) String ¶
func (m *CreateIndexMessage) String() string
func (*CreateIndexMessage) Unmarshal ¶
func (m *CreateIndexMessage) Unmarshal(dAtA []byte) error
type CreateShardMessage ¶ added in v1.0.0
type CreateShardMessage struct { Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` Field string `protobuf:"bytes,3,opt,name=Field,proto3" json:"Field,omitempty"` Shard uint64 `protobuf:"varint,2,opt,name=Shard,proto3" json:"Shard,omitempty"` }
func (*CreateShardMessage) Descriptor ¶ added in v1.0.0
func (*CreateShardMessage) Descriptor() ([]byte, []int)
func (*CreateShardMessage) GetField ¶ added in v1.2.0
func (m *CreateShardMessage) GetField() string
func (*CreateShardMessage) GetIndex ¶ added in v1.0.0
func (m *CreateShardMessage) GetIndex() string
func (*CreateShardMessage) GetShard ¶ added in v1.0.0
func (m *CreateShardMessage) GetShard() uint64
func (*CreateShardMessage) Marshal ¶ added in v1.0.0
func (m *CreateShardMessage) Marshal() (dAtA []byte, err error)
func (*CreateShardMessage) MarshalTo ¶ added in v1.0.0
func (m *CreateShardMessage) MarshalTo(dAtA []byte) (int, error)
func (*CreateShardMessage) ProtoMessage ¶ added in v1.0.0
func (*CreateShardMessage) ProtoMessage()
func (*CreateShardMessage) Reset ¶ added in v1.0.0
func (m *CreateShardMessage) Reset()
func (*CreateShardMessage) Size ¶ added in v1.0.0
func (m *CreateShardMessage) Size() (n int)
func (*CreateShardMessage) String ¶ added in v1.0.0
func (m *CreateShardMessage) String() string
func (*CreateShardMessage) Unmarshal ¶ added in v1.0.0
func (m *CreateShardMessage) Unmarshal(dAtA []byte) error
type CreateViewMessage ¶ added in v0.9.0
type CreateViewMessage struct { Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"` View string `protobuf:"bytes,3,opt,name=View,proto3" json:"View,omitempty"` }
func (*CreateViewMessage) Descriptor ¶ added in v0.9.0
func (*CreateViewMessage) Descriptor() ([]byte, []int)
func (*CreateViewMessage) GetField ¶ added in v1.0.0
func (m *CreateViewMessage) GetField() string
func (*CreateViewMessage) GetIndex ¶ added in v0.9.0
func (m *CreateViewMessage) GetIndex() string
func (*CreateViewMessage) GetView ¶ added in v0.9.0
func (m *CreateViewMessage) GetView() string
func (*CreateViewMessage) Marshal ¶ added in v0.9.0
func (m *CreateViewMessage) Marshal() (dAtA []byte, err error)
func (*CreateViewMessage) MarshalTo ¶ added in v0.9.0
func (m *CreateViewMessage) MarshalTo(dAtA []byte) (int, error)
func (*CreateViewMessage) ProtoMessage ¶ added in v0.9.0
func (*CreateViewMessage) ProtoMessage()
func (*CreateViewMessage) Reset ¶ added in v0.9.0
func (m *CreateViewMessage) Reset()
func (*CreateViewMessage) Size ¶ added in v0.9.0
func (m *CreateViewMessage) Size() (n int)
func (*CreateViewMessage) String ¶ added in v0.9.0
func (m *CreateViewMessage) String() string
func (*CreateViewMessage) Unmarshal ¶ added in v0.9.0
func (m *CreateViewMessage) Unmarshal(dAtA []byte) error
type Decoder ¶
type Decoder struct {
// contains filtered or unexported fields
}
Decoder decodes messages from a reader.
func NewDecoder ¶
NewDecoder returns a new instance of Decoder.
type DeleteAvailableShardMessage ¶ added in v1.2.0
type DeleteAvailableShardMessage struct { Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"` ShardID uint64 `protobuf:"varint,3,opt,name=ShardID,proto3" json:"ShardID,omitempty"` }
func (*DeleteAvailableShardMessage) Descriptor ¶ added in v1.2.0
func (*DeleteAvailableShardMessage) Descriptor() ([]byte, []int)
func (*DeleteAvailableShardMessage) GetField ¶ added in v1.2.0
func (m *DeleteAvailableShardMessage) GetField() string
func (*DeleteAvailableShardMessage) GetIndex ¶ added in v1.2.0
func (m *DeleteAvailableShardMessage) GetIndex() string
func (*DeleteAvailableShardMessage) GetShardID ¶ added in v1.2.0
func (m *DeleteAvailableShardMessage) GetShardID() uint64
func (*DeleteAvailableShardMessage) Marshal ¶ added in v1.2.0
func (m *DeleteAvailableShardMessage) Marshal() (dAtA []byte, err error)
func (*DeleteAvailableShardMessage) MarshalTo ¶ added in v1.2.0
func (m *DeleteAvailableShardMessage) MarshalTo(dAtA []byte) (int, error)
func (*DeleteAvailableShardMessage) ProtoMessage ¶ added in v1.2.0
func (*DeleteAvailableShardMessage) ProtoMessage()
func (*DeleteAvailableShardMessage) Reset ¶ added in v1.2.0
func (m *DeleteAvailableShardMessage) Reset()
func (*DeleteAvailableShardMessage) Size ¶ added in v1.2.0
func (m *DeleteAvailableShardMessage) Size() (n int)
func (*DeleteAvailableShardMessage) String ¶ added in v1.2.0
func (m *DeleteAvailableShardMessage) String() string
func (*DeleteAvailableShardMessage) Unmarshal ¶ added in v1.2.0
func (m *DeleteAvailableShardMessage) Unmarshal(dAtA []byte) error
type DeleteFieldMessage ¶ added in v0.9.0
type DeleteFieldMessage struct { Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"` }
func (*DeleteFieldMessage) Descriptor ¶ added in v0.9.0
func (*DeleteFieldMessage) Descriptor() ([]byte, []int)
func (*DeleteFieldMessage) GetField ¶ added in v0.9.0
func (m *DeleteFieldMessage) GetField() string
func (*DeleteFieldMessage) GetIndex ¶ added in v0.9.0
func (m *DeleteFieldMessage) GetIndex() string
func (*DeleteFieldMessage) Marshal ¶ added in v0.9.0
func (m *DeleteFieldMessage) Marshal() (dAtA []byte, err error)
func (*DeleteFieldMessage) MarshalTo ¶ added in v0.9.0
func (m *DeleteFieldMessage) MarshalTo(dAtA []byte) (int, error)
func (*DeleteFieldMessage) ProtoMessage ¶ added in v0.9.0
func (*DeleteFieldMessage) ProtoMessage()
func (*DeleteFieldMessage) Reset ¶ added in v0.9.0
func (m *DeleteFieldMessage) Reset()
func (*DeleteFieldMessage) Size ¶ added in v0.9.0
func (m *DeleteFieldMessage) Size() (n int)
func (*DeleteFieldMessage) String ¶ added in v0.9.0
func (m *DeleteFieldMessage) String() string
func (*DeleteFieldMessage) Unmarshal ¶ added in v0.9.0
func (m *DeleteFieldMessage) Unmarshal(dAtA []byte) error
type DeleteIndexMessage ¶
type DeleteIndexMessage struct {
Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
}
func (*DeleteIndexMessage) Descriptor ¶
func (*DeleteIndexMessage) Descriptor() ([]byte, []int)
func (*DeleteIndexMessage) GetIndex ¶ added in v0.8.0
func (m *DeleteIndexMessage) GetIndex() string
func (*DeleteIndexMessage) Marshal ¶
func (m *DeleteIndexMessage) Marshal() (dAtA []byte, err error)
func (*DeleteIndexMessage) MarshalTo ¶
func (m *DeleteIndexMessage) MarshalTo(dAtA []byte) (int, error)
func (*DeleteIndexMessage) ProtoMessage ¶
func (*DeleteIndexMessage) ProtoMessage()
func (*DeleteIndexMessage) Reset ¶
func (m *DeleteIndexMessage) Reset()
func (*DeleteIndexMessage) Size ¶
func (m *DeleteIndexMessage) Size() (n int)
func (*DeleteIndexMessage) String ¶
func (m *DeleteIndexMessage) String() string
func (*DeleteIndexMessage) Unmarshal ¶
func (m *DeleteIndexMessage) Unmarshal(dAtA []byte) error
type DeleteViewMessage ¶ added in v0.7.0
type DeleteViewMessage struct { Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"` View string `protobuf:"bytes,3,opt,name=View,proto3" json:"View,omitempty"` }
func (*DeleteViewMessage) Descriptor ¶ added in v0.7.0
func (*DeleteViewMessage) Descriptor() ([]byte, []int)
func (*DeleteViewMessage) GetField ¶ added in v1.0.0
func (m *DeleteViewMessage) GetField() string
func (*DeleteViewMessage) GetIndex ¶ added in v0.8.0
func (m *DeleteViewMessage) GetIndex() string
func (*DeleteViewMessage) GetView ¶ added in v0.8.0
func (m *DeleteViewMessage) GetView() string
func (*DeleteViewMessage) Marshal ¶ added in v0.7.0
func (m *DeleteViewMessage) Marshal() (dAtA []byte, err error)
func (*DeleteViewMessage) MarshalTo ¶ added in v0.7.0
func (m *DeleteViewMessage) MarshalTo(dAtA []byte) (int, error)
func (*DeleteViewMessage) ProtoMessage ¶ added in v0.7.0
func (*DeleteViewMessage) ProtoMessage()
func (*DeleteViewMessage) Reset ¶ added in v0.7.0
func (m *DeleteViewMessage) Reset()
func (*DeleteViewMessage) Size ¶ added in v0.7.0
func (m *DeleteViewMessage) Size() (n int)
func (*DeleteViewMessage) String ¶ added in v0.7.0
func (m *DeleteViewMessage) String() string
func (*DeleteViewMessage) Unmarshal ¶ added in v0.7.0
func (m *DeleteViewMessage) Unmarshal(dAtA []byte) error
type Encoder ¶
type Encoder struct {
// contains filtered or unexported fields
}
Encoder encodes messages to a writer.
func NewEncoder ¶
NewEncoder returns a new instance of Encoder.
type Field ¶ added in v0.5.0
type Field struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Meta *FieldOptions `protobuf:"bytes,2,opt,name=Meta" json:"Meta,omitempty"` Views []string `protobuf:"bytes,3,rep,name=Views" json:"Views,omitempty"` }
func (*Field) Descriptor ¶ added in v0.5.0
func (*Field) GetMeta ¶ added in v1.0.0
func (m *Field) GetMeta() *FieldOptions
func (*Field) ProtoMessage ¶ added in v0.5.0
func (*Field) ProtoMessage()
type FieldOptions ¶ added in v1.0.0
type FieldOptions struct { Type string `protobuf:"bytes,8,opt,name=Type,proto3" json:"Type,omitempty"` CacheType string `protobuf:"bytes,3,opt,name=CacheType,proto3" json:"CacheType,omitempty"` CacheSize uint32 `protobuf:"varint,4,opt,name=CacheSize,proto3" json:"CacheSize,omitempty"` TimeQuantum string `protobuf:"bytes,5,opt,name=TimeQuantum,proto3" json:"TimeQuantum,omitempty"` Keys bool `protobuf:"varint,11,opt,name=Keys,proto3" json:"Keys,omitempty"` NoStandardView bool `protobuf:"varint,12,opt,name=NoStandardView,proto3" json:"NoStandardView,omitempty"` Base int64 `protobuf:"varint,13,opt,name=Base,proto3" json:"Base,omitempty"` BitDepth uint64 `protobuf:"varint,14,opt,name=BitDepth,proto3" json:"BitDepth,omitempty"` Min int64 `protobuf:"varint,9,opt,name=Min,proto3" json:"Min,omitempty"` Max int64 `protobuf:"varint,10,opt,name=Max,proto3" json:"Max,omitempty"` }
func (*FieldOptions) Descriptor ¶ added in v1.0.0
func (*FieldOptions) Descriptor() ([]byte, []int)
func (*FieldOptions) GetBase ¶ added in v1.4.0
func (m *FieldOptions) GetBase() int64
func (*FieldOptions) GetBitDepth ¶ added in v1.4.0
func (m *FieldOptions) GetBitDepth() uint64
func (*FieldOptions) GetCacheSize ¶ added in v1.0.0
func (m *FieldOptions) GetCacheSize() uint32
func (*FieldOptions) GetCacheType ¶ added in v1.0.0
func (m *FieldOptions) GetCacheType() string
func (*FieldOptions) GetKeys ¶ added in v1.0.0
func (m *FieldOptions) GetKeys() bool
func (*FieldOptions) GetMax ¶ added in v1.0.0
func (m *FieldOptions) GetMax() int64
func (*FieldOptions) GetMin ¶ added in v1.0.0
func (m *FieldOptions) GetMin() int64
func (*FieldOptions) GetNoStandardView ¶ added in v1.2.0
func (m *FieldOptions) GetNoStandardView() bool
func (*FieldOptions) GetTimeQuantum ¶ added in v1.0.0
func (m *FieldOptions) GetTimeQuantum() string
func (*FieldOptions) GetType ¶ added in v1.0.0
func (m *FieldOptions) GetType() string
func (*FieldOptions) Marshal ¶ added in v1.0.0
func (m *FieldOptions) Marshal() (dAtA []byte, err error)
func (*FieldOptions) MarshalTo ¶ added in v1.0.0
func (m *FieldOptions) MarshalTo(dAtA []byte) (int, error)
func (*FieldOptions) ProtoMessage ¶ added in v1.0.0
func (*FieldOptions) ProtoMessage()
func (*FieldOptions) Reset ¶ added in v1.0.0
func (m *FieldOptions) Reset()
func (*FieldOptions) Size ¶ added in v1.0.0
func (m *FieldOptions) Size() (n int)
func (*FieldOptions) String ¶ added in v1.0.0
func (m *FieldOptions) String() string
func (*FieldOptions) Unmarshal ¶ added in v1.0.0
func (m *FieldOptions) Unmarshal(dAtA []byte) error
type FieldRow ¶ added in v1.2.0
type FieldRow struct { Field string `protobuf:"bytes,1,opt,name=Field,proto3" json:"Field,omitempty"` RowID uint64 `protobuf:"varint,2,opt,name=RowID,proto3" json:"RowID,omitempty"` RowKey string `protobuf:"bytes,3,opt,name=RowKey,proto3" json:"RowKey,omitempty"` }
func (*FieldRow) Descriptor ¶ added in v1.2.0
func (*FieldRow) ProtoMessage ¶ added in v1.2.0
func (*FieldRow) ProtoMessage()
type FieldStatus ¶ added in v1.2.0
type FieldStatus struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` AvailableShards []uint64 `protobuf:"varint,2,rep,packed,name=AvailableShards" json:"AvailableShards,omitempty"` }
func (*FieldStatus) Descriptor ¶ added in v1.2.0
func (*FieldStatus) Descriptor() ([]byte, []int)
func (*FieldStatus) GetAvailableShards ¶ added in v1.2.0
func (m *FieldStatus) GetAvailableShards() []uint64
func (*FieldStatus) GetName ¶ added in v1.2.0
func (m *FieldStatus) GetName() string
func (*FieldStatus) Marshal ¶ added in v1.2.0
func (m *FieldStatus) Marshal() (dAtA []byte, err error)
func (*FieldStatus) MarshalTo ¶ added in v1.2.0
func (m *FieldStatus) MarshalTo(dAtA []byte) (int, error)
func (*FieldStatus) ProtoMessage ¶ added in v1.2.0
func (*FieldStatus) ProtoMessage()
func (*FieldStatus) Reset ¶ added in v1.2.0
func (m *FieldStatus) Reset()
func (*FieldStatus) Size ¶ added in v1.2.0
func (m *FieldStatus) Size() (n int)
func (*FieldStatus) String ¶ added in v1.2.0
func (m *FieldStatus) String() string
func (*FieldStatus) Unmarshal ¶ added in v1.2.0
func (m *FieldStatus) Unmarshal(dAtA []byte) error
type GroupCount ¶ added in v1.2.0
type GroupCount struct { Group []*FieldRow `protobuf:"bytes,1,rep,name=Group" json:"Group,omitempty"` Count uint64 `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"` }
func (*GroupCount) Descriptor ¶ added in v1.2.0
func (*GroupCount) Descriptor() ([]byte, []int)
func (*GroupCount) GetCount ¶ added in v1.2.0
func (m *GroupCount) GetCount() uint64
func (*GroupCount) GetGroup ¶ added in v1.2.0
func (m *GroupCount) GetGroup() []*FieldRow
func (*GroupCount) Marshal ¶ added in v1.2.0
func (m *GroupCount) Marshal() (dAtA []byte, err error)
func (*GroupCount) MarshalTo ¶ added in v1.2.0
func (m *GroupCount) MarshalTo(dAtA []byte) (int, error)
func (*GroupCount) ProtoMessage ¶ added in v1.2.0
func (*GroupCount) ProtoMessage()
func (*GroupCount) Reset ¶ added in v1.2.0
func (m *GroupCount) Reset()
func (*GroupCount) Size ¶ added in v1.2.0
func (m *GroupCount) Size() (n int)
func (*GroupCount) String ¶ added in v1.2.0
func (m *GroupCount) String() string
func (*GroupCount) Unmarshal ¶ added in v1.2.0
func (m *GroupCount) Unmarshal(dAtA []byte) error
type ImportRequest ¶
type ImportRequest struct { Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"` Shard uint64 `protobuf:"varint,3,opt,name=Shard,proto3" json:"Shard,omitempty"` RowIDs []uint64 `protobuf:"varint,4,rep,packed,name=RowIDs" json:"RowIDs,omitempty"` ColumnIDs []uint64 `protobuf:"varint,5,rep,packed,name=ColumnIDs" json:"ColumnIDs,omitempty"` RowKeys []string `protobuf:"bytes,7,rep,name=RowKeys" json:"RowKeys,omitempty"` ColumnKeys []string `protobuf:"bytes,8,rep,name=ColumnKeys" json:"ColumnKeys,omitempty"` Timestamps []int64 `protobuf:"varint,6,rep,packed,name=Timestamps" json:"Timestamps,omitempty"` }
func (*ImportRequest) Descriptor ¶
func (*ImportRequest) Descriptor() ([]byte, []int)
func (*ImportRequest) GetColumnIDs ¶ added in v0.8.0
func (m *ImportRequest) GetColumnIDs() []uint64
func (*ImportRequest) GetColumnKeys ¶ added in v0.9.0
func (m *ImportRequest) GetColumnKeys() []string
func (*ImportRequest) GetField ¶ added in v1.0.0
func (m *ImportRequest) GetField() string
func (*ImportRequest) GetIndex ¶ added in v0.8.0
func (m *ImportRequest) GetIndex() string
func (*ImportRequest) GetRowIDs ¶ added in v0.8.0
func (m *ImportRequest) GetRowIDs() []uint64
func (*ImportRequest) GetRowKeys ¶ added in v0.9.0
func (m *ImportRequest) GetRowKeys() []string
func (*ImportRequest) GetShard ¶ added in v1.0.0
func (m *ImportRequest) GetShard() uint64
func (*ImportRequest) GetTimestamps ¶ added in v0.8.0
func (m *ImportRequest) GetTimestamps() []int64
func (*ImportRequest) Marshal ¶
func (m *ImportRequest) Marshal() (dAtA []byte, err error)
func (*ImportRequest) ProtoMessage ¶
func (*ImportRequest) ProtoMessage()
func (*ImportRequest) Reset ¶
func (m *ImportRequest) Reset()
func (*ImportRequest) Size ¶
func (m *ImportRequest) Size() (n int)
func (*ImportRequest) String ¶
func (m *ImportRequest) String() string
func (*ImportRequest) Unmarshal ¶
func (m *ImportRequest) Unmarshal(dAtA []byte) error
type ImportResponse ¶
type ImportResponse struct {
Err string `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
}
func (*ImportResponse) Descriptor ¶
func (*ImportResponse) Descriptor() ([]byte, []int)
func (*ImportResponse) GetErr ¶ added in v0.8.0
func (m *ImportResponse) GetErr() string
func (*ImportResponse) Marshal ¶
func (m *ImportResponse) Marshal() (dAtA []byte, err error)
func (*ImportResponse) ProtoMessage ¶
func (*ImportResponse) ProtoMessage()
func (*ImportResponse) Reset ¶
func (m *ImportResponse) Reset()
func (*ImportResponse) Size ¶
func (m *ImportResponse) Size() (n int)
func (*ImportResponse) String ¶
func (m *ImportResponse) String() string
func (*ImportResponse) Unmarshal ¶
func (m *ImportResponse) Unmarshal(dAtA []byte) error
type ImportRoaringRequest ¶ added in v1.2.0
type ImportRoaringRequest struct { Clear bool `protobuf:"varint,1,opt,name=Clear,proto3" json:"Clear,omitempty"` Views []*ImportRoaringRequestView `protobuf:"bytes,2,rep,name=views" json:"views,omitempty"` }
func (*ImportRoaringRequest) Descriptor ¶ added in v1.2.0
func (*ImportRoaringRequest) Descriptor() ([]byte, []int)
func (*ImportRoaringRequest) GetClear ¶ added in v1.2.0
func (m *ImportRoaringRequest) GetClear() bool
func (*ImportRoaringRequest) GetViews ¶ added in v1.2.0
func (m *ImportRoaringRequest) GetViews() []*ImportRoaringRequestView
func (*ImportRoaringRequest) Marshal ¶ added in v1.2.0
func (m *ImportRoaringRequest) Marshal() (dAtA []byte, err error)
func (*ImportRoaringRequest) MarshalTo ¶ added in v1.2.0
func (m *ImportRoaringRequest) MarshalTo(dAtA []byte) (int, error)
func (*ImportRoaringRequest) ProtoMessage ¶ added in v1.2.0
func (*ImportRoaringRequest) ProtoMessage()
func (*ImportRoaringRequest) Reset ¶ added in v1.2.0
func (m *ImportRoaringRequest) Reset()
func (*ImportRoaringRequest) Size ¶ added in v1.2.0
func (m *ImportRoaringRequest) Size() (n int)
func (*ImportRoaringRequest) String ¶ added in v1.2.0
func (m *ImportRoaringRequest) String() string
func (*ImportRoaringRequest) Unmarshal ¶ added in v1.2.0
func (m *ImportRoaringRequest) Unmarshal(dAtA []byte) error
type ImportRoaringRequestView ¶ added in v1.2.0
type ImportRoaringRequestView struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"` }
func (*ImportRoaringRequestView) Descriptor ¶ added in v1.2.0
func (*ImportRoaringRequestView) Descriptor() ([]byte, []int)
func (*ImportRoaringRequestView) GetData ¶ added in v1.2.0
func (m *ImportRoaringRequestView) GetData() []byte
func (*ImportRoaringRequestView) GetName ¶ added in v1.2.0
func (m *ImportRoaringRequestView) GetName() string
func (*ImportRoaringRequestView) Marshal ¶ added in v1.2.0
func (m *ImportRoaringRequestView) Marshal() (dAtA []byte, err error)
func (*ImportRoaringRequestView) MarshalTo ¶ added in v1.2.0
func (m *ImportRoaringRequestView) MarshalTo(dAtA []byte) (int, error)
func (*ImportRoaringRequestView) ProtoMessage ¶ added in v1.2.0
func (*ImportRoaringRequestView) ProtoMessage()
func (*ImportRoaringRequestView) Reset ¶ added in v1.2.0
func (m *ImportRoaringRequestView) Reset()
func (*ImportRoaringRequestView) Size ¶ added in v1.2.0
func (m *ImportRoaringRequestView) Size() (n int)
func (*ImportRoaringRequestView) String ¶ added in v1.2.0
func (m *ImportRoaringRequestView) String() string
func (*ImportRoaringRequestView) Unmarshal ¶ added in v1.2.0
func (m *ImportRoaringRequestView) Unmarshal(dAtA []byte) error
type ImportValueRequest ¶ added in v0.7.0
type ImportValueRequest struct { Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"` Shard uint64 `protobuf:"varint,3,opt,name=Shard,proto3" json:"Shard,omitempty"` ColumnIDs []uint64 `protobuf:"varint,5,rep,packed,name=ColumnIDs" json:"ColumnIDs,omitempty"` ColumnKeys []string `protobuf:"bytes,7,rep,name=ColumnKeys" json:"ColumnKeys,omitempty"` Values []int64 `protobuf:"varint,6,rep,packed,name=Values" json:"Values,omitempty"` }
func (*ImportValueRequest) Descriptor ¶ added in v0.7.0
func (*ImportValueRequest) Descriptor() ([]byte, []int)
func (*ImportValueRequest) GetColumnIDs ¶ added in v0.8.0
func (m *ImportValueRequest) GetColumnIDs() []uint64
func (*ImportValueRequest) GetColumnKeys ¶ added in v0.9.0
func (m *ImportValueRequest) GetColumnKeys() []string
func (*ImportValueRequest) GetField ¶ added in v0.8.0
func (m *ImportValueRequest) GetField() string
func (*ImportValueRequest) GetIndex ¶ added in v0.8.0
func (m *ImportValueRequest) GetIndex() string
func (*ImportValueRequest) GetShard ¶ added in v1.0.0
func (m *ImportValueRequest) GetShard() uint64
func (*ImportValueRequest) GetValues ¶ added in v0.8.0
func (m *ImportValueRequest) GetValues() []int64
func (*ImportValueRequest) Marshal ¶ added in v0.7.0
func (m *ImportValueRequest) Marshal() (dAtA []byte, err error)
func (*ImportValueRequest) MarshalTo ¶ added in v0.7.0
func (m *ImportValueRequest) MarshalTo(dAtA []byte) (int, error)
func (*ImportValueRequest) ProtoMessage ¶ added in v0.7.0
func (*ImportValueRequest) ProtoMessage()
func (*ImportValueRequest) Reset ¶ added in v0.7.0
func (m *ImportValueRequest) Reset()
func (*ImportValueRequest) Size ¶ added in v0.7.0
func (m *ImportValueRequest) Size() (n int)
func (*ImportValueRequest) String ¶ added in v0.7.0
func (m *ImportValueRequest) String() string
func (*ImportValueRequest) Unmarshal ¶ added in v0.7.0
func (m *ImportValueRequest) Unmarshal(dAtA []byte) error
type Index ¶
type Index struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Fields []*Field `protobuf:"bytes,4,rep,name=Fields" json:"Fields,omitempty"` }
func (*Index) Descriptor ¶
func (*Index) ProtoMessage ¶
func (*Index) ProtoMessage()
type IndexMeta ¶
type IndexMeta struct { Keys bool `protobuf:"varint,3,opt,name=Keys,proto3" json:"Keys,omitempty"` TrackExistence bool `protobuf:"varint,4,opt,name=TrackExistence,proto3" json:"TrackExistence,omitempty"` }
func (*IndexMeta) Descriptor ¶
func (*IndexMeta) GetTrackExistence ¶ added in v1.2.0
func (*IndexMeta) ProtoMessage ¶
func (*IndexMeta) ProtoMessage()
type IndexStatus ¶ added in v1.2.0
type IndexStatus struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Fields []*FieldStatus `protobuf:"bytes,2,rep,name=Fields" json:"Fields,omitempty"` }
func (*IndexStatus) Descriptor ¶ added in v1.2.0
func (*IndexStatus) Descriptor() ([]byte, []int)
func (*IndexStatus) GetFields ¶ added in v1.2.0
func (m *IndexStatus) GetFields() []*FieldStatus
func (*IndexStatus) GetName ¶ added in v1.2.0
func (m *IndexStatus) GetName() string
func (*IndexStatus) Marshal ¶ added in v1.2.0
func (m *IndexStatus) Marshal() (dAtA []byte, err error)
func (*IndexStatus) MarshalTo ¶ added in v1.2.0
func (m *IndexStatus) MarshalTo(dAtA []byte) (int, error)
func (*IndexStatus) ProtoMessage ¶ added in v1.2.0
func (*IndexStatus) ProtoMessage()
func (*IndexStatus) Reset ¶ added in v1.2.0
func (m *IndexStatus) Reset()
func (*IndexStatus) Size ¶ added in v1.2.0
func (m *IndexStatus) Size() (n int)
func (*IndexStatus) String ¶ added in v1.2.0
func (m *IndexStatus) String() string
func (*IndexStatus) Unmarshal ¶ added in v1.2.0
func (m *IndexStatus) Unmarshal(dAtA []byte) error
type MaxShards ¶ added in v1.0.0
func (*MaxShards) Descriptor ¶ added in v1.0.0
func (*MaxShards) GetStandard ¶ added in v1.0.0
func (*MaxShards) ProtoMessage ¶ added in v1.0.0
func (*MaxShards) ProtoMessage()
type Node ¶ added in v0.9.0
type Node struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` URI *URI `protobuf:"bytes,2,opt,name=URI" json:"URI,omitempty"` IsCoordinator bool `protobuf:"varint,3,opt,name=IsCoordinator,proto3" json:"IsCoordinator,omitempty"` State string `protobuf:"bytes,4,opt,name=State,proto3" json:"State,omitempty"` }
func (*Node) Descriptor ¶ added in v0.9.0
func (*Node) GetIsCoordinator ¶ added in v0.9.0
func (*Node) ProtoMessage ¶ added in v0.9.0
func (*Node) ProtoMessage()
type NodeEventMessage ¶ added in v0.9.0
type NodeEventMessage struct { Event uint32 `protobuf:"varint,1,opt,name=Event,proto3" json:"Event,omitempty"` Node *Node `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"` }
func (*NodeEventMessage) Descriptor ¶ added in v0.9.0
func (*NodeEventMessage) Descriptor() ([]byte, []int)
func (*NodeEventMessage) GetEvent ¶ added in v0.9.0
func (m *NodeEventMessage) GetEvent() uint32
func (*NodeEventMessage) GetNode ¶ added in v0.9.0
func (m *NodeEventMessage) GetNode() *Node
func (*NodeEventMessage) Marshal ¶ added in v0.9.0
func (m *NodeEventMessage) Marshal() (dAtA []byte, err error)
func (*NodeEventMessage) MarshalTo ¶ added in v0.9.0
func (m *NodeEventMessage) MarshalTo(dAtA []byte) (int, error)
func (*NodeEventMessage) ProtoMessage ¶ added in v0.9.0
func (*NodeEventMessage) ProtoMessage()
func (*NodeEventMessage) Reset ¶ added in v0.9.0
func (m *NodeEventMessage) Reset()
func (*NodeEventMessage) Size ¶ added in v0.9.0
func (m *NodeEventMessage) Size() (n int)
func (*NodeEventMessage) String ¶ added in v0.9.0
func (m *NodeEventMessage) String() string
func (*NodeEventMessage) Unmarshal ¶ added in v0.9.0
func (m *NodeEventMessage) Unmarshal(dAtA []byte) error
type NodeStateMessage ¶ added in v0.9.0
type NodeStateMessage struct { NodeID string `protobuf:"bytes,1,opt,name=NodeID,proto3" json:"NodeID,omitempty"` State string `protobuf:"bytes,2,opt,name=State,proto3" json:"State,omitempty"` }
func (*NodeStateMessage) Descriptor ¶ added in v0.9.0
func (*NodeStateMessage) Descriptor() ([]byte, []int)
func (*NodeStateMessage) GetNodeID ¶ added in v0.9.0
func (m *NodeStateMessage) GetNodeID() string
func (*NodeStateMessage) GetState ¶ added in v0.9.0
func (m *NodeStateMessage) GetState() string
func (*NodeStateMessage) Marshal ¶ added in v0.9.0
func (m *NodeStateMessage) Marshal() (dAtA []byte, err error)
func (*NodeStateMessage) MarshalTo ¶ added in v0.9.0
func (m *NodeStateMessage) MarshalTo(dAtA []byte) (int, error)
func (*NodeStateMessage) ProtoMessage ¶ added in v0.9.0
func (*NodeStateMessage) ProtoMessage()
func (*NodeStateMessage) Reset ¶ added in v0.9.0
func (m *NodeStateMessage) Reset()
func (*NodeStateMessage) Size ¶ added in v0.9.0
func (m *NodeStateMessage) Size() (n int)
func (*NodeStateMessage) String ¶ added in v0.9.0
func (m *NodeStateMessage) String() string
func (*NodeStateMessage) Unmarshal ¶ added in v0.9.0
func (m *NodeStateMessage) Unmarshal(dAtA []byte) error
type NodeStatus ¶
type NodeStatus struct { Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"` Schema *Schema `protobuf:"bytes,3,opt,name=Schema" json:"Schema,omitempty"` Indexes []*IndexStatus `protobuf:"bytes,4,rep,name=Indexes" json:"Indexes,omitempty"` }
func (*NodeStatus) Descriptor ¶
func (*NodeStatus) Descriptor() ([]byte, []int)
func (*NodeStatus) GetIndexes ¶
func (m *NodeStatus) GetIndexes() []*IndexStatus
func (*NodeStatus) GetNode ¶ added in v0.9.0
func (m *NodeStatus) GetNode() *Node
func (*NodeStatus) GetSchema ¶ added in v0.9.0
func (m *NodeStatus) GetSchema() *Schema
func (*NodeStatus) Marshal ¶
func (m *NodeStatus) Marshal() (dAtA []byte, err error)
func (*NodeStatus) ProtoMessage ¶
func (*NodeStatus) ProtoMessage()
func (*NodeStatus) Reset ¶
func (m *NodeStatus) Reset()
func (*NodeStatus) Size ¶
func (m *NodeStatus) Size() (n int)
func (*NodeStatus) String ¶
func (m *NodeStatus) String() string
func (*NodeStatus) Unmarshal ¶
func (m *NodeStatus) Unmarshal(dAtA []byte) error
type Pair ¶
type Pair struct { ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` Key string `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"` Count uint64 `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"` }
func (*Pair) Descriptor ¶
func (*Pair) ProtoMessage ¶
func (*Pair) ProtoMessage()
type QueryRequest ¶
type QueryRequest struct { Query string `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"` Shards []uint64 `protobuf:"varint,2,rep,packed,name=Shards" json:"Shards,omitempty"` ColumnAttrs bool `protobuf:"varint,3,opt,name=ColumnAttrs,proto3" json:"ColumnAttrs,omitempty"` Remote bool `protobuf:"varint,5,opt,name=Remote,proto3" json:"Remote,omitempty"` ExcludeRowAttrs bool `protobuf:"varint,6,opt,name=ExcludeRowAttrs,proto3" json:"ExcludeRowAttrs,omitempty"` ExcludeColumns bool `protobuf:"varint,7,opt,name=ExcludeColumns,proto3" json:"ExcludeColumns,omitempty"` }
func (*QueryRequest) Descriptor ¶
func (*QueryRequest) Descriptor() ([]byte, []int)
func (*QueryRequest) GetColumnAttrs ¶ added in v0.8.0
func (m *QueryRequest) GetColumnAttrs() bool
func (*QueryRequest) GetExcludeColumns ¶ added in v1.0.0
func (m *QueryRequest) GetExcludeColumns() bool
func (*QueryRequest) GetExcludeRowAttrs ¶ added in v1.0.0
func (m *QueryRequest) GetExcludeRowAttrs() bool
func (*QueryRequest) GetQuery ¶ added in v0.8.0
func (m *QueryRequest) GetQuery() string
func (*QueryRequest) GetRemote ¶ added in v0.8.0
func (m *QueryRequest) GetRemote() bool
func (*QueryRequest) GetShards ¶ added in v1.0.0
func (m *QueryRequest) GetShards() []uint64
func (*QueryRequest) Marshal ¶
func (m *QueryRequest) Marshal() (dAtA []byte, err error)
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) Reset ¶
func (m *QueryRequest) Reset()
func (*QueryRequest) Size ¶
func (m *QueryRequest) Size() (n int)
func (*QueryRequest) String ¶
func (m *QueryRequest) String() string
func (*QueryRequest) Unmarshal ¶
func (m *QueryRequest) Unmarshal(dAtA []byte) error
type QueryResponse ¶
type QueryResponse struct { Err string `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"` Results []*QueryResult `protobuf:"bytes,2,rep,name=Results" json:"Results,omitempty"` ColumnAttrSets []*ColumnAttrSet `protobuf:"bytes,3,rep,name=ColumnAttrSets" json:"ColumnAttrSets,omitempty"` }
func (*QueryResponse) Descriptor ¶
func (*QueryResponse) Descriptor() ([]byte, []int)
func (*QueryResponse) GetColumnAttrSets ¶
func (m *QueryResponse) GetColumnAttrSets() []*ColumnAttrSet
func (*QueryResponse) GetErr ¶ added in v0.8.0
func (m *QueryResponse) GetErr() string
func (*QueryResponse) GetResults ¶
func (m *QueryResponse) GetResults() []*QueryResult
func (*QueryResponse) Marshal ¶
func (m *QueryResponse) Marshal() (dAtA []byte, err error)
func (*QueryResponse) ProtoMessage ¶
func (*QueryResponse) ProtoMessage()
func (*QueryResponse) Reset ¶
func (m *QueryResponse) Reset()
func (*QueryResponse) Size ¶
func (m *QueryResponse) Size() (n int)
func (*QueryResponse) String ¶
func (m *QueryResponse) String() string
func (*QueryResponse) Unmarshal ¶
func (m *QueryResponse) Unmarshal(dAtA []byte) error
type QueryResult ¶
type QueryResult struct { Type uint32 `protobuf:"varint,6,opt,name=Type,proto3" json:"Type,omitempty"` Row *Row `protobuf:"bytes,1,opt,name=Row" json:"Row,omitempty"` N uint64 `protobuf:"varint,2,opt,name=N,proto3" json:"N,omitempty"` Pairs []*Pair `protobuf:"bytes,3,rep,name=Pairs" json:"Pairs,omitempty"` Changed bool `protobuf:"varint,4,opt,name=Changed,proto3" json:"Changed,omitempty"` ValCount *ValCount `protobuf:"bytes,5,opt,name=ValCount" json:"ValCount,omitempty"` RowIDs []uint64 `protobuf:"varint,7,rep,packed,name=RowIDs" json:"RowIDs,omitempty"` GroupCounts []*GroupCount `protobuf:"bytes,8,rep,name=GroupCounts" json:"GroupCounts,omitempty"` RowIdentifiers *RowIdentifiers `protobuf:"bytes,9,opt,name=RowIdentifiers" json:"RowIdentifiers,omitempty"` }
func (*QueryResult) Descriptor ¶
func (*QueryResult) Descriptor() ([]byte, []int)
func (*QueryResult) GetChanged ¶ added in v0.8.0
func (m *QueryResult) GetChanged() bool
func (*QueryResult) GetGroupCounts ¶ added in v1.2.0
func (m *QueryResult) GetGroupCounts() []*GroupCount
func (*QueryResult) GetN ¶ added in v0.8.0
func (m *QueryResult) GetN() uint64
func (*QueryResult) GetPairs ¶
func (m *QueryResult) GetPairs() []*Pair
func (*QueryResult) GetRow ¶ added in v1.0.0
func (m *QueryResult) GetRow() *Row
func (*QueryResult) GetRowIDs ¶ added in v1.2.0
func (m *QueryResult) GetRowIDs() []uint64
func (*QueryResult) GetRowIdentifiers ¶ added in v1.2.0
func (m *QueryResult) GetRowIdentifiers() *RowIdentifiers
func (*QueryResult) GetType ¶ added in v0.9.0
func (m *QueryResult) GetType() uint32
func (*QueryResult) GetValCount ¶ added in v0.9.0
func (m *QueryResult) GetValCount() *ValCount
func (*QueryResult) Marshal ¶
func (m *QueryResult) Marshal() (dAtA []byte, err error)
func (*QueryResult) ProtoMessage ¶
func (*QueryResult) ProtoMessage()
func (*QueryResult) Reset ¶
func (m *QueryResult) Reset()
func (*QueryResult) Size ¶
func (m *QueryResult) Size() (n int)
func (*QueryResult) String ¶
func (m *QueryResult) String() string
func (*QueryResult) Unmarshal ¶
func (m *QueryResult) Unmarshal(dAtA []byte) error
type RecalculateCaches ¶ added in v0.9.0
type RecalculateCaches struct { }
func (*RecalculateCaches) Descriptor ¶ added in v0.9.0
func (*RecalculateCaches) Descriptor() ([]byte, []int)
func (*RecalculateCaches) Marshal ¶ added in v0.9.0
func (m *RecalculateCaches) Marshal() (dAtA []byte, err error)
func (*RecalculateCaches) MarshalTo ¶ added in v0.9.0
func (m *RecalculateCaches) MarshalTo(dAtA []byte) (int, error)
func (*RecalculateCaches) ProtoMessage ¶ added in v0.9.0
func (*RecalculateCaches) ProtoMessage()
func (*RecalculateCaches) Reset ¶ added in v0.9.0
func (m *RecalculateCaches) Reset()
func (*RecalculateCaches) Size ¶ added in v0.9.0
func (m *RecalculateCaches) Size() (n int)
func (*RecalculateCaches) String ¶ added in v0.9.0
func (m *RecalculateCaches) String() string
func (*RecalculateCaches) Unmarshal ¶ added in v0.9.0
func (m *RecalculateCaches) Unmarshal(dAtA []byte) error
type ResizeInstruction ¶ added in v0.9.0
type ResizeInstruction struct { JobID int64 `protobuf:"varint,1,opt,name=JobID,proto3" json:"JobID,omitempty"` Node *Node `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"` Coordinator *Node `protobuf:"bytes,3,opt,name=Coordinator" json:"Coordinator,omitempty"` Sources []*ResizeSource `protobuf:"bytes,4,rep,name=Sources" json:"Sources,omitempty"` NodeStatus *NodeStatus `protobuf:"bytes,7,opt,name=NodeStatus" json:"NodeStatus,omitempty"` ClusterStatus *ClusterStatus `protobuf:"bytes,6,opt,name=ClusterStatus" json:"ClusterStatus,omitempty"` }
func (*ResizeInstruction) Descriptor ¶ added in v0.9.0
func (*ResizeInstruction) Descriptor() ([]byte, []int)
func (*ResizeInstruction) GetClusterStatus ¶ added in v0.9.0
func (m *ResizeInstruction) GetClusterStatus() *ClusterStatus
func (*ResizeInstruction) GetCoordinator ¶ added in v0.9.0
func (m *ResizeInstruction) GetCoordinator() *Node
func (*ResizeInstruction) GetJobID ¶ added in v0.9.0
func (m *ResizeInstruction) GetJobID() int64
func (*ResizeInstruction) GetNode ¶ added in v0.9.0
func (m *ResizeInstruction) GetNode() *Node
func (*ResizeInstruction) GetNodeStatus ¶ added in v1.2.0
func (m *ResizeInstruction) GetNodeStatus() *NodeStatus
func (*ResizeInstruction) GetSources ¶ added in v0.9.0
func (m *ResizeInstruction) GetSources() []*ResizeSource
func (*ResizeInstruction) Marshal ¶ added in v0.9.0
func (m *ResizeInstruction) Marshal() (dAtA []byte, err error)
func (*ResizeInstruction) MarshalTo ¶ added in v0.9.0
func (m *ResizeInstruction) MarshalTo(dAtA []byte) (int, error)
func (*ResizeInstruction) ProtoMessage ¶ added in v0.9.0
func (*ResizeInstruction) ProtoMessage()
func (*ResizeInstruction) Reset ¶ added in v0.9.0
func (m *ResizeInstruction) Reset()
func (*ResizeInstruction) Size ¶ added in v0.9.0
func (m *ResizeInstruction) Size() (n int)
func (*ResizeInstruction) String ¶ added in v0.9.0
func (m *ResizeInstruction) String() string
func (*ResizeInstruction) Unmarshal ¶ added in v0.9.0
func (m *ResizeInstruction) Unmarshal(dAtA []byte) error
type ResizeInstructionComplete ¶ added in v0.9.0
type ResizeInstructionComplete struct { JobID int64 `protobuf:"varint,1,opt,name=JobID,proto3" json:"JobID,omitempty"` Node *Node `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"` Error string `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"` }
func (*ResizeInstructionComplete) Descriptor ¶ added in v0.9.0
func (*ResizeInstructionComplete) Descriptor() ([]byte, []int)
func (*ResizeInstructionComplete) GetError ¶ added in v0.9.0
func (m *ResizeInstructionComplete) GetError() string
func (*ResizeInstructionComplete) GetJobID ¶ added in v0.9.0
func (m *ResizeInstructionComplete) GetJobID() int64
func (*ResizeInstructionComplete) GetNode ¶ added in v0.9.0
func (m *ResizeInstructionComplete) GetNode() *Node
func (*ResizeInstructionComplete) Marshal ¶ added in v0.9.0
func (m *ResizeInstructionComplete) Marshal() (dAtA []byte, err error)
func (*ResizeInstructionComplete) MarshalTo ¶ added in v0.9.0
func (m *ResizeInstructionComplete) MarshalTo(dAtA []byte) (int, error)
func (*ResizeInstructionComplete) ProtoMessage ¶ added in v0.9.0
func (*ResizeInstructionComplete) ProtoMessage()
func (*ResizeInstructionComplete) Reset ¶ added in v0.9.0
func (m *ResizeInstructionComplete) Reset()
func (*ResizeInstructionComplete) Size ¶ added in v0.9.0
func (m *ResizeInstructionComplete) Size() (n int)
func (*ResizeInstructionComplete) String ¶ added in v0.9.0
func (m *ResizeInstructionComplete) String() string
func (*ResizeInstructionComplete) Unmarshal ¶ added in v0.9.0
func (m *ResizeInstructionComplete) Unmarshal(dAtA []byte) error
type ResizeSource ¶ added in v0.9.0
type ResizeSource struct { Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"` Index string `protobuf:"bytes,2,opt,name=Index,proto3" json:"Index,omitempty"` Field string `protobuf:"bytes,3,opt,name=Field,proto3" json:"Field,omitempty"` View string `protobuf:"bytes,4,opt,name=View,proto3" json:"View,omitempty"` Shard uint64 `protobuf:"varint,5,opt,name=Shard,proto3" json:"Shard,omitempty"` }
func (*ResizeSource) Descriptor ¶ added in v0.9.0
func (*ResizeSource) Descriptor() ([]byte, []int)
func (*ResizeSource) GetField ¶ added in v1.0.0
func (m *ResizeSource) GetField() string
func (*ResizeSource) GetIndex ¶ added in v0.9.0
func (m *ResizeSource) GetIndex() string
func (*ResizeSource) GetNode ¶ added in v0.9.0
func (m *ResizeSource) GetNode() *Node
func (*ResizeSource) GetShard ¶ added in v1.0.0
func (m *ResizeSource) GetShard() uint64
func (*ResizeSource) GetView ¶ added in v0.9.0
func (m *ResizeSource) GetView() string
func (*ResizeSource) Marshal ¶ added in v0.9.0
func (m *ResizeSource) Marshal() (dAtA []byte, err error)
func (*ResizeSource) MarshalTo ¶ added in v0.9.0
func (m *ResizeSource) MarshalTo(dAtA []byte) (int, error)
func (*ResizeSource) ProtoMessage ¶ added in v0.9.0
func (*ResizeSource) ProtoMessage()
func (*ResizeSource) Reset ¶ added in v0.9.0
func (m *ResizeSource) Reset()
func (*ResizeSource) Size ¶ added in v0.9.0
func (m *ResizeSource) Size() (n int)
func (*ResizeSource) String ¶ added in v0.9.0
func (m *ResizeSource) String() string
func (*ResizeSource) Unmarshal ¶ added in v0.9.0
func (m *ResizeSource) Unmarshal(dAtA []byte) error
type Row ¶ added in v1.0.0
type Row struct { Columns []uint64 `protobuf:"varint,1,rep,packed,name=Columns" json:"Columns,omitempty"` Keys []string `protobuf:"bytes,3,rep,name=Keys" json:"Keys,omitempty"` Attrs []*Attr `protobuf:"bytes,2,rep,name=Attrs" json:"Attrs,omitempty"` }
func (*Row) Descriptor ¶ added in v1.0.0
func (*Row) GetColumns ¶ added in v1.0.0
func (*Row) ProtoMessage ¶ added in v1.0.0
func (*Row) ProtoMessage()
type RowIdentifiers ¶ added in v1.2.0
type RowIdentifiers struct { Rows []uint64 `protobuf:"varint,1,rep,packed,name=Rows" json:"Rows,omitempty"` Keys []string `protobuf:"bytes,2,rep,name=Keys" json:"Keys,omitempty"` }
func (*RowIdentifiers) Descriptor ¶ added in v1.2.0
func (*RowIdentifiers) Descriptor() ([]byte, []int)
func (*RowIdentifiers) GetKeys ¶ added in v1.2.0
func (m *RowIdentifiers) GetKeys() []string
func (*RowIdentifiers) GetRows ¶ added in v1.2.0
func (m *RowIdentifiers) GetRows() []uint64
func (*RowIdentifiers) Marshal ¶ added in v1.2.0
func (m *RowIdentifiers) Marshal() (dAtA []byte, err error)
func (*RowIdentifiers) MarshalTo ¶ added in v1.2.0
func (m *RowIdentifiers) MarshalTo(dAtA []byte) (int, error)
func (*RowIdentifiers) ProtoMessage ¶ added in v1.2.0
func (*RowIdentifiers) ProtoMessage()
func (*RowIdentifiers) Reset ¶ added in v1.2.0
func (m *RowIdentifiers) Reset()
func (*RowIdentifiers) Size ¶ added in v1.2.0
func (m *RowIdentifiers) Size() (n int)
func (*RowIdentifiers) String ¶ added in v1.2.0
func (m *RowIdentifiers) String() string
func (*RowIdentifiers) Unmarshal ¶ added in v1.2.0
func (m *RowIdentifiers) Unmarshal(dAtA []byte) error
type Schema ¶ added in v0.9.0
type Schema struct {
Indexes []*Index `protobuf:"bytes,1,rep,name=Indexes" json:"Indexes,omitempty"`
}
func (*Schema) Descriptor ¶ added in v0.9.0
func (*Schema) GetIndexes ¶ added in v0.9.0
func (*Schema) ProtoMessage ¶ added in v0.9.0
func (*Schema) ProtoMessage()
type SetCoordinatorMessage ¶ added in v0.9.0
type SetCoordinatorMessage struct {
New *Node `protobuf:"bytes,1,opt,name=New" json:"New,omitempty"`
}
func (*SetCoordinatorMessage) Descriptor ¶ added in v0.9.0
func (*SetCoordinatorMessage) Descriptor() ([]byte, []int)
func (*SetCoordinatorMessage) GetNew ¶ added in v0.9.0
func (m *SetCoordinatorMessage) GetNew() *Node
func (*SetCoordinatorMessage) Marshal ¶ added in v0.9.0
func (m *SetCoordinatorMessage) Marshal() (dAtA []byte, err error)
func (*SetCoordinatorMessage) MarshalTo ¶ added in v0.9.0
func (m *SetCoordinatorMessage) MarshalTo(dAtA []byte) (int, error)
func (*SetCoordinatorMessage) ProtoMessage ¶ added in v0.9.0
func (*SetCoordinatorMessage) ProtoMessage()
func (*SetCoordinatorMessage) Reset ¶ added in v0.9.0
func (m *SetCoordinatorMessage) Reset()
func (*SetCoordinatorMessage) Size ¶ added in v0.9.0
func (m *SetCoordinatorMessage) Size() (n int)
func (*SetCoordinatorMessage) String ¶ added in v0.9.0
func (m *SetCoordinatorMessage) String() string
func (*SetCoordinatorMessage) Unmarshal ¶ added in v0.9.0
func (m *SetCoordinatorMessage) Unmarshal(dAtA []byte) error
type Topology ¶ added in v0.9.0
type Topology struct { ClusterID string `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"` NodeIDs []string `protobuf:"bytes,2,rep,name=NodeIDs" json:"NodeIDs,omitempty"` }
func (*Topology) Descriptor ¶ added in v0.9.0
func (*Topology) GetClusterID ¶ added in v0.9.0
func (*Topology) GetNodeIDs ¶ added in v0.9.0
func (*Topology) ProtoMessage ¶ added in v0.9.0
func (*Topology) ProtoMessage()
type TranslateKeysRequest ¶ added in v1.2.0
type TranslateKeysRequest struct { Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"` Keys []string `protobuf:"bytes,3,rep,name=Keys" json:"Keys,omitempty"` }
func (*TranslateKeysRequest) Descriptor ¶ added in v1.2.0
func (*TranslateKeysRequest) Descriptor() ([]byte, []int)
func (*TranslateKeysRequest) GetField ¶ added in v1.2.0
func (m *TranslateKeysRequest) GetField() string
func (*TranslateKeysRequest) GetIndex ¶ added in v1.2.0
func (m *TranslateKeysRequest) GetIndex() string
func (*TranslateKeysRequest) GetKeys ¶ added in v1.2.0
func (m *TranslateKeysRequest) GetKeys() []string
func (*TranslateKeysRequest) Marshal ¶ added in v1.2.0
func (m *TranslateKeysRequest) Marshal() (dAtA []byte, err error)
func (*TranslateKeysRequest) MarshalTo ¶ added in v1.2.0
func (m *TranslateKeysRequest) MarshalTo(dAtA []byte) (int, error)
func (*TranslateKeysRequest) ProtoMessage ¶ added in v1.2.0
func (*TranslateKeysRequest) ProtoMessage()
func (*TranslateKeysRequest) Reset ¶ added in v1.2.0
func (m *TranslateKeysRequest) Reset()
func (*TranslateKeysRequest) Size ¶ added in v1.2.0
func (m *TranslateKeysRequest) Size() (n int)
func (*TranslateKeysRequest) String ¶ added in v1.2.0
func (m *TranslateKeysRequest) String() string
func (*TranslateKeysRequest) Unmarshal ¶ added in v1.2.0
func (m *TranslateKeysRequest) Unmarshal(dAtA []byte) error
type TranslateKeysResponse ¶ added in v1.2.0
type TranslateKeysResponse struct {
IDs []uint64 `protobuf:"varint,3,rep,packed,name=IDs" json:"IDs,omitempty"`
}
func (*TranslateKeysResponse) Descriptor ¶ added in v1.2.0
func (*TranslateKeysResponse) Descriptor() ([]byte, []int)
func (*TranslateKeysResponse) GetIDs ¶ added in v1.2.0
func (m *TranslateKeysResponse) GetIDs() []uint64
func (*TranslateKeysResponse) Marshal ¶ added in v1.2.0
func (m *TranslateKeysResponse) Marshal() (dAtA []byte, err error)
func (*TranslateKeysResponse) MarshalTo ¶ added in v1.2.0
func (m *TranslateKeysResponse) MarshalTo(dAtA []byte) (int, error)
func (*TranslateKeysResponse) ProtoMessage ¶ added in v1.2.0
func (*TranslateKeysResponse) ProtoMessage()
func (*TranslateKeysResponse) Reset ¶ added in v1.2.0
func (m *TranslateKeysResponse) Reset()
func (*TranslateKeysResponse) Size ¶ added in v1.2.0
func (m *TranslateKeysResponse) Size() (n int)
func (*TranslateKeysResponse) String ¶ added in v1.2.0
func (m *TranslateKeysResponse) String() string
func (*TranslateKeysResponse) Unmarshal ¶ added in v1.2.0
func (m *TranslateKeysResponse) Unmarshal(dAtA []byte) error
type URI ¶ added in v0.9.0
type URI struct { Scheme string `protobuf:"bytes,1,opt,name=Scheme,proto3" json:"Scheme,omitempty"` Host string `protobuf:"bytes,2,opt,name=Host,proto3" json:"Host,omitempty"` Port uint32 `protobuf:"varint,3,opt,name=Port,proto3" json:"Port,omitempty"` }
func (*URI) Descriptor ¶ added in v0.9.0
func (*URI) ProtoMessage ¶ added in v0.9.0
func (*URI) ProtoMessage()
type UpdateCoordinatorMessage ¶ added in v0.9.0
type UpdateCoordinatorMessage struct {
New *Node `protobuf:"bytes,1,opt,name=New" json:"New,omitempty"`
}
func (*UpdateCoordinatorMessage) Descriptor ¶ added in v0.9.0
func (*UpdateCoordinatorMessage) Descriptor() ([]byte, []int)
func (*UpdateCoordinatorMessage) GetNew ¶ added in v0.9.0
func (m *UpdateCoordinatorMessage) GetNew() *Node
func (*UpdateCoordinatorMessage) Marshal ¶ added in v0.9.0
func (m *UpdateCoordinatorMessage) Marshal() (dAtA []byte, err error)
func (*UpdateCoordinatorMessage) MarshalTo ¶ added in v0.9.0
func (m *UpdateCoordinatorMessage) MarshalTo(dAtA []byte) (int, error)
func (*UpdateCoordinatorMessage) ProtoMessage ¶ added in v0.9.0
func (*UpdateCoordinatorMessage) ProtoMessage()
func (*UpdateCoordinatorMessage) Reset ¶ added in v0.9.0
func (m *UpdateCoordinatorMessage) Reset()
func (*UpdateCoordinatorMessage) Size ¶ added in v0.9.0
func (m *UpdateCoordinatorMessage) Size() (n int)
func (*UpdateCoordinatorMessage) String ¶ added in v0.9.0
func (m *UpdateCoordinatorMessage) String() string
func (*UpdateCoordinatorMessage) Unmarshal ¶ added in v0.9.0
func (m *UpdateCoordinatorMessage) Unmarshal(dAtA []byte) error
type ValCount ¶ added in v0.9.0
type ValCount struct { Val int64 `protobuf:"varint,1,opt,name=Val,proto3" json:"Val,omitempty"` Count int64 `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"` }
func (*ValCount) Descriptor ¶ added in v0.9.0
func (*ValCount) ProtoMessage ¶ added in v0.9.0
func (*ValCount) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.