internal

package
v1.4.1 Latest Latest
Warning

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

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

Documentation

Index

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Attr) Descriptor 

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

func (*Attr) GetBoolValue 

func (m *Attr) GetBoolValue() bool

func (*Attr) GetFloatValue 

func (m *Attr) GetFloatValue() float64

func (*Attr) GetIntValue 

func (m *Attr) GetIntValue() int64

func (*Attr) GetKey 

func (m *Attr) GetKey() string

func (*Attr) GetStringValue 

func (m *Attr) GetStringValue() string

func (*Attr) GetType 

func (m *Attr) GetType() uint64

func (*Attr) Marshal 

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

func (*Attr) MarshalTo 

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

func (*Attr) ProtoMessage 

func (*Attr) ProtoMessage()

func (*Attr) Reset 

func (m *Attr) Reset()

func (*Attr) Size 

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

func (*Attr) String 

func (m *Attr) String() string

func (*Attr) Unmarshal 

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

func (*Attr) XXX_DiscardUnknown 

func (m *Attr) XXX_DiscardUnknown()

func (*Attr) XXX_Marshal 

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

func (*Attr) XXX_Merge 

func (dst *Attr) XXX_Merge(src proto.Message)

func (*Attr) XXX_Size 

func (m *Attr) XXX_Size() int

func (*Attr) XXX_Unmarshal 

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

type AttrMap 

type AttrMap struct {
	Attrs                []*Attr  `protobuf:"bytes,1,rep,name=Attrs" json:"Attrs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AttrMap) Descriptor 

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

func (*AttrMap) GetAttrs 

func (m *AttrMap) GetAttrs() []*Attr

func (*AttrMap) Marshal 

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

func (*AttrMap) MarshalTo 

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

func (*AttrMap) ProtoMessage 

func (*AttrMap) ProtoMessage()

func (*AttrMap) Reset 

func (m *AttrMap) Reset()

func (*AttrMap) Size 

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

func (*AttrMap) String 

func (m *AttrMap) String() string

func (*AttrMap) Unmarshal 

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

func (*AttrMap) XXX_DiscardUnknown 

func (m *AttrMap) XXX_DiscardUnknown()

func (*AttrMap) XXX_Marshal 

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

func (*AttrMap) XXX_Merge 

func (dst *AttrMap) XXX_Merge(src proto.Message)

func (*AttrMap) XXX_Size 

func (m *AttrMap) XXX_Size() int

func (*AttrMap) XXX_Unmarshal 

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

type BSIGroup 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BSIGroup) Descriptor 

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

func (*BSIGroup) GetMax 

func (m *BSIGroup) GetMax() int64

func (*BSIGroup) GetMin 

func (m *BSIGroup) GetMin() int64

func (*BSIGroup) GetName 

func (m *BSIGroup) GetName() string

func (*BSIGroup) GetType 

func (m *BSIGroup) GetType() string

func (*BSIGroup) Marshal 

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

func (*BSIGroup) MarshalTo 

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

func (*BSIGroup) ProtoMessage 

func (*BSIGroup) ProtoMessage()

func (*BSIGroup) Reset 

func (m *BSIGroup) Reset()

func (*BSIGroup) Size 

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

func (*BSIGroup) String 

func (m *BSIGroup) String() string

func (*BSIGroup) Unmarshal 

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

func (*BSIGroup) XXX_DiscardUnknown 

func (m *BSIGroup) XXX_DiscardUnknown()

func (*BSIGroup) XXX_Marshal 

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

func (*BSIGroup) XXX_Merge 

func (dst *BSIGroup) XXX_Merge(src proto.Message)

func (*BSIGroup) XXX_Size 

func (m *BSIGroup) XXX_Size() int

func (*BSIGroup) XXX_Unmarshal 

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

type Bit 

type Bit struct {
	RowID                uint64   `protobuf:"varint,1,opt,name=RowID,proto3" json:"RowID,omitempty"`
	ColumnID             uint64   `protobuf:"varint,2,opt,name=ColumnID,proto3" json:"ColumnID,omitempty"`
	Timestamp            int64    `protobuf:"varint,3,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Bit) Descriptor 

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

func (*Bit) GetColumnID 

func (m *Bit) GetColumnID() uint64

func (*Bit) GetRowID 

func (m *Bit) GetRowID() uint64

func (*Bit) GetTimestamp 

func (m *Bit) GetTimestamp() int64

func (*Bit) Marshal 

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

func (*Bit) MarshalTo 

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

func (*Bit) ProtoMessage 

func (*Bit) ProtoMessage()

func (*Bit) Reset 

func (m *Bit) Reset()

func (*Bit) Size 

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

func (*Bit) String 

func (m *Bit) String() string

func (*Bit) Unmarshal 

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

func (*Bit) XXX_DiscardUnknown 

func (m *Bit) XXX_DiscardUnknown()

func (*Bit) XXX_Marshal 

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

func (*Bit) XXX_Merge 

func (dst *Bit) XXX_Merge(src proto.Message)

func (*Bit) XXX_Size 

func (m *Bit) XXX_Size() int

func (*Bit) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlockDataRequest) Descriptor 

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

func (*BlockDataRequest) GetBlock 

func (m *BlockDataRequest) GetBlock() uint64

func (*BlockDataRequest) GetField 

func (m *BlockDataRequest) GetField() string

func (*BlockDataRequest) GetIndex 

func (m *BlockDataRequest) GetIndex() string

func (*BlockDataRequest) GetShard 

func (m *BlockDataRequest) GetShard() uint64

func (*BlockDataRequest) GetView 

func (m *BlockDataRequest) GetView() string

func (*BlockDataRequest) Marshal 

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

func (*BlockDataRequest) MarshalTo 

