internal

package
v1.4.1 Latest Latest
Warning

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

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

Documentation

Overview

Package internal is a generated protocol buffer package.

It is generated from these files: 

private.proto

It has these top-level messages: 

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

Package internal is a generated protocol buffer package.

It is generated from these files: 

public.proto

It has these top-level messages: 

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

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type Attr 

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

func (*Attr) Descriptor 

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

func (*Attr) GetBoolValue added in v0.8.0 

func (m *Attr) GetBoolValue() bool

func (*Attr) GetFloatValue added in v0.8.0 

func (m *Attr) GetFloatValue() float64

func (*Attr) GetIntValue added in v0.8.0 

func (m *Attr) GetIntValue() int64

func (*Attr) GetKey added in v0.8.0 

func (m *Attr) GetKey() string

func (*Attr) GetStringValue added in v0.8.0 

func (m *Attr) GetStringValue() string

func (*Attr) GetType added in v0.8.0 

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

type AttrMap 

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

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

type BSIGroup added in v1.0.0 

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

func (*BSIGroup) Descriptor added in v1.0.0 

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

func (*BSIGroup) GetMax added in v1.0.0 

func (m *BSIGroup) GetMax() int64

func (*BSIGroup) GetMin added in v1.0.0 

func (m *BSIGroup) GetMin() int64

func (*BSIGroup) GetName added in v1.0.0 

func (m *BSIGroup) GetName() string

func (*BSIGroup) GetType added in v1.0.0 

func (m *BSIGroup) GetType() string

func (*BSIGroup) Marshal added in v1.0.0 

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

func (*BSIGroup) MarshalTo added in v1.0.0 

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

func (*BSIGroup) ProtoMessage added in v1.0.0 

func (*BSIGroup) ProtoMessage()

func (*BSIGroup) Reset added in v1.0.0 

func (m *BSIGroup) Reset()

func (*BSIGroup) Size added in v1.0.0 

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

func (*BSIGroup) String added in v1.0.0 

func (m *BSIGroup) String() string

func (*BSIGroup) Unmarshal added in v1.0.0 

func (m *BSIGroup) Unmarshal(dAtA []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"`
}

func (*BlockDataRequest) Descriptor 

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

func (*BlockDataRequest) GetBlock added in v0.8.0 

func (m *BlockDataRequest) GetBlock() uint64

func (*BlockDataRequest) GetField added in v1.0.0 

func (m *BlockDataRequest) GetField() string

func (*BlockDataRequest) GetIndex added in v0.8.0 

func (m *BlockDataRequest) GetIndex() string

func (*BlockDataRequest) GetShard added in v1.0.0 

func (m *BlockDataRequest) GetShard() uint64

func (*BlockDataRequest) GetView added in v0.8.0 

func (m *BlockDataRequest) GetView() string

func (*BlockDataRequest) Marshal 

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

func (*BlockDataRequest) 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

type BlockDataResponse 

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

func (*BlockDataResponse) Descriptor 

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

func (*BlockDataResponse) GetColumnIDs added in v0.8.0 

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

func (*BlockDataResponse) GetRowIDs added in v0.8.0 

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

func (*BlockDataResponse) Marshal 

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

func (*BlockDataResponse) MarshalTo 

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

func (*BlockDataResponse) ProtoMessage 

func (*BlockDataResponse) ProtoMessage()

func (*BlockDataResponse) Reset 

func (m *BlockDataResponse) Reset()

func (*BlockDataResponse) Size 

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

func (*BlockDataResponse) String 

func (m *BlockDataResponse) String() string

func (*BlockDataResponse) Unmarshal 

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

type Cache 

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

func (*Cache) Descriptor 

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

func (*Cache) GetIDs added in v0.8.0 

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

type ClusterStatus 

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

func (*ClusterStatus) Descriptor 

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

func (*ClusterStatus) GetClusterID added in v0.9.0 

func (m *ClusterStatus) GetClusterID() string

func (*ClusterStatus) GetNodes 

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

func (*ClusterStatus) GetState added in v0.9.0 

func (m *ClusterStatus) GetState() string

func (*ClusterStatus) Marshal 

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

func (*ClusterStatus) 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

type ColumnAttrSet 

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

func (*ColumnAttrSet) Descriptor 

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

func (*ColumnAttrSet) GetAttrs 

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

func (*ColumnAttrSet) GetID added in v0.8.0 

func (m *ColumnAttrSet) GetID() uint64

func (*ColumnAttrSet) GetKey added in v0.9.0 

func (m *ColumnAttrSet) GetKey() string

func (*ColumnAttrSet) Marshal 

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

func (*ColumnAttrSet) 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

type CreateFieldMessage added in v0.9.0 

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

func (*CreateFieldMessage) Descriptor added in v0.9.0 

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

func (*CreateFieldMessage) GetField added in v0.9.0 

func (m *CreateFieldMessage) GetField() string

func (*CreateFieldMessage) GetIndex added in v0.9.0 

func (m *CreateFieldMessage) GetIndex() string

func (*CreateFieldMessage) GetMeta added in v1.0.0 

func (m *CreateFieldMessage) GetMeta() *FieldOptions

func (*CreateFieldMessage) Marshal added in v0.9.0 

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

func (*CreateFieldMessage) MarshalTo added in v0.9.0 

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

func (*CreateFieldMessage) ProtoMessage added in v0.9.0 

func (*CreateFieldMessage) ProtoMessage()

func (*CreateFieldMessage) Reset added in v0.9.0 

func (m *CreateFieldMessage) Reset()

