internal

package
v0.10.1 Latest Latest
Warning

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

 Go to latest Published: May 22, 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
FrameMeta
ImportResponse
BlockDataRequest
BlockDataResponse
Cache
MaxSlices
CreateSliceMessage
DeleteIndexMessage
CreateIndexMessage
CreateFrameMessage
DeleteFrameMessage
CreateFieldMessage
DeleteFieldMessage
Frame
Schema
Index
URI
Node
NodeStateMessage
NodeEventMessage
NodeStatus
ClusterStatus
Field
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: 

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

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

func (*Bitmap) Descriptor 

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

func (*Bitmap) GetAttrs 

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

func (*Bitmap) GetBits added in v0.8.0 

func (m *Bitmap) GetBits() []uint64

func (*Bitmap) GetKeys added in v0.9.0 

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

func (*Bitmap) Marshal 

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

func (*Bitmap) MarshalTo 

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

func (*Bitmap) ProtoMessage 

func (*Bitmap) ProtoMessage()

func (*Bitmap) Reset 

func (m *Bitmap) Reset()

func (*Bitmap) Size 

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

func (*Bitmap) String 

func (m *Bitmap) String() string

func (*Bitmap) Unmarshal 

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

type BlockDataRequest 

type BlockDataRequest struct {
	Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Frame string `protobuf:"bytes,2,opt,name=Frame,proto3" json:"Frame,omitempty"`
	View  string `protobuf:"bytes,5,opt,name=View,proto3" json:"View,omitempty"`
	Slice uint64 `protobuf:"varint,4,opt,name=Slice,proto3" json:"Slice,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) GetFrame added in v0.8.0 

func (m *BlockDataRequest) GetFrame() string

func (*BlockDataRequest) GetIndex added in v0.8.0 

func (m *BlockDataRequest) GetIndex() string

func (*BlockDataRequest) GetSlice added in v0.8.0 

func (m *BlockDataRequest) GetSlice() 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"`
	Frame string `protobuf:"bytes,2,opt,name=Frame,proto3" json:"Frame,omitempty"`
	Field *Field `protobuf:"bytes,3,opt,name=Field" json:"Field,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() *Field

func (*CreateFieldMessage) GetFrame added in v0.9.0 

func (m *CreateFieldMessage) GetFrame() string

func (*CreateFieldMessage) GetIndex added in v0.9.0 

func (m *CreateFieldMessage) GetIndex() string

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 CreateFrameMessage 

type CreateFrameMessage struct {
	Index string     `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Frame string     `protobuf:"bytes,2,opt,name=Frame,proto3" json:"Frame,omitempty"`
	Meta  *FrameMeta `protobuf:"bytes,3,opt,name=Meta" json:"Meta,omitempty"`
}

func (*CreateFrameMessage) Descriptor 

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

func (*CreateFrameMessage) GetFrame added in v0.8.0 

func (m *CreateFrameMessage) GetFrame() string

func (*CreateFrameMessage) GetIndex added in v0.8.0 

func (m *CreateFrameMessage) GetIndex() string

func (*CreateFrameMessage) GetMeta 

func (m *CreateFrameMessage) GetMeta() *FrameMeta

func (*CreateFrameMessage) Marshal 

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

func (*CreateFrameMessage) MarshalTo 

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

func (*CreateFrameMessage) ProtoMessage 

func (*CreateFrameMessage) ProtoMessage()

func (*CreateFrameMessage) Reset 

func (m *CreateFrameMessage) Reset()

func (*CreateFrameMessage) Size 

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

func (*CreateFrameMessage) String 

func (m *CreateFrameMessage) String() string

func (*CreateFrameMessage) Unmarshal 

func (m *CreateFrameMessage) 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 CreateSliceMessage 

type CreateSliceMessage struct {
	Index     string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Slice     uint64 `protobuf:"varint,2,opt,name=Slice,proto3" json:"Slice,omitempty"`
	IsInverse bool   `protobuf:"varint,3,opt,name=IsInverse,proto3" json:"IsInverse,omitempty"`
}

func (*CreateSliceMessage) Descriptor 

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

func (*CreateSliceMessage) GetIndex added in v0.8.0 

func (m *CreateSliceMessage) GetIndex() string

func (*CreateSliceMessage) GetIsInverse added in v0.8.0 

func (m *CreateSliceMessage) GetIsInverse() bool

func (*CreateSliceMessage) GetSlice added in v0.8.0 

func (m *CreateSliceMessage) GetSlice() uint64

func (*CreateSliceMessage) Marshal 

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

