internal

package
v0.8.5 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 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
MaxSlicesResponse
CreateSliceMessage
DeleteIndexMessage
CreateIndexMessage
CreateFrameMessage
DeleteFrameMessage
Frame
Index
InputDefinition
InputDefinitionField
InputDefinitionAction
CreateInputDefinitionMessage
DeleteInputDefinitionMessage
NodeStatus
ClusterStatus
FrameSchema
Field
DeleteViewMessage
AttrBlock
AttrBlockRequest

Package internal is a generated protocol buffer package.

It is generated from these files: 

public.proto

It has these top-level messages: 

Bitmap
Pair
SumCount
Bit
ColumnAttrSet
Attr
AttrMap
QueryRequest
QueryResponse
QueryResult
ImportRequest
ImportValueRequest
AttrBlockResponse

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

type AttrBlock struct {
	ID       uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Checksum []byte `protobuf:"bytes,2,opt,name=Checksum,proto3" json:"Checksum,omitempty"`
}

AttrBlock represents a checksummed block of the attribute store.

func (*AttrBlock) Descriptor added in v0.8.4 

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

func (*AttrBlock) GetChecksum added in v0.8.4 

func (m *AttrBlock) GetChecksum() []byte

func (*AttrBlock) GetID added in v0.8.4 

func (m *AttrBlock) GetID() uint64

func (*AttrBlock) Marshal added in v0.8.4 

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

func (*AttrBlock) MarshalTo added in v0.8.4 

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

func (*AttrBlock) ProtoMessage added in v0.8.4 

func (*AttrBlock) ProtoMessage()

func (*AttrBlock) Reset added in v0.8.4 

func (m *AttrBlock) Reset()

func (*AttrBlock) Size added in v0.8.4 

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

func (*AttrBlock) String added in v0.8.4 

func (m *AttrBlock) String() string

func (*AttrBlock) Unmarshal added in v0.8.4 

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

type AttrBlockRequest added in v0.8.4 

type AttrBlockRequest struct {
	Blocks []*AttrBlock `protobuf:"bytes,1,rep,name=Blocks" json:"Blocks,omitempty"`
}

func (*AttrBlockRequest) Descriptor added in v0.8.4 

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

func (*AttrBlockRequest) GetBlocks added in v0.8.4 

func (m *AttrBlockRequest) GetBlocks() []*AttrBlock

func (*AttrBlockRequest) Marshal added in v0.8.4 

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

func (*AttrBlockRequest) MarshalTo added in v0.8.4 

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

func (*AttrBlockRequest) ProtoMessage added in v0.8.4 

func (*AttrBlockRequest) ProtoMessage()

func (*AttrBlockRequest) Reset added in v0.8.4 

func (m *AttrBlockRequest) Reset()

func (*AttrBlockRequest) Size added in v0.8.4 

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

func (*AttrBlockRequest) String added in v0.8.4 

func (m *AttrBlockRequest) String() string

func (*AttrBlockRequest) Unmarshal added in v0.8.4 

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

type AttrBlockResponse added in v0.8.4 

type AttrBlockResponse struct {
	Attrs map[uint64]*AttrMap `` /* 138-byte string literal not displayed */
}

func (*AttrBlockResponse) Descriptor added in v0.8.4 

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

func (*AttrBlockResponse) GetAttrs added in v0.8.4 

func (m *AttrBlockResponse) GetAttrs() map[uint64]*AttrMap

func (*AttrBlockResponse) Marshal added in v0.8.4 

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

func (*AttrBlockResponse) MarshalTo added in v0.8.4 

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

func (*AttrBlockResponse) ProtoMessage added in v0.8.4 

func (*AttrBlockResponse) ProtoMessage()

func (*AttrBlockResponse) Reset added in v0.8.4 

func (m *AttrBlockResponse) Reset()

func (*AttrBlockResponse) Size added in v0.8.4 

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

func (*AttrBlockResponse) String added in v0.8.4 

func (m *AttrBlockResponse) String() string

func (*AttrBlockResponse) Unmarshal added in v0.8.4 

func (m *AttrBlockResponse) 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"`
	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) 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 {
	Nodes []*NodeStatus `protobuf:"bytes,1,rep,name=Nodes" json:"Nodes,omitempty"`
}

func (*ClusterStatus) Descriptor 

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

func (*ClusterStatus) GetNodes 

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

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"`
	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) 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 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 CreateInputDefinitionMessage added in v0.5.0 

