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
- Variables
- type TsCell
- func (*TsCell) Descriptor() ([]byte, []int)
- func (m *TsCell) GetBooleanValue() bool
- func (m *TsCell) GetDoubleValue() float64
- func (m *TsCell) GetSint64Value() int64
- func (m *TsCell) GetTimestampValue() int64
- func (m *TsCell) GetVarcharValue() []byte
- func (*TsCell) ProtoMessage()
- func (m *TsCell) Reset()
- func (m *TsCell) String() string
- type TsColumnDescription
- type TsColumnType
- type TsCoverageEntry
- func (*TsCoverageEntry) Descriptor() ([]byte, []int)
- func (m *TsCoverageEntry) GetCoverContext() []byte
- func (m *TsCoverageEntry) GetIp() []byte
- func (m *TsCoverageEntry) GetPort() uint32
- func (m *TsCoverageEntry) GetRange() *TsRange
- func (*TsCoverageEntry) ProtoMessage()
- func (m *TsCoverageEntry) Reset()
- func (m *TsCoverageEntry) String() string
- type TsCoverageReq
- func (*TsCoverageReq) Descriptor() ([]byte, []int)
- func (m *TsCoverageReq) GetQuery() *TsInterpolation
- func (m *TsCoverageReq) GetReplaceCover() []byte
- func (m *TsCoverageReq) GetTable() []byte
- func (m *TsCoverageReq) GetUnavailableCover() [][]byte
- func (*TsCoverageReq) ProtoMessage()
- func (m *TsCoverageReq) Reset()
- func (m *TsCoverageReq) String() string
- type TsCoverageResp
- type TsDelReq
- type TsDelResp
- type TsGetReq
- type TsGetResp
- type TsInterpolation
- type TsListKeysReq
- type TsListKeysResp
- type TsPutReq
- type TsPutResp
- type TsQueryReq
- type TsQueryResp
- type TsRange
- func (*TsRange) Descriptor() ([]byte, []int)
- func (m *TsRange) GetDesc() []byte
- func (m *TsRange) GetFieldName() []byte
- func (m *TsRange) GetLowerBound() int64
- func (m *TsRange) GetLowerBoundInclusive() bool
- func (m *TsRange) GetUpperBound() int64
- func (m *TsRange) GetUpperBoundInclusive() bool
- func (*TsRange) ProtoMessage()
- func (m *TsRange) Reset()
- func (m *TsRange) String() string
- type TsRow
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) GetBooleanValue ¶
func (*TsCell) GetDoubleValue ¶
func (*TsCell) GetSint64Value ¶
func (*TsCell) GetTimestampValue ¶
func (*TsCell) GetVarcharValue ¶
func (*TsCell) ProtoMessage ¶
func (*TsCell) ProtoMessage()
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"` 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) GetTimeout ¶
func (*TsDelReq) ProtoMessage ¶
func (*TsDelReq) ProtoMessage()
type TsDelResp ¶
type TsDelResp struct {
XXX_unrecognized []byte `json:"-"`
}
func (*TsDelResp) Descriptor ¶
func (*TsDelResp) ProtoMessage ¶
func (*TsDelResp) ProtoMessage()
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) GetTimeout ¶
func (*TsGetReq) ProtoMessage ¶
func (*TsGetReq) ProtoMessage()
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) GetColumns ¶
func (m *TsGetResp) GetColumns() []*TsColumnDescription
func (*TsGetResp) ProtoMessage ¶
func (*TsGetResp) ProtoMessage()
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) GetColumns ¶
func (m *TsPutReq) GetColumns() []*TsColumnDescription
func (*TsPutReq) ProtoMessage ¶
func (*TsPutReq) ProtoMessage()
type TsPutResp ¶
type TsPutResp struct {
XXX_unrecognized []byte `json:"-"`
}
func (*TsPutResp) Descriptor ¶
func (*TsPutResp) ProtoMessage ¶
func (*TsPutResp) ProtoMessage()
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) GetFieldName ¶
func (*TsRange) GetLowerBound ¶
func (*TsRange) GetLowerBoundInclusive ¶
func (*TsRange) GetUpperBound ¶
func (*TsRange) GetUpperBoundInclusive ¶
func (*TsRange) ProtoMessage ¶
func (*TsRange) ProtoMessage()
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) ProtoMessage ¶
func (*TsRow) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.