riak_ts

package
v1.7.0 Latest Latest
Warning

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

Go to latest
Published: Jun 15, 2016 License: Apache-2.0 Imports: 4 Imported by: 6

Documentation

Overview

Package riak_ts is a generated protocol buffer package.

It is generated from these files:

riak_ts.proto

It has these top-level messages:

TsQueryReq
TsQueryResp
TsGetReq
TsGetResp
TsPutReq
TsPutResp
TsDelReq
TsDelResp
TsInterpolation
TsColumnDescription
TsRow
TsCell
TsListKeysReq
TsListKeysResp
TsCoverageReq
TsCoverageResp
TsCoverageEntry
TsRange

Index

Constants

View Source
const Default_TsQueryReq_Stream bool = false
View Source
const Default_TsQueryResp_Done bool = true

Variables

View Source
var TsColumnType_name = map[int32]string{
	0: "VARCHAR",
	1: "SINT64",
	2: "DOUBLE",
	3: "TIMESTAMP",
	4: "BOOLEAN",
}
View Source
var TsColumnType_value = map[string]int32{
	"VARCHAR":   0,
	"SINT64":    1,
	"DOUBLE":    2,
	"TIMESTAMP": 3,
	"BOOLEAN":   4,
}

Functions

This section is empty.

Types

type TsCell