type CreateInputDefinitionMessage struct {
	Index      string           `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Definition *InputDefinition `protobuf:"bytes,3,opt,name=Definition" json:"Definition,omitempty"`
}

func (*CreateInputDefinitionMessage) Descriptor added in v0.5.0 

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

func (*CreateInputDefinitionMessage) GetDefinition added in v0.5.0 

func (m *CreateInputDefinitionMessage) GetDefinition() *InputDefinition

func (*CreateInputDefinitionMessage) GetIndex added in v0.8.0 

func (m *CreateInputDefinitionMessage) GetIndex() string

func (*CreateInputDefinitionMessage) Marshal added in v0.5.0 

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

func (*CreateInputDefinitionMessage) MarshalTo added in v0.5.0 

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

func (*CreateInputDefinitionMessage) ProtoMessage added in v0.5.0 

func (*CreateInputDefinitionMessage) ProtoMessage()

func (*CreateInputDefinitionMessage) Reset added in v0.5.0 

func (m *CreateInputDefinitionMessage) Reset()

func (*CreateInputDefinitionMessage) Size added in v0.5.0 

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

func (*CreateInputDefinitionMessage) String added in v0.5.0 

func (m *CreateInputDefinitionMessage) String() string

func (*CreateInputDefinitionMessage) Unmarshal added in v0.5.0 

func (m *CreateInputDefinitionMessage) 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 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 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 DeleteInputDefinitionMessage added in v0.5.0 

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

func (*DeleteInputDefinitionMessage) Descriptor added in v0.5.0 

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

func (*DeleteInputDefinitionMessage) GetIndex added in v0.8.0 

func (m *DeleteInputDefinitionMessage) GetIndex() string

func (*DeleteInputDefinitionMessage) GetName added in v0.8.0 

func (m *DeleteInputDefinitionMessage) GetName() string

func (*DeleteInputDefinitionMessage) Marshal added in v0.5.0 

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

func (*DeleteInputDefinitionMessage) MarshalTo added in v0.5.0 

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

func (*DeleteInputDefinitionMessage) ProtoMessage added in v0.5.0 

func (*DeleteInputDefinitionMessage) ProtoMessage()

func (*DeleteInputDefinitionMessage) Reset added in v0.5.0 

func (m *DeleteInputDefinitionMessage) Reset()

func (*DeleteInputDefinitionMessage) Size added in v0.5.0 

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

func (*DeleteInputDefinitionMessage) String added in v0.5.0 

func (m *DeleteInputDefinitionMessage) String() string

func (*DeleteInputDefinitionMessage) Unmarshal added in v0.5.0 

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

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) 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 {
	RowLabel       string   `protobuf:"bytes,1,opt,name=RowLabel,proto3" json:"RowLabel,omitempty"`
	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) GetRowLabel added in v0.8.0 

func (m *FrameMeta) GetRowLabel() string

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

type FrameSchema struct {
	Fields []*Field `protobuf:"bytes,1,rep,name=Fields" json:"Fields,omitempty"`
}

func (*FrameSchema) Descriptor added in v0.5.0 

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

func (*FrameSchema) GetFields added in v0.5.0 

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

func (*FrameSchema) Marshal added in v0.5.0 

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

func (*FrameSchema) MarshalTo added in v0.5.0 

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

func (*FrameSchema) ProtoMessage added in v0.5.0 

func (*FrameSchema) ProtoMessage()

func (*FrameSchema) Reset added in v0.5.0 

func (m *FrameSchema) Reset()

func (*FrameSchema) Size added in v0.5.0 

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

func (*FrameSchema) String added in v0.5.0 

func (m *FrameSchema) String() string

func (*FrameSchema) Unmarshal added in v0.5.0 

func (m *FrameSchema) 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"`
	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) 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) 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"`
	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) 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"`
	Meta             *IndexMeta         `protobuf:"bytes,2,opt,name=Meta" json:"Meta,omitempty"`
	MaxSlice         uint64             `protobuf:"varint,3,opt,name=MaxSlice,proto3" json:"MaxSlice,omitempty"`
	Frames           []*Frame           `protobuf:"bytes,4,rep,name=Frames" json:"Frames,omitempty"`
	Slices           []uint64           `protobuf:"varint,5,rep,packed,name=Slices" json:"Slices,omitempty"`
	InputDefinitions []*InputDefinition `protobuf:"bytes,6,rep,name=InputDefinitions" json:"InputDefinitions,omitempty"`
}