func (m *BlockDataRequest) MarshalTo(dAtA []byte) (int, 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

func (*BlockDataRequest) XXX_DiscardUnknown 

func (m *BlockDataRequest) XXX_DiscardUnknown()

func (*BlockDataRequest) XXX_Marshal 

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

func (*BlockDataRequest) XXX_Merge 

func (dst *BlockDataRequest) XXX_Merge(src proto.Message)

func (*BlockDataRequest) XXX_Size 

func (m *BlockDataRequest) XXX_Size() int

func (*BlockDataRequest) XXX_Unmarshal 

func (m *BlockDataRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlockDataResponse) Descriptor 

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

func (*BlockDataResponse) GetColumnIDs 

func (m *BlockDataResponse) GetColumnIDs() []uint64

func (*BlockDataResponse) GetRowIDs 

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

func (*BlockDataResponse) XXX_DiscardUnknown 

func (m *BlockDataResponse) XXX_DiscardUnknown()

func (*BlockDataResponse) XXX_Marshal 

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

func (*BlockDataResponse) XXX_Merge 

func (dst *BlockDataResponse) XXX_Merge(src proto.Message)

func (*BlockDataResponse) XXX_Size 

func (m *BlockDataResponse) XXX_Size() int

func (*BlockDataResponse) XXX_Unmarshal 

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

type Cache 

type Cache struct {
	IDs                  []uint64 `protobuf:"varint,1,rep,packed,name=IDs" json:"IDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Cache) Descriptor 

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

func (*Cache) GetIDs 

func (m *Cache) GetIDs() []uint64

func (*Cache) Marshal 

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

func (*Cache) MarshalTo 

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

func (*Cache) ProtoMessage 

func (*Cache) ProtoMessage()

func (*Cache) Reset 

func (m *Cache) Reset()

func (*Cache) Size 

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

func (*Cache) String 

func (m *Cache) String() string

func (*Cache) Unmarshal 

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

func (*Cache) XXX_DiscardUnknown 

func (m *Cache) XXX_DiscardUnknown()

func (*Cache) XXX_Marshal 

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

func (*Cache) XXX_Merge 

func (dst *Cache) XXX_Merge(src proto.Message)

func (*Cache) XXX_Size 

func (m *Cache) XXX_Size() int

func (*Cache) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClusterStatus) Descriptor 

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

func (*ClusterStatus) GetClusterID 

func (m *ClusterStatus) GetClusterID() string

func (*ClusterStatus) GetNodes 

func (m *ClusterStatus) GetNodes() []*Node

func (*ClusterStatus) GetState 

func (m *ClusterStatus) GetState() string

func (*ClusterStatus) Marshal 

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

func (*ClusterStatus) MarshalTo 

func (m *ClusterStatus) MarshalTo(dAtA []byte) (int, 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

func (*ClusterStatus) XXX_DiscardUnknown 

func (m *ClusterStatus) XXX_DiscardUnknown()

func (*ClusterStatus) XXX_Marshal 

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

func (*ClusterStatus) XXX_Merge 

func (dst *ClusterStatus) XXX_Merge(src proto.Message)

func (*ClusterStatus) XXX_Size 

func (m *ClusterStatus) XXX_Size() int

func (*ClusterStatus) XXX_Unmarshal 

func (m *ClusterStatus) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ColumnAttrSet) Descriptor 

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

func (*ColumnAttrSet) GetAttrs 

func (m *ColumnAttrSet) GetAttrs() []*Attr

func (*ColumnAttrSet) GetID 

func (m *ColumnAttrSet) GetID() uint64

func (*ColumnAttrSet) GetKey 

func (m *ColumnAttrSet) GetKey() string

func (*ColumnAttrSet) Marshal 

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

func (*ColumnAttrSet) MarshalTo 

func (m *ColumnAttrSet) MarshalTo(dAtA []byte) (int, 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

func (*ColumnAttrSet) XXX_DiscardUnknown 

func (m *ColumnAttrSet) XXX_DiscardUnknown()

func (*ColumnAttrSet) XXX_Marshal 

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

func (*ColumnAttrSet) XXX_Merge 

func (dst *ColumnAttrSet) XXX_Merge(src proto.Message)

func (*ColumnAttrSet) XXX_Size 

func (m *ColumnAttrSet) XXX_Size() int

func (*ColumnAttrSet) XXX_Unmarshal 

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

type CreateFieldMessage 

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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*CreateFieldMessage) Descriptor 

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

func (*CreateFieldMessage) GetField 

func (m *CreateFieldMessage) GetField() string

func (*CreateFieldMessage) GetIndex 

func (m *CreateFieldMessage) GetIndex() string

func (*CreateFieldMessage) GetMeta 

func (m *CreateFieldMessage) GetMeta() *FieldOptions

func (*CreateFieldMessage) Marshal 

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

func (*CreateFieldMessage) MarshalTo 

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

func (*CreateFieldMessage) ProtoMessage 

func (*CreateFieldMessage) ProtoMessage()

func (*CreateFieldMessage) Reset 

func (m *CreateFieldMessage) Reset()

func (*CreateFieldMessage) Size 

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

func (*CreateFieldMessage) String 

func (m *CreateFieldMessage) String() string

func (*CreateFieldMessage) Unmarshal 

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

func (*CreateFieldMessage) XXX_DiscardUnknown 

func (m *CreateFieldMessage) XXX_DiscardUnknown()

func (*CreateFieldMessage) XXX_Marshal 

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

func (*CreateFieldMessage) XXX_Merge 

func (dst *CreateFieldMessage) XXX_Merge(src proto.Message)

func (*CreateFieldMessage) XXX_Size 

func (m *CreateFieldMessage) XXX_Size() int

func (*CreateFieldMessage) XXX_Unmarshal 

func (m *CreateFieldMessage) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CreateIndexMessage) Descriptor 

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

func (*CreateIndexMessage) GetIndex 

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

func (*CreateIndexMessage) XXX_DiscardUnknown 

func (m *CreateIndexMessage) XXX_DiscardUnknown()

func (*CreateIndexMessage) XXX_Marshal 

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

func (*CreateIndexMessage) XXX_Merge 

func (dst *CreateIndexMessage) XXX_Merge(src proto.Message)

func (*CreateIndexMessage) XXX_Size 

func (m *CreateIndexMessage) XXX_Size() int

func (*CreateIndexMessage) XXX_Unmarshal 

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

type CreateShardMessage 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateShardMessage) Descriptor 

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

func (*CreateShardMessage) GetField 

func (m *CreateShardMessage) GetField() string

func (*CreateShardMessage) GetIndex 

func (m *CreateShardMessage) GetIndex() string

func (*CreateShardMessage) GetShard 

func (m *CreateShardMessage) GetShard() uint64

func (*CreateShardMessage) Marshal 

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

func (*CreateShardMessage) MarshalTo 

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

func (*CreateShardMessage) ProtoMessage 

func (*CreateShardMessage) ProtoMessage()

func (*CreateShardMessage) Reset 

func (m *CreateShardMessage) Reset()

func (*CreateShardMessage) Size 

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

func (*CreateShardMessage) String 

func (m *CreateShardMessage) String() string

func (*CreateShardMessage) Unmarshal 

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

func (*CreateShardMessage) XXX_DiscardUnknown 

func (m *CreateShardMessage) XXX_DiscardUnknown()

func (*CreateShardMessage) XXX_Marshal 

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

func (*CreateShardMessage) XXX_Merge 

func (dst *CreateShardMessage) XXX_Merge(src proto.Message)

func (*CreateShardMessage) XXX_Size 

func (m *CreateShardMessage) XXX_Size() int

func (*CreateShardMessage) XXX_Unmarshal 

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

type CreateViewMessage 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateViewMessage) Descriptor 

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

func (*CreateViewMessage) GetField 

func (m *CreateViewMessage) GetField() string

func (*CreateViewMessage) GetIndex 

func (m *CreateViewMessage) GetIndex() string

func (*CreateViewMessage) GetView 

func (m *CreateViewMessage) GetView() string

func (*CreateViewMessage) Marshal 

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

func (*CreateViewMessage) MarshalTo 

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

func (*CreateViewMessage) ProtoMessage 

func (*CreateViewMessage) ProtoMessage()

func (*CreateViewMessage) Reset 

func (m *CreateViewMessage) Reset()

func (*CreateViewMessage) Size 

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

func (*CreateViewMessage) String 

func (m *CreateViewMessage) String() string

func (*CreateViewMessage) Unmarshal 

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

func (*CreateViewMessage) XXX_DiscardUnknown 

func (m *CreateViewMessage) XXX_DiscardUnknown()

func (*CreateViewMessage) XXX_Marshal 

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

func (*CreateViewMessage) XXX_Merge 

func (dst *CreateViewMessage) XXX_Merge(src proto.Message)

func (*CreateViewMessage) XXX_Size 

func (m *CreateViewMessage) XXX_Size() int

func (*CreateViewMessage) XXX_Unmarshal 

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

type Decoder 

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

Decoder decodes messages from a reader.

func NewDecoder 

func NewDecoder(r io.Reader) *Decoder

NewDecoder returns a new instance of Decoder.

func (*Decoder) Decode 

func (dec *Decoder) Decode(pb proto.Message) error

Decode reads all bytes from the reader and unmarshals them into pb.

type DeleteAvailableShardMessage 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteAvailableShardMessage) Descriptor 

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

func (*DeleteAvailableShardMessage) GetField 

func (m *DeleteAvailableShardMessage) GetField() string

func (*DeleteAvailableShardMessage) GetIndex 

func (m *DeleteAvailableShardMessage) GetIndex() string

func (*DeleteAvailableShardMessage) GetShardID 

func (m *DeleteAvailableShardMessage) GetShardID() uint64

func (*DeleteAvailableShardMessage) Marshal 

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

func (*DeleteAvailableShardMessage) MarshalTo 

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

func (*DeleteAvailableShardMessage) ProtoMessage 

func (*DeleteAvailableShardMessage) ProtoMessage()

func (*DeleteAvailableShardMessage) Reset 

func (m *DeleteAvailableShardMessage) Reset()

func (*DeleteAvailableShardMessage) Size 

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

func (*DeleteAvailableShardMessage) String 

func (m *DeleteAvailableShardMessage) String() string

func (*DeleteAvailableShardMessage) Unmarshal 

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

func (*DeleteAvailableShardMessage) XXX_DiscardUnknown 

func (m *DeleteAvailableShardMessage) XXX_DiscardUnknown()

func (*DeleteAvailableShardMessage) XXX_Marshal 

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

func (*DeleteAvailableShardMessage) XXX_Merge 

func (dst *DeleteAvailableShardMessage) XXX_Merge(src proto.Message)

func (*DeleteAvailableShardMessage) XXX_Size 

func (m *DeleteAvailableShardMessage) XXX_Size() int

func (*DeleteAvailableShardMessage) XXX_Unmarshal 

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

type DeleteFieldMessage 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteFieldMessage) Descriptor 

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

func (*DeleteFieldMessage) GetField 

func (m *DeleteFieldMessage) GetField() string

func (*DeleteFieldMessage) GetIndex 

func (m *DeleteFieldMessage) GetIndex() string

func (*DeleteFieldMessage) Marshal 

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

func (*DeleteFieldMessage) MarshalTo 

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

func (*DeleteFieldMessage) ProtoMessage 

func (*DeleteFieldMessage) ProtoMessage()

func (*DeleteFieldMessage) Reset 

func (m *DeleteFieldMessage) Reset()

func (*DeleteFieldMessage) Size 

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

func (*DeleteFieldMessage) String 

func (m *DeleteFieldMessage) String() string

func (*DeleteFieldMessage) Unmarshal 

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

func (*DeleteFieldMessage) XXX_DiscardUnknown 

func (m *DeleteFieldMessage) XXX_DiscardUnknown()

func (*DeleteFieldMessage) XXX_Marshal 

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

func (*DeleteFieldMessage) XXX_Merge 

func (dst *DeleteFieldMessage) XXX_Merge(src proto.Message)

func (*DeleteFieldMessage) XXX_Size 

func (m *DeleteFieldMessage) XXX_Size() int

func (*DeleteFieldMessage) XXX_Unmarshal 

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

type DeleteIndexMessage 

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

func (*DeleteIndexMessage) Descriptor 

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

func (*DeleteIndexMessage) GetIndex 

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

func (*DeleteIndexMessage) XXX_DiscardUnknown 

func (m *DeleteIndexMessage) XXX_DiscardUnknown()

func (*DeleteIndexMessage) XXX_Marshal 

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

func (*DeleteIndexMessage) XXX_Merge 

func (dst *DeleteIndexMessage) XXX_Merge(src proto.Message)

func (*DeleteIndexMessage) XXX_Size 

func (m *DeleteIndexMessage) XXX_Size() int

func (*DeleteIndexMessage) XXX_Unmarshal 

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

type DeleteViewMessage 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteViewMessage) Descriptor 

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

func (*DeleteViewMessage) GetField 

func (m *DeleteViewMessage) GetField() string

func (*DeleteViewMessage) GetIndex 

func (m *DeleteViewMessage) GetIndex() string

func (*DeleteViewMessage) GetView 

func (m *DeleteViewMessage) GetView() string

func (*DeleteViewMessage) Marshal 

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

func (*DeleteViewMessage) MarshalTo 

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

func (*DeleteViewMessage) ProtoMessage 

func (*DeleteViewMessage) ProtoMessage()

func (*DeleteViewMessage) Reset 

func (m *DeleteViewMessage) Reset()

func (*DeleteViewMessage) Size 

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

func (*DeleteViewMessage) String 

func (m *DeleteViewMessage) String() string

func (*DeleteViewMessage) Unmarshal 

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

func (*DeleteViewMessage) XXX_DiscardUnknown 

func (m *DeleteViewMessage) XXX_DiscardUnknown()

func (*DeleteViewMessage) XXX_Marshal 

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

func (*DeleteViewMessage) XXX_Merge 

func (dst *DeleteViewMessage) XXX_Merge(src proto.Message)

func (*DeleteViewMessage) XXX_Size 

func (m *DeleteViewMessage) XXX_Size() int

func (*DeleteViewMessage) XXX_Unmarshal 

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

type Encoder 

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

Encoder encodes messages to a writer.

func NewEncoder 

func NewEncoder(w io.Writer) *Encoder

NewEncoder returns a new instance of Encoder.

func (*Encoder) Encode 

func (enc *Encoder) Encode(pb proto.Message) error

Encode marshals m into bytes and writes them to r.

type Field 

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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Field) Descriptor 

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

func (*Field) GetMeta 

func (m *Field) GetMeta() *FieldOptions

func (*Field) GetName 

func (m *Field) GetName() string

func (*Field) GetViews 

func (m *Field) GetViews() []string

func (*Field) Marshal 

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

func (*Field) MarshalTo 

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

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) Reset 

func (m *Field) Reset()

func (*Field) Size 

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

func (*Field) String 

func (m *Field) String() string

func (*Field) Unmarshal 

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

func (*Field) XXX_DiscardUnknown 

func (m *Field) XXX_DiscardUnknown()

func (*Field) XXX_Marshal 

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

func (*Field) XXX_Merge 

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

func (*Field) XXX_Size 

func (m *Field) XXX_Size() int

func (*Field) XXX_Unmarshal 

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

type FieldOptions 

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"`
	Min                  int64    `protobuf:"varint,9,opt,name=Min,proto3" json:"Min,omitempty"`
	Max                  int64    `protobuf:"varint,10,opt,name=Max,proto3" json:"Max,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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldOptions) Descriptor 

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

func (*FieldOptions) GetCacheSize 

func (m *FieldOptions) GetCacheSize() uint32

func (*FieldOptions) GetCacheType 

func (m *FieldOptions) GetCacheType() string

func (*FieldOptions) GetKeys 

func (m *FieldOptions) GetKeys() bool

func (*FieldOptions) GetMax 

func (m *FieldOptions) GetMax() int64

func (*FieldOptions) GetMin 

func (m *FieldOptions) GetMin() int64

func (*FieldOptions) GetNoStandardView 

func (m *FieldOptions) GetNoStandardView() bool

func (*FieldOptions) GetTimeQuantum 

func (m *FieldOptions) GetTimeQuantum() string

func (*FieldOptions) GetType 

func (m *FieldOptions) GetType() string

func (*FieldOptions) Marshal 

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

func (*FieldOptions) MarshalTo 

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

func (*FieldOptions) ProtoMessage 

func (*FieldOptions) ProtoMessage()

func (*FieldOptions) Reset 

func (m *FieldOptions) Reset()

func (*FieldOptions) Size 

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

func (*FieldOptions) String 

func (m *FieldOptions) String() string

func (*FieldOptions) Unmarshal 

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

func (*FieldOptions) XXX_DiscardUnknown 

func (m *FieldOptions) XXX_DiscardUnknown()

func (*FieldOptions) XXX_Marshal 

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

func (*FieldOptions) XXX_Merge 

func (dst *FieldOptions) XXX_Merge(src proto.Message)

func (*FieldOptions) XXX_Size 

func (m *FieldOptions) XXX_Size() int

func (*FieldOptions) XXX_Unmarshal 

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

type FieldRow 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldRow) Descriptor 

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

func (*FieldRow) GetField 

func (m *FieldRow) GetField() string

func (*FieldRow) GetRowID 

func (m *FieldRow) GetRowID() uint64

func (*FieldRow) Marshal 

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

func (*FieldRow) MarshalTo 

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

func (*FieldRow) ProtoMessage 

func (*FieldRow) ProtoMessage()

func (*FieldRow) Reset 

func (m *FieldRow) Reset()

func (*FieldRow) Size 

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

func (*FieldRow) String 

func (m *FieldRow) String() string

func (*FieldRow) Unmarshal 

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

func (*FieldRow) XXX_DiscardUnknown 

func (m *FieldRow) XXX_DiscardUnknown()

func (*FieldRow) XXX_Marshal 

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

func (*FieldRow) XXX_Merge 

func (dst *FieldRow) XXX_Merge(src proto.Message)

func (*FieldRow) XXX_Size 

func (m *FieldRow) XXX_Size() int

func (*FieldRow) XXX_Unmarshal 

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

type FieldStatus 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldStatus) Descriptor 

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

func (*FieldStatus) GetAvailableShards 

func (m *FieldStatus) GetAvailableShards() []uint64

func (*FieldStatus) GetName 

func (m *FieldStatus) GetName() string

func (*FieldStatus) Marshal 

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

func (*FieldStatus) MarshalTo 

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

func (*FieldStatus) ProtoMessage 

func (*FieldStatus) ProtoMessage()

func (*FieldStatus) Reset 

func (m *FieldStatus) Reset()

func (*FieldStatus) Size 

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

func (*FieldStatus) String 

func (m *FieldStatus) String() string

func (*FieldStatus) Unmarshal 

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

func (*FieldStatus) XXX_DiscardUnknown 

func (m *FieldStatus) XXX_DiscardUnknown()

func (*FieldStatus) XXX_Marshal 

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

func (*FieldStatus) XXX_Merge 

func (dst *FieldStatus) XXX_Merge(src proto.Message)

func (*FieldStatus) XXX_Size 

func (m *FieldStatus) XXX_Size() int

func (*FieldStatus) XXX_Unmarshal 

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

type GroupCount 

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*GroupCount) Descriptor 

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

func (*GroupCount) GetCount 

func (m *GroupCount) GetCount() uint64

func (*GroupCount) GetGroup 

func (m *GroupCount) GetGroup() []*FieldRow

func (*GroupCount) Marshal 

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

func (*GroupCount) MarshalTo 

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

func (*GroupCount) ProtoMessage 

func (*GroupCount) ProtoMessage()

func (*GroupCount) Reset 

func (m *GroupCount) Reset()

func (*GroupCount) Size 

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

func (*GroupCount) String 

func (m *GroupCount) String() string

func (*GroupCount) Unmarshal 

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

func (*GroupCount) XXX_DiscardUnknown 

func (m *GroupCount) XXX_DiscardUnknown()

func (*GroupCount) XXX_Marshal 

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

func (*GroupCount) XXX_Merge 

func (dst *GroupCount) XXX_Merge(src proto.Message)

func (*GroupCount) XXX_Size 

func (m *GroupCount) XXX_Size() int

func (*GroupCount) XXX_Unmarshal 

func (m *GroupCount) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImportRequest) Descriptor 

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

func (*ImportRequest) GetColumnIDs 

func (m *ImportRequest) GetColumnIDs() []uint64

func (*ImportRequest) GetColumnKeys 

func (m *ImportRequest) GetColumnKeys() []string

func (*ImportRequest) GetField 

func (m *ImportRequest) GetField() string

func (*ImportRequest) GetIndex 

func (m *ImportRequest) GetIndex() string

func (*ImportRequest) GetRowIDs 

func (m *ImportRequest) GetRowIDs() []uint64

func (*ImportRequest) GetRowKeys 

func (m *ImportRequest) GetRowKeys() []string

func (*ImportRequest) GetShard 

func (m *ImportRequest) GetShard() uint64

func (*ImportRequest) GetTimestamps 

func (m *ImportRequest) GetTimestamps() []int64

func (*ImportRequest) Marshal 

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

func (*ImportRequest) MarshalTo 

func (m *ImportRequest) MarshalTo(dAtA []byte) (int, 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

func (*ImportRequest) XXX_DiscardUnknown 

func (m *ImportRequest) XXX_DiscardUnknown()

func (*ImportRequest) XXX_Marshal 

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

func (*ImportRequest) XXX_Merge 

func (dst *ImportRequest) XXX_Merge(src proto.Message)

func (*ImportRequest) XXX_Size 

func (m *ImportRequest) XXX_Size() int

func (*ImportRequest) XXX_Unmarshal 

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

type ImportResponse 

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

func (*ImportResponse) Descriptor 

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

func (*ImportResponse) GetErr 

func (m *ImportResponse) GetErr() string

func (*ImportResponse) Marshal 

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

func (*ImportResponse) MarshalTo 

func (m *ImportResponse) MarshalTo(dAtA []byte) (int, 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

func (*ImportResponse) XXX_DiscardUnknown 

func (m *ImportResponse) XXX_DiscardUnknown()

func (*ImportResponse) XXX_Marshal 

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

func (*ImportResponse) XXX_Merge 

func (dst *ImportResponse) XXX_Merge(src proto.Message)

func (*ImportResponse) XXX_Size 

func (m *ImportResponse) XXX_Size() int

func (*ImportResponse) XXX_Unmarshal 

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

type ImportRoaringRequest 

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"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ImportRoaringRequest) Descriptor 

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

func (*ImportRoaringRequest) GetClear 

func (m *ImportRoaringRequest) GetClear() bool

func (*ImportRoaringRequest) GetViews 

func (m *ImportRoaringRequest) GetViews() []*ImportRoaringRequestView

func (*ImportRoaringRequest) Marshal 

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

func (*ImportRoaringRequest) MarshalTo 

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

func (*ImportRoaringRequest) ProtoMessage 

func (*ImportRoaringRequest) ProtoMessage()

func (*ImportRoaringRequest) Reset 

func (m *ImportRoaringRequest) Reset()

func (*ImportRoaringRequest) Size 

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

func (*ImportRoaringRequest) String 

func (m *ImportRoaringRequest) String() string

func (*ImportRoaringRequest) Unmarshal 

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

func (*ImportRoaringRequest) XXX_DiscardUnknown 

func (m *ImportRoaringRequest) XXX_DiscardUnknown()

func (*ImportRoaringRequest) XXX_Marshal 

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

func (*ImportRoaringRequest) XXX_Merge 

func (dst *ImportRoaringRequest) XXX_Merge(src proto.Message)

func (*ImportRoaringRequest) XXX_Size 

func (m *ImportRoaringRequest) XXX_Size() int

func (*ImportRoaringRequest) XXX_Unmarshal 

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

type ImportRoaringRequestView 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImportRoaringRequestView) Descriptor 

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

func (*ImportRoaringRequestView) GetData 

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

func (*ImportRoaringRequestView) GetName 

func (m *ImportRoaringRequestView) GetName() string

func (*ImportRoaringRequestView) Marshal 

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

func (*ImportRoaringRequestView) MarshalTo 

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

func (*ImportRoaringRequestView) ProtoMessage 

func (*ImportRoaringRequestView) ProtoMessage()

func (*ImportRoaringRequestView) Reset 

func (m *ImportRoaringRequestView) Reset()

func (*ImportRoaringRequestView) Size 

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

func (*ImportRoaringRequestView) String 

func (m *ImportRoaringRequestView) String() string

func (*ImportRoaringRequestView) Unmarshal 

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

func (*ImportRoaringRequestView) XXX_DiscardUnknown 

func (m *ImportRoaringRequestView) XXX_DiscardUnknown()

func (*ImportRoaringRequestView) XXX_Marshal 

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

func (*ImportRoaringRequestView) XXX_Merge 

func (dst *ImportRoaringRequestView) XXX_Merge(src proto.Message)

func (*ImportRoaringRequestView) XXX_Size 

func (m *ImportRoaringRequestView) XXX_Size() int

func (*ImportRoaringRequestView) XXX_Unmarshal 

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

type ImportValueRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImportValueRequest) Descriptor 

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

func (*ImportValueRequest) GetColumnIDs 

func (m *ImportValueRequest) GetColumnIDs() []uint64

func (*ImportValueRequest) GetColumnKeys 

func (m *ImportValueRequest) GetColumnKeys() []string

func (*ImportValueRequest) GetField 

func (m *ImportValueRequest) GetField() string

func (*ImportValueRequest) GetIndex 

func (m *ImportValueRequest) GetIndex() string

func (*ImportValueRequest) GetShard 

func (m *ImportValueRequest) GetShard() uint64

func (*ImportValueRequest) GetValues 

func (m *ImportValueRequest) GetValues() []int64

func (*ImportValueRequest) Marshal 

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

func (*ImportValueRequest) MarshalTo 

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

func (*ImportValueRequest) ProtoMessage 

func (*ImportValueRequest) ProtoMessage()

func (*ImportValueRequest) Reset 

func (m *ImportValueRequest) Reset()

func (*ImportValueRequest) Size 

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

func (*ImportValueRequest) String 

func (m *ImportValueRequest) String() string

func (*ImportValueRequest) Unmarshal 

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

func (*ImportValueRequest) XXX_DiscardUnknown 

func (m *ImportValueRequest) XXX_DiscardUnknown()

func (*ImportValueRequest) XXX_Marshal 

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

func (*ImportValueRequest) XXX_Merge 

func (dst *ImportValueRequest) XXX_Merge(src proto.Message)

func (*ImportValueRequest) XXX_Size 

func (m *ImportValueRequest) XXX_Size() int

func (*ImportValueRequest) XXX_Unmarshal 

func (m *ImportValueRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Index) Descriptor 

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

func (*Index) GetFields 

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

func (*Index) GetName 

func (m *Index) GetName() string

func (*Index) Marshal 

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

func (*Index) MarshalTo 

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

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) Reset 

func (m *Index) Reset()

func (*Index) Size 

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

func (*Index) String 

func (m *Index) String() string

func (*Index) Unmarshal 

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

func (*Index) XXX_DiscardUnknown 

func (m *Index) XXX_DiscardUnknown()

func (*Index) XXX_Marshal 

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

func (*Index) XXX_Merge 

func (dst *Index) XXX_Merge(src proto.Message)

func (*Index) XXX_Size 

func (m *Index) XXX_Size() int

func (*Index) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexMeta) Descriptor 

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

func (*IndexMeta) GetKeys 

func (m *IndexMeta) GetKeys() bool

func (*IndexMeta) GetTrackExistence 

func (m *IndexMeta) GetTrackExistence() bool

func (*IndexMeta) Marshal 

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

func (*IndexMeta) MarshalTo 

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

func (*IndexMeta) ProtoMessage 

func (*IndexMeta) ProtoMessage()

func (*IndexMeta) Reset 

func (m *IndexMeta) Reset()

func (*IndexMeta) Size 

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

func (*IndexMeta) String 

func (m *IndexMeta) String() string

func (*IndexMeta) Unmarshal 

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

func (*IndexMeta) XXX_DiscardUnknown 

func (m *IndexMeta) XXX_DiscardUnknown()

func (*IndexMeta) XXX_Marshal 

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

func (*IndexMeta) XXX_Merge 

func (dst *IndexMeta) XXX_Merge(src proto.Message)

func (*IndexMeta) XXX_Size 

func (m *IndexMeta) XXX_Size() int

func (*IndexMeta) XXX_Unmarshal 

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

type IndexStatus 

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*IndexStatus) Descriptor 

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

func (*IndexStatus) GetFields 

func (m *IndexStatus) GetFields() []*FieldStatus

func (*IndexStatus) GetName 

func (m *IndexStatus) GetName() string

func (*IndexStatus) Marshal 

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

func (*IndexStatus) MarshalTo 

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

func (*IndexStatus) ProtoMessage 

func (*IndexStatus) ProtoMessage()

func (*IndexStatus) Reset 

func (m *IndexStatus) Reset()

func (*IndexStatus) Size 

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

func (*IndexStatus) String 

func (m *IndexStatus) String() string

func (*IndexStatus) Unmarshal 

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

func (*IndexStatus) XXX_DiscardUnknown 

func (m *IndexStatus) XXX_DiscardUnknown()

func (*IndexStatus) XXX_Marshal 

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

func (*IndexStatus) XXX_Merge 

func (dst *IndexStatus) XXX_Merge(src proto.Message)

func (*IndexStatus) XXX_Size 

func (m *IndexStatus) XXX_Size() int

func (*IndexStatus) XXX_Unmarshal 

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

type MaxShards 

type MaxShards struct {
	Standard             map[string]uint64 `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*MaxShards) Descriptor 

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

func (*MaxShards) GetStandard 

func (m *MaxShards) GetStandard() map[string]uint64

func (*MaxShards) Marshal 

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

func (*MaxShards) MarshalTo 

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

func (*MaxShards) ProtoMessage 

func (*MaxShards) ProtoMessage()

func (*MaxShards) Reset 

func (m *MaxShards) Reset()

func (*MaxShards) Size 

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

func (*MaxShards) String 

func (m *MaxShards) String() string

func (*MaxShards) Unmarshal 

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

func (*MaxShards) XXX_DiscardUnknown 

func (m *MaxShards) XXX_DiscardUnknown()

func (*MaxShards) XXX_Marshal 

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

func (*MaxShards) XXX_Merge 

func (dst *MaxShards) XXX_Merge(src proto.Message)

func (*MaxShards) XXX_Size 

func (m *MaxShards) XXX_Size() int

func (*MaxShards) XXX_Unmarshal 

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

type Node 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Node) Descriptor 

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