type TsCell struct {
	VarcharValue     []byte   `protobuf:"bytes,1,opt,name=varchar_value" json:"varchar_value,omitempty"`
	Sint64Value      *int64   `protobuf:"zigzag64,2,opt,name=sint64_value" json:"sint64_value,omitempty"`
	TimestampValue   *int64   `protobuf:"zigzag64,3,opt,name=timestamp_value" json:"timestamp_value,omitempty"`
	BooleanValue     *bool    `protobuf:"varint,4,opt,name=boolean_value" json:"boolean_value,omitempty"`
	DoubleValue      *float64 `protobuf:"fixed64,5,opt,name=double_value" json:"double_value,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*TsCell) Descriptor

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

func (*TsCell) GetBooleanValue

func (m *TsCell) GetBooleanValue() bool

func (*TsCell) GetDoubleValue

func (m *TsCell) GetDoubleValue() float64

func (*TsCell) GetSint64Value

func (m *TsCell) GetSint64Value() int64

func (*TsCell) GetTimestampValue

func (m *TsCell) GetTimestampValue() int64

func (*TsCell) GetVarcharValue

func (m *TsCell) GetVarcharValue() []byte

func (*TsCell) ProtoMessage

func (*TsCell) ProtoMessage()

func (*TsCell) Reset

func (m *TsCell) Reset()

func (*TsCell) String

func (m *TsCell) String() string

type TsColumnDescription

type TsColumnDescription struct {
	Name             []byte        `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Type             *TsColumnType `protobuf:"varint,2,req,name=type,enum=TsColumnType" json:"type,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*TsColumnDescription) Descriptor

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

func (*TsColumnDescription) GetName

func (m *TsColumnDescription) GetName() []byte

func (*TsColumnDescription) GetType

func (m *TsColumnDescription) GetType() TsColumnType

func (*TsColumnDescription) ProtoMessage

func (*TsColumnDescription) ProtoMessage()

func (*TsColumnDescription) Reset

func (m *TsColumnDescription) Reset()

func (*TsColumnDescription) String

func (m *TsColumnDescription) String() string

type TsColumnType

type TsColumnType int32
const (
	TsColumnType_VARCHAR   TsColumnType = 0
	TsColumnType_SINT64    TsColumnType = 1
	TsColumnType_DOUBLE    TsColumnType = 2
	TsColumnType_TIMESTAMP TsColumnType = 3
	TsColumnType_BOOLEAN   TsColumnType = 4
)

func (TsColumnType) Enum

func (x TsColumnType) Enum() *TsColumnType

func (TsColumnType) EnumDescriptor

func (TsColumnType) EnumDescriptor() ([]byte, []int)

func (TsColumnType) String

func (x TsColumnType) String() string

func (*TsColumnType) UnmarshalJSON

func (x *TsColumnType) UnmarshalJSON(data []byte) error

type TsCoverageEntry

type TsCoverageEntry struct {
	Ip               []byte   `protobuf:"bytes,1,req,name=ip" json:"ip,omitempty"`
	Port             *uint32  `protobuf:"varint,2,req,name=port" json:"port,omitempty"`
	CoverContext     []byte   `protobuf:"bytes,3,req,name=cover_context" json:"cover_context,omitempty"`
	Range            *TsRange `protobuf:"bytes,4,opt,name=range" json:"range,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

Segment of a TS coverage plan

func (*TsCoverageEntry) Descriptor

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

func (*TsCoverageEntry) GetCoverContext

func (m *TsCoverageEntry) GetCoverContext() []byte

func (*TsCoverageEntry) GetIp

func (m *TsCoverageEntry) GetIp() []byte

func (*TsCoverageEntry) GetPort

func (m *TsCoverageEntry) GetPort() uint32

func (*TsCoverageEntry) GetRange

func (m *TsCoverageEntry) GetRange() *TsRange

func (*TsCoverageEntry) ProtoMessage

func (*TsCoverageEntry) ProtoMessage()

func (*TsCoverageEntry) Reset

func (m *TsCoverageEntry) Reset()

func (*TsCoverageEntry) String

func (m *TsCoverageEntry) String() string

type TsCoverageReq

type TsCoverageReq struct {
	// left optional to support parameterized queries in the future
	Query            *TsInterpolation `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	Table            []byte           `protobuf:"bytes,2,req,name=table" json:"table,omitempty"`
	ReplaceCover     []byte           `protobuf:"bytes,3,opt,name=replace_cover" json:"replace_cover,omitempty"`
	UnavailableCover [][]byte         `protobuf:"bytes,4,rep,name=unavailable_cover" json:"unavailable_cover,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

Request a segmented coverage plan for this query

func (*TsCoverageReq) Descriptor

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

func (*TsCoverageReq) GetQuery

func (m *TsCoverageReq) GetQuery() *TsInterpolation

func (*TsCoverageReq) GetReplaceCover

func (m *TsCoverageReq) GetReplaceCover() []byte

func (*TsCoverageReq) GetTable

func (m *TsCoverageReq) GetTable() []byte

func (*TsCoverageReq) GetUnavailableCover

func (m *TsCoverageReq) GetUnavailableCover() [][]byte

func (*TsCoverageReq) ProtoMessage

func (*TsCoverageReq) ProtoMessage()

func (*TsCoverageReq) Reset

func (m *TsCoverageReq) Reset()

func (*TsCoverageReq) String

func (m *TsCoverageReq) String() string

type TsCoverageResp

type TsCoverageResp struct {
	Entries          []*TsCoverageEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

Segmented TS coverage plan response

func (*TsCoverageResp) Descriptor

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

func (*TsCoverageResp) GetEntries

func (m *TsCoverageResp) GetEntries() []*TsCoverageEntry

func (*TsCoverageResp) ProtoMessage

func (*TsCoverageResp) ProtoMessage()

func (*TsCoverageResp) Reset

func (m *TsCoverageResp) Reset()

func (*TsCoverageResp) String

func (m *TsCoverageResp) String() string

type TsDelReq

type TsDelReq struct {
	Table            []byte    `protobuf:"bytes,1,req,name=table" json:"table,omitempty"`
	Key              []*TsCell `protobuf:"bytes,2,rep,name=key" json:"key,omitempty"`
	Vclock           []byte    `protobuf:"bytes,3,opt,name=vclock" json:"vclock,omitempty"`
	Timeout          *uint32   `protobuf:"varint,4,opt,name=timeout" json:"timeout,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*TsDelReq) Descriptor

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

func (*TsDelReq) GetKey

func (m *TsDelReq) GetKey() []*TsCell

func (*TsDelReq) GetTable

func (m *TsDelReq) GetTable() []byte

func (*TsDelReq) GetTimeout

func (m *TsDelReq) GetTimeout() uint32

func (*TsDelReq) GetVclock

func (m *TsDelReq) GetVclock() []byte

func (*TsDelReq) ProtoMessage

func (*TsDelReq) ProtoMessage()

func (*TsDelReq) Reset

func (m *TsDelReq) Reset()

func (*TsDelReq) String

func (m *TsDelReq) String() string

type TsDelResp

type TsDelResp struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*TsDelResp) Descriptor

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

func (*TsDelResp) ProtoMessage

func (*TsDelResp) ProtoMessage()

func (*TsDelResp) Reset

func (m *TsDelResp) Reset()

func (*TsDelResp) String

func (m *TsDelResp) String() string

type TsGetReq

type TsGetReq struct {
	Table            []byte    `protobuf:"bytes,1,req,name=table" json:"table,omitempty"`
	Key              []*TsCell `protobuf:"bytes,2,rep,name=key" json:"key,omitempty"`
	Timeout          *uint32   `protobuf:"varint,3,opt,name=timeout" json:"timeout,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*TsGetReq) Descriptor

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

func (*TsGetReq) GetKey

func (m *TsGetReq) GetKey() []*TsCell

func (*TsGetReq) GetTable

func (m *TsGetReq) GetTable() []byte

func (*TsGetReq) GetTimeout

func (m *TsGetReq) GetTimeout() uint32

func (*TsGetReq) ProtoMessage

func (*TsGetReq) ProtoMessage()

func (*TsGetReq) Reset

func (m *TsGetReq) Reset()

func (*TsGetReq) String

func (m *TsGetReq) String() string

type TsGetResp

type TsGetResp struct {
	Columns          []*TsColumnDescription `protobuf:"bytes,1,rep,name=columns" json:"columns,omitempty"`
	Rows             []*TsRow               `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*TsGetResp) Descriptor

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

func (*TsGetResp) GetColumns

func (m *TsGetResp) GetColumns() []*TsColumnDescription

func (*TsGetResp) GetRows

func (m *TsGetResp) GetRows() []*TsRow

func (*TsGetResp) ProtoMessage

func (*TsGetResp) ProtoMessage()

func (*TsGetResp) Reset

func (m *TsGetResp) Reset()

func (*TsGetResp) String

func (m *TsGetResp) String() string

type TsInterpolation

type TsInterpolation struct {
	Base             []byte          `protobuf:"bytes,1,req,name=base" json:"base,omitempty"`
	Interpolations   []*riak.RpbPair `protobuf:"bytes,2,rep,name=interpolations" json:"interpolations,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*TsInterpolation) Descriptor

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

func (*TsInterpolation) GetBase

func (m *TsInterpolation) GetBase() []byte

func (*TsInterpolation) GetInterpolations

func (m *TsInterpolation) GetInterpolations() []*riak.RpbPair

func (*TsInterpolation) ProtoMessage

func (*TsInterpolation) ProtoMessage()

func (*TsInterpolation) Reset

func (m *TsInterpolation) Reset()

func (*TsInterpolation) String

func (m *TsInterpolation) String() string

type TsListKeysReq

type TsListKeysReq struct {
	Table            []byte  `protobuf:"bytes,1,req,name=table" json:"table,omitempty"`
	Timeout          *uint32 `protobuf:"varint,2,opt,name=timeout" json:"timeout,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*TsListKeysReq) Descriptor

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

func (*TsListKeysReq) GetTable

func (m *TsListKeysReq) GetTable() []byte

func (*TsListKeysReq) GetTimeout

func (m *TsListKeysReq) GetTimeout() uint32

func (*TsListKeysReq) ProtoMessage

func (*TsListKeysReq) ProtoMessage()

func (*TsListKeysReq) Reset

func (m *TsListKeysReq) Reset()

func (*TsListKeysReq) String

func (m *TsListKeysReq) String() string

type TsListKeysResp

type TsListKeysResp struct {
	Keys             []*TsRow `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
	Done             *bool    `protobuf:"varint,2,opt,name=done" json:"done,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*TsListKeysResp) Descriptor

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

func (*TsListKeysResp) GetDone

func (m *TsListKeysResp) GetDone() bool

func (*TsListKeysResp) GetKeys

func (m *TsListKeysResp) GetKeys() []*TsRow

func (*TsListKeysResp) ProtoMessage

func (*TsListKeysResp) ProtoMessage()

func (*TsListKeysResp) Reset

func (m *TsListKeysResp) Reset()

func (*TsListKeysResp) String

func (m *TsListKeysResp) String() string

type TsPutReq

type TsPutReq struct {
	Table []byte `protobuf:"bytes,1,req,name=table" json:"table,omitempty"`
	// optional: omitting it should use table order
	Columns          []*TsColumnDescription `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"`
	Rows             []*TsRow               `protobuf:"bytes,3,rep,name=rows" json:"rows,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*TsPutReq) Descriptor

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

func (*TsPutReq) GetColumns

func (m *TsPutReq) GetColumns() []*TsColumnDescription

func (*TsPutReq) GetRows

func (m *TsPutReq) GetRows() []*TsRow

func (*TsPutReq) GetTable

func (m *TsPutReq) GetTable() []byte

func (*TsPutReq) ProtoMessage

func (*TsPutReq) ProtoMessage()

func (*TsPutReq) Reset

func (m *TsPutReq) Reset()

func (*TsPutReq) String

func (m *TsPutReq) String() string

type TsPutResp

type TsPutResp struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*TsPutResp) Descriptor

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

func (*TsPutResp) ProtoMessage

func (*TsPutResp) ProtoMessage()

func (*TsPutResp) Reset

func (m *TsPutResp) Reset()

func (*TsPutResp) String

func (m *TsPutResp) String() string

type TsQueryReq

type TsQueryReq struct {
	// left optional to support parameterized queries in the future
	Query            *TsInterpolation `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	Stream           *bool            `protobuf:"varint,2,opt,name=stream,def=0" json:"stream,omitempty"`
	CoverContext     []byte           `protobuf:"bytes,3,opt,name=cover_context" json:"cover_context,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

Dispatch a query to Riak

func (*TsQueryReq) Descriptor

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

func (*TsQueryReq) GetCoverContext

func (m *TsQueryReq) GetCoverContext() []byte

func (*TsQueryReq) GetQuery

func (m *TsQueryReq) GetQuery() *TsInterpolation

func (*TsQueryReq) GetStream

func (m *TsQueryReq) GetStream() bool

func (*TsQueryReq) ProtoMessage

func (*TsQueryReq) ProtoMessage()

func (*TsQueryReq) Reset

func (m *TsQueryReq) Reset()

func (*TsQueryReq) String

func (m *TsQueryReq) String() string

type TsQueryResp

type TsQueryResp struct {
	Columns          []*TsColumnDescription `protobuf:"bytes,1,rep,name=columns" json:"columns,omitempty"`
	Rows             []*TsRow               `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
	Done             *bool                  `protobuf:"varint,3,opt,name=done,def=1" json:"done,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*TsQueryResp) Descriptor

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

func (*TsQueryResp) GetColumns

func (m *TsQueryResp) GetColumns() []*TsColumnDescription

func (*TsQueryResp) GetDone

func (m *TsQueryResp) GetDone() bool

func (*TsQueryResp) GetRows

func (m *TsQueryResp) GetRows() []*TsRow

func (*TsQueryResp) ProtoMessage

func (*TsQueryResp) ProtoMessage()

func (*TsQueryResp) Reset

func (m *TsQueryResp) Reset()

func (*TsQueryResp) String

func (m *TsQueryResp) String() string

type TsRange

type TsRange struct {
	FieldName           []byte `protobuf:"bytes,1,req,name=field_name" json:"field_name,omitempty"`
	LowerBound          *int64 `protobuf:"zigzag64,2,req,name=lower_bound" json:"lower_bound,omitempty"`
	LowerBoundInclusive *bool  `protobuf:"varint,3,req,name=lower_bound_inclusive" json:"lower_bound_inclusive,omitempty"`
	UpperBound          *int64 `protobuf:"zigzag64,4,req,name=upper_bound" json:"upper_bound,omitempty"`
	UpperBoundInclusive *bool  `protobuf:"varint,5,req,name=upper_bound_inclusive" json:"upper_bound_inclusive,omitempty"`
	Desc                []byte `protobuf:"bytes,6,req,name=desc" json:"desc,omitempty"`
	XXX_unrecognized    []byte `json:"-"`
}

Each prospective subquery has a range of valid time values

func (*TsRange) Descriptor

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

func (*TsRange) GetDesc

func (m *TsRange) GetDesc() []byte

func (*TsRange) GetFieldName

func (m *TsRange) GetFieldName() []byte

func (*TsRange) GetLowerBound

func (m *TsRange) GetLowerBound() int64

func (*TsRange) GetLowerBoundInclusive

func (m *TsRange) GetLowerBoundInclusive() bool

func (*TsRange) GetUpperBound

func (m *TsRange) GetUpperBound() int64

func (*TsRange) GetUpperBoundInclusive

func (m *TsRange) GetUpperBoundInclusive() bool

func (*TsRange) ProtoMessage

func (*TsRange) ProtoMessage()

func (*TsRange) Reset

func (m *TsRange) Reset()

func (*TsRange) String

func (m *TsRange) String() string

type TsRow

type TsRow struct {
	Cells            []*TsCell `protobuf:"bytes,1,rep,name=cells" json:"cells,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*TsRow) Descriptor

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

func (*TsRow) GetCells

func (m *TsRow) GetCells() []*TsCell

func (*TsRow) ProtoMessage

func (*TsRow) ProtoMessage()

func (*TsRow) Reset

func (m *TsRow) Reset()

func (*TsRow) String

func (m *TsRow) String() string

Jump to

Keyboard shortcuts

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