internal

package
v0.3.1 Latest Latest
Warning

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

Go to latest
Published: Apr 30, 2017 License: 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
NodeStatus
ClusterStatus

Package internal is a generated protocol buffer package.

It is generated from these files:

public.proto

It has these top-level messages:

Bitmap
Pair
Bit
ColumnAttrSet
Attr
AttrMap
QueryRequest
QueryResponse
QueryResult
ImportRequest

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

func (*FrameMeta) Descriptor

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

func (*FrameMeta) Marshal

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

func (*FrameMeta) MarshalTo

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

func (*FrameMeta) ProtoMessage

func (*FrameMeta) ProtoMessage()

func (*FrameMeta) Reset

func (m *FrameMeta) Reset()

func (*FrameMeta) Size

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

func (*FrameMeta) String

func (m *FrameMeta) String() string

func (*FrameMeta) Unmarshal

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

type ImportRequest

type ImportRequest struct {
	Index      string   `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Frame      string   `protobuf:"bytes,2,opt,name=Frame,proto3" json:"Frame,omitempty"`
	Slice      uint64   `protobuf:"varint,3,opt,name=Slice,proto3" json:"Slice,omitempty"`
	RowIDs     []uint64 `protobuf:"varint,4,rep,packed,name=RowIDs" json:"RowIDs,omitempty"`
	ColumnIDs  []uint64 `protobuf:"varint,5,rep,packed,name=ColumnIDs" json:"ColumnIDs,omitempty"`
	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 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"`
}

func (*Index) Descriptor

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

func (*Index) GetFrames

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

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 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"`
	Quantum     string   `protobuf:"bytes,4,opt,name=Quantum,proto3" json:"Quantum,omitempty"`
	Remote      bool     `protobuf:"varint,5,opt,name=Remote,proto3" json:"Remote,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"`
	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) 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

Jump to

Keyboard shortcuts

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