func (*CreateSliceMessage) MarshalTo 

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

func (*CreateSliceMessage) ProtoMessage 

func (*CreateSliceMessage) ProtoMessage()

func (*CreateSliceMessage) Reset 

func (m *CreateSliceMessage) Reset()

func (*CreateSliceMessage) Size 

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

func (*CreateSliceMessage) String 

func (m *CreateSliceMessage) String() string

func (*CreateSliceMessage) Unmarshal 

func (m *CreateSliceMessage) 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"`
	Frame string `protobuf:"bytes,2,opt,name=Frame,proto3" json:"Frame,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) GetFrame added in v0.9.0 

func (m *CreateViewMessage) GetFrame() 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"`
	Frame string `protobuf:"bytes,2,opt,name=Frame,proto3" json:"Frame,omitempty"`
	Field string `protobuf:"bytes,3,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) GetFrame added in v0.9.0 

func (m *DeleteFieldMessage) GetFrame() 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 DeleteFrameMessage 

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

func (*DeleteFrameMessage) Descriptor 

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

func (*DeleteFrameMessage) GetFrame added in v0.8.0 

func (m *DeleteFrameMessage) GetFrame() string

func (*DeleteFrameMessage) GetIndex added in v0.8.0 

func (m *DeleteFrameMessage) GetIndex() string

func (*DeleteFrameMessage) Marshal 

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

func (*DeleteFrameMessage) MarshalTo 

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

func (*DeleteFrameMessage) ProtoMessage 

func (*DeleteFrameMessage) ProtoMessage()

func (*DeleteFrameMessage) Reset 

func (m *DeleteFrameMessage) Reset()

func (*DeleteFrameMessage) Size 

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

func (*DeleteFrameMessage) String 

func (m *DeleteFrameMessage) String() string

func (*DeleteFrameMessage) Unmarshal 

func (m *DeleteFrameMessage) 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"`
	Frame string `protobuf:"bytes,2,opt,name=Frame,proto3" json:"Frame,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) GetFrame added in v0.8.0 

func (m *DeleteViewMessage) GetFrame() 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"`
	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 (*Field) Descriptor added in v0.5.0 

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

func (*Field) GetMax added in v0.8.0 

func (m *Field) GetMax() int64

func (*Field) GetMin added in v0.8.0 

func (m *Field) GetMin() int64

func (*Field) GetName added in v0.8.0 

func (m *Field) GetName() string

func (*Field) GetType added in v0.8.0 

func (m *Field) GetType() 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 Frame 

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

func (*Frame) Descriptor 

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

func (*Frame) GetMeta 

func (m *Frame) GetMeta() *FrameMeta

func (*Frame) GetName added in v0.8.0 

func (m *Frame) GetName() string

func (*Frame) GetViews added in v0.9.0 

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

func (*Frame) Marshal 

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

func (*Frame) MarshalTo 

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

func (*Frame) ProtoMessage 

func (*Frame) ProtoMessage()

func (*Frame) Reset 

func (m *Frame) Reset()

func (*Frame) Size 

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

func (*Frame) String 

func (m *Frame) String() string

func (*Frame) Unmarshal 

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

type FrameMeta 

type FrameMeta struct {
	InverseEnabled bool     `protobuf:"varint,2,opt,name=InverseEnabled,proto3" json:"InverseEnabled,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"`
	RangeEnabled   bool     `protobuf:"varint,6,opt,name=RangeEnabled,proto3" json:"RangeEnabled,omitempty"`
	Fields         []*Field `protobuf:"bytes,7,rep,name=Fields" json:"Fields,omitempty"`
}

func (*FrameMeta) Descriptor 

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

func (*FrameMeta) GetCacheSize added in v0.8.0 

func (m *FrameMeta) GetCacheSize() uint32

func (*FrameMeta) GetCacheType added in v0.8.0 

func (m *FrameMeta) GetCacheType() string

func (*FrameMeta) GetFields added in v0.7.0 

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

func (*FrameMeta) GetInverseEnabled added in v0.8.0 

func (m *FrameMeta) GetInverseEnabled() bool

func (*FrameMeta) GetRangeEnabled added in v0.8.0 

func (m *FrameMeta) GetRangeEnabled() bool

func (*FrameMeta) GetTimeQuantum added in v0.8.0 

func (m *FrameMeta) GetTimeQuantum() string

func (*FrameMeta) Marshal 

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

func (*FrameMeta) MarshalTo 

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

func (*FrameMeta) ProtoMessage 

