pilosa: github.com/pilosa/pilosa/internal Index | Files | Directories

package internal

import "github.com/pilosa/pilosa/internal"

Package internal is a generated protocol buffer package.

It is generated from these files:

private.proto

It has these top-level messages:

IndexMeta
FieldOptions
ImportResponse
BlockDataRequest
BlockDataResponse
Cache
MaxShards
CreateShardMessage
DeleteIndexMessage
CreateIndexMessage
CreateFieldMessage
DeleteFieldMessage
DeleteAvailableShardMessage
Field
Schema
Index
URI
Node
NodeStateMessage
NodeEventMessage
NodeStatus
IndexStatus
FieldStatus
ClusterStatus
BSIGroup
CreateViewMessage
DeleteViewMessage
ResizeInstruction
ResizeSource
ResizeInstructionComplete
SetCoordinatorMessage
UpdateCoordinatorMessage
Topology
RecalculateCaches

Package internal is a generated protocol buffer package.

It is generated from these files:

public.proto

It has these top-level messages:

Row
RowIdentifiers
Pair
FieldRow
GroupCount
ValCount
ColumnAttrSet
Attr
AttrMap
QueryRequest
QueryResponse
QueryResult
ImportRequest
ImportValueRequest
TranslateKeysRequest
TranslateKeysResponse
ImportRoaringRequestView
ImportRoaringRequest

Index

Package Files

internal.go private.pb.go public.pb.go

Variables

var (
    ErrInvalidLengthPrivate = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowPrivate   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthPublic = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowPublic   = fmt.Errorf("proto: integer overflow")
)

type Attr Uses

type Attr struct {
    Key         string  `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
    Type        uint64  `protobuf:"varint,2,opt,name=Type,proto3" json:"Type,omitempty"`
    StringValue string  `protobuf:"bytes,3,opt,name=StringValue,proto3" json:"StringValue,omitempty"`
    IntValue    int64   `protobuf:"varint,4,opt,name=IntValue,proto3" json:"IntValue,omitempty"`
    BoolValue   bool    `protobuf:"varint,5,opt,name=BoolValue,proto3" json:"BoolValue,omitempty"`
    FloatValue  float64 `protobuf:"fixed64,6,opt,name=FloatValue,proto3" json:"FloatValue,omitempty"`
}

func (*Attr) Descriptor Uses

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

func (*Attr) GetBoolValue Uses

func (m *Attr) GetBoolValue() bool

func (*Attr) GetFloatValue Uses

func (m *Attr) GetFloatValue() float64

func (*Attr) GetIntValue Uses

func (m *Attr) GetIntValue() int64

func (*Attr) GetKey Uses

func (m *Attr) GetKey() string

func (*Attr) GetStringValue Uses

func (m *Attr) GetStringValue() string

func (*Attr) GetType Uses

func (m *Attr) GetType() uint64

func (*Attr) Marshal Uses

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

func (*Attr) MarshalTo Uses

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

func (*Attr) ProtoMessage Uses

func (*Attr) ProtoMessage()

func (*Attr) Reset Uses

func (m *Attr) Reset()

func (*Attr) Size Uses

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

func (*Attr) String Uses

func (m *Attr) String() string

func (*Attr) Unmarshal Uses

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

type AttrMap Uses

type AttrMap struct {
    Attrs []*Attr `protobuf:"bytes,1,rep,name=Attrs" json:"Attrs,omitempty"`
}

func (*AttrMap) Descriptor Uses

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

func (*AttrMap) GetAttrs Uses

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

func (*AttrMap) Marshal Uses

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

func (*AttrMap) MarshalTo Uses

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

func (*AttrMap) ProtoMessage Uses

func (*AttrMap) ProtoMessage()

func (*AttrMap) Reset Uses

func (m *AttrMap) Reset()

func (*AttrMap) Size Uses

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

func (*AttrMap) String Uses

func (m *AttrMap) String() string

func (*AttrMap) Unmarshal Uses

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

type BSIGroup Uses

type BSIGroup struct {
    Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
    Type string `protobuf:"bytes,2,opt,name=Type,proto3" json:"Type,omitempty"`
    Min  int64  `protobuf:"varint,3,opt,name=Min,proto3" json:"Min,omitempty"`
    Max  int64  `protobuf:"varint,4,opt,name=Max,proto3" json:"Max,omitempty"`
}

func (*BSIGroup) Descriptor Uses

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

func (*BSIGroup) GetMax Uses

func (m *BSIGroup) GetMax() int64

func (*BSIGroup) GetMin Uses

func (m *BSIGroup) GetMin() int64

func (*BSIGroup) GetName Uses

func (m *BSIGroup) GetName() string

func (*BSIGroup) GetType Uses

func (m *BSIGroup) GetType() string

func (*BSIGroup) Marshal Uses

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

func (*BSIGroup) MarshalTo Uses

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

func (*BSIGroup) ProtoMessage Uses

func (*BSIGroup) ProtoMessage()

func (*BSIGroup) Reset Uses

func (m *BSIGroup) Reset()

func (*BSIGroup) Size Uses

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

func (*BSIGroup) String Uses

func (m *BSIGroup) String() string

func (*BSIGroup) Unmarshal Uses

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

type BlockDataRequest Uses

type BlockDataRequest struct {
    Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
    Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
    View  string `protobuf:"bytes,5,opt,name=View,proto3" json:"View,omitempty"`
    Shard uint64 `protobuf:"varint,4,opt,name=Shard,proto3" json:"Shard,omitempty"`
    Block uint64 `protobuf:"varint,3,opt,name=Block,proto3" json:"Block,omitempty"`
}

func (*BlockDataRequest) Descriptor Uses

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

func (*BlockDataRequest) GetBlock Uses

func (m *BlockDataRequest) GetBlock() uint64

func (*BlockDataRequest) GetField Uses

func (m *BlockDataRequest) GetField() string

func (*BlockDataRequest) GetIndex Uses

func (m *BlockDataRequest) GetIndex() string

func (*BlockDataRequest) GetShard Uses

func (m *BlockDataRequest) GetShard() uint64

func (*BlockDataRequest) GetView Uses

func (m *BlockDataRequest) GetView() string

func (*BlockDataRequest) Marshal Uses

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

func (*BlockDataRequest) MarshalTo Uses

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

func (*BlockDataRequest) ProtoMessage Uses

func (*BlockDataRequest) ProtoMessage()

func (*BlockDataRequest) Reset Uses

func (m *BlockDataRequest) Reset()

func (*BlockDataRequest) Size Uses

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

func (*BlockDataRequest) String Uses

func (m *BlockDataRequest) String() string

func (*BlockDataRequest) Unmarshal Uses

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

type BlockDataResponse Uses

type BlockDataResponse struct {
    RowIDs    []uint64 `protobuf:"varint,1,rep,packed,name=RowIDs" json:"RowIDs,omitempty"`
    ColumnIDs []uint64 `protobuf:"varint,2,rep,packed,name=ColumnIDs" json:"ColumnIDs,omitempty"`
}

func (*BlockDataResponse) Descriptor Uses

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

func (*BlockDataResponse) GetColumnIDs Uses

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

func (*BlockDataResponse) GetRowIDs Uses

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

func (*BlockDataResponse) Marshal Uses

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

func (*BlockDataResponse) MarshalTo Uses

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

func (*BlockDataResponse) ProtoMessage Uses

func (*BlockDataResponse) ProtoMessage()

func (*BlockDataResponse) Reset Uses

func (m *BlockDataResponse) Reset()

func (*BlockDataResponse) Size Uses

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

func (*BlockDataResponse) String Uses

func (m *BlockDataResponse) String() string

func (*BlockDataResponse) Unmarshal Uses

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

type Cache Uses

type Cache struct {
    IDs []uint64 `protobuf:"varint,1,rep,packed,name=IDs" json:"IDs,omitempty"`
}

func (*Cache) Descriptor Uses

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

func (*Cache) GetIDs Uses

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

func (*Cache) Marshal Uses

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

func (*Cache) MarshalTo Uses

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

func (*Cache) ProtoMessage Uses

func (*Cache) ProtoMessage()

func (*Cache) Reset Uses

func (m *Cache) Reset()

func (*Cache) Size Uses

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

func (*Cache) String Uses

func (m *Cache) String() string

func (*Cache) Unmarshal Uses

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

type ClusterStatus Uses

type ClusterStatus struct {
    ClusterID string  `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
    State     string  `protobuf:"bytes,2,opt,name=State,proto3" json:"State,omitempty"`
    Nodes     []*Node `protobuf:"bytes,3,rep,name=Nodes" json:"Nodes,omitempty"`
}

