cluster

package
v0.10.1-0...-e076de5 Latest Latest
Warning

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

 Go to latest Published: May 2, 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 

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 

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

func (*CreateIteratorRequest) GetShardIDs 

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

func (*CreateIteratorRequest) ProtoMessage 

func (*CreateIteratorRequest) ProtoMessage()

func (*CreateIteratorRequest) Reset 

func (m *CreateIteratorRequest) Reset()

func (*CreateIteratorRequest) String 

func (m *CreateIteratorRequest) String() string

type CreateIteratorResponse 

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 

func (m *CreateIteratorResponse) GetErr() string

func (*CreateIteratorResponse) GetStats 

func (m *CreateIteratorResponse) GetStats() *IteratorStats

func (*CreateIteratorResponse) GetType 

func (m *CreateIteratorResponse) GetType() int32

func (*CreateIteratorResponse) ProtoMessage 

func (*CreateIteratorResponse) ProtoMessage()

func (*CreateIteratorResponse) Reset 

func (m *CreateIteratorResponse) Reset()

func (*CreateIteratorResponse) String 

func (m *CreateIteratorResponse) String() string

type ExecuteStatementRequest 

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 

func (m *ExecuteStatementRequest) GetDatabase() string

func (*ExecuteStatementRequest) GetStatement 

func (m *ExecuteStatementRequest) GetStatement() string

func (*ExecuteStatementRequest) ProtoMessage 

func (*ExecuteStatementRequest) ProtoMessage()

func (*ExecuteStatementRequest) Reset 

func (m *ExecuteStatementRequest) Reset()

func (*ExecuteStatementRequest) String 

func (m *ExecuteStatementRequest) String() string

type ExecuteStatementResponse 

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 

func (m *ExecuteStatementResponse) GetCode() int32

func (*ExecuteStatementResponse) GetMessage 

func (m *ExecuteStatementResponse) GetMessage() string

func (*ExecuteStatementResponse) ProtoMessage 

func (*ExecuteStatementResponse) ProtoMessage()

func (*ExecuteStatementResponse) Reset 

func (m *ExecuteStatementResponse) Reset()

func (*ExecuteStatementResponse) String 

func (m *ExecuteStatementResponse) String() string

type ExpandSourcesRequest 

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 

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

func (*ExpandSourcesRequest) GetSources 

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

func (*ExpandSourcesRequest) ProtoMessage 

func (*ExpandSourcesRequest) ProtoMessage()

func (*ExpandSourcesRequest) Reset 

func (m *ExpandSourcesRequest) Reset()

func (*ExpandSourcesRequest) String 

func (m *ExpandSourcesRequest) String() string

type ExpandSourcesResponse 

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 

func (m *ExpandSourcesResponse) GetErr() string

func (*ExpandSourcesResponse) GetSources 

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

func (*ExpandSourcesResponse) ProtoMessage 

func (*ExpandSourcesResponse) ProtoMessage()

func (*ExpandSourcesResponse) Reset 

func (m *ExpandSourcesResponse) Reset()

func (*ExpandSourcesResponse) String 

func (m *ExpandSourcesResponse) String() string

type FieldDimensionsRequest 

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 

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

func (*FieldDimensionsRequest) GetSources 

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

func (*FieldDimensionsRequest) ProtoMessage 

func (*FieldDimensionsRequest) ProtoMessage()

func (*FieldDimensionsRequest) Reset 

func (m *FieldDimensionsRequest) Reset()

func (*FieldDimensionsRequest) String 

func (m *FieldDimensionsRequest) String() string

type FieldDimensionsResponse 

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 

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

func (*FieldDimensionsResponse) GetErr 

func (m *FieldDimensionsResponse) GetErr() string

func (*FieldDimensionsResponse) GetFields 

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

func (*FieldDimensionsResponse) ProtoMessage 

func (*FieldDimensionsResponse) ProtoMessage()

func (*FieldDimensionsResponse) Reset 

func (m *FieldDimensionsResponse) Reset()

func (*FieldDimensionsResponse) String 

func (m *FieldDimensionsResponse) String() string

type IteratorStats 

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 

func (m *IteratorStats) GetPointN() int64

func (*IteratorStats) GetSeriesN 

func (m *IteratorStats) GetSeriesN() int64

func (*IteratorStats) ProtoMessage 

func (*IteratorStats) ProtoMessage()

func (*IteratorStats) Reset 

func (m *IteratorStats) Reset()

func (*IteratorStats) String 

func (m *IteratorStats) String() string

type SeriesKeysRequest 

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 

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

func (*SeriesKeysRequest) GetShardIDs 

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

func (*SeriesKeysRequest) ProtoMessage 

func (*SeriesKeysRequest) ProtoMessage()

func (*SeriesKeysRequest) Reset 

func (m *SeriesKeysRequest) Reset()

func (*SeriesKeysRequest) String 

func (m *SeriesKeysRequest) String() string

type SeriesKeysResponse 

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 

func (m *SeriesKeysResponse) GetErr() string

func (*SeriesKeysResponse) GetSeriesList 

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

func (*SeriesKeysResponse) ProtoMessage 

func (*SeriesKeysResponse) ProtoMessage()

func (*SeriesKeysResponse) Reset 

func (m *SeriesKeysResponse) Reset()

func (*SeriesKeysResponse) String 

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 

func (m *WriteShardRequest) GetDatabase() string

func (*WriteShardRequest) GetPoints 

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

func (*WriteShardRequest) GetRetentionPolicy 

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.