func (*CreateFieldMessage) Size added in v0.9.0 

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

func (*CreateFieldMessage) String added in v0.9.0 

func (m *CreateFieldMessage) String() string

func (*CreateFieldMessage) Unmarshal added in v0.9.0 

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

type CreateIndexMessage 

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

func (*CreateIndexMessage) Descriptor 

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

func (*CreateIndexMessage) GetIndex added in v0.8.0 

func (m *CreateIndexMessage) GetIndex() string

func (*CreateIndexMessage) GetMeta 

func (m *CreateIndexMessage) GetMeta() *IndexMeta

func (*CreateIndexMessage) Marshal 

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

func (*CreateIndexMessage) MarshalTo 

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

func (*CreateIndexMessage) ProtoMessage 

func (*CreateIndexMessage) ProtoMessage()

func (*CreateIndexMessage) Reset 

func (m *CreateIndexMessage) Reset()

func (*CreateIndexMessage) Size 

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

func (*CreateIndexMessage) String 

func (m *CreateIndexMessage) String() string

func (*CreateIndexMessage) Unmarshal 

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

type CreateShardMessage added in v1.0.0 

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

func (*CreateShardMessage) Descriptor added in v1.0.0 

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

func (*CreateShardMessage) GetField added in v1.2.0 

func (m *CreateShardMessage) GetField() string

func (*CreateShardMessage) GetIndex added in v1.0.0 

func (m *CreateShardMessage) GetIndex() string

func (*CreateShardMessage) GetShard added in v1.0.0 

func (m *CreateShardMessage) GetShard() uint64

func (*CreateShardMessage) Marshal added in v1.0.0 

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

func (*CreateShardMessage) MarshalTo added in v1.0.0 

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

func (*CreateShardMessage) ProtoMessage added in v1.0.0 

func (*CreateShardMessage) ProtoMessage()

func (*CreateShardMessage) Reset added in v1.0.0 

func (m *CreateShardMessage) Reset()

func (*CreateShardMessage) Size added in v1.0.0 

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

func (*CreateShardMessage) String added in v1.0.0 

func (m *CreateShardMessage) String() string

func (*CreateShardMessage) Unmarshal added in v1.0.0 

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

type CreateViewMessage added in v0.9.0 

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

func (*CreateViewMessage) Descriptor added in v0.9.0 

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

func (*CreateViewMessage) GetField added in v1.0.0 

func (m *CreateViewMessage) GetField() string

func (*CreateViewMessage) GetIndex added in v0.9.0 

func (m *CreateViewMessage) GetIndex() string

func (*CreateViewMessage) GetView added in v0.9.0 

func (m *CreateViewMessage) GetView() string

func (*CreateViewMessage) Marshal added in v0.9.0 

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

func (*CreateViewMessage) MarshalTo added in v0.9.0 

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

func (*CreateViewMessage) ProtoMessage added in v0.9.0 

func (*CreateViewMessage) ProtoMessage()

func (*CreateViewMessage) Reset added in v0.9.0 

func (m *CreateViewMessage) Reset()

func (*CreateViewMessage) Size added in v0.9.0 

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

func (*CreateViewMessage) String added in v0.9.0 

func (m *CreateViewMessage) String() string

func (*CreateViewMessage) Unmarshal added in v0.9.0 

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

type Decoder 

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

Decoder decodes messages from a reader.

func NewDecoder 

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 added in v1.2.0 

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

func (*DeleteAvailableShardMessage) Descriptor added in v1.2.0 

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

func (*DeleteAvailableShardMessage) GetField added in v1.2.0 

func (m *DeleteAvailableShardMessage) GetField() string

func (*DeleteAvailableShardMessage) GetIndex added in v1.2.0 

func (m *DeleteAvailableShardMessage) GetIndex() string

func (*DeleteAvailableShardMessage) GetShardID added in v1.2.0 

func (m *DeleteAvailableShardMessage) GetShardID() uint64

func (*DeleteAvailableShardMessage) Marshal added in v1.2.0 

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

func (*DeleteAvailableShardMessage) MarshalTo added in v1.2.0 

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

func (*DeleteAvailableShardMessage) ProtoMessage added in v1.2.0 

func (*DeleteAvailableShardMessage) ProtoMessage()

func (*DeleteAvailableShardMessage) Reset added in v1.2.0 

func (m *DeleteAvailableShardMessage) Reset()

func (*DeleteAvailableShardMessage) Size added in v1.2.0 

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

func (*DeleteAvailableShardMessage) String added in v1.2.0 

func (m *DeleteAvailableShardMessage) String() string

func (*DeleteAvailableShardMessage) Unmarshal added in v1.2.0 

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

type DeleteFieldMessage added in v0.9.0 

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

func (*DeleteFieldMessage) Descriptor added in v0.9.0 

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

func (*DeleteFieldMessage) GetField added in v0.9.0 

func (m *DeleteFieldMessage) GetField() string

func (*DeleteFieldMessage) GetIndex added in v0.9.0 

func (m *DeleteFieldMessage) GetIndex() string

func (*DeleteFieldMessage) Marshal added in v0.9.0 

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

func (*DeleteFieldMessage) MarshalTo added in v0.9.0 

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

func (*DeleteFieldMessage) ProtoMessage added in v0.9.0 

func (*DeleteFieldMessage) ProtoMessage()

func (*DeleteFieldMessage) Reset added in v0.9.0 

func (m *DeleteFieldMessage) Reset()

func (*DeleteFieldMessage) Size added in v0.9.0 

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

func (*DeleteFieldMessage) String added in v0.9.0 

