internal

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Aug 21, 2018 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
Field
Schema
Index
URI
Node
NodeStateMessage
NodeEventMessage
NodeStatus
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
Pair
ValCount
Bit
ColumnAttrSet
Attr
AttrMap
QueryRequest
QueryResponse
QueryResult
ImportRequest
ImportValueRequest

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 Bit 

type Bit struct {
	RowID     uint64 `protobuf:"varint,1,opt,name=RowID,proto3" json:"RowID,omitempty"`
	ColumnID  uint64 `protobuf:"varint,2,opt,name=ColumnID,proto3" json:"ColumnID,omitempty"`
	Timestamp int64  `protobuf:"varint,3,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
}

func (*Bit) Descriptor 

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

func (*Bit) GetColumnID added in v0.8.0 

func (m *Bit) GetColumnID() uint64

func (*Bit) GetRowID added in v0.8.0 

func (m *Bit) GetRowID() uint64

func (*Bit) GetTimestamp added in v0.8.0 

func (m *Bit) GetTimestamp() int64

func (*Bit) Marshal 

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

func (*Bit) MarshalTo 

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

func (*Bit) ProtoMessage 

func (*Bit) ProtoMessage()

func (*Bit) Reset 

func (m *Bit) Reset()

func (*Bit) Size 

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

func (*Bit) String 

func (m *Bit) String() string

func (*Bit) Unmarshal 

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

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"`
	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) 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 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"`
	Min         int64  `protobuf:"varint,9,opt,name=Min,proto3" json:"Min,omitempty"`
	Max         int64  `protobuf:"varint,10,opt,name=Max,proto3" json:"Max,omitempty"`
	TimeQuantum string `protobuf:"bytes,5,opt,name=TimeQuantum,proto3" json:"TimeQuantum,omitempty"`
	Keys        bool   `protobuf:"varint,11,opt,name=Keys,proto3" json:"Keys,omitempty"`
}

func (*FieldOptions) Descriptor added in v1.0.0 

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

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) 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 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 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"`
}

func (*IndexMeta) Descriptor 

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

func (*IndexMeta) GetKeys added in v1.0.0 

func (m *IndexMeta) GetKeys() 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 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"`
}

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) 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"`
	MaxShards *MaxShards `protobuf:"bytes,2,opt,name=MaxShards" json:"MaxShards,omitempty"`
	Schema    *Schema    `protobuf:"bytes,3,opt,name=Schema" json:"Schema,omitempty"`
}

func (*NodeStatus) Descriptor 

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

func (*NodeStatus) GetMaxShards added in v1.0.0 

func (m *NodeStatus) GetMaxShards() *MaxShards

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"`
	ValCount *ValCount `protobuf:"bytes,5,opt,name=ValCount" json:"ValCount,omitempty"`
	Changed  bool      `protobuf:"varint,4,opt,name=Changed,proto3" json:"Changed,omitempty"`
}

func (*QueryResult) Descriptor 

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

func (*QueryResult) GetChanged added in v0.8.0 

func (m *QueryResult) GetChanged() bool

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) 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"`
	Schema        *Schema         `protobuf:"bytes,5,opt,name=Schema" json:"Schema,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) GetSchema added in v0.9.0 

func (m *ResizeInstruction) GetSchema() *Schema

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 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 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.