func (*ClusterStatus) Descriptor Uses

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

func (*ClusterStatus) GetClusterID Uses

func (m *ClusterStatus) GetClusterID() string

func (*ClusterStatus) GetNodes Uses

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

func (*ClusterStatus) GetState Uses

func (m *ClusterStatus) GetState() string

func (*ClusterStatus) Marshal Uses

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

func (*ClusterStatus) MarshalTo Uses

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

func (*ClusterStatus) ProtoMessage Uses

func (*ClusterStatus) ProtoMessage()

func (*ClusterStatus) Reset Uses

func (m *ClusterStatus) Reset()

func (*ClusterStatus) Size Uses

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

func (*ClusterStatus) String Uses

func (m *ClusterStatus) String() string

func (*ClusterStatus) Unmarshal Uses

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

type ColumnAttrSet Uses

type ColumnAttrSet struct {
    ID    uint64  `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
    Key   string  `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"`
    Attrs []*Attr `protobuf:"bytes,2,rep,name=Attrs" json:"Attrs,omitempty"`
}

func (*ColumnAttrSet) Descriptor Uses

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

func (*ColumnAttrSet) GetAttrs Uses

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

func (*ColumnAttrSet) GetID Uses

func (m *ColumnAttrSet) GetID() uint64

func (*ColumnAttrSet) GetKey Uses

func (m *ColumnAttrSet) GetKey() string

func (*ColumnAttrSet) Marshal Uses

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

func (*ColumnAttrSet) MarshalTo Uses

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

func (*ColumnAttrSet) ProtoMessage Uses

func (*ColumnAttrSet) ProtoMessage()

func (*ColumnAttrSet) Reset Uses

func (m *ColumnAttrSet) Reset()

func (*ColumnAttrSet) Size Uses

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

func (*ColumnAttrSet) String Uses

func (m *ColumnAttrSet) String() string

func (*ColumnAttrSet) Unmarshal Uses

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

type CreateFieldMessage Uses

type CreateFieldMessage struct {
    Index string        `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
    Field string        `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
    Meta  *FieldOptions `protobuf:"bytes,3,opt,name=Meta" json:"Meta,omitempty"`
}

func (*CreateFieldMessage) Descriptor Uses

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

func (*CreateFieldMessage) GetField Uses

func (m *CreateFieldMessage) GetField() string

func (*CreateFieldMessage) GetIndex Uses

func (m *CreateFieldMessage) GetIndex() string

func (*CreateFieldMessage) GetMeta Uses

func (m *CreateFieldMessage) GetMeta() *FieldOptions

func (*CreateFieldMessage) Marshal Uses

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

func (*CreateFieldMessage) MarshalTo Uses

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

func (*CreateFieldMessage) ProtoMessage Uses

func (*CreateFieldMessage) ProtoMessage()

func (*CreateFieldMessage) Reset Uses

func (m *CreateFieldMessage) Reset()

func (*CreateFieldMessage) Size Uses

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

func (*CreateFieldMessage) String Uses

func (m *CreateFieldMessage) String() string

func (*CreateFieldMessage) Unmarshal Uses

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

type CreateIndexMessage Uses

type CreateIndexMessage struct {
    Index string     `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
    Meta  *IndexMeta `protobuf:"bytes,2,opt,name=Meta" json:"Meta,omitempty"`
}

func (*CreateIndexMessage) Descriptor Uses

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

func (*CreateIndexMessage) GetIndex Uses

func (m *CreateIndexMessage) GetIndex() string

func (*CreateIndexMessage) GetMeta Uses

func (m *CreateIndexMessage) GetMeta() *IndexMeta

func (*CreateIndexMessage) Marshal Uses

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

func (*CreateIndexMessage) MarshalTo Uses

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

func (*CreateIndexMessage) ProtoMessage Uses

func (*CreateIndexMessage) ProtoMessage()

func (*CreateIndexMessage) Reset Uses

func (m *CreateIndexMessage) Reset()

func (*CreateIndexMessage) Size Uses

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

func (*CreateIndexMessage) String Uses

func (m *CreateIndexMessage) String() string

func (*CreateIndexMessage) Unmarshal Uses

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

type CreateShardMessage Uses

type CreateShardMessage struct {
    Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
    Field string `protobuf:"bytes,3,opt,name=Field,proto3" json:"Field,omitempty"`
    Shard uint64 `protobuf:"varint,2,opt,name=Shard,proto3" json:"Shard,omitempty"`
}

func (*CreateShardMessage) Descriptor Uses

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

func (*CreateShardMessage) GetField Uses

func (m *CreateShardMessage) GetField() string

func (*CreateShardMessage) GetIndex Uses

func (m *CreateShardMessage) GetIndex() string

func (*CreateShardMessage) GetShard Uses

func (m *CreateShardMessage) GetShard() uint64

func (*CreateShardMessage) Marshal Uses

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

func (*CreateShardMessage) MarshalTo Uses

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

func (*CreateShardMessage) ProtoMessage Uses

func (*CreateShardMessage) ProtoMessage()

func (*CreateShardMessage) Reset Uses

func (m *CreateShardMessage) Reset()

func (*CreateShardMessage) Size Uses

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

func (*CreateShardMessage) String Uses

func (m *CreateShardMessage) String() string

func (*CreateShardMessage) Unmarshal Uses

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

type CreateViewMessage Uses

type CreateViewMessage struct {
    Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
    Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
    View  string `protobuf:"bytes,3,opt,name=View,proto3" json:"View,omitempty"`
}

func (*CreateViewMessage) Descriptor Uses

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

func (*CreateViewMessage) GetField Uses

func (m *CreateViewMessage) GetField() string

func (*CreateViewMessage) GetIndex Uses

func (m *CreateViewMessage) GetIndex() string

func (*CreateViewMessage) GetView Uses

func (m *CreateViewMessage) GetView() string

func (*CreateViewMessage) Marshal Uses

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

func (*CreateViewMessage) MarshalTo Uses

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

func (*CreateViewMessage) ProtoMessage Uses

func (*CreateViewMessage) ProtoMessage()

func (*CreateViewMessage) Reset Uses

func (m *CreateViewMessage) Reset()

func (*CreateViewMessage) Size Uses

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

func (*CreateViewMessage) String Uses

func (m *CreateViewMessage) String() string

func (*CreateViewMessage) Unmarshal Uses

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

type Decoder Uses

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

Decoder decodes messages from a reader.

func NewDecoder Uses

func NewDecoder(r io.Reader) *Decoder

NewDecoder returns a new instance of Decoder.

func (*Decoder) Decode Uses

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

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

type DeleteAvailableShardMessage Uses

type DeleteAvailableShardMessage struct {
    Index   string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
    Field   string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
    ShardID uint64 `protobuf:"varint,3,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
}