func (m *DeleteFieldMessage) String() string

func (*DeleteFieldMessage) Unmarshal added in v0.9.0 

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

type DeleteIndexMessage 

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

func (*DeleteIndexMessage) Descriptor 

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

func (*DeleteIndexMessage) GetIndex added in v0.8.0 

func (m *DeleteIndexMessage) GetIndex() string

func (*DeleteIndexMessage) Marshal 

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

func (*DeleteIndexMessage) MarshalTo 

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

func (*DeleteIndexMessage) ProtoMessage 

func (*DeleteIndexMessage) ProtoMessage()

func (*DeleteIndexMessage) Reset 

func (m *DeleteIndexMessage) Reset()

func (*DeleteIndexMessage) Size 

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

func (*DeleteIndexMessage) String 

func (m *DeleteIndexMessage) String() string

func (*DeleteIndexMessage) Unmarshal 

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

type DeleteViewMessage added in v0.7.0 

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

func (*DeleteViewMessage) Descriptor added in v0.7.0 

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

func (*DeleteViewMessage) GetField added in v1.0.0 

func (m *DeleteViewMessage) GetField() string

func (*DeleteViewMessage) GetIndex added in v0.8.0 

func (m *DeleteViewMessage) GetIndex() string

func (*DeleteViewMessage) GetView added in v0.8.0 

func (m *DeleteViewMessage) GetView() string

func (*DeleteViewMessage) Marshal added in v0.7.0 

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

func (*DeleteViewMessage) MarshalTo added in v0.7.0 

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

func (*DeleteViewMessage) ProtoMessage added in v0.7.0 

func (*DeleteViewMessage) ProtoMessage()

func (*DeleteViewMessage) Reset added in v0.7.0 

func (m *DeleteViewMessage) Reset()

func (*DeleteViewMessage) Size added in v0.7.0 

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

func (*DeleteViewMessage) String added in v0.7.0 

func (m *DeleteViewMessage) String() string

func (*DeleteViewMessage) Unmarshal added in v0.7.0 

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

type Encoder 

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

Encoder encodes messages to a writer.

func NewEncoder 

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 added in v0.5.0 

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

func (*Field) Descriptor added in v0.5.0 

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

func (*Field) GetMeta added in v1.0.0 

func (m *Field) GetMeta() *FieldOptions

func (*Field) GetName added in v0.8.0 

func (m *Field) GetName() string

func (*Field) GetViews added in v1.0.0 

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

func (*Field) Marshal added in v0.5.0 

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

func (*Field) MarshalTo added in v0.5.0 

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

func (*Field) ProtoMessage added in v0.5.0 

func (*Field) ProtoMessage()

func (*Field) Reset added in v0.5.0 

func (m *Field) Reset()

func (*Field) Size added in v0.5.0 

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

func (*Field) String added in v0.5.0 

func (m *Field) String() string

func (*Field) Unmarshal added in v0.5.0 

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

type FieldOptions added in v1.0.0 

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

func (*FieldOptions) Descriptor added in v1.0.0 

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

func (*FieldOptions) GetBase added in v1.4.0 

func (m *FieldOptions) GetBase() int64

func (*FieldOptions) GetBitDepth added in v1.4.0 

func (m *FieldOptions) GetBitDepth() uint64

func (*FieldOptions) GetCacheSize added in v1.0.0 

func (m *FieldOptions) GetCacheSize() uint32

func (*FieldOptions) GetCacheType added in v1.0.0 

func (m *FieldOptions) GetCacheType() string

func (*FieldOptions) GetKeys added in v1.0.0 

func (m *FieldOptions) GetKeys() bool

func (*FieldOptions) GetMax added in v1.0.0 

func (m *FieldOptions) GetMax() int64

func (*FieldOptions) GetMin added in v1.0.0 

func (m *FieldOptions) GetMin() int64

func (*FieldOptions) GetNoStandardView added in v1.2.0 

func (m *FieldOptions) GetNoStandardView() bool

func (*FieldOptions) GetTimeQuantum added in v1.0.0 

func (m *FieldOptions) GetTimeQuantum() string

func (*FieldOptions) GetType added in v1.0.0 

func (m *FieldOptions) GetType() string

func (*FieldOptions) Marshal added in v1.0.0 

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

func (*FieldOptions) MarshalTo added in v1.0.0 

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

func (*FieldOptions) ProtoMessage added in v1.0.0 

func (*FieldOptions) ProtoMessage()

func (*FieldOptions) Reset added in v1.0.0 

func (m *FieldOptions) Reset()

func (*FieldOptions) Size added in v1.0.0 

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

func (*FieldOptions) String added in v1.0.0 

func (m *FieldOptions) String() string

func (*FieldOptions) Unmarshal added in v1.0.0 

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

type FieldRow added in v1.2.0 

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

func (*FieldRow) Descriptor added in v1.2.0 

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

func (*FieldRow) GetField added in v1.2.0 

func (m *FieldRow) GetField() string

func (*FieldRow) GetRowID added in v1.2.0 

func (m *FieldRow) GetRowID() uint64

func (*FieldRow) GetRowKey added in v1.3.0 

func (m *FieldRow) GetRowKey() string

func (*FieldRow) Marshal added in v1.2.0 

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

func (*FieldRow) MarshalTo added in v1.2.0 

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

func (*FieldRow) ProtoMessage added in v1.2.0 

func (*FieldRow) ProtoMessage()

func (*FieldRow) Reset added in v1.2.0 

func (m *FieldRow) Reset()

func (*FieldRow) Size added in v1.2.0 

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