func (*Node) GetID 

func (m *Node) GetID() string

func (*Node) GetIsCoordinator 

func (m *Node) GetIsCoordinator() bool

func (*Node) GetState 

func (m *Node) GetState() string

func (*Node) GetURI 

func (m *Node) GetURI() *URI

func (*Node) Marshal 

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

func (*Node) MarshalTo 

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

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

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

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

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

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

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

func (*Node) XXX_Merge 

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

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

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

type NodeEventMessage 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeEventMessage) Descriptor 

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

func (*NodeEventMessage) GetEvent 

func (m *NodeEventMessage) GetEvent() uint32

func (*NodeEventMessage) GetNode 

func (m *NodeEventMessage) GetNode() *Node

func (*NodeEventMessage) Marshal 

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

func (*NodeEventMessage) MarshalTo 

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

func (*NodeEventMessage) ProtoMessage 

func (*NodeEventMessage) ProtoMessage()

func (*NodeEventMessage) Reset 

func (m *NodeEventMessage) Reset()

func (*NodeEventMessage) Size 

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

func (*NodeEventMessage) String 

func (m *NodeEventMessage) String() string

func (*NodeEventMessage) Unmarshal 

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

func (*NodeEventMessage) XXX_DiscardUnknown 

func (m *NodeEventMessage) XXX_DiscardUnknown()