func (*DeleteAvailableShardMessage) Descriptor Uses

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

func (*DeleteAvailableShardMessage) GetField Uses

func (m *DeleteAvailableShardMessage) GetField() string

func (*DeleteAvailableShardMessage) GetIndex Uses

func (m *DeleteAvailableShardMessage) GetIndex() string

func (*DeleteAvailableShardMessage) GetShardID Uses

func (m *DeleteAvailableShardMessage) GetShardID() uint64

func (*DeleteAvailableShardMessage) Marshal Uses

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

func (*DeleteAvailableShardMessage) MarshalTo Uses

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

func (*DeleteAvailableShardMessage) ProtoMessage Uses

func (*DeleteAvailableShardMessage) ProtoMessage()

func (*DeleteAvailableShardMessage) Reset Uses

func (m *DeleteAvailableShardMessage) Reset()

func (*DeleteAvailableShardMessage) Size Uses

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

func (*DeleteAvailableShardMessage) String Uses

func (m *DeleteAvailableShardMessage) String() string

func (*DeleteAvailableShardMessage) Unmarshal Uses

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

type DeleteFieldMessage Uses

type DeleteFieldMessage struct {
    Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
    Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
}

func (*DeleteFieldMessage) Descriptor Uses

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

func (*DeleteFieldMessage) GetField Uses

func (m *DeleteFieldMessage) GetField() string

func (*DeleteFieldMessage) GetIndex Uses

func (m *DeleteFieldMessage) GetIndex() string

func (*DeleteFieldMessage) Marshal Uses

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

func (*DeleteFieldMessage) MarshalTo Uses

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

func (*DeleteFieldMessage) ProtoMessage Uses

func (*DeleteFieldMessage) ProtoMessage()

func (*DeleteFieldMessage) Reset Uses

func (m *DeleteFieldMessage) Reset()

func (*DeleteFieldMessage) Size Uses

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

func (*DeleteFieldMessage) String Uses

func (m *DeleteFieldMessage) String() string

func (*DeleteFieldMessage) Unmarshal Uses

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

type DeleteIndexMessage Uses

type DeleteIndexMessage struct {
    Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
}

func (*DeleteIndexMessage) Descriptor Uses

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

func (*DeleteIndexMessage) GetIndex Uses

func (m *DeleteIndexMessage) GetIndex() string

func (*DeleteIndexMessage) Marshal Uses

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

func (*DeleteIndexMessage) MarshalTo Uses

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

func (*DeleteIndexMessage) ProtoMessage Uses

func (*DeleteIndexMessage) ProtoMessage()

func (*DeleteIndexMessage) Reset Uses

func (m *DeleteIndexMessage) Reset()

func (*DeleteIndexMessage) Size Uses

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

func (*DeleteIndexMessage) String Uses

func (m *DeleteIndexMessage) String() string

func (*DeleteIndexMessage) Unmarshal Uses

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

type DeleteViewMessage Uses

type DeleteViewMessage struct {
    Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
    Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
    View  string `protobuf:"bytes,3,opt,name=View,proto3" json:"View,omitempty"`
}

func (*DeleteViewMessage) Descriptor Uses

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

func (*DeleteViewMessage) GetField Uses

func (m *DeleteViewMessage) GetField() string

func (*DeleteViewMessage) GetIndex Uses

func (m *DeleteViewMessage) GetIndex() string

func (*DeleteViewMessage) GetView Uses

func (m *DeleteViewMessage) GetView() string

func (*DeleteViewMessage) Marshal Uses

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

func (*DeleteViewMessage) MarshalTo Uses

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

func (*DeleteViewMessage) ProtoMessage Uses

func (*DeleteViewMessage) ProtoMessage()

func (*DeleteViewMessage) Reset Uses

func (m *DeleteViewMessage) Reset()

func (*DeleteViewMessage) Size Uses

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

func (*DeleteViewMessage) String Uses

func (m *DeleteViewMessage) String() string

func (*DeleteViewMessage) Unmarshal Uses

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

type Encoder Uses

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

Encoder encodes messages to a writer.

func NewEncoder Uses

func NewEncoder(w io.Writer) *Encoder

NewEncoder returns a new instance of Encoder.

func (*Encoder) Encode Uses

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

Encode marshals m into bytes and writes them to r.

type Field Uses

type Field struct {
    Name  string        `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
    Meta  *FieldOptions `protobuf:"bytes,2,opt,name=Meta" json:"Meta,omitempty"`
    Views []string      `protobuf:"bytes,3,rep,name=Views" json:"Views,omitempty"`
}

func (*Field) Descriptor Uses

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

func (*Field) GetMeta Uses

func (m *Field) GetMeta() *FieldOptions

func (*Field) GetName Uses

func (m *Field) GetName() string

func (*Field) GetViews Uses

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

func (*Field) Marshal Uses

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

func (*Field) MarshalTo Uses

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

func (*Field) ProtoMessage Uses

func (*Field) ProtoMessage()

func (*Field) Reset Uses

func (m *Field) Reset()

func (*Field) Size Uses

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

func (*Field) String Uses

func (m *Field) String() string

func (*Field) Unmarshal Uses

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

type FieldOptions Uses

type FieldOptions struct {
    Type           string `protobuf:"bytes,8,opt,name=Type,proto3" json:"Type,omitempty"`
    CacheType      string `protobuf:"bytes,3,opt,name=CacheType,proto3" json:"CacheType,omitempty"`
    CacheSize      uint32 `protobuf:"varint,4,opt,name=CacheSize,proto3" json:"CacheSize,omitempty"`
    TimeQuantum    string `protobuf:"bytes,5,opt,name=TimeQuantum,proto3" json:"TimeQuantum,omitempty"`
    Keys           bool   `protobuf:"varint,11,opt,name=Keys,proto3" json:"Keys,omitempty"`
    NoStandardView bool   `protobuf:"varint,12,opt,name=NoStandardView,proto3" json:"NoStandardView,omitempty"`
    Base           int64  `protobuf:"varint,13,opt,name=Base,proto3" json:"Base,omitempty"`
    BitDepth       uint64 `protobuf:"varint,14,opt,name=BitDepth,proto3" json:"BitDepth,omitempty"`
    Min            int64  `protobuf:"varint,9,opt,name=Min,proto3" json:"Min,omitempty"`
    Max            int64  `protobuf:"varint,10,opt,name=Max,proto3" json:"Max,omitempty"`
}

func (*FieldOptions) Descriptor Uses

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

func (*FieldOptions) GetBase Uses

func (m *FieldOptions) GetBase() int64

func (*FieldOptions) GetBitDepth Uses

func (m *FieldOptions) GetBitDepth() uint64

func (*FieldOptions) GetCacheSize Uses

func (m *FieldOptions) GetCacheSize() uint32

func (*FieldOptions) GetCacheType Uses

func (m *FieldOptions) GetCacheType() string

func (*FieldOptions) GetKeys Uses

func (m *FieldOptions) GetKeys() bool

func (*FieldOptions) GetMax Uses

func (m *FieldOptions) GetMax() int64

func (*FieldOptions) GetMin Uses

func (m *FieldOptions) GetMin() int64

func (*FieldOptions) GetNoStandardView Uses

func (m *FieldOptions) GetNoStandardView() bool

func (*FieldOptions) GetTimeQuantum Uses

func (m *FieldOptions) GetTimeQuantum() string

func (*FieldOptions) GetType Uses

func (m *FieldOptions) GetType() string

func (*FieldOptions) Marshal Uses

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

func (*FieldOptions) MarshalTo Uses

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

func (*FieldOptions) ProtoMessage Uses

func (*FieldOptions) ProtoMessage()

func (*FieldOptions) Reset Uses

func (m *FieldOptions) Reset()

func (*FieldOptions) Size Uses

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

func (*FieldOptions) String Uses

func (m *FieldOptions) String() string

func (*FieldOptions) Unmarshal Uses

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

type FieldRow Uses

type FieldRow struct {
    Field  string `protobuf:"bytes,1,opt,name=Field,proto3" json:"Field,omitempty"`
    RowID  uint64 `protobuf:"varint,2,opt,name=RowID,proto3" json:"RowID,omitempty"`
    RowKey string `protobuf:"bytes,3,opt,name=RowKey,proto3" json:"RowKey,omitempty"`
}

func (*FieldRow) Descriptor Uses

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

func (*FieldRow) GetField Uses

func (m *FieldRow) GetField() string

func (*FieldRow) GetRowID Uses

func (m *FieldRow) GetRowID() uint64

func (*FieldRow) GetRowKey Uses

func (m *FieldRow) GetRowKey() string

func (*FieldRow) Marshal Uses

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

func (*FieldRow) MarshalTo Uses

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

func (*FieldRow) ProtoMessage Uses

func (*FieldRow) ProtoMessage()

func (*FieldRow) Reset Uses

func (m *FieldRow) Reset()

func (*FieldRow) Size Uses

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

func (*FieldRow) String Uses

func (m *FieldRow) String() string

func (*FieldRow) Unmarshal Uses

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

type FieldStatus Uses

type FieldStatus struct {
    Name            string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
    AvailableShards []uint64 `protobuf:"varint,2,rep,packed,name=AvailableShards" json:"AvailableShards,omitempty"`
}

func (*FieldStatus) Descriptor Uses

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

func (*FieldStatus) GetAvailableShards Uses

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

func (*FieldStatus) GetName Uses

func (m *FieldStatus) GetName() string

func (*FieldStatus) Marshal Uses

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

func (*FieldStatus) MarshalTo Uses

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

func (*FieldStatus) ProtoMessage Uses

func (*FieldStatus) ProtoMessage()

func (*FieldStatus) Reset Uses

func (m *FieldStatus) Reset()

func (*FieldStatus) Size Uses

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

func (*FieldStatus) String Uses

func (m *FieldStatus) String() string

func (*FieldStatus) Unmarshal Uses

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

type GroupCount Uses

type GroupCount struct {
    Group []*FieldRow `protobuf:"bytes,1,rep,name=Group" json:"Group,omitempty"`
    Count uint64      `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"`
}