func (*FieldRow) String added in v1.2.0 

func (m *FieldRow) String() string

func (*FieldRow) Unmarshal added in v1.2.0 

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

type FieldStatus added in v1.2.0 

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

func (*FieldStatus) Descriptor added in v1.2.0 

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

func (*FieldStatus) GetAvailableShards added in v1.2.0 

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

func (*FieldStatus) GetName added in v1.2.0 

func (m *FieldStatus) GetName() string

func (*FieldStatus) Marshal added in v1.2.0 

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

func (*FieldStatus) MarshalTo added in v1.2.0 

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

func (*FieldStatus) ProtoMessage added in v1.2.0 

func (*FieldStatus) ProtoMessage()

func (*FieldStatus) Reset added in v1.2.0 

func (m *FieldStatus) Reset()

func (*FieldStatus) Size added in v1.2.0 

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

func (*FieldStatus) String added in v1.2.0 

func (m *FieldStatus) String() string

func (*FieldStatus) Unmarshal added in v1.2.0 

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

type GroupCount added in v1.2.0 

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

func (*GroupCount) Descriptor added in v1.2.0 

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

func (*GroupCount) GetCount added in v1.2.0 

func (m *GroupCount) GetCount() uint64

func (*GroupCount) GetGroup added in v1.2.0 

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

func (*GroupCount) Marshal added in v1.2.0 

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

func (*GroupCount) MarshalTo added in v1.2.0 

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

func (*GroupCount) ProtoMessage added in v1.2.0 

func (*GroupCount) ProtoMessage()

func (*GroupCount) Reset added in v1.2.0 

func (m *GroupCount) Reset()

func (*GroupCount) Size added in v1.2.0 

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

func (*GroupCount) String added in v1.2.0 

func (m *GroupCount) String() string

func (*GroupCount) Unmarshal added in v1.2.0 

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

type ImportRequest 

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

func (*ImportRequest) Descriptor 

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

func (*ImportRequest) GetColumnIDs added in v0.8.0 

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

func (*ImportRequest) GetColumnKeys added in v0.9.0 

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

func (*ImportRequest) GetField added in v1.0.0 

func (m *ImportRequest) GetField() string

func (*ImportRequest) GetIndex added in v0.8.0 

func (m *ImportRequest) GetIndex() string

func (*ImportRequest) GetRowIDs added in v0.8.0 

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

func (*ImportRequest) GetRowKeys added in v0.9.0 

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

func (*ImportRequest) GetShard added in v1.0.0 

func (m *ImportRequest) GetShard() uint64

func (*ImportRequest) GetTimestamps added in v0.8.0 

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

func (*ImportRequest) Marshal 

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

func (*ImportRequest) 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

type ImportResponse 

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

func (*ImportResponse) Descriptor 

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

func (*ImportResponse) GetErr added in v0.8.0 

func (m *ImportResponse) GetErr() string

func (*ImportResponse) Marshal 

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

func (*ImportResponse) 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

type ImportRoaringRequest added in v1.2.0 

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

func (*ImportRoaringRequest) Descriptor added in v1.2.0 

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

func (*ImportRoaringRequest) GetClear added in v1.2.0 

func (m *ImportRoaringRequest) GetClear() bool

func (*ImportRoaringRequest) GetViews added in v1.2.0 

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

func (*ImportRoaringRequest) Marshal added in v1.2.0 

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

func (*ImportRoaringRequest) MarshalTo added in v1.2.0 

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

func (*ImportRoaringRequest) ProtoMessage added in v1.2.0 

func (*ImportRoaringRequest) ProtoMessage()

func (*ImportRoaringRequest) Reset added in v1.2.0 

func (m *ImportRoaringRequest) Reset()

func (*ImportRoaringRequest) Size added in v1.2.0 

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

func (*ImportRoaringRequest) String added in v1.2.0 

func (m *ImportRoaringRequest) String() string

func (*ImportRoaringRequest) Unmarshal added in v1.2.0 

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

type ImportRoaringRequestView added in v1.2.0 

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

func (*ImportRoaringRequestView) Descriptor added in v1.2.0 

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

func (*ImportRoaringRequestView) GetData added in v1.2.0 

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

func (*ImportRoaringRequestView) GetName added in v1.2.0 

func (m *ImportRoaringRequestView) GetName() string

func (*ImportRoaringRequestView) Marshal added in v1.2.0 

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

func (*ImportRoaringRequestView) MarshalTo added in v1.2.0 

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

func (*ImportRoaringRequestView) ProtoMessage added in v1.2.0 

func (*ImportRoaringRequestView) ProtoMessage()

func (*ImportRoaringRequestView) Reset added in v1.2.0 

func (m *ImportRoaringRequestView) Reset()

func (*ImportRoaringRequestView) Size added in v1.2.0 

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

func (*ImportRoaringRequestView) String added in v1.2.0 

func (m *ImportRoaringRequestView) String() string

func (*ImportRoaringRequestView) Unmarshal added in v1.2.0 

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

type ImportValueRequest added in v0.7.0 

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

func (*ImportValueRequest) Descriptor added in v0.7.0 

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

func (*ImportValueRequest) GetColumnIDs added in v0.8.0 

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

func (*ImportValueRequest) GetColumnKeys added in v0.9.0 

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

func (*ImportValueRequest) GetField added in v0.8.0 

func (m *ImportValueRequest) GetField() string

func (*ImportValueRequest) GetIndex added in v0.8.0 

func (m *ImportValueRequest) GetIndex() string

func (*ImportValueRequest) GetShard added in v1.0.0 