func (*FrameMeta) ProtoMessage()

func (*FrameMeta) Reset 

func (m *FrameMeta) Reset()

func (*FrameMeta) Size 

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

func (*FrameMeta) String 

func (m *FrameMeta) String() string

func (*FrameMeta) Unmarshal 

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

type ImportRequest 

type ImportRequest struct {
	Index      string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Frame      string   `protobuf:"bytes,2,opt,name=Frame,proto3" json:"Frame,omitempty"`
	Slice      uint64   `protobuf:"varint,3,opt,name=Slice,proto3" json:"Slice,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) GetFrame added in v0.8.0 

func (m *ImportRequest) GetFrame() 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) GetSlice added in v0.8.0 

func (m *ImportRequest) GetSlice() 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"`
	Frame      string   `protobuf:"bytes,2,opt,name=Frame,proto3" json:"Frame,omitempty"`
	Slice      uint64   `protobuf:"varint,3,opt,name=Slice,proto3" json:"Slice,omitempty"`
	Field      string   `protobuf:"bytes,4,opt,name=Field,proto3" json:"Field,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) GetFrame added in v0.8.0 

func (m *ImportValueRequest) GetFrame() string

func (*ImportValueRequest) GetIndex added in v0.8.0 

func (m *ImportValueRequest) GetIndex() string

func (*ImportValueRequest) GetSlice added in v0.8.0 

func (m *ImportValueRequest) GetSlice() 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"`
	Frames []*Frame `protobuf:"bytes,4,rep,name=Frames" json:"Frames,omitempty"`
}

func (*Index) Descriptor 

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

func (*Index) GetFrames 

func (m *Index) GetFrames() []*Frame

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 {
}

func (*IndexMeta) Descriptor 

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

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

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

func (*MaxSlices) Descriptor added in v0.9.0 

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

func (*MaxSlices) GetInverse added in v0.9.0 

func (m *MaxSlices) GetInverse() map[string]uint64

func (*MaxSlices) GetStandard added in v0.9.0 

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

func (*MaxSlices) Marshal added in v0.9.0 

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

func (*MaxSlices) MarshalTo added in v0.9.0 

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

func (*MaxSlices) ProtoMessage added in v0.9.0 

func (*MaxSlices) ProtoMessage()

func (*MaxSlices) Reset added in v0.9.0 

func (m *MaxSlices) Reset()

func (*MaxSlices) Size added in v0.9.0 

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

func (*MaxSlices) String added in v0.9.0 

func (m *MaxSlices) String() string

func (*MaxSlices) Unmarshal added in v0.9.0 

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

func (*NodeStatus) Descriptor 

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

func (*NodeStatus) GetMaxSlices added in v0.9.0 

func (m *NodeStatus) GetMaxSlices() *MaxSlices

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"`
	Slices       []uint64 `protobuf:"varint,2,rep,packed,name=Slices" json:"Slices,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"`
	ExcludeAttrs bool     `protobuf:"varint,6,opt,name=ExcludeAttrs,proto3" json:"ExcludeAttrs,omitempty"`
	ExcludeBits  bool     `protobuf:"varint,7,opt,name=ExcludeBits,proto3" json:"ExcludeBits,omitempty"`
}

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) GetColumnAttrs added in v0.8.0 

func (m *QueryRequest) GetColumnAttrs() bool

func (*QueryRequest) GetExcludeAttrs added in v0.8.0 

func (m *QueryRequest) GetExcludeAttrs() bool

func (*QueryRequest) GetExcludeBits added in v0.8.0 

func (m *QueryRequest) GetExcludeBits() 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) GetSlices added in v0.8.0 

func (m *QueryRequest) GetSlices() []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"`
	Bitmap   *Bitmap   `protobuf:"bytes,1,opt,name=Bitmap" json:"Bitmap,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) GetBitmap 

func (m *QueryResult) GetBitmap() *Bitmap

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) 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"`
	Frame string `protobuf:"bytes,3,opt,name=Frame,proto3" json:"Frame,omitempty"`
	View  string `protobuf:"bytes,4,opt,name=View,proto3" json:"View,omitempty"`
	Slice uint64 `protobuf:"varint,5,opt,name=Slice,proto3" json:"Slice,omitempty"`
}

func (*ResizeSource) Descriptor added in v0.9.0 

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

func (*ResizeSource) GetFrame added in v0.9.0 

func (m *ResizeSource) GetFrame() 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) GetSlice added in v0.9.0 

func (m *ResizeSource) GetSlice() 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 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

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.