func (*GroupCount) Descriptor Uses

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

func (*GroupCount) GetCount Uses

func (m *GroupCount) GetCount() uint64

func (*GroupCount) GetGroup Uses

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

func (*GroupCount) Marshal Uses

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

func (*GroupCount) MarshalTo Uses

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

func (*GroupCount) ProtoMessage Uses

func (*GroupCount) ProtoMessage()

func (*GroupCount) Reset Uses

func (m *GroupCount) Reset()

func (*GroupCount) Size Uses

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

func (*GroupCount) String Uses

func (m *GroupCount) String() string

func (*GroupCount) Unmarshal Uses

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

type ImportRequest Uses

type ImportRequest struct {
    Index      string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
    Field      string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
    Shard      uint64   `protobuf:"varint,3,opt,name=Shard,proto3" json:"Shard,omitempty"`
    RowIDs     []uint64 `protobuf:"varint,4,rep,packed,name=RowIDs" json:"RowIDs,omitempty"`
    ColumnIDs  []uint64 `protobuf:"varint,5,rep,packed,name=ColumnIDs" json:"ColumnIDs,omitempty"`
    RowKeys    []string `protobuf:"bytes,7,rep,name=RowKeys" json:"RowKeys,omitempty"`
    ColumnKeys []string `protobuf:"bytes,8,rep,name=ColumnKeys" json:"ColumnKeys,omitempty"`
    Timestamps []int64  `protobuf:"varint,6,rep,packed,name=Timestamps" json:"Timestamps,omitempty"`
}

func (*ImportRequest) Descriptor Uses

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

func (*ImportRequest) GetColumnIDs Uses

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

func (*ImportRequest) GetColumnKeys Uses

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

func (*ImportRequest) GetField Uses

func (m *ImportRequest) GetField() string

func (*ImportRequest) GetIndex Uses

func (m *ImportRequest) GetIndex() string

func (*ImportRequest) GetRowIDs Uses

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

func (*ImportRequest) GetRowKeys Uses

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

func (*ImportRequest) GetShard Uses

func (m *ImportRequest) GetShard() uint64

func (*ImportRequest) GetTimestamps Uses

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

func (*ImportRequest) Marshal Uses

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

func (*ImportRequest) MarshalTo Uses

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

func (*ImportRequest) ProtoMessage Uses

func (*ImportRequest) ProtoMessage()

func (*ImportRequest) Reset Uses

func (m *ImportRequest) Reset()

func (*ImportRequest) Size Uses

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

func (*ImportRequest) String Uses

func (m *ImportRequest) String() string

func (*ImportRequest) Unmarshal Uses

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

type ImportResponse Uses

type ImportResponse struct {
    Err string `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
}

func (*ImportResponse) Descriptor Uses

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

func (*ImportResponse) GetErr Uses

func (m *ImportResponse) GetErr() string

func (*ImportResponse) Marshal Uses

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

func (*ImportResponse) MarshalTo Uses

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

func (*ImportResponse) ProtoMessage Uses

func (*ImportResponse) ProtoMessage()

func (*ImportResponse) Reset Uses

func (m *ImportResponse) Reset()

func (*ImportResponse) Size Uses

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

func (*ImportResponse) String Uses

func (m *ImportResponse) String() string

func (*ImportResponse) Unmarshal Uses

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

type ImportRoaringRequest Uses

type ImportRoaringRequest struct {
    Clear bool                        `protobuf:"varint,1,opt,name=Clear,proto3" json:"Clear,omitempty"`
    Views []*ImportRoaringRequestView `protobuf:"bytes,2,rep,name=views" json:"views,omitempty"`
}

func (*ImportRoaringRequest) Descriptor Uses

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

func (*ImportRoaringRequest) GetClear Uses

func (m *ImportRoaringRequest) GetClear() bool

func (*ImportRoaringRequest) GetViews Uses

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

func (*ImportRoaringRequest) Marshal Uses

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

func (*ImportRoaringRequest) MarshalTo Uses

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

func (*ImportRoaringRequest) ProtoMessage Uses

func (*ImportRoaringRequest) ProtoMessage()

func (*ImportRoaringRequest) Reset Uses

func (m *ImportRoaringRequest) Reset()

func (*ImportRoaringRequest) Size Uses

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

func (*ImportRoaringRequest) String Uses

func (m *ImportRoaringRequest) String() string

func (*ImportRoaringRequest) Unmarshal Uses

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

type ImportRoaringRequestView Uses

type ImportRoaringRequestView struct {
    Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
    Data []byte `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"`
}

func (*ImportRoaringRequestView) Descriptor Uses

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

func (*ImportRoaringRequestView) GetData Uses

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

func (*ImportRoaringRequestView) GetName Uses

func (m *ImportRoaringRequestView) GetName() string

func (*ImportRoaringRequestView) Marshal Uses

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

func (*ImportRoaringRequestView) MarshalTo Uses

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