func (*NodeEventMessage) XXX_Marshal 

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

func (*NodeEventMessage) XXX_Merge 

func (dst *NodeEventMessage) XXX_Merge(src proto.Message)

func (*NodeEventMessage) XXX_Size 

func (m *NodeEventMessage) XXX_Size() int

func (*NodeEventMessage) XXX_Unmarshal 

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

type NodeStateMessage 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeStateMessage) Descriptor 

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

func (*NodeStateMessage) GetNodeID 

func (m *NodeStateMessage) GetNodeID() string

func (*NodeStateMessage) GetState 

func (m *NodeStateMessage) GetState() string

func (*NodeStateMessage) Marshal 

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

func (*NodeStateMessage) MarshalTo 

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

func (*NodeStateMessage) ProtoMessage 

func (*NodeStateMessage) ProtoMessage()

func (*NodeStateMessage) Reset 

func (m *NodeStateMessage) Reset()

func (*NodeStateMessage) Size 

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

func (*NodeStateMessage) String 

func (m *NodeStateMessage) String() string

func (*NodeStateMessage) Unmarshal 

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

func (*NodeStateMessage) XXX_DiscardUnknown 

func (m *NodeStateMessage) XXX_DiscardUnknown()

func (*NodeStateMessage) XXX_Marshal 

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

