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

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.