func (*Index) Descriptor 

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

func (*Index) GetFrames 

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

func (*Index) GetInputDefinitions added in v0.5.0 

func (m *Index) GetInputDefinitions() []*InputDefinition

func (*Index) GetMaxSlice added in v0.8.0 

func (m *Index) GetMaxSlice() uint64

func (*Index) GetMeta 

func (m *Index) GetMeta() *IndexMeta

func (*Index) GetName added in v0.8.0 

func (m *Index) GetName() string

func (*Index) GetSlices added in v0.8.0 

func (m *Index) GetSlices() []uint64

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 {
	ColumnLabel string `protobuf:"bytes,1,opt,name=ColumnLabel,proto3" json:"ColumnLabel,omitempty"`
	TimeQuantum string `protobuf:"bytes,2,opt,name=TimeQuantum,proto3" json:"TimeQuantum,omitempty"`
}

func (*IndexMeta) Descriptor 

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

func (*IndexMeta) GetColumnLabel added in v0.8.0 

func (m *IndexMeta) GetColumnLabel() string

func (*IndexMeta) GetTimeQuantum added in v0.8.0 

func (m *IndexMeta) GetTimeQuantum() string

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

type InputDefinition struct {
	Name   string                  `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Frames []*Frame                `protobuf:"bytes,2,rep,name=Frames" json:"Frames,omitempty"`
	Fields []*InputDefinitionField `protobuf:"bytes,3,rep,name=Fields" json:"Fields,omitempty"`
}

func (*InputDefinition) Descriptor added in v0.5.0 

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

func (*InputDefinition) GetFields added in v0.5.0 

func (m *InputDefinition) GetFields() []*InputDefinitionField

func (*InputDefinition) GetFrames added in v0.5.0 

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

func (*InputDefinition) GetName added in v0.8.0 

func (m *InputDefinition) GetName() string

func (*InputDefinition) Marshal added in v0.5.0 

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

func (*InputDefinition) MarshalTo added in v0.5.0 

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

func (*InputDefinition) ProtoMessage added in v0.5.0 

func (*InputDefinition) ProtoMessage()

func (*InputDefinition) Reset added in v0.5.0 

func (m *InputDefinition) Reset()

func (*InputDefinition) Size added in v0.5.0 

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

func (*InputDefinition) String added in v0.5.0 

func (m *InputDefinition) String() string

func (*InputDefinition) Unmarshal added in v0.5.0 

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

type InputDefinitionAction added in v0.5.0 

type InputDefinitionAction struct {
	Frame            string            `protobuf:"bytes,1,opt,name=Frame,proto3" json:"Frame,omitempty"`
	ValueDestination string            `protobuf:"bytes,2,opt,name=ValueDestination,proto3" json:"ValueDestination,omitempty"`
	ValueMap         map[string]uint64 `` /* 151-byte string literal not displayed */
	RowID            uint64            `protobuf:"varint,4,opt,name=RowID,proto3" json:"RowID,omitempty"`
}

func (*InputDefinitionAction) Descriptor added in v0.5.0 

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

func (*InputDefinitionAction) GetFrame added in v0.8.0 

func (m *InputDefinitionAction) GetFrame() string

func (*InputDefinitionAction) GetRowID added in v0.8.0 

func (m *InputDefinitionAction) GetRowID() uint64

func (*InputDefinitionAction) GetValueDestination added in v0.8.0 

func (m *InputDefinitionAction) GetValueDestination() string

func (*InputDefinitionAction) GetValueMap added in v0.5.0 

func (m *InputDefinitionAction) GetValueMap() map[string]uint64

func (*InputDefinitionAction) Marshal added in v0.5.0 

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

func (*InputDefinitionAction) MarshalTo added in v0.5.0 

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

func (*InputDefinitionAction) ProtoMessage added in v0.5.0 

func (*InputDefinitionAction) ProtoMessage()

func (*InputDefinitionAction) Reset added in v0.5.0 

func (m *InputDefinitionAction) Reset()

func (*InputDefinitionAction) Size added in v0.5.0 

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

func (*InputDefinitionAction) String added in v0.5.0 

func (m *InputDefinitionAction) String() string

func (*InputDefinitionAction) Unmarshal added in v0.5.0 

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

type InputDefinitionField added in v0.5.0 

type InputDefinitionField struct {
	Name                   string                   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	PrimaryKey             bool                     `protobuf:"varint,2,opt,name=PrimaryKey,proto3" json:"PrimaryKey,omitempty"`
	InputDefinitionActions []*InputDefinitionAction `protobuf:"bytes,3,rep,name=InputDefinitionActions" json:"InputDefinitionActions,omitempty"`
}

func (*InputDefinitionField) Descriptor added in v0.5.0 

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

func (*InputDefinitionField) GetInputDefinitionActions added in v0.5.0 

func (m *InputDefinitionField) GetInputDefinitionActions() []*InputDefinitionAction

func (*InputDefinitionField) GetName added in v0.8.0 

func (m *InputDefinitionField) GetName() string

func (*InputDefinitionField) GetPrimaryKey added in v0.8.0 

func (m *InputDefinitionField) GetPrimaryKey() bool

func (*InputDefinitionField) Marshal added in v0.5.0 

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

func (*InputDefinitionField) MarshalTo added in v0.5.0 

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

func (*InputDefinitionField) ProtoMessage added in v0.5.0 

func (*InputDefinitionField) ProtoMessage()

func (*InputDefinitionField) Reset added in v0.5.0 

func (m *InputDefinitionField) Reset()

func (*InputDefinitionField) Size added in v0.5.0 

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

func (*InputDefinitionField) String added in v0.5.0 

func (m *InputDefinitionField) String() string

func (*InputDefinitionField) Unmarshal added in v0.5.0 

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

type MaxSlicesResponse 

type MaxSlicesResponse struct {
	MaxSlices map[string]uint64 `` /* 153-byte string literal not displayed */
}

func (*MaxSlicesResponse) Descriptor 

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

func (*MaxSlicesResponse) GetMaxSlices 

func (m *MaxSlicesResponse) GetMaxSlices() map[string]uint64

func (*MaxSlicesResponse) Marshal 

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

func (*MaxSlicesResponse) MarshalTo 

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

func (*MaxSlicesResponse) ProtoMessage 

func (*MaxSlicesResponse) ProtoMessage()

func (*MaxSlicesResponse) Reset 

func (m *MaxSlicesResponse) Reset()

func (*MaxSlicesResponse) Size 

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

func (*MaxSlicesResponse) String 

func (m *MaxSlicesResponse) String() string

func (*MaxSlicesResponse) Unmarshal 

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

type NodeStatus 

type NodeStatus struct {
	Host    string   `protobuf:"bytes,1,opt,name=Host,proto3" json:"Host,omitempty"`
	State   string   `protobuf:"bytes,2,opt,name=State,proto3" json:"State,omitempty"`
	Indexes []*Index `protobuf:"bytes,3,rep,name=Indexes" json:"Indexes,omitempty"`
	Scheme  string   `protobuf:"bytes,4,opt,name=Scheme,proto3" json:"Scheme,omitempty"`
}

func (*NodeStatus) Descriptor 

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

func (*NodeStatus) GetHost added in v0.8.0 

func (m *NodeStatus) GetHost() string

func (*NodeStatus) GetIndexes 

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

func (*NodeStatus) GetScheme added in v0.8.0 

func (m *NodeStatus) GetScheme() string

func (*NodeStatus) GetState added in v0.8.0 

func (m *NodeStatus) GetState() string

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 {
	Key   uint64 `protobuf:"varint,1,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) GetKey added in v0.8.0 

func (m *Pair) GetKey() uint64

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 {
	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"`
	SumCount *SumCount `protobuf:"bytes,5,opt,name=SumCount" json:"SumCount,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) GetSumCount added in v0.7.0 

func (m *QueryResult) GetSumCount() *SumCount

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 Request 

type Request proto.Message

type Response 

type Response proto.Message

type SumCount added in v0.7.0 

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

func (*SumCount) Descriptor added in v0.7.0 

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

func (*SumCount) GetCount added in v0.8.0 

func (m *SumCount) GetCount() int64

func (*SumCount) GetSum added in v0.8.0 

func (m *SumCount) GetSum() int64

func (*SumCount) Marshal added in v0.7.0 

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

func (*SumCount) MarshalTo added in v0.7.0 

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

func (*SumCount) ProtoMessage added in v0.7.0 

func (*SumCount) ProtoMessage()

func (*SumCount) Reset added in v0.7.0 

func (m *SumCount) Reset()

func (*SumCount) Size added in v0.7.0 

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

func (*SumCount) String added in v0.7.0 

func (m *SumCount) String() string

func (*SumCount) Unmarshal added in v0.7.0 

func (m *SumCount) 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.