func (*NodeStateMessage) XXX_Merge 

func (dst *NodeStateMessage) XXX_Merge(src proto.Message)

func (*NodeStateMessage) XXX_Size 

func (m *NodeStateMessage) XXX_Size() int

func (*NodeStateMessage) XXX_Unmarshal 

func (m *NodeStateMessage) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*NodeStatus) Descriptor 

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

func (*NodeStatus) GetIndexes 

func (m *NodeStatus) GetIndexes() []*IndexStatus

func (*NodeStatus) GetNode 

func (m *NodeStatus) GetNode() *Node

func (*NodeStatus) GetSchema 

func (m *NodeStatus) GetSchema() *Schema

func (*NodeStatus) Marshal 

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

func (*NodeStatus) MarshalTo 

func (m *NodeStatus) MarshalTo(dAtA []byte) (int, 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

func (*NodeStatus) XXX_DiscardUnknown 

func (m *NodeStatus) XXX_DiscardUnknown()

func (*NodeStatus) XXX_Marshal 

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

func (*NodeStatus) XXX_Merge 

func (dst *NodeStatus) XXX_Merge(src proto.Message)

func (*NodeStatus) XXX_Size 

func (m *NodeStatus) XXX_Size() int

func (*NodeStatus) XXX_Unmarshal 

func (m *NodeStatus) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Pair) Descriptor 

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