func (*ImportRoaringRequestView) ProtoMessage Uses

func (*ImportRoaringRequestView) ProtoMessage()

func (*ImportRoaringRequestView) Reset Uses

func (m *ImportRoaringRequestView) Reset()

func (*ImportRoaringRequestView) Size Uses

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

func (*ImportRoaringRequestView) String Uses

func (m *ImportRoaringRequestView) String() string

func (*ImportRoaringRequestView) Unmarshal Uses

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

type ImportValueRequest Uses

type ImportValueRequest struct {
    Index      string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
    Field      string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
    Shard      uint64   `protobuf:"varint,3,opt,name=Shard,proto3" json:"Shard,omitempty"`
    ColumnIDs  []uint64 `protobuf:"varint,5,rep,packed,name=ColumnIDs" json:"ColumnIDs,omitempty"`
    ColumnKeys []string `protobuf:"bytes,7,rep,name=ColumnKeys" json:"ColumnKeys,omitempty"`
    Values     []int64  `protobuf:"varint,6,rep,packed,name=Values" json:"Values,omitempty"`
}

func (*ImportValueRequest) Descriptor Uses

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

func (*ImportValueRequest) GetColumnIDs Uses

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

func (*ImportValueRequest) GetColumnKeys Uses

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

func (*ImportValueRequest) GetField Uses

func (m *ImportValueRequest) GetField() string

func (*ImportValueRequest) GetIndex Uses

func (m *ImportValueRequest) GetIndex() string

func (*ImportValueRequest) GetShard Uses

func (m *ImportValueRequest) GetShard() uint64

func (*ImportValueRequest) GetValues Uses

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

func (*ImportValueRequest) Marshal Uses

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

func (*ImportValueRequest) MarshalTo Uses

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

func (*ImportValueRequest) ProtoMessage Uses

func (*ImportValueRequest) ProtoMessage()

func (*ImportValueRequest) Reset Uses

func (m *ImportValueRequest) Reset()

func (*ImportValueRequest) Size Uses

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

func (*ImportValueRequest) String Uses

func (m *ImportValueRequest) String() string

func (*ImportValueRequest) Unmarshal Uses

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

type Index Uses

type Index struct {
    Name   string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
    Fields []*Field `protobuf:"bytes,4,rep,name=Fields" json:"Fields,omitempty"`
}

func (*Index) Descriptor Uses

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

func (*Index) GetFields Uses

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

func (*Index) GetName Uses

func (m *Index) GetName() string

func (*Index) Marshal Uses

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

func (*Index) MarshalTo Uses

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

func (*Index) ProtoMessage Uses

func (*Index) ProtoMessage()

func (*Index) Reset Uses

func (m *Index) Reset()

func (*Index) Size Uses

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

func (*Index) String Uses

func (m *Index) String() string

func (*Index) Unmarshal Uses

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

type IndexMeta Uses

type IndexMeta struct {
    Keys           bool `protobuf:"varint,3,opt,name=Keys,proto3" json:"Keys,omitempty"`
    TrackExistence bool `protobuf:"varint,4,opt,name=TrackExistence,proto3" json:"TrackExistence,omitempty"`
}

func (*IndexMeta) Descriptor Uses

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

func (*IndexMeta) GetKeys Uses

func (m *IndexMeta) GetKeys() bool

func (*IndexMeta) GetTrackExistence Uses

func (m *IndexMeta) GetTrackExistence() bool

func (*IndexMeta) Marshal Uses

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

func (*IndexMeta) MarshalTo Uses

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

func (*IndexMeta) ProtoMessage Uses

func (*IndexMeta) ProtoMessage()

func (*IndexMeta) Reset Uses

func (m *IndexMeta) Reset()

func (*IndexMeta) Size Uses

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

func (*IndexMeta) String Uses

func (m *IndexMeta) String() string

func (*IndexMeta) Unmarshal Uses

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

type IndexStatus Uses

type IndexStatus struct {
    Name   string         `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
    Fields []*FieldStatus `protobuf:"bytes,2,rep,name=Fields" json:"Fields,omitempty"`
}

func (*IndexStatus) Descriptor Uses

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

func (*IndexStatus) GetFields Uses

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

func (*IndexStatus) GetName Uses

func (m *IndexStatus) GetName() string

func (*IndexStatus) Marshal Uses

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

func (*IndexStatus) MarshalTo Uses

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

func (*IndexStatus) ProtoMessage Uses

func (*IndexStatus) ProtoMessage()

func (*IndexStatus) Reset Uses

func (m *IndexStatus) Reset()

func (*IndexStatus) Size Uses

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

func (*IndexStatus) String Uses

func (m *IndexStatus) String() string

func (*IndexStatus) Unmarshal Uses

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

type MaxShards Uses

type MaxShards struct {
    Standard map[string]uint64 `protobuf:"bytes,1,rep,name=Standard" json:"Standard,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
}

func (*MaxShards) Descriptor Uses

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

func (*MaxShards) GetStandard Uses

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

func (*MaxShards) Marshal Uses

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

func (*MaxShards) MarshalTo Uses

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

func (*MaxShards) ProtoMessage Uses

func (*MaxShards) ProtoMessage()

func (*MaxShards) Reset Uses

func (m *MaxShards) Reset()

func (*MaxShards) Size Uses

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

func (*MaxShards) String Uses

func (m *MaxShards) String() string

func (*MaxShards) Unmarshal Uses

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

type Node Uses

type Node struct {
    ID            string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
    URI           *URI   `protobuf:"bytes,2,opt,name=URI" json:"URI,omitempty"`
    IsCoordinator bool   `protobuf:"varint,3,opt,name=IsCoordinator,proto3" json:"IsCoordinator,omitempty"`
    State         string `protobuf:"bytes,4,opt,name=State,proto3" json:"State,omitempty"`
}

func (*Node) Descriptor Uses

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

func (*Node) GetID Uses

func (m *Node) GetID() string

func (*Node) GetIsCoordinator Uses

func (m *Node) GetIsCoordinator() bool

func (*Node) GetState Uses

func (m *Node) GetState() string

func (*Node) GetURI Uses

func (m *Node) GetURI() *URI

func (*Node) Marshal Uses

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

func (*Node) MarshalTo Uses

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

func (*Node) ProtoMessage Uses

func (*Node) ProtoMessage()

func (*Node) Reset Uses

func (m *Node) Reset()

func (*Node) Size Uses

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

func (*Node) String Uses

func (m *Node) String() string

func (*Node) Unmarshal Uses

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

type NodeEventMessage Uses

type NodeEventMessage struct {
    Event uint32 `protobuf:"varint,1,opt,name=Event,proto3" json:"Event,omitempty"`
    Node  *Node  `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"`
}

func (*NodeEventMessage) Descriptor Uses

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

func (*NodeEventMessage) GetEvent Uses

func (m *NodeEventMessage) GetEvent() uint32

func (*NodeEventMessage) GetNode Uses

func (m *NodeEventMessage) GetNode() *Node

func (*NodeEventMessage) Marshal Uses

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

func (*NodeEventMessage) MarshalTo Uses

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

func (*NodeEventMessage) ProtoMessage Uses

func (*NodeEventMessage) ProtoMessage()

func (*NodeEventMessage) Reset Uses

func (m *NodeEventMessage) Reset()

func (*NodeEventMessage) Size Uses

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

func (*NodeEventMessage) String Uses

func (m *NodeEventMessage) String() string

func (*NodeEventMessage) Unmarshal Uses

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

type NodeStateMessage Uses

