cluster

package
v0.13.0 Latest Latest
Warning

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

Go to latest
Published: May 11, 2016 License: MIT Imports: 3 Imported by: 0

Documentation

Overview

Package cluster is a generated protocol buffer package.

It is generated from these files:

internal/data.proto

It has these top-level messages:

WriteShardRequest
WriteShardResponse
ExecuteStatementRequest
ExecuteStatementResponse
CreateIteratorRequest
CreateIteratorResponse
IteratorStats
FieldDimensionsRequest
FieldDimensionsResponse
SeriesKeysRequest
SeriesKeysResponse
ExpandSourcesRequest
ExpandSourcesResponse

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateIteratorRequest added in v0.11.0

type CreateIteratorRequest struct {
	ShardIDs         []uint64 `protobuf:"varint,1,rep,name=ShardIDs" json:"ShardIDs,omitempty"`
	Opt              []byte   `protobuf:"bytes,2,req,name=Opt" json:"Opt,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*CreateIteratorRequest) GetOpt added in v0.11.0

func (m *CreateIteratorRequest) GetOpt() []byte

func (*CreateIteratorRequest) GetShardIDs added in v0.11.0

func (m *CreateIteratorRequest) GetShardIDs() []uint64

func (*CreateIteratorRequest) ProtoMessage added in v0.11.0

func (*CreateIteratorRequest) ProtoMessage()

func (*CreateIteratorRequest) Reset added in v0.11.0

func (m *CreateIteratorRequest) Reset()

func (*CreateIteratorRequest) String added in v0.11.0

func (m *CreateIteratorRequest) String() string

type CreateIteratorResponse added in v0.11.0

type CreateIteratorResponse struct {
	Err              *string        `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	Type             *int32         `protobuf:"varint,2,req,name=Type" json:"Type,omitempty"`
	Stats            *IteratorStats `protobuf:"bytes,3,opt,name=Stats" json:"Stats,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*CreateIteratorResponse) GetErr added in v0.11.0

func (m *CreateIteratorResponse) GetErr() string

func (*CreateIteratorResponse) GetStats added in v0.13.0

func (m *CreateIteratorResponse) GetStats() *IteratorStats

func (*CreateIteratorResponse) GetType added in v0.13.0

func (m *CreateIteratorResponse) GetType() int32

func (*CreateIteratorResponse) ProtoMessage added in v0.11.0

func (*CreateIteratorResponse) ProtoMessage()

func (*CreateIteratorResponse) Reset added in v0.11.0

func (m *CreateIteratorResponse) Reset()

func (*CreateIteratorResponse) String added in v0.11.0

func (m *CreateIteratorResponse) String() string

type ExecuteStatementRequest added in v0.11.0

type ExecuteStatementRequest struct {
	Statement        *string `protobuf:"bytes,1,req,name=Statement" json:"Statement,omitempty"`
	Database         *string `protobuf:"bytes,2,req,name=Database" json:"Database,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ExecuteStatementRequest) GetDatabase added in v0.11.0

func (m *ExecuteStatementRequest) GetDatabase() string

func (*ExecuteStatementRequest) GetStatement added in v0.11.0

func (m *ExecuteStatementRequest) GetStatement() string

func (*ExecuteStatementRequest) ProtoMessage added in v0.11.0

func (*ExecuteStatementRequest) ProtoMessage()

func (*ExecuteStatementRequest) Reset added in v0.11.0

func (m *ExecuteStatementRequest) Reset()

func (*ExecuteStatementRequest) String added in v0.11.0

func (m *ExecuteStatementRequest) String() string

type ExecuteStatementResponse added in v0.11.0

type ExecuteStatementResponse struct {
	Code             *int32  `protobuf:"varint,1,req,name=Code" json:"Code,omitempty"`
	Message          *string `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ExecuteStatementResponse) GetCode added in v0.11.0

func (m *ExecuteStatementResponse) GetCode() int32

func (*ExecuteStatementResponse) GetMessage added in v0.11.0

func (m *ExecuteStatementResponse) GetMessage() string

func (*ExecuteStatementResponse) ProtoMessage added in v0.11.0

func (*ExecuteStatementResponse) ProtoMessage()

func (*ExecuteStatementResponse) Reset added in v0.11.0

func (m *ExecuteStatementResponse) Reset()

func (*ExecuteStatementResponse) String added in v0.11.0

func (m *ExecuteStatementResponse) String() string

type ExpandSourcesRequest added in v0.12.0

type ExpandSourcesRequest struct {
	ShardIDs         []uint64 `protobuf:"varint,1,rep,name=ShardIDs" json:"ShardIDs,omitempty"`
	Sources          []byte   `protobuf:"bytes,2,req,name=Sources" json:"Sources,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ExpandSourcesRequest) GetShardIDs added in v0.12.0

func (m *ExpandSourcesRequest) GetShardIDs() []uint64

func (*ExpandSourcesRequest) GetSources added in v0.12.0

func (m *ExpandSourcesRequest) GetSources() []byte

func (*ExpandSourcesRequest) ProtoMessage added in v0.12.0

func (*ExpandSourcesRequest) ProtoMessage()

func (*ExpandSourcesRequest) Reset added in v0.12.0

func (m *ExpandSourcesRequest) Reset()

func (*ExpandSourcesRequest) String added in v0.12.0

func (m *ExpandSourcesRequest) String() string

type ExpandSourcesResponse added in v0.12.0

type ExpandSourcesResponse struct {
	Sources          []byte  `protobuf:"bytes,1,req,name=Sources" json:"Sources,omitempty"`
	Err              *string `protobuf:"bytes,2,opt,name=Err" json:"Err,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ExpandSourcesResponse) GetErr added in v0.12.0

func (m *ExpandSourcesResponse) GetErr() string

func (*ExpandSourcesResponse) GetSources added in v0.12.0

func (m *ExpandSourcesResponse) GetSources() []byte

func (*ExpandSourcesResponse) ProtoMessage added in v0.12.0

func (*ExpandSourcesResponse) ProtoMessage()

func (*ExpandSourcesResponse) Reset added in v0.12.0

func (m *ExpandSourcesResponse) Reset()

func (*ExpandSourcesResponse) String added in v0.12.0

func (m *ExpandSourcesResponse) String() string

type FieldDimensionsRequest added in v0.11.0

type FieldDimensionsRequest struct {
	ShardIDs         []uint64 `protobuf:"varint,1,rep,name=ShardIDs" json:"ShardIDs,omitempty"`
	Sources          []byte   `protobuf:"bytes,2,req,name=Sources" json:"Sources,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*FieldDimensionsRequest) GetShardIDs added in v0.11.0

func (m *FieldDimensionsRequest) GetShardIDs() []uint64

func (*FieldDimensionsRequest) GetSources added in v0.11.0

func (m *FieldDimensionsRequest) GetSources() []byte

func (*FieldDimensionsRequest) ProtoMessage added in v0.11.0

func (*FieldDimensionsRequest) ProtoMessage()

func (*FieldDimensionsRequest) Reset added in v0.11.0

func (m *FieldDimensionsRequest) Reset()

func (*FieldDimensionsRequest) String added in v0.11.0

func (m *FieldDimensionsRequest) String() string

type FieldDimensionsResponse added in v0.11.0

type FieldDimensionsResponse struct {
	Fields           []string `protobuf:"bytes,1,rep,name=Fields" json:"Fields,omitempty"`
	Dimensions       []string `protobuf:"bytes,2,rep,name=Dimensions" json:"Dimensions,omitempty"`
	Err              *string  `protobuf:"bytes,3,opt,name=Err" json:"Err,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*FieldDimensionsResponse) GetDimensions added in v0.11.0

func (m *FieldDimensionsResponse) GetDimensions() []string

func (*FieldDimensionsResponse) GetErr added in v0.11.0

func (m *FieldDimensionsResponse) GetErr() string

func (*FieldDimensionsResponse) GetFields added in v0.11.0

func (m *FieldDimensionsResponse) GetFields() []string

func (*FieldDimensionsResponse) ProtoMessage added in v0.11.0

func (*FieldDimensionsResponse) ProtoMessage()

func (*FieldDimensionsResponse) Reset added in v0.11.0

func (m *FieldDimensionsResponse) Reset()

func (*FieldDimensionsResponse) String added in v0.11.0

func (m *FieldDimensionsResponse) String() string

type IteratorStats added in v0.13.0

type IteratorStats struct {
	SeriesN          *int64 `protobuf:"varint,1,opt,name=SeriesN" json:"SeriesN,omitempty"`
	PointN           *int64 `protobuf:"varint,2,opt,name=PointN" json:"PointN,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*IteratorStats) GetPointN added in v0.13.0

func (m *IteratorStats) GetPointN() int64

func (*IteratorStats) GetSeriesN added in v0.13.0

func (m *IteratorStats) GetSeriesN() int64

func (*IteratorStats) ProtoMessage added in v0.13.0

func (*IteratorStats) ProtoMessage()

func (*IteratorStats) Reset added in v0.13.0

func (m *IteratorStats) Reset()

func (*IteratorStats) String added in v0.13.0

func (m *IteratorStats) String() string

type SeriesKeysRequest added in v0.11.0

type SeriesKeysRequest struct {
	ShardIDs         []uint64 `protobuf:"varint,1,rep,name=ShardIDs" json:"ShardIDs,omitempty"`
	Opt              []byte   `protobuf:"bytes,2,req,name=Opt" json:"Opt,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*SeriesKeysRequest) GetOpt added in v0.11.0

func (m *SeriesKeysRequest) GetOpt() []byte

func (*SeriesKeysRequest) GetShardIDs added in v0.11.0

func (m *SeriesKeysRequest) GetShardIDs() []uint64

func (*SeriesKeysRequest) ProtoMessage added in v0.11.0

func (*SeriesKeysRequest) ProtoMessage()

func (*SeriesKeysRequest) Reset added in v0.11.0

func (m *SeriesKeysRequest) Reset()

func (*SeriesKeysRequest) String added in v0.11.0

func (m *SeriesKeysRequest) String() string

type SeriesKeysResponse added in v0.11.0

type SeriesKeysResponse struct {
	SeriesList       []byte  `protobuf:"bytes,1,opt,name=SeriesList" json:"SeriesList,omitempty"`
	Err              *string `protobuf:"bytes,2,opt,name=Err" json:"Err,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SeriesKeysResponse) GetErr added in v0.11.0

func (m *SeriesKeysResponse) GetErr() string

func (*SeriesKeysResponse) GetSeriesList added in v0.11.0

func (m *SeriesKeysResponse) GetSeriesList() []byte

func (*SeriesKeysResponse) ProtoMessage added in v0.11.0

func (*SeriesKeysResponse) ProtoMessage()

func (*SeriesKeysResponse) Reset added in v0.11.0

func (m *SeriesKeysResponse) Reset()

func (*SeriesKeysResponse) String added in v0.11.0

func (m *SeriesKeysResponse) String() string

type WriteShardRequest

type WriteShardRequest struct {
	ShardID          *uint64  `protobuf:"varint,1,req,name=ShardID" json:"ShardID,omitempty"`
	Points           [][]byte `protobuf:"bytes,2,rep,name=Points" json:"Points,omitempty"`
	Database         *string  `protobuf:"bytes,3,opt,name=Database" json:"Database,omitempty"`
	RetentionPolicy  *string  `protobuf:"bytes,4,opt,name=RetentionPolicy" json:"RetentionPolicy,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*WriteShardRequest) GetDatabase added in v0.11.0

func (m *WriteShardRequest) GetDatabase() string

func (*WriteShardRequest) GetPoints

func (m *WriteShardRequest) GetPoints() [][]byte

func (*WriteShardRequest) GetRetentionPolicy added in v0.11.0

func (m *WriteShardRequest) GetRetentionPolicy() string

func (*WriteShardRequest) GetShardID

func (m *WriteShardRequest) GetShardID() uint64

func (*WriteShardRequest) ProtoMessage

func (*WriteShardRequest) ProtoMessage()

func (*WriteShardRequest) Reset

func (m *WriteShardRequest) Reset()

func (*WriteShardRequest) String

func (m *WriteShardRequest) String() string

type WriteShardResponse

type WriteShardResponse struct {
	Code             *int32  `protobuf:"varint,1,req,name=Code" json:"Code,omitempty"`
	Message          *string `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*WriteShardResponse) GetCode

func (m *WriteShardResponse) GetCode() int32

func (*WriteShardResponse) GetMessage

func (m *WriteShardResponse) GetMessage() string

func (*WriteShardResponse) ProtoMessage

func (*WriteShardResponse) ProtoMessage()

func (*WriteShardResponse) Reset

func (m *WriteShardResponse) Reset()

func (*WriteShardResponse) String

func (m *WriteShardResponse) String() string

Jump to

Keyboard shortcuts

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