func (m *ImportValueRequest) GetShard() uint64

func (*ImportValueRequest) GetValues added in v0.8.0 

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

func (*ImportValueRequest) Marshal added in v0.7.0 

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

func (*ImportValueRequest) MarshalTo added in v0.7.0 

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

func (*ImportValueRequest) ProtoMessage added in v0.7.0 

func (*ImportValueRequest) ProtoMessage()

func (*ImportValueRequest) Reset added in v0.7.0 

func (m *ImportValueRequest) Reset()

func (*ImportValueRequest) Size added in v0.7.0 

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

func (*ImportValueRequest) String added in v0.7.0 

func (m *ImportValueRequest) String() string

func (*ImportValueRequest) Unmarshal added in v0.7.0 

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

type Index 

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

func (*Index) Descriptor 

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

func (*Index) GetFields added in v1.0.0 

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

func (*Index) GetName added in v0.8.0 

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

type IndexMeta 

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

func (*IndexMeta) Descriptor 

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

func (*IndexMeta) GetKeys added in v1.0.0 

func (m *IndexMeta) GetKeys() bool

func (*IndexMeta) GetTrackExistence added in v1.2.0 

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

type IndexStatus added in v1.2.0 

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

func (*IndexStatus) Descriptor added in v1.2.0 

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

func (*IndexStatus) GetFields added in v1.2.0 

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

func (*IndexStatus) GetName added in v1.2.0 

func (m *IndexStatus) GetName() string

func (*IndexStatus) Marshal added in v1.2.0 

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

func (*IndexStatus) MarshalTo added in v1.2.0 

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

func (*IndexStatus) ProtoMessage added in v1.2.0 

func (*IndexStatus) ProtoMessage()

func (*IndexStatus) Reset added in v1.2.0 

func (m *IndexStatus) Reset()

func (*IndexStatus) Size added in v1.2.0 

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

func (*IndexStatus) String added in v1.2.0 

func (m *IndexStatus) String() string

func (*IndexStatus) Unmarshal added in v1.2.0 

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

type MaxShards added in v1.0.0 

type MaxShards struct {
	Standard map[string]uint64 `` /* 151-byte string literal not displayed */
}

func (*MaxShards) Descriptor added in v1.0.0 

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

func (*MaxShards) GetStandard added in v1.0.0 

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

func (*MaxShards) Marshal added in v1.0.0 

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

func (*MaxShards) MarshalTo added in v1.0.0 

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

func (*MaxShards) ProtoMessage added in v1.0.0 

func (*MaxShards) ProtoMessage()

func (*MaxShards) Reset added in v1.0.0 

func (m *MaxShards) Reset()

func (*MaxShards) Size added in v1.0.0 

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

func (*MaxShards) String added in v1.0.0 

func (m *MaxShards) String() string

func (*MaxShards) Unmarshal added in v1.0.0 

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

type Node added in v0.9.0 

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

func (*Node) Descriptor added in v0.9.0 

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

func (*Node) GetID added in v0.9.0 

func (m *Node) GetID() string

func (*Node) GetIsCoordinator added in v0.9.0 

func (m *Node) GetIsCoordinator() bool

func (*Node) GetState added in v1.2.0 

func (m *Node) GetState() string

func (*Node) GetURI added in v0.9.0 

func (m *Node) GetURI() *URI

func (*Node) Marshal added in v0.9.0 

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

func (*Node) MarshalTo added in v0.9.0 

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

func (*Node) ProtoMessage added in v0.9.0 

func (*Node) ProtoMessage()

func (*Node) Reset added in v0.9.0 

func (m *Node) Reset()

func (*Node) Size added in v0.9.0 

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

func (*Node) String added in v0.9.0 

func (m *Node) String() string

func (*Node) Unmarshal added in v0.9.0 

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

type NodeEventMessage added in v0.9.0 

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

func (*NodeEventMessage) Descriptor added in v0.9.0 

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

func (*NodeEventMessage) GetEvent added in v0.9.0 

func (m *NodeEventMessage) GetEvent() uint32

func (*NodeEventMessage) GetNode added in v0.9.0 

func (m *NodeEventMessage) GetNode() *Node

func (*NodeEventMessage) Marshal added in v0.9.0 

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

func (*NodeEventMessage) MarshalTo added in v0.9.0 

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

func (*NodeEventMessage) ProtoMessage added in v0.9.0 

func (*NodeEventMessage) ProtoMessage()

func (*NodeEventMessage) Reset added in v0.9.0 

func (m *NodeEventMessage) Reset()

func (*NodeEventMessage) Size added in v0.9.0 

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

func (*NodeEventMessage) String added in v0.9.0 

func (m *NodeEventMessage) String() string

func (*NodeEventMessage) Unmarshal added in v0.9.0 

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

type NodeStateMessage added in v0.9.0 

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

func (*NodeStateMessage) Descriptor added in v0.9.0 

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

func (*NodeStateMessage) GetNodeID added in v0.9.0 

func (m *NodeStateMessage) GetNodeID() string

func (*NodeStateMessage) GetState added in v0.9.0 

func (m *NodeStateMessage) GetState() string

func (*NodeStateMessage) Marshal added in v0.9.0 

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

func (*NodeStateMessage) MarshalTo added in v0.9.0 

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

func (*NodeStateMessage) ProtoMessage added in v0.9.0 

func (*NodeStateMessage) ProtoMessage()

func (*NodeStateMessage) Reset added in v0.9.0 

func (m *NodeStateMessage) Reset()

func (*NodeStateMessage) Size added in v0.9.0 

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