type NodeStateMessage struct {
    NodeID string `protobuf:"bytes,1,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
    State  string `protobuf:"bytes,2,opt,name=State,proto3" json:"State,omitempty"`
}

func (*NodeStateMessage) Descriptor Uses

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

func (*NodeStateMessage) GetNodeID Uses

func (m *NodeStateMessage) GetNodeID() string

func (*NodeStateMessage) GetState Uses

func (m *NodeStateMessage) GetState() string

func (*NodeStateMessage) Marshal Uses

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

func (*NodeStateMessage) MarshalTo Uses

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

func (*NodeStateMessage) ProtoMessage Uses

func (*NodeStateMessage) ProtoMessage()

func (*NodeStateMessage) Reset Uses

func (m *NodeStateMessage) Reset()

func (*NodeStateMessage) Size Uses

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

func (*NodeStateMessage) String Uses

func (m *NodeStateMessage) String() string

func (*NodeStateMessage) Unmarshal Uses

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

type NodeStatus Uses

type NodeStatus struct {
    Node    *Node          `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
    Schema  *Schema        `protobuf:"bytes,3,opt,name=Schema" json:"Schema,omitempty"`
    Indexes []*IndexStatus `protobuf:"bytes,4,rep,name=Indexes" json:"Indexes,omitempty"`
}

func (*NodeStatus) Descriptor Uses

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

func (*NodeStatus) GetIndexes Uses

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

func (*NodeStatus) GetNode Uses

func (m *NodeStatus) GetNode() *Node

func (*NodeStatus) GetSchema Uses

func (m *NodeStatus) GetSchema() *Schema

func (*NodeStatus) Marshal Uses

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

func (*NodeStatus) MarshalTo Uses

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

func (*NodeStatus) ProtoMessage Uses

func (*NodeStatus) ProtoMessage()

func (*NodeStatus) Reset Uses

func (m *NodeStatus) Reset()

func (*NodeStatus) Size Uses

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

func (*NodeStatus) String Uses

func (m *NodeStatus) String() string

func (*NodeStatus) Unmarshal Uses

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

type Pair Uses

type Pair struct {
    ID    uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
    Key   string `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"`
    Count uint64 `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"`
}

func (*Pair) Descriptor Uses

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

func (*Pair) GetCount Uses

func (m *Pair) GetCount() uint64

func (*Pair) GetID Uses

func (m *Pair) GetID() uint64

func (*Pair) GetKey Uses

func (m *Pair) GetKey() string

func (*Pair) Marshal Uses

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

func (*Pair) MarshalTo Uses

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

func (*Pair) ProtoMessage Uses

func (*Pair) ProtoMessage()

func (*Pair) Reset Uses

func (m *Pair) Reset()

func (*Pair) Size Uses

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

func (*Pair) String Uses

func (m *Pair) String() string

func (*Pair) Unmarshal Uses

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

type QueryRequest Uses

type QueryRequest struct {
    Query           string   `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"`
    Shards          []uint64 `protobuf:"varint,2,rep,packed,name=Shards" json:"Shards,omitempty"`
    ColumnAttrs     bool     `protobuf:"varint,3,opt,name=ColumnAttrs,proto3" json:"ColumnAttrs,omitempty"`
    Remote          bool     `protobuf:"varint,5,opt,name=Remote,proto3" json:"Remote,omitempty"`
    ExcludeRowAttrs bool     `protobuf:"varint,6,opt,name=ExcludeRowAttrs,proto3" json:"ExcludeRowAttrs,omitempty"`
    ExcludeColumns  bool     `protobuf:"varint,7,opt,name=ExcludeColumns,proto3" json:"ExcludeColumns,omitempty"`
}

func (*QueryRequest) Descriptor Uses

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

func (*QueryRequest) GetColumnAttrs Uses

func (m *QueryRequest) GetColumnAttrs() bool

func (*QueryRequest) GetExcludeColumns Uses

func (m *QueryRequest) GetExcludeColumns() bool

func (*QueryRequest) GetExcludeRowAttrs Uses

func (m *QueryRequest) GetExcludeRowAttrs() bool

func (*QueryRequest) GetQuery Uses

func (m *QueryRequest) GetQuery() string

func (*QueryRequest) GetRemote Uses

func (m *QueryRequest) GetRemote() bool

func (*QueryRequest) GetShards Uses

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

func (*QueryRequest) Marshal Uses

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

func (*QueryRequest) MarshalTo Uses

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

func (*QueryRequest) ProtoMessage Uses

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset Uses

func (m *QueryRequest) Reset()

func (*QueryRequest) Size Uses

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

func (*QueryRequest) String Uses

func (m *QueryRequest) String() string

func (*QueryRequest) Unmarshal Uses

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

type QueryResponse Uses

type QueryResponse struct {
    Err            string           `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
    Results        []*QueryResult   `protobuf:"bytes,2,rep,name=Results" json:"Results,omitempty"`
    ColumnAttrSets []*ColumnAttrSet `protobuf:"bytes,3,rep,name=ColumnAttrSets" json:"ColumnAttrSets,omitempty"`
}

func (*QueryResponse) Descriptor Uses

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

func (*QueryResponse) GetColumnAttrSets Uses

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

func (*QueryResponse) GetErr Uses

func (m *QueryResponse) GetErr() string

func (*QueryResponse) GetResults Uses

func (m *QueryResponse) GetResults() []*QueryResult

func (*QueryResponse) Marshal Uses

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

func (*QueryResponse) MarshalTo Uses

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

func (*QueryResponse) ProtoMessage Uses

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset Uses

func (m *QueryResponse) Reset()

func (*QueryResponse) Size Uses

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

func (*QueryResponse) String Uses

func (m *QueryResponse) String() string

func (*QueryResponse) Unmarshal Uses

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

type QueryResult Uses

type QueryResult struct {
    Type           uint32          `protobuf:"varint,6,opt,name=Type,proto3" json:"Type,omitempty"`
    Row            *Row            `protobuf:"bytes,1,opt,name=Row" json:"Row,omitempty"`
    N              uint64          `protobuf:"varint,2,opt,name=N,proto3" json:"N,omitempty"`
    Pairs          []*Pair         `protobuf:"bytes,3,rep,name=Pairs" json:"Pairs,omitempty"`
    Changed        bool            `protobuf:"varint,4,opt,name=Changed,proto3" json:"Changed,omitempty"`
    ValCount       *ValCount       `protobuf:"bytes,5,opt,name=ValCount" json:"ValCount,omitempty"`
    RowIDs         []uint64        `protobuf:"varint,7,rep,packed,name=RowIDs" json:"RowIDs,omitempty"`
    GroupCounts    []*GroupCount   `protobuf:"bytes,8,rep,name=GroupCounts" json:"GroupCounts,omitempty"`
    RowIdentifiers *RowIdentifiers `protobuf:"bytes,9,opt,name=RowIdentifiers" json:"RowIdentifiers,omitempty"`
}

func (*QueryResult) Descriptor Uses

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

func (*QueryResult) GetChanged Uses

func (m *QueryResult) GetChanged() bool

func (*QueryResult) GetGroupCounts Uses

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

func (*QueryResult) GetN Uses

func (m *QueryResult) GetN() uint64

func (*QueryResult) GetPairs Uses

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

func (*QueryResult) GetRow Uses

func (m *QueryResult) GetRow() *Row

func (*QueryResult) GetRowIDs Uses

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

func (*QueryResult) GetRowIdentifiers Uses

func (m *QueryResult) GetRowIdentifiers() *RowIdentifiers

func (*QueryResult) GetType Uses

func (m *QueryResult) GetType() uint32

func (*QueryResult) GetValCount Uses

func (m *QueryResult) GetValCount() *ValCount

func (*QueryResult) Marshal Uses

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

func (*QueryResult) MarshalTo Uses

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

func (*QueryResult) ProtoMessage Uses

func (*QueryResult) ProtoMessage()

func (*QueryResult) Reset Uses

func (m *QueryResult) Reset()

func (*QueryResult) Size Uses

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

func (*QueryResult) String Uses

func (m *QueryResult) String() string

func (*QueryResult) Unmarshal Uses

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

type RecalculateCaches Uses

type RecalculateCaches struct {
}

func (*RecalculateCaches) Descriptor Uses

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

func (*RecalculateCaches) Marshal Uses

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

func (*RecalculateCaches) MarshalTo Uses

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

func (*RecalculateCaches) ProtoMessage Uses

func (*RecalculateCaches) ProtoMessage()

func (*RecalculateCaches) Reset Uses

func (m *RecalculateCaches) Reset()

func (*RecalculateCaches) Size Uses

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

func (*RecalculateCaches) String Uses

func (m *RecalculateCaches) String() string

func (*RecalculateCaches) Unmarshal Uses

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

type Request Uses

type Request proto.Message

type ResizeInstruction Uses

type ResizeInstruction struct {
    JobID         int64           `protobuf:"varint,1,opt,name=JobID,proto3" json:"JobID,omitempty"`
    Node          *Node           `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"`
    Coordinator   *Node           `protobuf:"bytes,3,opt,name=Coordinator" json:"Coordinator,omitempty"`
    Sources       []*ResizeSource `protobuf:"bytes,4,rep,name=Sources" json:"Sources,omitempty"`
    NodeStatus    *NodeStatus     `protobuf:"bytes,7,opt,name=NodeStatus" json:"NodeStatus,omitempty"`
    ClusterStatus *ClusterStatus  `protobuf:"bytes,6,opt,name=ClusterStatus" json:"ClusterStatus,omitempty"`
}