func (*Pair) GetCount 

func (m *Pair) GetCount() uint64

func (*Pair) GetID 

func (m *Pair) GetID() uint64

func (*Pair) GetKey 

func (m *Pair) GetKey() string

func (*Pair) Marshal 

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

func (*Pair) MarshalTo 

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

func (*Pair) ProtoMessage 

func (*Pair) ProtoMessage()

func (*Pair) Reset 

func (m *Pair) Reset()

func (*Pair) Size 

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

func (*Pair) String 

func (m *Pair) String() string

func (*Pair) Unmarshal 

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

func (*Pair) XXX_DiscardUnknown 

func (m *Pair) XXX_DiscardUnknown()

func (*Pair) XXX_Marshal 

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

func (*Pair) XXX_Merge 

func (dst *Pair) XXX_Merge(src proto.Message)

func (*Pair) XXX_Size 

func (m *Pair) XXX_Size() int

func (*Pair) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) GetColumnAttrs 

func (m *QueryRequest) GetColumnAttrs() bool

func (*QueryRequest) GetExcludeColumns 

func (m *QueryRequest) GetExcludeColumns() bool

func (*QueryRequest) GetExcludeRowAttrs 

func (m *QueryRequest) GetExcludeRowAttrs() bool

func (*QueryRequest) GetQuery 

func (m *QueryRequest) GetQuery() string

func (*QueryRequest) GetRemote 

func (m *QueryRequest) GetRemote() bool

func (*QueryRequest) GetShards 

func (m *QueryRequest) GetShards() []uint64

func (*QueryRequest) Marshal 

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

func (*QueryRequest) MarshalTo 

func (m *QueryRequest) MarshalTo(dAtA []byte) (int, 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

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

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

func (*QueryRequest) XXX_Merge 

func (dst *QueryRequest) XXX_Merge(src proto.Message)

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

func (m *QueryRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*QueryResponse) Descriptor 

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

func (*QueryResponse) GetColumnAttrSets 

func (m *QueryResponse) GetColumnAttrSets() []*ColumnAttrSet

func (*QueryResponse) GetErr 

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) MarshalTo 

func (m *QueryResponse) MarshalTo(dAtA []byte) (int, 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

func (*QueryResponse) XXX_DiscardUnknown 

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal 

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

func (*QueryResponse) XXX_Merge 

func (dst *QueryResponse) XXX_Merge(src proto.Message)

func (*QueryResponse) XXX_Size 

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal 

func (m *QueryResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*QueryResult) Descriptor 

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

func (*QueryResult) GetChanged 

func (m *QueryResult) GetChanged() bool

func (*QueryResult) GetGroupCounts 

func (m *QueryResult) GetGroupCounts() []*GroupCount

func (*QueryResult) GetN 

func (m *QueryResult) GetN() uint64

func (*QueryResult) GetPairs 

func (m *QueryResult) GetPairs() []*Pair

func (*QueryResult) GetRow 

func (m *QueryResult) GetRow() *Row

func (*QueryResult) GetRowIDs 

func (m *QueryResult) GetRowIDs() []uint64

func (*QueryResult) GetRowIdentifiers 

func (m *QueryResult) GetRowIdentifiers() *RowIdentifiers

func (*QueryResult) GetType 

func (m *QueryResult) GetType() uint32

func (*QueryResult) GetValCount 

func (m *QueryResult) GetValCount() *ValCount

func (*QueryResult) Marshal 

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

func (*QueryResult) MarshalTo 

func (m *QueryResult) MarshalTo(dAtA []byte) (int, 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

func (*QueryResult) XXX_DiscardUnknown 

func (m *QueryResult) XXX_DiscardUnknown()

func (*QueryResult) XXX_Marshal 

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

func (*QueryResult) XXX_Merge 

func (dst *QueryResult) XXX_Merge(src proto.Message)

func (*QueryResult) XXX_Size 

func (m *QueryResult) XXX_Size() int

func (*QueryResult) XXX_Unmarshal 

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

type RecalculateCaches 

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

func (*RecalculateCaches) Descriptor 

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

func (*RecalculateCaches) Marshal 

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

func (*RecalculateCaches) MarshalTo 

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

func (*RecalculateCaches) ProtoMessage 

func (*RecalculateCaches) ProtoMessage()

func (*RecalculateCaches) Reset 

func (m *RecalculateCaches) Reset()

func (*RecalculateCaches) Size 

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

func (*RecalculateCaches) String 

func (m *RecalculateCaches) String() string

func (*RecalculateCaches) Unmarshal 

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

func (*RecalculateCaches) XXX_DiscardUnknown 

func (m *RecalculateCaches) XXX_DiscardUnknown()

func (*RecalculateCaches) XXX_Marshal 

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

func (*RecalculateCaches) XXX_Merge 

func (dst *RecalculateCaches) XXX_Merge(src proto.Message)

func (*RecalculateCaches) XXX_Size 

func (m *RecalculateCaches) XXX_Size() int

func (*RecalculateCaches) XXX_Unmarshal 

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

type Request 

type Request proto.Message

type ResizeInstruction 

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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ResizeInstruction) Descriptor 

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

func (*ResizeInstruction) GetClusterStatus 

func (m *ResizeInstruction) GetClusterStatus() *ClusterStatus

func (*ResizeInstruction) GetCoordinator 

func (m *ResizeInstruction) GetCoordinator() *Node

func (*ResizeInstruction) GetJobID 

func (m *ResizeInstruction) GetJobID() int64

func (*ResizeInstruction) GetNode 

func (m *ResizeInstruction) GetNode() *Node

func (*ResizeInstruction) GetNodeStatus 

func (m *ResizeInstruction) GetNodeStatus() *NodeStatus

func (*ResizeInstruction) GetSources 

func (m *ResizeInstruction) GetSources() []*ResizeSource

func (*ResizeInstruction) Marshal 

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

func (*ResizeInstruction) MarshalTo 

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

func (*ResizeInstruction) ProtoMessage 

func (*ResizeInstruction) ProtoMessage()

func (*ResizeInstruction) Reset 

func (m *ResizeInstruction) Reset()

func (*ResizeInstruction) Size 

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

func (*ResizeInstruction) String 

func (m *ResizeInstruction) String() string

func (*ResizeInstruction) Unmarshal 

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

func (*ResizeInstruction) XXX_DiscardUnknown 

func (m *ResizeInstruction) XXX_DiscardUnknown()

func (*ResizeInstruction) XXX_Marshal 

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

func (*ResizeInstruction) XXX_Merge 

func (dst *ResizeInstruction) XXX_Merge(src proto.Message)

func (*ResizeInstruction) XXX_Size 

func (m *ResizeInstruction) XXX_Size() int

func (*ResizeInstruction) XXX_Unmarshal 

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

type ResizeInstructionComplete 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResizeInstructionComplete) Descriptor 

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