func (*NodeStateMessage) String added in v0.9.0 

func (m *NodeStateMessage) String() string

func (*NodeStateMessage) Unmarshal added in v0.9.0 

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

type NodeStatus 

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

func (*NodeStatus) Descriptor 

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

func (*NodeStatus) GetIndexes 

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

func (*NodeStatus) GetNode added in v0.9.0 

func (m *NodeStatus) GetNode() *Node

func (*NodeStatus) GetSchema added in v0.9.0 

func (m *NodeStatus) GetSchema() *Schema

func (*NodeStatus) Marshal 

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

func (*NodeStatus) 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

type Pair 

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

func (*Pair) Descriptor 

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

func (*Pair) GetCount added in v0.8.0 

func (m *Pair) GetCount() uint64

func (*Pair) GetID added in v0.9.0 

func (m *Pair) GetID() uint64

func (*Pair) GetKey added in v0.8.0 

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

type QueryRequest 

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

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) GetColumnAttrs added in v0.8.0 

func (m *QueryRequest) GetColumnAttrs() bool

func (*QueryRequest) GetExcludeColumns added in v1.0.0 

func (m *QueryRequest) GetExcludeColumns() bool

func (*QueryRequest) GetExcludeRowAttrs added in v1.0.0 

func (m *QueryRequest) GetExcludeRowAttrs() bool

func (*QueryRequest) GetQuery added in v0.8.0 

func (m *QueryRequest) GetQuery() string

func (*QueryRequest) GetRemote added in v0.8.0 

func (m *QueryRequest) GetRemote() bool

func (*QueryRequest) GetShards added in v1.0.0 

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

func (*QueryRequest) Marshal 

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

func (*QueryRequest) 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

type QueryResponse 

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

func (*QueryResponse) Descriptor 

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

func (*QueryResponse) GetColumnAttrSets 

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

func (*QueryResponse) GetErr added in v0.8.0 

func (m *QueryResponse) GetErr() string

func (*QueryResponse) GetResults 

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

func (*QueryResponse) Marshal 

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

func (*QueryResponse) 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

type QueryResult 

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

func (*QueryResult) Descriptor 

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

func (*QueryResult) GetChanged added in v0.8.0 

func (m *QueryResult) GetChanged() bool

func (*QueryResult) GetGroupCounts added in v1.2.0 

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

func (*QueryResult) GetN added in v0.8.0 

func (m *QueryResult) GetN() uint64

func (*QueryResult) GetPairs 

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

func (*QueryResult) GetRow added in v1.0.0 

func (m *QueryResult) GetRow() *Row

func (*QueryResult) GetRowIDs added in v1.2.0 

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

func (*QueryResult) GetRowIdentifiers added in v1.2.0 

func (m *QueryResult) GetRowIdentifiers() *RowIdentifiers

func (*QueryResult) GetType added in v0.9.0 

func (m *QueryResult) GetType() uint32

func (*QueryResult) GetValCount added in v0.9.0 

func (m *QueryResult) GetValCount() *ValCount

func (*QueryResult) Marshal 

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

func (*QueryResult) 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

type RecalculateCaches added in v0.9.0 

type RecalculateCaches struct {
}

func (*RecalculateCaches) Descriptor added in v0.9.0 

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

func (*RecalculateCaches) Marshal added in v0.9.0 

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

func (*RecalculateCaches) MarshalTo added in v0.9.0 

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

func (*RecalculateCaches) ProtoMessage added in v0.9.0 

func (*RecalculateCaches) ProtoMessage()

func (*RecalculateCaches) Reset added in v0.9.0 

func (m *RecalculateCaches) Reset()

func (*RecalculateCaches) Size added in v0.9.0 

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

func (*RecalculateCaches) String added in v0.9.0 

func (m *RecalculateCaches) String() string

func (*RecalculateCaches) Unmarshal added in v0.9.0 

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

type Request 

type Request proto.Message

type ResizeInstruction added in v0.9.0 

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

func (*ResizeInstruction) Descriptor added in v0.9.0 

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

func (*ResizeInstruction) GetClusterStatus added in v0.9.0 

func (m *ResizeInstruction) GetClusterStatus() *ClusterStatus

func (*ResizeInstruction) GetCoordinator added in v0.9.0 

func (m *ResizeInstruction) GetCoordinator() *Node

func (*ResizeInstruction) GetJobID added in v0.9.0 

func (m *ResizeInstruction) GetJobID() int64

func (*ResizeInstruction) GetNode added in v0.9.0 

func (m *ResizeInstruction) GetNode() *Node

func (*ResizeInstruction) GetNodeStatus added in v1.2.0 

func (m *ResizeInstruction) GetNodeStatus() *NodeStatus

func (*ResizeInstruction) GetSources added in v0.9.0 

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

func (*ResizeInstruction) Marshal added in v0.9.0 

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

func (*ResizeInstruction) MarshalTo added in v0.9.0 

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

func (*ResizeInstruction) ProtoMessage added in v0.9.0 

func (*ResizeInstruction) ProtoMessage()

func (*ResizeInstruction) Reset added in v0.9.0 

func (m *ResizeInstruction) Reset()

func (*ResizeInstruction) Size added in v0.9.0 

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

func (*ResizeInstruction) String added in v0.9.0 

func (m *ResizeInstruction) String() string

func (*ResizeInstruction) Unmarshal added in v0.9.0 

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

type ResizeInstructionComplete added in v0.9.0 

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

func (*ResizeInstructionComplete) Descriptor added in v0.9.0 

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