func (*ResizeInstruction) Descriptor Uses

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

func (*ResizeInstruction) GetClusterStatus Uses

func (m *ResizeInstruction) GetClusterStatus() *ClusterStatus

func (*ResizeInstruction) GetCoordinator Uses

func (m *ResizeInstruction) GetCoordinator() *Node

func (*ResizeInstruction) GetJobID Uses

func (m *ResizeInstruction) GetJobID() int64

func (*ResizeInstruction) GetNode Uses

func (m *ResizeInstruction) GetNode() *Node

func (*ResizeInstruction) GetNodeStatus Uses

func (m *ResizeInstruction) GetNodeStatus() *NodeStatus

func (*ResizeInstruction) GetSources Uses

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

func (*ResizeInstruction) Marshal Uses

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

func (*ResizeInstruction) MarshalTo Uses

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

func (*ResizeInstruction) ProtoMessage Uses

func (*ResizeInstruction) ProtoMessage()

func (*ResizeInstruction) Reset Uses

func (m *ResizeInstruction) Reset()

func (*ResizeInstruction) Size Uses

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

func (*ResizeInstruction) String Uses

func (m *ResizeInstruction) String() string

func (*ResizeInstruction) Unmarshal Uses

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

type ResizeInstructionComplete Uses

type ResizeInstructionComplete struct {
    JobID int64  `protobuf:"varint,1,opt,name=JobID,proto3" json:"JobID,omitempty"`
    Node  *Node  `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"`
    Error string `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
}

func (*ResizeInstructionComplete) Descriptor Uses

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

func (*ResizeInstructionComplete) GetError Uses

func (m *ResizeInstructionComplete) GetError() string

func (*ResizeInstructionComplete) GetJobID Uses

func (m *ResizeInstructionComplete) GetJobID() int64

func (*ResizeInstructionComplete) GetNode Uses

func (m *ResizeInstructionComplete) GetNode() *Node

func (*ResizeInstructionComplete) Marshal Uses

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

func (*ResizeInstructionComplete) MarshalTo Uses

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

func (*ResizeInstructionComplete) ProtoMessage Uses

func (*ResizeInstructionComplete) ProtoMessage()

func (*ResizeInstructionComplete) Reset Uses

func (m *ResizeInstructionComplete) Reset()

func (*ResizeInstructionComplete) Size Uses

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

func (*ResizeInstructionComplete) String Uses

func (m *ResizeInstructionComplete) String() string

func (*ResizeInstructionComplete) Unmarshal Uses

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

type ResizeSource Uses

type ResizeSource struct {
    Node  *Node  `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
    Index string `protobuf:"bytes,2,opt,name=Index,proto3" json:"Index,omitempty"`
    Field string `protobuf:"bytes,3,opt,name=Field,proto3" json:"Field,omitempty"`
    View  string `protobuf:"bytes,4,opt,name=View,proto3" json:"View,omitempty"`
    Shard uint64 `protobuf:"varint,5,opt,name=Shard,proto3" json:"Shard,omitempty"`
}

func (*ResizeSource) Descriptor Uses

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

func (*ResizeSource) GetField Uses

func (m *ResizeSource) GetField() string

func (*ResizeSource) GetIndex Uses

func (m *ResizeSource) GetIndex() string

func (*ResizeSource) GetNode Uses

func (m *ResizeSource) GetNode() *Node

func (*ResizeSource) GetShard Uses

func (m *ResizeSource) GetShard() uint64

func (*ResizeSource) GetView Uses

func (m *ResizeSource) GetView() string

func (*ResizeSource) Marshal Uses

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

func (*ResizeSource) MarshalTo Uses

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

func (*ResizeSource) ProtoMessage Uses

func (*ResizeSource) ProtoMessage()

func (*ResizeSource) Reset Uses

func (m *ResizeSource) Reset()

func (*ResizeSource) Size Uses

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

func (*ResizeSource) String Uses

func (m *ResizeSource) String() string

func (*ResizeSource) Unmarshal Uses

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

type Response Uses

type Response proto.Message

type Row Uses

type Row struct {
    Columns []uint64 `protobuf:"varint,1,rep,packed,name=Columns" json:"Columns,omitempty"`
    Keys    []string `protobuf:"bytes,3,rep,name=Keys" json:"Keys,omitempty"`
    Attrs   []*Attr  `protobuf:"bytes,2,rep,name=Attrs" json:"Attrs,omitempty"`
}

func (*Row) Descriptor Uses

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

func (*Row) GetAttrs Uses

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

func (*Row) GetColumns Uses

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

func (*Row) GetKeys Uses

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

func (*Row) Marshal Uses

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

func (*Row) MarshalTo Uses

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

func (*Row) ProtoMessage Uses

func (*Row) ProtoMessage()

func (*Row) Reset Uses

func (m *Row) Reset()

func (*Row) Size Uses

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

func (*Row) String Uses

func (m *Row) String() string

func (*Row) Unmarshal Uses

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

type RowIdentifiers Uses

type RowIdentifiers struct {
    Rows []uint64 `protobuf:"varint,1,rep,packed,name=Rows" json:"Rows,omitempty"`
    Keys []string `protobuf:"bytes,2,rep,name=Keys" json:"Keys,omitempty"`
}

func (*RowIdentifiers) Descriptor Uses

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

func (*RowIdentifiers) GetKeys Uses

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

func (*RowIdentifiers) GetRows Uses

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

func (*RowIdentifiers) Marshal Uses

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

func (*RowIdentifiers) MarshalTo Uses

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

func (*RowIdentifiers) ProtoMessage Uses

func (*RowIdentifiers) ProtoMessage()

func (*RowIdentifiers) Reset Uses

