Versions in this module Expand all Collapse all v1 v1.4.1 Sep 2, 2020 Changes in this version + var ErrIntOverflowPrivate = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowPublic = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthPrivate = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthPublic = fmt.Errorf("proto: negative length found during unmarshaling") + type Attr struct + BoolValue bool + FloatValue float64 + IntValue int64 + Key string + StringValue string + Type uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Attr) Descriptor() ([]byte, []int) + func (*Attr) ProtoMessage() + func (dst *Attr) XXX_Merge(src proto.Message) + 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 (m *Attr) Reset() + func (m *Attr) Size() (n int) + func (m *Attr) String() string + func (m *Attr) Unmarshal(dAtA []byte) error + func (m *Attr) XXX_DiscardUnknown() + func (m *Attr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Attr) XXX_Size() int + func (m *Attr) XXX_Unmarshal(b []byte) error + type AttrMap struct + Attrs []*Attr + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AttrMap) Descriptor() ([]byte, []int) + func (*AttrMap) ProtoMessage() + func (dst *AttrMap) XXX_Merge(src proto.Message) + func (m *AttrMap) GetAttrs() []*Attr + func (m *AttrMap) Marshal() (dAtA []byte, err error) + func (m *AttrMap) MarshalTo(dAtA []byte) (int, error) + func (m *AttrMap) Reset() + func (m *AttrMap) Size() (n int) + func (m *AttrMap) String() string + func (m *AttrMap) Unmarshal(dAtA []byte) error + func (m *AttrMap) XXX_DiscardUnknown() + func (m *AttrMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AttrMap) XXX_Size() int + func (m *AttrMap) XXX_Unmarshal(b []byte) error + type BSIGroup struct + Max int64 + Min int64 + Name string + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BSIGroup) Descriptor() ([]byte, []int) + func (*BSIGroup) ProtoMessage() + func (dst *BSIGroup) XXX_Merge(src proto.Message) + 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 (m *BSIGroup) Reset() + func (m *BSIGroup) Size() (n int) + func (m *BSIGroup) String() string + func (m *BSIGroup) Unmarshal(dAtA []byte) error + func (m *BSIGroup) XXX_DiscardUnknown() + func (m *BSIGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BSIGroup) XXX_Size() int + func (m *BSIGroup) XXX_Unmarshal(b []byte) error + type Bit struct + ColumnID uint64 + RowID uint64 + Timestamp int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Bit) Descriptor() ([]byte, []int) + func (*Bit) ProtoMessage() + func (dst *Bit) XXX_Merge(src proto.Message) + func (m *Bit) GetColumnID() uint64 + func (m *Bit) GetRowID() uint64 + func (m *Bit) GetTimestamp() int64 + func (m *Bit) Marshal() (dAtA []byte, err error) + func (m *Bit) MarshalTo(dAtA []byte) (int, error) + func (m *Bit) Reset() + func (m *Bit) Size() (n int) + func (m *Bit) String() string + func (m *Bit) Unmarshal(dAtA []byte) error + func (m *Bit) XXX_DiscardUnknown() + func (m *Bit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Bit) XXX_Size() int + func (m *Bit) XXX_Unmarshal(b []byte) error + type BlockDataRequest struct + Block uint64 + Field string + Index string + Shard uint64 + View string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BlockDataRequest) Descriptor() ([]byte, []int) + func (*BlockDataRequest) ProtoMessage() + func (dst *BlockDataRequest) XXX_Merge(src proto.Message) + 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 (m *BlockDataRequest) Reset() + func (m *BlockDataRequest) Size() (n int) + func (m *BlockDataRequest) String() string + func (m *BlockDataRequest) Unmarshal(dAtA []byte) error + func (m *BlockDataRequest) XXX_DiscardUnknown() + func (m *BlockDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BlockDataRequest) XXX_Size() int + func (m *BlockDataRequest) XXX_Unmarshal(b []byte) error + type BlockDataResponse struct + ColumnIDs []uint64 + RowIDs []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BlockDataResponse) Descriptor() ([]byte, []int) + func (*BlockDataResponse) ProtoMessage() + func (dst *BlockDataResponse) XXX_Merge(src proto.Message) + 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 (m *BlockDataResponse) Reset() + func (m *BlockDataResponse) Size() (n int) + func (m *BlockDataResponse) String() string + func (m *BlockDataResponse) Unmarshal(dAtA []byte) error + func (m *BlockDataResponse) XXX_DiscardUnknown() + func (m *BlockDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BlockDataResponse) XXX_Size() int + func (m *BlockDataResponse) XXX_Unmarshal(b []byte) error + type Cache struct + IDs []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Cache) Descriptor() ([]byte, []int) + func (*Cache) ProtoMessage() + func (dst *Cache) XXX_Merge(src proto.Message) + func (m *Cache) GetIDs() []uint64 + func (m *Cache) Marshal() (dAtA []byte, err error) + func (m *Cache) MarshalTo(dAtA []byte) (int, error) + func (m *Cache) Reset() + func (m *Cache) Size() (n int) + func (m *Cache) String() string + func (m *Cache) Unmarshal(dAtA []byte) error + func (m *Cache) XXX_DiscardUnknown() + func (m *Cache) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Cache) XXX_Size() int + func (m *Cache) XXX_Unmarshal(b []byte) error + type ClusterStatus struct + ClusterID string + Nodes []*Node + State string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClusterStatus) Descriptor() ([]byte, []int) + func (*ClusterStatus) ProtoMessage() + func (dst *ClusterStatus) XXX_Merge(src proto.Message) + 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 (m *ClusterStatus) Reset() + func (m *ClusterStatus) Size() (n int) + func (m *ClusterStatus) String() string + func (m *ClusterStatus) Unmarshal(dAtA []byte) error + func (m *ClusterStatus) XXX_DiscardUnknown() + func (m *ClusterStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClusterStatus) XXX_Size() int + func (m *ClusterStatus) XXX_Unmarshal(b []byte) error + type ColumnAttrSet struct + Attrs []*Attr + ID uint64 + Key string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ColumnAttrSet) Descriptor() ([]byte, []int) + func (*ColumnAttrSet) ProtoMessage() + func (dst *ColumnAttrSet) XXX_Merge(src proto.Message) + 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 (m *ColumnAttrSet) Reset() + func (m *ColumnAttrSet) Size() (n int) + func (m *ColumnAttrSet) String() string + func (m *ColumnAttrSet) Unmarshal(dAtA []byte) error + func (m *ColumnAttrSet) XXX_DiscardUnknown() + func (m *ColumnAttrSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ColumnAttrSet) XXX_Size() int + func (m *ColumnAttrSet) XXX_Unmarshal(b []byte) error + type CreateFieldMessage struct + Field string + Index string + Meta *FieldOptions + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateFieldMessage) Descriptor() ([]byte, []int) + func (*CreateFieldMessage) ProtoMessage() + func (dst *CreateFieldMessage) XXX_Merge(src proto.Message) + 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 (m *CreateFieldMessage) Reset() + func (m *CreateFieldMessage) Size() (n int) + func (m *CreateFieldMessage) String() string + func (m *CreateFieldMessage) Unmarshal(dAtA []byte) error + func (m *CreateFieldMessage) XXX_DiscardUnknown() + func (m *CreateFieldMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateFieldMessage) XXX_Size() int + func (m *CreateFieldMessage) XXX_Unmarshal(b []byte) error + type CreateIndexMessage struct + Index string + Meta *IndexMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateIndexMessage) Descriptor() ([]byte, []int) + func (*CreateIndexMessage) ProtoMessage() + func (dst *CreateIndexMessage) XXX_Merge(src proto.Message) + 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 (m *CreateIndexMessage) Reset() + func (m *CreateIndexMessage) Size() (n int) + func (m *CreateIndexMessage) String() string + func (m *CreateIndexMessage) Unmarshal(dAtA []byte) error + func (m *CreateIndexMessage) XXX_DiscardUnknown() + func (m *CreateIndexMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateIndexMessage) XXX_Size() int + func (m *CreateIndexMessage) XXX_Unmarshal(b []byte) error + type CreateShardMessage struct + Field string + Index string + Shard uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateShardMessage) Descriptor() ([]byte, []int) + func (*CreateShardMessage) ProtoMessage() + func (dst *CreateShardMessage) XXX_Merge(src proto.Message) + 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 (m *CreateShardMessage) Reset() + func (m *CreateShardMessage) Size() (n int) + func (m *CreateShardMessage) String() string + func (m *CreateShardMessage) Unmarshal(dAtA []byte) error + func (m *CreateShardMessage) XXX_DiscardUnknown() + func (m *CreateShardMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateShardMessage) XXX_Size() int + func (m *CreateShardMessage) XXX_Unmarshal(b []byte) error + type CreateViewMessage struct + Field string + Index string + View string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateViewMessage) Descriptor() ([]byte, []int) + func (*CreateViewMessage) ProtoMessage() + func (dst *CreateViewMessage) XXX_Merge(src proto.Message) + 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 (m *CreateViewMessage) Reset() + func (m *CreateViewMessage) Size() (n int) + func (m *CreateViewMessage) String() string + func (m *CreateViewMessage) Unmarshal(dAtA []byte) error + func (m *CreateViewMessage) XXX_DiscardUnknown() + func (m *CreateViewMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateViewMessage) XXX_Size() int + func (m *CreateViewMessage) XXX_Unmarshal(b []byte) error + type Decoder struct + func NewDecoder(r io.Reader) *Decoder + func (dec *Decoder) Decode(pb proto.Message) error + type DeleteAvailableShardMessage struct + Field string + Index string + ShardID uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteAvailableShardMessage) Descriptor() ([]byte, []int) + func (*DeleteAvailableShardMessage) ProtoMessage() + func (dst *DeleteAvailableShardMessage) XXX_Merge(src proto.Message) + 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 (m *DeleteAvailableShardMessage) Reset() + func (m *DeleteAvailableShardMessage) Size() (n int) + func (m *DeleteAvailableShardMessage) String() string + func (m *DeleteAvailableShardMessage) Unmarshal(dAtA []byte) error + func (m *DeleteAvailableShardMessage) XXX_DiscardUnknown() + func (m *DeleteAvailableShardMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteAvailableShardMessage) XXX_Size() int + func (m *DeleteAvailableShardMessage) XXX_Unmarshal(b []byte) error + type DeleteFieldMessage struct + Field string + Index string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteFieldMessage) Descriptor() ([]byte, []int) + func (*DeleteFieldMessage) ProtoMessage() + func (dst *DeleteFieldMessage) XXX_Merge(src proto.Message) + 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 (m *DeleteFieldMessage) Reset() + func (m *DeleteFieldMessage) Size() (n int) + func (m *DeleteFieldMessage) String() string + func (m *DeleteFieldMessage) Unmarshal(dAtA []byte) error + func (m *DeleteFieldMessage) XXX_DiscardUnknown() + func (m *DeleteFieldMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteFieldMessage) XXX_Size() int + func (m *DeleteFieldMessage) XXX_Unmarshal(b []byte) error + type DeleteIndexMessage struct + Index string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteIndexMessage) Descriptor() ([]byte, []int) + func (*DeleteIndexMessage) ProtoMessage() + func (dst *DeleteIndexMessage) XXX_Merge(src proto.Message) + func (m *DeleteIndexMessage) GetIndex() string + func (m *DeleteIndexMessage) Marshal() (dAtA []byte, err error) + func (m *DeleteIndexMessage) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteIndexMessage) Reset() + func (m *DeleteIndexMessage) Size() (n int) + func (m *DeleteIndexMessage) String() string + func (m *DeleteIndexMessage) Unmarshal(dAtA []byte) error + func (m *DeleteIndexMessage) XXX_DiscardUnknown() + func (m *DeleteIndexMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteIndexMessage) XXX_Size() int + func (m *DeleteIndexMessage) XXX_Unmarshal(b []byte) error + type DeleteViewMessage struct + Field string + Index string + View string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteViewMessage) Descriptor() ([]byte, []int) + func (*DeleteViewMessage) ProtoMessage() + func (dst *DeleteViewMessage) XXX_Merge(src proto.Message) + 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 (m *DeleteViewMessage) Reset() + func (m *DeleteViewMessage) Size() (n int) + func (m *DeleteViewMessage) String() string + func (m *DeleteViewMessage) Unmarshal(dAtA []byte) error + func (m *DeleteViewMessage) XXX_DiscardUnknown() + func (m *DeleteViewMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteViewMessage) XXX_Size() int + func (m *DeleteViewMessage) XXX_Unmarshal(b []byte) error + type Encoder struct + func NewEncoder(w io.Writer) *Encoder + func (enc *Encoder) Encode(pb proto.Message) error + type Field struct + Meta *FieldOptions + Name string + Views []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Field) Descriptor() ([]byte, []int) + func (*Field) ProtoMessage() + func (dst *Field) XXX_Merge(src proto.Message) + 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 (m *Field) Reset() + func (m *Field) Size() (n int) + func (m *Field) String() string + func (m *Field) Unmarshal(dAtA []byte) error + func (m *Field) XXX_DiscardUnknown() + func (m *Field) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Field) XXX_Size() int + func (m *Field) XXX_Unmarshal(b []byte) error + type FieldOptions struct + CacheSize uint32 + CacheType string + Keys bool + Max int64 + Min int64 + NoStandardView bool + TimeQuantum string + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FieldOptions) Descriptor() ([]byte, []int) + func (*FieldOptions) ProtoMessage() + func (dst *FieldOptions) XXX_Merge(src proto.Message) + 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 (m *FieldOptions) Reset() + func (m *FieldOptions) Size() (n int) + func (m *FieldOptions) String() string + func (m *FieldOptions) Unmarshal(dAtA []byte) error + func (m *FieldOptions) XXX_DiscardUnknown() + func (m *FieldOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FieldOptions) XXX_Size() int + func (m *FieldOptions) XXX_Unmarshal(b []byte) error + type FieldRow struct + Field string + RowID uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FieldRow) Descriptor() ([]byte, []int) + func (*FieldRow) ProtoMessage() + func (dst *FieldRow) XXX_Merge(src proto.Message) + func (m *FieldRow) GetField() string + func (m *FieldRow) GetRowID() uint64 + func (m *FieldRow) Marshal() (dAtA []byte, err error) + func (m *FieldRow) MarshalTo(dAtA []byte) (int, error) + func (m *FieldRow) Reset() + func (m *FieldRow) Size() (n int) + func (m *FieldRow) String() string + func (m *FieldRow) Unmarshal(dAtA []byte) error + func (m *FieldRow) XXX_DiscardUnknown() + func (m *FieldRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FieldRow) XXX_Size() int + func (m *FieldRow) XXX_Unmarshal(b []byte) error + type FieldStatus struct + AvailableShards []uint64 + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FieldStatus) Descriptor() ([]byte, []int) + func (*FieldStatus) ProtoMessage() + func (dst *FieldStatus) XXX_Merge(src proto.Message) + 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 (m *FieldStatus) Reset() + func (m *FieldStatus) Size() (n int) + func (m *FieldStatus) String() string + func (m *FieldStatus) Unmarshal(dAtA []byte) error + func (m *FieldStatus) XXX_DiscardUnknown() + func (m *FieldStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FieldStatus) XXX_Size() int + func (m *FieldStatus) XXX_Unmarshal(b []byte) error + type GroupCount struct + Count uint64 + Group []*FieldRow + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GroupCount) Descriptor() ([]byte, []int) + func (*GroupCount) ProtoMessage() + func (dst *GroupCount) XXX_Merge(src proto.Message) + 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 (m *GroupCount) Reset() + func (m *GroupCount) Size() (n int) + func (m *GroupCount) String() string + func (m *GroupCount) Unmarshal(dAtA []byte) error + func (m *GroupCount) XXX_DiscardUnknown() + func (m *GroupCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GroupCount) XXX_Size() int + func (m *GroupCount) XXX_Unmarshal(b []byte) error + type ImportRequest struct + ColumnIDs []uint64 + ColumnKeys []string + Field string + Index string + RowIDs []uint64 + RowKeys []string + Shard uint64 + Timestamps []int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportRequest) Descriptor() ([]byte, []int) + func (*ImportRequest) ProtoMessage() + func (dst *ImportRequest) XXX_Merge(src proto.Message) + 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 (m *ImportRequest) Reset() + func (m *ImportRequest) Size() (n int) + func (m *ImportRequest) String() string + func (m *ImportRequest) Unmarshal(dAtA []byte) error + func (m *ImportRequest) XXX_DiscardUnknown() + func (m *ImportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportRequest) XXX_Size() int + func (m *ImportRequest) XXX_Unmarshal(b []byte) error + type ImportResponse struct + Err string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportResponse) Descriptor() ([]byte, []int) + func (*ImportResponse) ProtoMessage() + func (dst *ImportResponse) XXX_Merge(src proto.Message) + func (m *ImportResponse) GetErr() string + func (m *ImportResponse) Marshal() (dAtA []byte, err error) + func (m *ImportResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ImportResponse) Reset() + func (m *ImportResponse) Size() (n int) + func (m *ImportResponse) String() string + func (m *ImportResponse) Unmarshal(dAtA []byte) error + func (m *ImportResponse) XXX_DiscardUnknown() + func (m *ImportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportResponse) XXX_Size() int + func (m *ImportResponse) XXX_Unmarshal(b []byte) error + type ImportRoaringRequest struct + Clear bool + Views []*ImportRoaringRequestView + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportRoaringRequest) Descriptor() ([]byte, []int) + func (*ImportRoaringRequest) ProtoMessage() + func (dst *ImportRoaringRequest) XXX_Merge(src proto.Message) + 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 (m *ImportRoaringRequest) Reset() + func (m *ImportRoaringRequest) Size() (n int) + func (m *ImportRoaringRequest) String() string + func (m *ImportRoaringRequest) Unmarshal(dAtA []byte) error + func (m *ImportRoaringRequest) XXX_DiscardUnknown() + func (m *ImportRoaringRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportRoaringRequest) XXX_Size() int + func (m *ImportRoaringRequest) XXX_Unmarshal(b []byte) error + type ImportRoaringRequestView struct + Data []byte + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportRoaringRequestView) Descriptor() ([]byte, []int) + func (*ImportRoaringRequestView) ProtoMessage() + func (dst *ImportRoaringRequestView) XXX_Merge(src proto.Message) + 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 (m *ImportRoaringRequestView) Reset() + func (m *ImportRoaringRequestView) Size() (n int) + func (m *ImportRoaringRequestView) String() string + func (m *ImportRoaringRequestView) Unmarshal(dAtA []byte) error + func (m *ImportRoaringRequestView) XXX_DiscardUnknown() + func (m *ImportRoaringRequestView) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportRoaringRequestView) XXX_Size() int + func (m *ImportRoaringRequestView) XXX_Unmarshal(b []byte) error + type ImportValueRequest struct + ColumnIDs []uint64 + ColumnKeys []string + Field string + Index string + Shard uint64 + Values []int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportValueRequest) Descriptor() ([]byte, []int) + func (*ImportValueRequest) ProtoMessage() + func (dst *ImportValueRequest) XXX_Merge(src proto.Message) + 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 (m *ImportValueRequest) Reset() + func (m *ImportValueRequest) Size() (n int) + func (m *ImportValueRequest) String() string + func (m *ImportValueRequest) Unmarshal(dAtA []byte) error + func (m *ImportValueRequest) XXX_DiscardUnknown() + func (m *ImportValueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportValueRequest) XXX_Size() int + func (m *ImportValueRequest) XXX_Unmarshal(b []byte) error + type Index struct + Fields []*Field + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Index) Descriptor() ([]byte, []int) + func (*Index) ProtoMessage() + func (dst *Index) XXX_Merge(src proto.Message) + 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 (m *Index) Reset() + func (m *Index) Size() (n int) + func (m *Index) String() string + func (m *Index) Unmarshal(dAtA []byte) error + func (m *Index) XXX_DiscardUnknown() + func (m *Index) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Index) XXX_Size() int + func (m *Index) XXX_Unmarshal(b []byte) error + type IndexMeta struct + Keys bool + TrackExistence bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IndexMeta) Descriptor() ([]byte, []int) + func (*IndexMeta) ProtoMessage() + func (dst *IndexMeta) XXX_Merge(src proto.Message) + 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 (m *IndexMeta) Reset() + func (m *IndexMeta) Size() (n int) + func (m *IndexMeta) String() string + func (m *IndexMeta) Unmarshal(dAtA []byte) error + func (m *IndexMeta) XXX_DiscardUnknown() + func (m *IndexMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexMeta) XXX_Size() int + func (m *IndexMeta) XXX_Unmarshal(b []byte) error + type IndexStatus struct + Fields []*FieldStatus + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IndexStatus) Descriptor() ([]byte, []int) + func (*IndexStatus) ProtoMessage() + func (dst *IndexStatus) XXX_Merge(src proto.Message) + 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 (m *IndexStatus) Reset() + func (m *IndexStatus) Size() (n int) + func (m *IndexStatus) String() string + func (m *IndexStatus) Unmarshal(dAtA []byte) error + func (m *IndexStatus) XXX_DiscardUnknown() + func (m *IndexStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexStatus) XXX_Size() int + func (m *IndexStatus) XXX_Unmarshal(b []byte) error + type MaxShards struct + Standard map[string]uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MaxShards) Descriptor() ([]byte, []int) + func (*MaxShards) ProtoMessage() + func (dst *MaxShards) XXX_Merge(src proto.Message) + func (m *MaxShards) GetStandard() map[string]uint64 + func (m *MaxShards) Marshal() (dAtA []byte, err error) + func (m *MaxShards) MarshalTo(dAtA []byte) (int, error) + func (m *MaxShards) Reset() + func (m *MaxShards) Size() (n int) + func (m *MaxShards) String() string + func (m *MaxShards) Unmarshal(dAtA []byte) error + func (m *MaxShards) XXX_DiscardUnknown() + func (m *MaxShards) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MaxShards) XXX_Size() int + func (m *MaxShards) XXX_Unmarshal(b []byte) error + type Node struct + ID string + IsCoordinator bool + State string + URI *URI + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Node) Descriptor() ([]byte, []int) + func (*Node) ProtoMessage() + func (dst *Node) XXX_Merge(src proto.Message) + 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 (m *Node) Reset() + func (m *Node) Size() (n int) + func (m *Node) String() string + func (m *Node) Unmarshal(dAtA []byte) error + func (m *Node) XXX_DiscardUnknown() + func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Node) XXX_Size() int + func (m *Node) XXX_Unmarshal(b []byte) error + type NodeEventMessage struct + Event uint32 + Node *Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeEventMessage) Descriptor() ([]byte, []int) + func (*NodeEventMessage) ProtoMessage() + func (dst *NodeEventMessage) XXX_Merge(src proto.Message) + 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 (m *NodeEventMessage) Reset() + func (m *NodeEventMessage) Size() (n int) + func (m *NodeEventMessage) String() string + func (m *NodeEventMessage) Unmarshal(dAtA []byte) error + func (m *NodeEventMessage) XXX_DiscardUnknown() + func (m *NodeEventMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeEventMessage) XXX_Size() int + func (m *NodeEventMessage) XXX_Unmarshal(b []byte) error + type NodeStateMessage struct + NodeID string + State string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeStateMessage) Descriptor() ([]byte, []int) + func (*NodeStateMessage) ProtoMessage() + func (dst *NodeStateMessage) XXX_Merge(src proto.Message) + 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 (m *NodeStateMessage) Reset() + func (m *NodeStateMessage) Size() (n int) + func (m *NodeStateMessage) String() string + func (m *NodeStateMessage) Unmarshal(dAtA []byte) error + func (m *NodeStateMessage) XXX_DiscardUnknown() + func (m *NodeStateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeStateMessage) XXX_Size() int + func (m *NodeStateMessage) XXX_Unmarshal(b []byte) error + type NodeStatus struct + Indexes []*IndexStatus + Node *Node + Schema *Schema + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeStatus) Descriptor() ([]byte, []int) + func (*NodeStatus) ProtoMessage() + func (dst *NodeStatus) XXX_Merge(src proto.Message) + 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 (m *NodeStatus) Reset() + func (m *NodeStatus) Size() (n int) + func (m *NodeStatus) String() string + func (m *NodeStatus) Unmarshal(dAtA []byte) error + func (m *NodeStatus) XXX_DiscardUnknown() + func (m *NodeStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeStatus) XXX_Size() int + func (m *NodeStatus) XXX_Unmarshal(b []byte) error + type Pair struct + Count uint64 + ID uint64 + Key string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Pair) Descriptor() ([]byte, []int) + func (*Pair) ProtoMessage() + func (dst *Pair) XXX_Merge(src proto.Message) + 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 (m *Pair) Reset() + func (m *Pair) Size() (n int) + func (m *Pair) String() string + func (m *Pair) Unmarshal(dAtA []byte) error + func (m *Pair) XXX_DiscardUnknown() + func (m *Pair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Pair) XXX_Size() int + func (m *Pair) XXX_Unmarshal(b []byte) error + type QueryRequest struct + ColumnAttrs bool + ExcludeColumns bool + ExcludeRowAttrs bool + Query string + Remote bool + Shards []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*QueryRequest) Descriptor() ([]byte, []int) + func (*QueryRequest) ProtoMessage() + func (dst *QueryRequest) XXX_Merge(src proto.Message) + 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 (m *QueryRequest) Reset() + func (m *QueryRequest) Size() (n int) + func (m *QueryRequest) String() string + func (m *QueryRequest) Unmarshal(dAtA []byte) error + func (m *QueryRequest) XXX_DiscardUnknown() + func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequest) XXX_Size() int + func (m *QueryRequest) XXX_Unmarshal(b []byte) error + type QueryResponse struct + ColumnAttrSets []*ColumnAttrSet + Err string + Results []*QueryResult + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*QueryResponse) Descriptor() ([]byte, []int) + func (*QueryResponse) ProtoMessage() + func (dst *QueryResponse) XXX_Merge(src proto.Message) + 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 (m *QueryResponse) Reset() + func (m *QueryResponse) Size() (n int) + func (m *QueryResponse) String() string + func (m *QueryResponse) Unmarshal(dAtA []byte) error + func (m *QueryResponse) XXX_DiscardUnknown() + func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryResponse) XXX_Size() int + func (m *QueryResponse) XXX_Unmarshal(b []byte) error + type QueryResult struct + Changed bool + GroupCounts []*GroupCount + N uint64 + Pairs []*Pair + Row *Row + RowIDs []uint64 + RowIdentifiers *RowIdentifiers + Type uint32 + ValCount *ValCount + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*QueryResult) Descriptor() ([]byte, []int) + func (*QueryResult) ProtoMessage() + func (dst *QueryResult) XXX_Merge(src proto.Message) + 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 (m *QueryResult) Reset() + func (m *QueryResult) Size() (n int) + func (m *QueryResult) String() string + func (m *QueryResult) Unmarshal(dAtA []byte) error + func (m *QueryResult) XXX_DiscardUnknown() + func (m *QueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryResult) XXX_Size() int + func (m *QueryResult) XXX_Unmarshal(b []byte) error + type RecalculateCaches struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RecalculateCaches) Descriptor() ([]byte, []int) + func (*RecalculateCaches) ProtoMessage() + func (dst *RecalculateCaches) XXX_Merge(src proto.Message) + func (m *RecalculateCaches) Marshal() (dAtA []byte, err error) + func (m *RecalculateCaches) MarshalTo(dAtA []byte) (int, error) + func (m *RecalculateCaches) Reset() + func (m *RecalculateCaches) Size() (n int) + func (m *RecalculateCaches) String() string + func (m *RecalculateCaches) Unmarshal(dAtA []byte) error + func (m *RecalculateCaches) XXX_DiscardUnknown() + func (m *RecalculateCaches) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RecalculateCaches) XXX_Size() int + func (m *RecalculateCaches) XXX_Unmarshal(b []byte) error + type Request proto.Message + type ResizeInstruction struct + ClusterStatus *ClusterStatus + Coordinator *Node + JobID int64 + Node *Node + NodeStatus *NodeStatus + Sources []*ResizeSource + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResizeInstruction) Descriptor() ([]byte, []int) + func (*ResizeInstruction) ProtoMessage() + func (dst *ResizeInstruction) XXX_Merge(src proto.Message) + 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 (m *ResizeInstruction) Reset() + func (m *ResizeInstruction) Size() (n int) + func (m *ResizeInstruction) String() string + func (m *ResizeInstruction) Unmarshal(dAtA []byte) error + func (m *ResizeInstruction) XXX_DiscardUnknown() + func (m *ResizeInstruction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResizeInstruction) XXX_Size() int + func (m *ResizeInstruction) XXX_Unmarshal(b []byte) error + type ResizeInstructionComplete struct + Error string + JobID int64 + Node *Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResizeInstructionComplete) Descriptor() ([]byte, []int) + func (*ResizeInstructionComplete) ProtoMessage() + func (dst *ResizeInstructionComplete) XXX_Merge(src proto.Message) + 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 (m *ResizeInstructionComplete) Reset() + func (m *ResizeInstructionComplete) Size() (n int) + func (m *ResizeInstructionComplete) String() string + func (m *ResizeInstructionComplete) Unmarshal(dAtA []byte) error + func (m *ResizeInstructionComplete) XXX_DiscardUnknown() + func (m *ResizeInstructionComplete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResizeInstructionComplete) XXX_Size() int + func (m *ResizeInstructionComplete) XXX_Unmarshal(b []byte) error + type ResizeSource struct + Field string + Index string + Node *Node + Shard uint64 + View string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResizeSource) Descriptor() ([]byte, []int) + func (*ResizeSource) ProtoMessage() + func (dst *ResizeSource) XXX_Merge(src proto.Message) + 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 (m *ResizeSource) Reset() + func (m *ResizeSource) Size() (n int) + func (m *ResizeSource) String() string + func (m *ResizeSource) Unmarshal(dAtA []byte) error + func (m *ResizeSource) XXX_DiscardUnknown() + func (m *ResizeSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResizeSource) XXX_Size() int + func (m *ResizeSource) XXX_Unmarshal(b []byte) error + type Response proto.Message + type Row struct + Attrs []*Attr + Columns []uint64 + Keys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Row) Descriptor() ([]byte, []int) + func (*Row) ProtoMessage() + func (dst *Row) XXX_Merge(src proto.Message) + 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 (m *Row) Reset() + func (m *Row) Size() (n int) + func (m *Row) String() string + func (m *Row) Unmarshal(dAtA []byte) error + func (m *Row) XXX_DiscardUnknown() + func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Row) XXX_Size() int + func (m *Row) XXX_Unmarshal(b []byte) error + type RowIdentifiers struct + Keys []string + Rows []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RowIdentifiers) Descriptor() ([]byte, []int) + func (*RowIdentifiers) ProtoMessage() + func (dst *RowIdentifiers) XXX_Merge(src proto.Message) + 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 (m *RowIdentifiers) Reset() + func (m *RowIdentifiers) Size() (n int) + func (m *RowIdentifiers) String() string + func (m *RowIdentifiers) Unmarshal(dAtA []byte) error + func (m *RowIdentifiers) XXX_DiscardUnknown() + func (m *RowIdentifiers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RowIdentifiers) XXX_Size() int + func (m *RowIdentifiers) XXX_Unmarshal(b []byte) error + type Schema struct + Indexes []*Index + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Schema) Descriptor() ([]byte, []int) + func (*Schema) ProtoMessage() + func (dst *Schema) XXX_Merge(src proto.Message) + func (m *Schema) GetIndexes() []*Index + func (m *Schema) Marshal() (dAtA []byte, err error) + func (m *Schema) MarshalTo(dAtA []byte) (int, error) + func (m *Schema) Reset() + func (m *Schema) Size() (n int) + func (m *Schema) String() string + func (m *Schema) Unmarshal(dAtA []byte) error + func (m *Schema) XXX_DiscardUnknown() + func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Schema) XXX_Size() int + func (m *Schema) XXX_Unmarshal(b []byte) error + type SetCoordinatorMessage struct + New *Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetCoordinatorMessage) Descriptor() ([]byte, []int) + func (*SetCoordinatorMessage) ProtoMessage() + func (dst *SetCoordinatorMessage) XXX_Merge(src proto.Message) + func (m *SetCoordinatorMessage) GetNew() *Node + func (m *SetCoordinatorMessage) Marshal() (dAtA []byte, err error) + func (m *SetCoordinatorMessage) MarshalTo(dAtA []byte) (int, error) + func (m *SetCoordinatorMessage) Reset() + func (m *SetCoordinatorMessage) Size() (n int) + func (m *SetCoordinatorMessage) String() string + func (m *SetCoordinatorMessage) Unmarshal(dAtA []byte) error + func (m *SetCoordinatorMessage) XXX_DiscardUnknown() + func (m *SetCoordinatorMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetCoordinatorMessage) XXX_Size() int + func (m *SetCoordinatorMessage) XXX_Unmarshal(b []byte) error + type Topology struct + ClusterID string + NodeIDs []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Topology) Descriptor() ([]byte, []int) + func (*Topology) ProtoMessage() + func (dst *Topology) XXX_Merge(src proto.Message) + 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 (m *Topology) Reset() + func (m *Topology) Size() (n int) + func (m *Topology) String() string + func (m *Topology) Unmarshal(dAtA []byte) error + func (m *Topology) XXX_DiscardUnknown() + func (m *Topology) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Topology) XXX_Size() int + func (m *Topology) XXX_Unmarshal(b []byte) error + type TranslateKeysRequest struct + Field string + Index string + Keys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TranslateKeysRequest) Descriptor() ([]byte, []int) + func (*TranslateKeysRequest) ProtoMessage() + func (dst *TranslateKeysRequest) XXX_Merge(src proto.Message) + 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 (m *TranslateKeysRequest) Reset() + func (m *TranslateKeysRequest) Size() (n int) + func (m *TranslateKeysRequest) String() string + func (m *TranslateKeysRequest) Unmarshal(dAtA []byte) error + func (m *TranslateKeysRequest) XXX_DiscardUnknown() + func (m *TranslateKeysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TranslateKeysRequest) XXX_Size() int + func (m *TranslateKeysRequest) XXX_Unmarshal(b []byte) error + type TranslateKeysResponse struct + IDs []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TranslateKeysResponse) Descriptor() ([]byte, []int) + func (*TranslateKeysResponse) ProtoMessage() + func (dst *TranslateKeysResponse) XXX_Merge(src proto.Message) + func (m *TranslateKeysResponse) GetIDs() []uint64 + func (m *TranslateKeysResponse) Marshal() (dAtA []byte, err error) + func (m *TranslateKeysResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TranslateKeysResponse) Reset() + func (m *TranslateKeysResponse) Size() (n int) + func (m *TranslateKeysResponse) String() string + func (m *TranslateKeysResponse) Unmarshal(dAtA []byte) error + func (m *TranslateKeysResponse) XXX_DiscardUnknown() + func (m *TranslateKeysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TranslateKeysResponse) XXX_Size() int + func (m *TranslateKeysResponse) XXX_Unmarshal(b []byte) error + type URI struct + Host string + Port uint32 + Scheme string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*URI) Descriptor() ([]byte, []int) + func (*URI) ProtoMessage() + func (dst *URI) XXX_Merge(src proto.Message) + 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 (m *URI) Reset() + func (m *URI) Size() (n int) + func (m *URI) String() string + func (m *URI) Unmarshal(dAtA []byte) error + func (m *URI) XXX_DiscardUnknown() + func (m *URI) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *URI) XXX_Size() int + func (m *URI) XXX_Unmarshal(b []byte) error + type UpdateCoordinatorMessage struct + New *Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateCoordinatorMessage) Descriptor() ([]byte, []int) + func (*UpdateCoordinatorMessage) ProtoMessage() + func (dst *UpdateCoordinatorMessage) XXX_Merge(src proto.Message) + func (m *UpdateCoordinatorMessage) GetNew() *Node + func (m *UpdateCoordinatorMessage) Marshal() (dAtA []byte, err error) + func (m *UpdateCoordinatorMessage) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateCoordinatorMessage) Reset() + func (m *UpdateCoordinatorMessage) Size() (n int) + func (m *UpdateCoordinatorMessage) String() string + func (m *UpdateCoordinatorMessage) Unmarshal(dAtA []byte) error + func (m *UpdateCoordinatorMessage) XXX_DiscardUnknown() + func (m *UpdateCoordinatorMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateCoordinatorMessage) XXX_Size() int + func (m *UpdateCoordinatorMessage) XXX_Unmarshal(b []byte) error + type ValCount struct + Count int64 + Val int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ValCount) Descriptor() ([]byte, []int) + func (*ValCount) ProtoMessage() + func (dst *ValCount) XXX_Merge(src proto.Message) + 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 (m *ValCount) Reset() + func (m *ValCount) Size() (n int) + func (m *ValCount) String() string + func (m *ValCount) Unmarshal(dAtA []byte) error + func (m *ValCount) XXX_DiscardUnknown() + func (m *ValCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ValCount) XXX_Size() int + func (m *ValCount) XXX_Unmarshal(b []byte) error