func (*ResizeInstructionComplete) GetError 

func (m *ResizeInstructionComplete) GetError() string

func (*ResizeInstructionComplete) GetJobID 

func (m *ResizeInstructionComplete) GetJobID() int64

func (*ResizeInstructionComplete) GetNode 

func (m *ResizeInstructionComplete) GetNode() *Node

func (*ResizeInstructionComplete) Marshal 

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

func (*ResizeInstructionComplete) MarshalTo 

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

func (*ResizeInstructionComplete) ProtoMessage 

func (*ResizeInstructionComplete) ProtoMessage()

func (*ResizeInstructionComplete) Reset 

func (m *ResizeInstructionComplete) Reset()

func (*ResizeInstructionComplete) Size 

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

func (*ResizeInstructionComplete) String 

func (m *ResizeInstructionComplete) String() string

func (*ResizeInstructionComplete) Unmarshal 

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

func (*ResizeInstructionComplete) XXX_DiscardUnknown 

func (m *ResizeInstructionComplete) XXX_DiscardUnknown()

func (*ResizeInstructionComplete) XXX_Marshal 

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

func (*ResizeInstructionComplete) XXX_Merge 

func (dst *ResizeInstructionComplete) XXX_Merge(src proto.Message)

func (*ResizeInstructionComplete) XXX_Size 

func (m *ResizeInstructionComplete) XXX_Size() int

func (*ResizeInstructionComplete) XXX_Unmarshal 

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

type ResizeSource 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResizeSource) Descriptor 

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

func (*ResizeSource) GetField 

func (m *ResizeSource) GetField() string

func (*ResizeSource) GetIndex 

func (m *ResizeSource) GetIndex() string

func (*ResizeSource) GetNode 

func (m *ResizeSource) GetNode() *Node

func (*ResizeSource) GetShard 

func (m *ResizeSource) GetShard() uint64

func (*ResizeSource) GetView 

func (m *ResizeSource) GetView() string

func (*ResizeSource) Marshal 

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

func (*ResizeSource) MarshalTo 

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

func (*ResizeSource) ProtoMessage 

func (*ResizeSource) ProtoMessage()

func (*ResizeSource) Reset 

func (m *ResizeSource) Reset()

func (*ResizeSource) Size 

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

func (*ResizeSource) String 

func (m *ResizeSource) String() string

func (*ResizeSource) Unmarshal 

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

func (*ResizeSource) XXX_DiscardUnknown 

func (m *ResizeSource) XXX_DiscardUnknown()

func (*ResizeSource) XXX_Marshal 

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

func (*ResizeSource) XXX_Merge 

func (dst *ResizeSource) XXX_Merge(src proto.Message)

func (*ResizeSource) XXX_Size 

func (m *ResizeSource) XXX_Size() int

func (*ResizeSource) XXX_Unmarshal 

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

type Response 

type Response proto.Message

type Row 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Row) Descriptor 

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

func (*Row) GetAttrs 

func (m *Row) GetAttrs() []*Attr

func (*Row) GetColumns 

func (m *Row) GetColumns() []uint64

func (*Row) GetKeys 

func (m *Row) GetKeys() []string

func (*Row) Marshal 

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

func (*Row) MarshalTo 

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

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) Reset 

func (m *Row) Reset()

func (*Row) Size 

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

func (*Row) String 

func (m *Row) String() string

func (*Row) Unmarshal 

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

func (*Row) XXX_DiscardUnknown 

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal 

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

func (*Row) XXX_Merge 

func (dst *Row) XXX_Merge(src proto.Message)

func (*Row) XXX_Size 

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal 

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

type RowIdentifiers 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RowIdentifiers) Descriptor 

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

func (*RowIdentifiers) GetKeys 

func (m *RowIdentifiers) GetKeys() []string

func (*RowIdentifiers) GetRows 

func (m *RowIdentifiers) GetRows() []uint64

func (*RowIdentifiers) Marshal 

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

func (*RowIdentifiers) MarshalTo 

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

func (*RowIdentifiers) ProtoMessage 

func (*RowIdentifiers) ProtoMessage()

func (*RowIdentifiers) Reset 

func (m *RowIdentifiers) Reset()

func (*RowIdentifiers) Size 

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

func (*RowIdentifiers) String 

func (m *RowIdentifiers) String() string

func (*RowIdentifiers) Unmarshal 

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

func (*RowIdentifiers) XXX_DiscardUnknown 

func (m *RowIdentifiers) XXX_DiscardUnknown()

func (*RowIdentifiers) XXX_Marshal 

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

func (*RowIdentifiers) XXX_Merge 

func (dst *RowIdentifiers) XXX_Merge(src proto.Message)

func (*RowIdentifiers) XXX_Size 

func (m *RowIdentifiers) XXX_Size() int

func (*RowIdentifiers) XXX_Unmarshal 

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

type Schema 

type Schema struct {
	Indexes              []*Index `protobuf:"bytes,1,rep,name=Indexes" json:"Indexes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Schema) Descriptor 

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

func (*Schema) GetIndexes 

func (m *Schema) GetIndexes() []*Index

func (*Schema) Marshal 

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

func (*Schema) MarshalTo 

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

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) Reset 

func (m *Schema) Reset()

func (*Schema) Size 

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

func (*Schema) String 

func (m *Schema) String() string

func (*Schema) Unmarshal 

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

func (*Schema) XXX_DiscardUnknown 

func (m *Schema) XXX_DiscardUnknown()

func (*Schema) XXX_Marshal 

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

func (*Schema) XXX_Merge 

func (dst *Schema) XXX_Merge(src proto.Message)

func (*Schema) XXX_Size 

func (m *Schema) XXX_Size() int

func (*Schema) XXX_Unmarshal 

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

type SetCoordinatorMessage 

type SetCoordinatorMessage struct {
	New                  *Node    `protobuf:"bytes,1,opt,name=New" json:"New,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetCoordinatorMessage) Descriptor 

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

func (*SetCoordinatorMessage) GetNew 

func (m *SetCoordinatorMessage) GetNew() *Node

func (*SetCoordinatorMessage) Marshal 

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

func (*SetCoordinatorMessage) MarshalTo 

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

func (*SetCoordinatorMessage) ProtoMessage 

func (*SetCoordinatorMessage) ProtoMessage()

func (*SetCoordinatorMessage) Reset 

func (m *SetCoordinatorMessage) Reset()

func (*SetCoordinatorMessage) Size 

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

func (*SetCoordinatorMessage) String 

func (m *SetCoordinatorMessage) String() string

func (*SetCoordinatorMessage) Unmarshal 

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

func (*SetCoordinatorMessage) XXX_DiscardUnknown 

func (m *SetCoordinatorMessage) XXX_DiscardUnknown()

func (*SetCoordinatorMessage) XXX_Marshal 

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

func (*SetCoordinatorMessage) XXX_Merge 

func (dst *SetCoordinatorMessage) XXX_Merge(src proto.Message)

func (*SetCoordinatorMessage) XXX_Size 

func (m *SetCoordinatorMessage) XXX_Size() int

func (*SetCoordinatorMessage) XXX_Unmarshal 

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

type Topology 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Topology) Descriptor 

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