func (*ResizeInstructionComplete) GetError added in v0.9.0 

func (m *ResizeInstructionComplete) GetError() string

func (*ResizeInstructionComplete) GetJobID added in v0.9.0 

func (m *ResizeInstructionComplete) GetJobID() int64

func (*ResizeInstructionComplete) GetNode added in v0.9.0 

func (m *ResizeInstructionComplete) GetNode() *Node

func (*ResizeInstructionComplete) Marshal added in v0.9.0 

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

func (*ResizeInstructionComplete) MarshalTo added in v0.9.0 

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

func (*ResizeInstructionComplete) ProtoMessage added in v0.9.0 

func (*ResizeInstructionComplete) ProtoMessage()

func (*ResizeInstructionComplete) Reset added in v0.9.0 

func (m *ResizeInstructionComplete) Reset()

func (*ResizeInstructionComplete) Size added in v0.9.0 

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

func (*ResizeInstructionComplete) String added in v0.9.0 

func (m *ResizeInstructionComplete) String() string

func (*ResizeInstructionComplete) Unmarshal added in v0.9.0 

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

type ResizeSource added in v0.9.0 

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

func (*ResizeSource) Descriptor added in v0.9.0 

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

func (*ResizeSource) GetField added in v1.0.0 

func (m *ResizeSource) GetField() string

func (*ResizeSource) GetIndex added in v0.9.0 

func (m *ResizeSource) GetIndex() string

func (*ResizeSource) GetNode added in v0.9.0 

func (m *ResizeSource) GetNode() *Node

func (*ResizeSource) GetShard added in v1.0.0 

func (m *ResizeSource) GetShard() uint64

func (*ResizeSource) GetView added in v0.9.0 

func (m *ResizeSource) GetView() string

func (*ResizeSource) Marshal added in v0.9.0 

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

func (*ResizeSource) MarshalTo added in v0.9.0 

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

func (*ResizeSource) ProtoMessage added in v0.9.0 

func (*ResizeSource) ProtoMessage()

func (*ResizeSource) Reset added in v0.9.0 

func (m *ResizeSource) Reset()

func (*ResizeSource) Size added in v0.9.0 

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

func (*ResizeSource) String added in v0.9.0 

func (m *ResizeSource) String() string

func (*ResizeSource) Unmarshal added in v0.9.0 

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

type Response 

type Response proto.Message

type Row added in v1.0.0 

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

func (*Row) Descriptor added in v1.0.0 

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

func (*Row) GetAttrs added in v1.0.0 

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

func (*Row) GetColumns added in v1.0.0 

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

func (*Row) GetKeys added in v1.0.0 

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

func (*Row) Marshal added in v1.0.0 

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

func (*Row) MarshalTo added in v1.0.0 

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

func (*Row) ProtoMessage added in v1.0.0 

func (*Row) ProtoMessage()

func (*Row) Reset added in v1.0.0 

func (m *Row) Reset()

func (*Row) Size added in v1.0.0 

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

func (*Row) String added in v1.0.0 

func (m *Row) String() string

func (*Row) Unmarshal added in v1.0.0 

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

type RowIdentifiers added in v1.2.0 

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

func (*RowIdentifiers) Descriptor added in v1.2.0 

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

func (*RowIdentifiers) GetKeys added in v1.2.0 

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

func (*RowIdentifiers) GetRows added in v1.2.0 

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

func (*RowIdentifiers) Marshal added in v1.2.0 

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

func (*RowIdentifiers) MarshalTo added in v1.2.0 

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

func (*RowIdentifiers) ProtoMessage added in v1.2.0 

func (*RowIdentifiers) ProtoMessage()

func (*RowIdentifiers) Reset added in v1.2.0 

func (m *RowIdentifiers) Reset()

func (*RowIdentifiers) Size added in v1.2.0 

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

func (*RowIdentifiers) String added in v1.2.0 

func (m *RowIdentifiers) String() string

func (*RowIdentifiers) Unmarshal added in v1.2.0 

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

type Schema added in v0.9.0 

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

func (*Schema) Descriptor added in v0.9.0 

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

func (*Schema) GetIndexes added in v0.9.0 

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

func (*Schema) Marshal added in v0.9.0 

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

func (*Schema) MarshalTo added in v0.9.0 

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

func (*Schema) ProtoMessage added in v0.9.0 

func (*Schema) ProtoMessage()

func (*Schema) Reset added in v0.9.0 

func (m *Schema) Reset()

func (*Schema) Size added in v0.9.0 

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

func (*Schema) String added in v0.9.0 

func (m *Schema) String() string

func (*Schema) Unmarshal added in v0.9.0 

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

type SetCoordinatorMessage added in v0.9.0 

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

func (*SetCoordinatorMessage) Descriptor added in v0.9.0 

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

func (*SetCoordinatorMessage) GetNew added in v0.9.0 

func (m *SetCoordinatorMessage) GetNew() *Node

func (*SetCoordinatorMessage) Marshal added in v0.9.0 

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

func (*SetCoordinatorMessage) MarshalTo added in v0.9.0 

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

func (*SetCoordinatorMessage) ProtoMessage added in v0.9.0 

func (*SetCoordinatorMessage) ProtoMessage()

func (*SetCoordinatorMessage) Reset added in v0.9.0 

func (m *SetCoordinatorMessage) Reset()

func (*SetCoordinatorMessage) Size added in v0.9.0 

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

func (*SetCoordinatorMessage) String added in v0.9.0 

func (m *SetCoordinatorMessage) String() string

func (*SetCoordinatorMessage) Unmarshal added in v0.9.0 

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