func (m *RowIdentifiers) Reset()

func (*RowIdentifiers) Size Uses

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

func (*RowIdentifiers) String Uses

func (m *RowIdentifiers) String() string

func (*RowIdentifiers) Unmarshal Uses

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

type Schema Uses

type Schema struct {
    Indexes []*Index `protobuf:"bytes,1,rep,name=Indexes" json:"Indexes,omitempty"`
}

func (*Schema) Descriptor Uses

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

func (*Schema) GetIndexes Uses

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

func (*Schema) Marshal Uses

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

func (*Schema) MarshalTo Uses

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

func (*Schema) ProtoMessage Uses

func (*Schema) ProtoMessage()

func (*Schema) Reset Uses

func (m *Schema) Reset()

func (*Schema) Size Uses

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

func (*Schema) String Uses

func (m *Schema) String() string

func (*Schema) Unmarshal Uses

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

type SetCoordinatorMessage Uses

type SetCoordinatorMessage struct {
    New *Node `protobuf:"bytes,1,opt,name=New" json:"New,omitempty"`
}

func (*SetCoordinatorMessage) Descriptor Uses

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

func (*SetCoordinatorMessage) GetNew Uses

func (m *SetCoordinatorMessage) GetNew() *Node

func (*SetCoordinatorMessage) Marshal Uses

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

func (*SetCoordinatorMessage) MarshalTo Uses

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

func (*SetCoordinatorMessage) ProtoMessage Uses

func (*SetCoordinatorMessage) ProtoMessage()

func (*SetCoordinatorMessage) Reset Uses

func (m *SetCoordinatorMessage) Reset()

func (*SetCoordinatorMessage) Size Uses

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

func (*SetCoordinatorMessage) String Uses

func (m *SetCoordinatorMessage) String() string

func (*SetCoordinatorMessage) Unmarshal Uses

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

type Topology Uses

type Topology struct {
    ClusterID string   `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
    NodeIDs   []string `protobuf:"bytes,2,rep,name=NodeIDs" json:"NodeIDs,omitempty"`
}

func (*Topology) Descriptor Uses

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

func (*Topology) GetClusterID Uses

func (m *Topology) GetClusterID() string

func (*Topology) GetNodeIDs Uses

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

func (*Topology) Marshal Uses

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

func (*Topology) MarshalTo Uses

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

func (*Topology) ProtoMessage Uses

func (*Topology) ProtoMessage()

func (*Topology) Reset Uses

func (m *Topology) Reset()

func (*Topology) Size Uses

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

func (*Topology) String Uses

func (m *Topology) String() string

func (*Topology) Unmarshal Uses

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

type TranslateKeysRequest Uses

type TranslateKeysRequest struct {
    Index string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
    Field string   `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"`
    Keys  []string `protobuf:"bytes,3,rep,name=Keys" json:"Keys,omitempty"`
}

func (*TranslateKeysRequest) Descriptor Uses

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

func (*TranslateKeysRequest) GetField Uses

func (m *TranslateKeysRequest) GetField() string

func (*TranslateKeysRequest) GetIndex Uses

func (m *TranslateKeysRequest) GetIndex() string

func (*TranslateKeysRequest) GetKeys Uses

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

func (*TranslateKeysRequest) Marshal Uses

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

func (*TranslateKeysRequest) MarshalTo Uses

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

func (*TranslateKeysRequest) ProtoMessage Uses

func (*TranslateKeysRequest) ProtoMessage()

func (*TranslateKeysRequest) Reset Uses

func (m *TranslateKeysRequest) Reset()

func (*TranslateKeysRequest) Size Uses

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

func (*TranslateKeysRequest) String Uses

func (m *TranslateKeysRequest) String() string

func (*TranslateKeysRequest) Unmarshal Uses

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

type TranslateKeysResponse Uses

type TranslateKeysResponse struct {
    IDs []uint64 `protobuf:"varint,3,rep,packed,name=IDs" json:"IDs,omitempty"`
}

func (*TranslateKeysResponse) Descriptor Uses

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

func (*TranslateKeysResponse) GetIDs Uses

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

func (*TranslateKeysResponse) Marshal Uses

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

func (*TranslateKeysResponse) MarshalTo Uses

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

func (*TranslateKeysResponse) ProtoMessage Uses

func (*TranslateKeysResponse) ProtoMessage()

func (*TranslateKeysResponse) Reset Uses

func (m *TranslateKeysResponse) Reset()

func (*TranslateKeysResponse) Size Uses

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

func (*TranslateKeysResponse) String Uses

func (m *TranslateKeysResponse) String() string

func (*TranslateKeysResponse) Unmarshal Uses

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

type URI Uses

type URI struct {
    Scheme string `protobuf:"bytes,1,opt,name=Scheme,proto3" json:"Scheme,omitempty"`
    Host   string `protobuf:"bytes,2,opt,name=Host,proto3" json:"Host,omitempty"`
    Port   uint32 `protobuf:"varint,3,opt,name=Port,proto3" json:"Port,omitempty"`
}

func (*URI) Descriptor Uses

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

func (*URI) GetHost Uses

func (m *URI) GetHost() string

func (*URI) GetPort Uses

func (m *URI) GetPort() uint32

func (*URI) GetScheme Uses

func (m *URI) GetScheme() string

func (*URI) Marshal Uses

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

func (*URI) MarshalTo Uses

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

func (*URI) ProtoMessage Uses

func (*URI) ProtoMessage()

func (*URI) Reset Uses

func (m *URI) Reset()

func (*URI) Size Uses

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

func (*URI) String Uses

func (m *URI) String() string

func (*URI) Unmarshal Uses

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

type UpdateCoordinatorMessage Uses

type UpdateCoordinatorMessage struct {
    New *Node `protobuf:"bytes,1,opt,name=New" json:"New,omitempty"`
}

func (*UpdateCoordinatorMessage) Descriptor Uses

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

func (*UpdateCoordinatorMessage) GetNew Uses

func (m *UpdateCoordinatorMessage) GetNew() *Node

func (*UpdateCoordinatorMessage) Marshal Uses

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

func (*UpdateCoordinatorMessage) MarshalTo Uses

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

func (*UpdateCoordinatorMessage) ProtoMessage Uses

func (*UpdateCoordinatorMessage) ProtoMessage()

func (*UpdateCoordinatorMessage) Reset Uses

func (m *UpdateCoordinatorMessage) Reset()

func (*UpdateCoordinatorMessage) Size Uses

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

func (*UpdateCoordinatorMessage) String Uses

func (m *UpdateCoordinatorMessage) String() string

func (*UpdateCoordinatorMessage) Unmarshal Uses

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

type ValCount Uses

type ValCount struct {
    Val   int64 `protobuf:"varint,1,opt,name=Val,proto3" json:"Val,omitempty"`
    Count int64 `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"`
}

func (*ValCount) Descriptor Uses

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

func (*ValCount) GetCount Uses

func (m *ValCount) GetCount() int64

func (*ValCount) GetVal Uses

func (m *ValCount) GetVal() int64

func (*ValCount) Marshal Uses

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

func (*ValCount) MarshalTo Uses

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

func (*ValCount) ProtoMessage Uses

func (*ValCount) ProtoMessage()

func (*ValCount) Reset Uses

func (m *ValCount) Reset()

func (*ValCount) Size Uses

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

func (*ValCount) String Uses

func (m *ValCount) String() string

func (*ValCount) Unmarshal Uses

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

Directories

PathSynopsis
test

Package internal imports 7 packages (graph) and is imported by 8 packages. Updated 2019-10-23. Refresh now. Tools for package owners.