func (*Topology) GetClusterID 

func (m *Topology) GetClusterID() string

func (*Topology) GetNodeIDs 

func (m *Topology) GetNodeIDs() []string

func (*Topology) Marshal 

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

func (*Topology) MarshalTo 

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

func (*Topology) ProtoMessage 

func (*Topology) ProtoMessage()

func (*Topology) Reset 

func (m *Topology) Reset()

func (*Topology) Size 

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

func (*Topology) String 

func (m *Topology) String() string

func (*Topology) Unmarshal 

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

func (*Topology) XXX_DiscardUnknown 

func (m *Topology) XXX_DiscardUnknown()

func (*Topology) XXX_Marshal 

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

func (*Topology) XXX_Merge 

func (dst *Topology) XXX_Merge(src proto.Message)

func (*Topology) XXX_Size 

func (m *Topology) XXX_Size() int

func (*Topology) XXX_Unmarshal 

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

type TranslateKeysRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TranslateKeysRequest) Descriptor 

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

func (*TranslateKeysRequest) GetField 

func (m *TranslateKeysRequest) GetField() string

func (*TranslateKeysRequest) GetIndex 

func (m *TranslateKeysRequest) GetIndex() string

func (*TranslateKeysRequest) GetKeys 

func (m *TranslateKeysRequest) GetKeys() []string

func (*TranslateKeysRequest) Marshal 

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

func (*TranslateKeysRequest) MarshalTo 

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

func (*TranslateKeysRequest) ProtoMessage 

func (*TranslateKeysRequest) ProtoMessage()

func (*TranslateKeysRequest) Reset 

func (m *TranslateKeysRequest) Reset()

func (*TranslateKeysRequest) Size 

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

func (*TranslateKeysRequest) String 

func (m *TranslateKeysRequest) String() string

func (*TranslateKeysRequest) Unmarshal 

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

func (*TranslateKeysRequest) XXX_DiscardUnknown 

func (m *TranslateKeysRequest) XXX_DiscardUnknown()

func (*TranslateKeysRequest) XXX_Marshal 

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

func (*TranslateKeysRequest) XXX_Merge 

func (dst *TranslateKeysRequest) XXX_Merge(src proto.Message)

func (*TranslateKeysRequest) XXX_Size 

func (m *TranslateKeysRequest) XXX_Size() int

func (*TranslateKeysRequest) XXX_Unmarshal 

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

type TranslateKeysResponse 

type TranslateKeysResponse struct {
	IDs                  []uint64 `protobuf:"varint,3,rep,packed,name=IDs" json:"IDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TranslateKeysResponse) Descriptor 

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

func (*TranslateKeysResponse) GetIDs 

func (m *TranslateKeysResponse) GetIDs() []uint64

func (*TranslateKeysResponse) Marshal 

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

func (*TranslateKeysResponse) MarshalTo 

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

func (*TranslateKeysResponse) ProtoMessage 

func (*TranslateKeysResponse) ProtoMessage()

func (*TranslateKeysResponse) Reset 

func (m *TranslateKeysResponse) Reset()

func (*TranslateKeysResponse) Size 

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

func (*TranslateKeysResponse) String 

func (m *TranslateKeysResponse) String() string

func (*TranslateKeysResponse) Unmarshal 

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

func (*TranslateKeysResponse) XXX_DiscardUnknown 

func (m *TranslateKeysResponse) XXX_DiscardUnknown()

func (*TranslateKeysResponse) XXX_Marshal 

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

func (*TranslateKeysResponse) XXX_Merge 

func (dst *TranslateKeysResponse) XXX_Merge(src proto.Message)

func (*TranslateKeysResponse) XXX_Size 

func (m *TranslateKeysResponse) XXX_Size() int

func (*TranslateKeysResponse) XXX_Unmarshal 

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

type URI 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*URI) Descriptor 

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

func (*URI) GetHost 

func (m *URI) GetHost() string

func (*URI) GetPort 

func (m *URI) GetPort() uint32

func (*URI) GetScheme 

func (m *URI) GetScheme() string

func (*URI) Marshal 

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

func (*URI) MarshalTo 

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

func (*URI) ProtoMessage 

func (*URI) ProtoMessage()

func (*URI) Reset 

func (m *URI) Reset()

func (*URI) Size 

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

func (*URI) String 

func (m *URI) String() string

func (*URI) Unmarshal 

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

func (*URI) XXX_DiscardUnknown 

func (m *URI) XXX_DiscardUnknown()

func (*URI) XXX_Marshal 

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

func (*URI) XXX_Merge 

func (dst *URI) XXX_Merge(src proto.Message)

func (*URI) XXX_Size 

func (m *URI) XXX_Size() int

func (*URI) XXX_Unmarshal 

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

type UpdateCoordinatorMessage 

type UpdateCoordinatorMessage struct {
	New                  *Node    `protobuf:"bytes,1,opt,name=New" json:"New,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateCoordinatorMessage) Descriptor 

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

func (*UpdateCoordinatorMessage) GetNew 

func (m *UpdateCoordinatorMessage) GetNew() *Node

func (*UpdateCoordinatorMessage) Marshal 

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

func (*UpdateCoordinatorMessage) MarshalTo 

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

func (*UpdateCoordinatorMessage) ProtoMessage 

func (*UpdateCoordinatorMessage) ProtoMessage()

func (*UpdateCoordinatorMessage) Reset 

func (m *UpdateCoordinatorMessage) Reset()

func (*UpdateCoordinatorMessage) Size 

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

func (*UpdateCoordinatorMessage) String 

func (m *UpdateCoordinatorMessage) String() string

func (*UpdateCoordinatorMessage) Unmarshal 

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

func (*UpdateCoordinatorMessage) XXX_DiscardUnknown 

func (m *UpdateCoordinatorMessage) XXX_DiscardUnknown()

func (*UpdateCoordinatorMessage) XXX_Marshal 

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

func (*UpdateCoordinatorMessage) XXX_Merge 

func (dst *UpdateCoordinatorMessage) XXX_Merge(src proto.Message)

func (*UpdateCoordinatorMessage) XXX_Size 

func (m *UpdateCoordinatorMessage) XXX_Size() int

func (*UpdateCoordinatorMessage) XXX_Unmarshal 

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

type ValCount 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ValCount) Descriptor 

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

func (*ValCount) GetCount 

func (m *ValCount) GetCount() int64

func (*ValCount) GetVal 

func (m *ValCount) GetVal() int64

func (*ValCount) Marshal 

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

func (*ValCount) MarshalTo 

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

func (*ValCount) ProtoMessage 

func (*ValCount) ProtoMessage()

func (*ValCount) Reset 

func (m *ValCount) Reset()

func (*ValCount) Size 

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

func (*ValCount) String 

func (m *ValCount) String() string

func (*ValCount) Unmarshal 

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

func (*ValCount) XXX_DiscardUnknown 

func (m *ValCount) XXX_DiscardUnknown()

func (*ValCount) XXX_Marshal 

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

func (*ValCount) XXX_Merge 

func (dst *ValCount) XXX_Merge(src proto.Message)

func (*ValCount) XXX_Size 

func (m *ValCount) XXX_Size() int

func (*ValCount) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.