type Topology added in v0.9.0 

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

func (*Topology) Descriptor added in v0.9.0 

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

func (*Topology) GetClusterID added in v0.9.0 

func (m *Topology) GetClusterID() string

func (*Topology) GetNodeIDs added in v0.9.0 

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

func (*Topology) Marshal added in v0.9.0 

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

func (*Topology) MarshalTo added in v0.9.0 

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

func (*Topology) ProtoMessage added in v0.9.0 

func (*Topology) ProtoMessage()

func (*Topology) Reset added in v0.9.0 

func (m *Topology) Reset()

func (*Topology) Size added in v0.9.0 

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

func (*Topology) String added in v0.9.0 

func (m *Topology) String() string

func (*Topology) Unmarshal added in v0.9.0 

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

type TranslateKeysRequest added in v1.2.0 

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

func (*TranslateKeysRequest) Descriptor added in v1.2.0 

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

func (*TranslateKeysRequest) GetField added in v1.2.0 

func (m *TranslateKeysRequest) GetField() string

func (*TranslateKeysRequest) GetIndex added in v1.2.0 

func (m *TranslateKeysRequest) GetIndex() string

func (*TranslateKeysRequest) GetKeys added in v1.2.0 

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

func (*TranslateKeysRequest) Marshal added in v1.2.0 

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

func (*TranslateKeysRequest) MarshalTo added in v1.2.0 

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

func (*TranslateKeysRequest) ProtoMessage added in v1.2.0 

func (*TranslateKeysRequest) ProtoMessage()

func (*TranslateKeysRequest) Reset added in v1.2.0 

func (m *TranslateKeysRequest) Reset()

func (*TranslateKeysRequest) Size added in v1.2.0 

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

func (*TranslateKeysRequest) String added in v1.2.0 

func (m *TranslateKeysRequest) String() string

func (*TranslateKeysRequest) Unmarshal added in v1.2.0 

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

type TranslateKeysResponse added in v1.2.0 

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

func (*TranslateKeysResponse) Descriptor added in v1.2.0 

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

func (*TranslateKeysResponse) GetIDs added in v1.2.0 

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

func (*TranslateKeysResponse) Marshal added in v1.2.0 

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

func (*TranslateKeysResponse) MarshalTo added in v1.2.0 

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

func (*TranslateKeysResponse) ProtoMessage added in v1.2.0 

func (*TranslateKeysResponse) ProtoMessage()

func (*TranslateKeysResponse) Reset added in v1.2.0 

func (m *TranslateKeysResponse) Reset()

func (*TranslateKeysResponse) Size added in v1.2.0 

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

func (*TranslateKeysResponse) String added in v1.2.0 

func (m *TranslateKeysResponse) String() string

func (*TranslateKeysResponse) Unmarshal added in v1.2.0 

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

type URI added in v0.9.0 

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

func (*URI) Descriptor added in v0.9.0 

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

func (*URI) GetHost added in v0.9.0 

func (m *URI) GetHost() string

func (*URI) GetPort added in v0.9.0 

func (m *URI) GetPort() uint32

func (*URI) GetScheme added in v0.9.0 

func (m *URI) GetScheme() string

func (*URI) Marshal added in v0.9.0 

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

func (*URI) MarshalTo added in v0.9.0 

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

func (*URI) ProtoMessage added in v0.9.0 

func (*URI) ProtoMessage()

func (*URI) Reset added in v0.9.0 

func (m *URI) Reset()

func (*URI) Size added in v0.9.0 

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

func (*URI) String added in v0.9.0 

func (m *URI) String() string

func (*URI) Unmarshal added in v0.9.0 

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

type UpdateCoordinatorMessage added in v0.9.0 

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

func (*UpdateCoordinatorMessage) Descriptor added in v0.9.0 

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

func (*UpdateCoordinatorMessage) GetNew added in v0.9.0 

func (m *UpdateCoordinatorMessage) GetNew() *Node

func (*UpdateCoordinatorMessage) Marshal added in v0.9.0 

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

func (*UpdateCoordinatorMessage) MarshalTo added in v0.9.0 

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

func (*UpdateCoordinatorMessage) ProtoMessage added in v0.9.0 

func (*UpdateCoordinatorMessage) ProtoMessage()

func (*UpdateCoordinatorMessage) Reset added in v0.9.0 

func (m *UpdateCoordinatorMessage) Reset()

func (*UpdateCoordinatorMessage) Size added in v0.9.0 

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

func (*UpdateCoordinatorMessage) String added in v0.9.0 

func (m *UpdateCoordinatorMessage) String() string

func (*UpdateCoordinatorMessage) Unmarshal added in v0.9.0 

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

type ValCount added in v0.9.0 

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

func (*ValCount) Descriptor added in v0.9.0 

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

func (*ValCount) GetCount added in v0.9.0 

func (m *ValCount) GetCount() int64

func (*ValCount) GetVal added in v0.9.0 

func (m *ValCount) GetVal() int64

func (*ValCount) Marshal added in v0.9.0 

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

func (*ValCount) MarshalTo added in v0.9.0 

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

func (*ValCount) ProtoMessage added in v0.9.0 

func (*ValCount) ProtoMessage()

func (*ValCount) Reset added in v0.9.0 

func (m *ValCount) Reset()

func (*ValCount) Size added in v0.9.0 

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

func (*ValCount) String added in v0.9.0 

func (m *ValCount) String() string

func (*ValCount) Unmarshal added in v0.9.0 

func (m *ValCount) Unmarshal(dAtA []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.