internal

package
v0.7.0 Latest Latest
Warning

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

Go to latest
Published: Oct 3, 2017 License: Apache-2.0, Apache-2.0 Imports: 6 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

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

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) 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) 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) 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) 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) 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) 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) 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) 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) 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) 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 (*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) 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) 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) 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) 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 (*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) 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) 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) 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) GetFields added in v0.7.0

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

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) 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) 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    []uint64 `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) 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) GetMeta

func (m *Index) GetMeta() *IndexMeta

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

func (*NodeStatus) Descriptor

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

func (*NodeStatus) GetIndexes

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL