storage

package
v1.2.3-0...-6d008c3 Latest Latest
Warning

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

Go to latest
Published: Feb 15, 2018 License: MIT Imports: 28 Imported by: 0

Documentation

Overview

Package storage is a generated protocol buffer package.

It is generated from these files:
	storage.proto
	predicate.proto

It has these top-level messages:
	ReadRequest
	Aggregate
	Tag
	ReadResponse
	CapabilitiesResponse
	HintsResponse
	TimestampRange
	Node
	Predicate

Package storage is a generated protocol buffer package.

It is generated from these files:

storage.proto
predicate.proto

It has these top-level messages:

ReadRequest
Aggregate
Tag
ReadResponse
CapabilitiesResponse
HintsResponse
TimestampRange
Node
Predicate

Index

Constants

View Source
const (
	// DefaultBindAddress is the default address to bind to.
	DefaultBindAddress = ":8082"
)

Variables

View Source
var (
	ErrInvalidLengthPredicate = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPredicate   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthStorage = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStorage   = fmt.Errorf("proto: integer overflow")
)
View Source
var Aggregate_AggregateType_name = map[int32]string{
	0: "NONE",
	1: "SUM",
	2: "COUNT",
}
View Source
var Aggregate_AggregateType_value = map[string]int32{
	"NONE":  0,
	"SUM":   1,
	"COUNT": 2,
}
View Source
var BooleanEmptyBatchCursor tsdb.BooleanBatchCursor = &booleanEmptyBatchCursor{}
View Source
var FloatEmptyBatchCursor tsdb.FloatBatchCursor = &floatEmptyBatchCursor{}
View Source
var IntegerEmptyBatchCursor tsdb.IntegerBatchCursor = &integerEmptyBatchCursor{}
View Source
var Node_Comparison_name = map[int32]string{
	0: "EQUAL",
	1: "NOT_EQUAL",
	2: "STARTS_WITH",
	3: "REGEX",
	4: "NOT_REGEX",
	5: "LT",
	6: "LTE",
	7: "GT",
	8: "GTE",
}
View Source
var Node_Comparison_value = map[string]int32{
	"EQUAL":       0,
	"NOT_EQUAL":   1,
	"STARTS_WITH": 2,
	"REGEX":       3,
	"NOT_REGEX":   4,
	"LT":          5,
	"LTE":         6,
	"GT":          7,
	"GTE":         8,
}
View Source
var Node_Logical_name = map[int32]string{
	0: "AND",
	1: "OR",
}
View Source
var Node_Logical_value = map[string]int32{
	"AND": 0,
	"OR":  1,
}
View Source
var Node_Type_name = map[int32]string{
	0: "LOGICAL_EXPRESSION",
	1: "COMPARISON_EXPRESSION",
	2: "PAREN_EXPRESSION",
	3: "TAG_REF",
	4: "LITERAL",
	5: "FIELD_REF",
}
View Source
var Node_Type_value = map[string]int32{
	"LOGICAL_EXPRESSION":    0,
	"COMPARISON_EXPRESSION": 1,
	"PAREN_EXPRESSION":      2,
	"TAG_REF":               3,
	"LITERAL":               4,
	"FIELD_REF":             5,
}
View Source
var ReadResponse_DataType_name = map[int32]string{
	0: "FLOAT",
	1: "INTEGER",
	2: "UNSIGNED",
	3: "BOOLEAN",
	4: "STRING",
}
View Source
var ReadResponse_DataType_value = map[string]int32{
	"FLOAT":    0,
	"INTEGER":  1,
	"UNSIGNED": 2,
	"BOOLEAN":  3,
	"STRING":   4,
}
View Source
var ReadResponse_FrameType_name = map[int32]string{
	0: "SERIES",
	1: "POINTS",
}
View Source
var ReadResponse_FrameType_value = map[string]int32{
	"SERIES": 0,
	"POINTS": 1,
}
View Source
var StringEmptyBatchCursor tsdb.StringBatchCursor = &stringEmptyBatchCursor{}
View Source
var UnsignedEmptyBatchCursor tsdb.UnsignedBatchCursor = &unsignedEmptyBatchCursor{}

Functions

func HasFieldKey

func HasFieldKey(expr influxql.Expr) bool

func HasFieldKeyOrValue

func HasFieldKeyOrValue(expr influxql.Expr) bool

func NodeToExpr

func NodeToExpr(node *Node) (influxql.Expr, error)

NodeToExpr transforms a predicate node to an influxql.Expr.

func PredicateToExprString

func PredicateToExprString(p *Predicate) string

func RegisterStorageServer

func RegisterStorageServer(s *yarpc.Server, srv StorageServer)

func RewriteExprRemoveFieldKeyAndValue

func RewriteExprRemoveFieldKeyAndValue(expr influxql.Expr) influxql.Expr

func RewriteExprRemoveFieldValue

func RewriteExprRemoveFieldValue(expr influxql.Expr) influxql.Expr

func WalkNode

func WalkNode(v NodeVisitor, node *Node)

Types

type Aggregate

type Aggregate struct {
	Type Aggregate_AggregateType `protobuf:"varint,1,opt,name=type,proto3,enum=storage.Aggregate_AggregateType" json:"type,omitempty"`
}

func (*Aggregate) Descriptor

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

func (*Aggregate) Marshal

func (m *Aggregate) Marshal() (dAtA []byte, err error)

func (*Aggregate) MarshalTo

func (m *Aggregate) MarshalTo(dAtA []byte) (int, error)

func (*Aggregate) ProtoMessage

func (*Aggregate) ProtoMessage()

func (*Aggregate) Reset

func (m *Aggregate) Reset()

func (*Aggregate) Size

func (m *Aggregate) Size() (n int)

func (*Aggregate) String

func (m *Aggregate) String() string

func (*Aggregate) Unmarshal

func (m *Aggregate) Unmarshal(dAtA []byte) error

type Aggregate_AggregateType

type Aggregate_AggregateType int32
const (
	AggregateTypeNone  Aggregate_AggregateType = 0
	AggregateTypeSum   Aggregate_AggregateType = 1
	AggregateTypeCount Aggregate_AggregateType = 2
)

func (Aggregate_AggregateType) EnumDescriptor

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

func (Aggregate_AggregateType) String

func (x Aggregate_AggregateType) String() string

type CapabilitiesResponse

type CapabilitiesResponse struct {
	Caps map[string]string `` /* 142-byte string literal not displayed */
}

func (*CapabilitiesResponse) Descriptor

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

func (*CapabilitiesResponse) Marshal

func (m *CapabilitiesResponse) Marshal() (dAtA []byte, err error)

func (*CapabilitiesResponse) MarshalTo

func (m *CapabilitiesResponse) MarshalTo(dAtA []byte) (int, error)

func (*CapabilitiesResponse) ProtoMessage

func (*CapabilitiesResponse) ProtoMessage()

func (*CapabilitiesResponse) Reset

func (m *CapabilitiesResponse) Reset()

func (*CapabilitiesResponse) Size

func (m *CapabilitiesResponse) Size() (n int)

func (*CapabilitiesResponse) String

func (m *CapabilitiesResponse) String() string

func (*CapabilitiesResponse) Unmarshal

func (m *CapabilitiesResponse) Unmarshal(dAtA []byte) error

type Config

type Config struct {
	Enabled     bool   `toml:"enabled"`
	LogEnabled  bool   `toml:"log-enabled"` // verbose logging
	BindAddress string `toml:"bind-address"`
}

Config represents a configuration for a HTTP service.

func NewConfig

func NewConfig() Config

NewConfig returns a new Config with default settings.

func (Config) Diagnostics

func (c Config) Diagnostics() (*diagnostics.Diagnostics, error)

Diagnostics returns a diagnostics representation of a subset of the Config.

type HintsResponse

type HintsResponse struct {
}

func (*HintsResponse) Descriptor

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

func (*HintsResponse) Marshal

func (m *HintsResponse) Marshal() (dAtA []byte, err error)

func (*HintsResponse) MarshalTo

func (m *HintsResponse) MarshalTo(dAtA []byte) (int, error)

func (*HintsResponse) ProtoMessage

func (*HintsResponse) ProtoMessage()

func (*HintsResponse) Reset

func (m *HintsResponse) Reset()

func (*HintsResponse) Size

func (m *HintsResponse) Size() (n int)

func (*HintsResponse) String

func (m *HintsResponse) String() string

func (*HintsResponse) Unmarshal

func (m *HintsResponse) Unmarshal(dAtA []byte) error

type Node

type Node struct {
	NodeType Node_Type `protobuf:"varint,1,opt,name=node_type,json=nodeType,proto3,enum=storage.Node_Type" json:"nodeType"`
	Children []*Node   `protobuf:"bytes,2,rep,name=children" json:"children,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*Node_StringValue
	//	*Node_BooleanValue
	//	*Node_IntegerValue
	//	*Node_UnsignedValue
	//	*Node_FloatValue
	//	*Node_RegexValue
	//	*Node_TagRefValue
	//	*Node_FieldRefValue
	//	*Node_Logical_
	//	*Node_Comparison_
	Value isNode_Value `protobuf_oneof:"value"`
}

func (*Node) Descriptor

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

func (*Node) GetBooleanValue

func (m *Node) GetBooleanValue() bool

func (*Node) GetChildren

func (m *Node) GetChildren() []*Node

func (*Node) GetComparison

func (m *Node) GetComparison() Node_Comparison

func (*Node) GetFieldRefValue

func (m *Node) GetFieldRefValue() string

func (*Node) GetFloatValue

func (m *Node) GetFloatValue() float64

func (*Node) GetIntegerValue

func (m *Node) GetIntegerValue() int64

func (*Node) GetLogical

func (m *Node) GetLogical() Node_Logical

func (*Node) GetNodeType

func (m *Node) GetNodeType() Node_Type

func (*Node) GetRegexValue

func (m *Node) GetRegexValue() string

func (*Node) GetStringValue

func (m *Node) GetStringValue() string

func (*Node) GetTagRefValue

func (m *Node) GetTagRefValue() string

func (*Node) GetUnsignedValue

func (m *Node) GetUnsignedValue() uint64

func (*Node) GetValue

func (m *Node) GetValue() isNode_Value

func (*Node) Marshal

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalTo

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) Reset

func (m *Node) Reset()

func (*Node) Size

func (m *Node) Size() (n int)

func (*Node) String

func (m *Node) String() string

func (*Node) Unmarshal

func (m *Node) Unmarshal(dAtA []byte) error

func (*Node) XXX_OneofFuncs

func (*Node) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type NodeVisitor

type NodeVisitor interface {
	Visit(*Node) NodeVisitor
}

NodeVisitor can be called by Walk to traverse the Node hierarchy. The Visit() function is called once per node.

type Node_BooleanValue

type Node_BooleanValue struct {
	BooleanValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

func (*Node_BooleanValue) MarshalTo

func (m *Node_BooleanValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_BooleanValue) Size

func (m *Node_BooleanValue) Size() (n int)

type Node_Comparison

type Node_Comparison int32
const (
	ComparisonEqual        Node_Comparison = 0
	ComparisonNotEqual     Node_Comparison = 1
	ComparisonStartsWith   Node_Comparison = 2
	ComparisonRegex        Node_Comparison = 3
	ComparisonNotRegex     Node_Comparison = 4
	ComparisonLess         Node_Comparison = 5
	ComparisonLessEqual    Node_Comparison = 6
	ComparisonGreater      Node_Comparison = 7
	ComparisonGreaterEqual Node_Comparison = 8
)

func (Node_Comparison) EnumDescriptor

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

func (Node_Comparison) String

func (x Node_Comparison) String() string

type Node_Comparison_

type Node_Comparison_ struct {
	Comparison Node_Comparison `protobuf:"varint,12,opt,name=comparison,proto3,enum=storage.Node_Comparison,oneof"`
}

func (*Node_Comparison_) MarshalTo

func (m *Node_Comparison_) MarshalTo(dAtA []byte) (int, error)

func (*Node_Comparison_) Size

func (m *Node_Comparison_) Size() (n int)

type Node_FieldRefValue

type Node_FieldRefValue struct {
	FieldRefValue string `protobuf:"bytes,10,opt,name=field_ref_value,json=fieldRefValue,proto3,oneof"`
}

func (*Node_FieldRefValue) MarshalTo

func (m *Node_FieldRefValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_FieldRefValue) Size

func (m *Node_FieldRefValue) Size() (n int)

type Node_FloatValue

type Node_FloatValue struct {
	FloatValue float64 `protobuf:"fixed64,7,opt,name=float_value,json=floatValue,proto3,oneof"`
}

func (*Node_FloatValue) MarshalTo

func (m *Node_FloatValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_FloatValue) Size

func (m *Node_FloatValue) Size() (n int)

type Node_IntegerValue

type Node_IntegerValue struct {
	IntegerValue int64 `protobuf:"varint,5,opt,name=int_value,json=intValue,proto3,oneof"`
}

func (*Node_IntegerValue) MarshalTo

func (m *Node_IntegerValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_IntegerValue) Size

func (m *Node_IntegerValue) Size() (n int)

type Node_Logical

type Node_Logical int32

Logical operators apply to boolean values and combine to produce a single boolean result.

const (
	LogicalAnd Node_Logical = 0
	LogicalOr  Node_Logical = 1
)

func (Node_Logical) EnumDescriptor

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

func (Node_Logical) String

func (x Node_Logical) String() string

type Node_Logical_

type Node_Logical_ struct {
	Logical Node_Logical `protobuf:"varint,11,opt,name=logical,proto3,enum=storage.Node_Logical,oneof"`
}

func (*Node_Logical_) MarshalTo

func (m *Node_Logical_) MarshalTo(dAtA []byte) (int, error)

func (*Node_Logical_) Size

func (m *Node_Logical_) Size() (n int)

type Node_RegexValue

type Node_RegexValue struct {
	RegexValue string `protobuf:"bytes,8,opt,name=regex_value,json=regexValue,proto3,oneof"`
}

func (*Node_RegexValue) MarshalTo

func (m *Node_RegexValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_RegexValue) Size

func (m *Node_RegexValue) Size() (n int)

type Node_StringValue

type Node_StringValue struct {
	StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3,oneof"`
}

func (*Node_StringValue) MarshalTo

func (m *Node_StringValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_StringValue) Size

func (m *Node_StringValue) Size() (n int)

type Node_TagRefValue

type Node_TagRefValue struct {
	TagRefValue string `protobuf:"bytes,9,opt,name=tag_ref_value,json=tagRefValue,proto3,oneof"`
}

func (*Node_TagRefValue) MarshalTo

func (m *Node_TagRefValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_TagRefValue) Size

func (m *Node_TagRefValue) Size() (n int)

type Node_Type

type Node_Type int32
const (
	NodeTypeLogicalExpression    Node_Type = 0
	NodeTypeComparisonExpression Node_Type = 1
	NodeTypeParenExpression      Node_Type = 2
	NodeTypeTagRef               Node_Type = 3
	NodeTypeLiteral              Node_Type = 4
	NodeTypeFieldRef             Node_Type = 5
)

func (Node_Type) EnumDescriptor

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

func (Node_Type) String

func (x Node_Type) String() string

type Node_UnsignedValue

type Node_UnsignedValue struct {
	UnsignedValue uint64 `protobuf:"varint,6,opt,name=uint_value,json=uintValue,proto3,oneof"`
}

func (*Node_UnsignedValue) MarshalTo

func (m *Node_UnsignedValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_UnsignedValue) Size

func (m *Node_UnsignedValue) Size() (n int)

type Predicate

type Predicate struct {
	Root *Node `protobuf:"bytes,1,opt,name=root" json:"root,omitempty"`
}

func (*Predicate) Descriptor

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

func (*Predicate) GetRoot

func (m *Predicate) GetRoot() *Node

func (*Predicate) Marshal

func (m *Predicate) Marshal() (dAtA []byte, err error)

func (*Predicate) MarshalTo

func (m *Predicate) MarshalTo(dAtA []byte) (int, error)

func (*Predicate) ProtoMessage

func (*Predicate) ProtoMessage()

func (*Predicate) Reset

func (m *Predicate) Reset()

func (*Predicate) Size

func (m *Predicate) Size() (n int)

func (*Predicate) String

func (m *Predicate) String() string

func (*Predicate) Unmarshal

func (m *Predicate) Unmarshal(dAtA []byte) error

type ReadRequest

type ReadRequest struct {
	// Database specifies the name of the database to issue the read request.
	Database       string         `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	TimestampRange TimestampRange `protobuf:"bytes,2,opt,name=timestamp_range,json=timestampRange" json:"timestamp_range"`
	// Descending indicates whether points should be returned in descending order.
	Descending bool `protobuf:"varint,3,opt,name=descending,proto3" json:"descending,omitempty"`
	// Grouping specifies a list of tags used to order the data
	Grouping []string `protobuf:"bytes,4,rep,name=grouping" json:"grouping,omitempty"`
	// Aggregate specifies an optional aggregate to apply to the data.
	// TODO(sgc): switch to slice for multiple aggregates in a single request
	Aggregate *Aggregate `protobuf:"bytes,9,opt,name=aggregate" json:"aggregate,omitempty"`
	Predicate *Predicate `protobuf:"bytes,5,opt,name=predicate" json:"predicate,omitempty"`
	// SeriesLimit determines the maximum number of series to be returned for the request. Specify 0 for no limit.
	SeriesLimit uint64 `protobuf:"varint,6,opt,name=series_limit,json=seriesLimit,proto3" json:"series_limit,omitempty"`
	// SeriesOffset determines how many series to skip before processing the request.
	SeriesOffset uint64 `protobuf:"varint,7,opt,name=series_offset,json=seriesOffset,proto3" json:"series_offset,omitempty"`
	// PointsLimit determines the maximum number of values per series to be returned for the request.
	// Specify 0 for no limit.
	PointsLimit uint64 `protobuf:"varint,8,opt,name=points_limit,json=pointsLimit,proto3" json:"points_limit,omitempty"`
	// Trace contains opaque data if a trace is active.
	Trace map[string]string `` /* 145-byte string literal not displayed */
}

Request message for Storage.Read.

func (*ReadRequest) Descriptor

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

func (*ReadRequest) Marshal

func (m *ReadRequest) Marshal() (dAtA []byte, err error)

func (*ReadRequest) MarshalTo

func (m *ReadRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReadRequest) ProtoMessage

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset

func (m *ReadRequest) Reset()

func (*ReadRequest) Size

func (m *ReadRequest) Size() (n int)

func (*ReadRequest) String

func (m *ReadRequest) String() string

func (*ReadRequest) Unmarshal

func (m *ReadRequest) Unmarshal(dAtA []byte) error

type ReadResponse

type ReadResponse struct {
	Frames []ReadResponse_Frame `protobuf:"bytes,1,rep,name=frames" json:"frames"`
}

Response message for Storage.Read.

func (*ReadResponse) Descriptor

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

func (*ReadResponse) Marshal

func (m *ReadResponse) Marshal() (dAtA []byte, err error)

func (*ReadResponse) MarshalTo

func (m *ReadResponse) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse) ProtoMessage

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset

func (m *ReadResponse) Reset()

func (*ReadResponse) Size

func (m *ReadResponse) Size() (n int)

func (*ReadResponse) String

func (m *ReadResponse) String() string

func (*ReadResponse) Unmarshal

func (m *ReadResponse) Unmarshal(dAtA []byte) error

type ReadResponse_BooleanPointsFrame

type ReadResponse_BooleanPointsFrame struct {
	Timestamps []int64 `protobuf:"fixed64,1,rep,packed,name=timestamps" json:"timestamps,omitempty"`
	Values     []bool  `protobuf:"varint,2,rep,packed,name=values" json:"values,omitempty"`
}

func (*ReadResponse_BooleanPointsFrame) Descriptor

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

func (*ReadResponse_BooleanPointsFrame) Marshal

func (m *ReadResponse_BooleanPointsFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_BooleanPointsFrame) MarshalTo

func (m *ReadResponse_BooleanPointsFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_BooleanPointsFrame) ProtoMessage

func (*ReadResponse_BooleanPointsFrame) ProtoMessage()

func (*ReadResponse_BooleanPointsFrame) Reset

func (*ReadResponse_BooleanPointsFrame) Size

func (m *ReadResponse_BooleanPointsFrame) Size() (n int)

func (*ReadResponse_BooleanPointsFrame) String

func (*ReadResponse_BooleanPointsFrame) Unmarshal

func (m *ReadResponse_BooleanPointsFrame) Unmarshal(dAtA []byte) error

type ReadResponse_DataType

type ReadResponse_DataType int32
const (
	DataTypeFloat    ReadResponse_DataType = 0
	DataTypeInteger  ReadResponse_DataType = 1
	DataTypeUnsigned ReadResponse_DataType = 2
	DataTypeBoolean  ReadResponse_DataType = 3
	DataTypeString   ReadResponse_DataType = 4
)

func (ReadResponse_DataType) EnumDescriptor

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

func (ReadResponse_DataType) String

func (x ReadResponse_DataType) String() string

type ReadResponse_FloatPointsFrame

type ReadResponse_FloatPointsFrame struct {
	Timestamps []int64   `protobuf:"fixed64,1,rep,packed,name=timestamps" json:"timestamps,omitempty"`
	Values     []float64 `protobuf:"fixed64,2,rep,packed,name=values" json:"values,omitempty"`
}

func (*ReadResponse_FloatPointsFrame) Descriptor

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

func (*ReadResponse_FloatPointsFrame) Marshal

func (m *ReadResponse_FloatPointsFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_FloatPointsFrame) MarshalTo

func (m *ReadResponse_FloatPointsFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_FloatPointsFrame) ProtoMessage

func (*ReadResponse_FloatPointsFrame) ProtoMessage()

func (*ReadResponse_FloatPointsFrame) Reset

func (m *ReadResponse_FloatPointsFrame) Reset()

func (*ReadResponse_FloatPointsFrame) Size

func (m *ReadResponse_FloatPointsFrame) Size() (n int)

func (*ReadResponse_FloatPointsFrame) String

func (*ReadResponse_FloatPointsFrame) Unmarshal

func (m *ReadResponse_FloatPointsFrame) Unmarshal(dAtA []byte) error

type ReadResponse_Frame

type ReadResponse_Frame struct {
	// Types that are valid to be assigned to Data:
	//	*ReadResponse_Frame_Series
	//	*ReadResponse_Frame_FloatPoints
	//	*ReadResponse_Frame_IntegerPoints
	//	*ReadResponse_Frame_UnsignedPoints
	//	*ReadResponse_Frame_BooleanPoints
	//	*ReadResponse_Frame_StringPoints
	Data isReadResponse_Frame_Data `protobuf_oneof:"data"`
}

func (*ReadResponse_Frame) Descriptor

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

func (*ReadResponse_Frame) GetBooleanPoints

func (m *ReadResponse_Frame) GetBooleanPoints() *ReadResponse_BooleanPointsFrame

func (*ReadResponse_Frame) GetData

func (m *ReadResponse_Frame) GetData() isReadResponse_Frame_Data

func (*ReadResponse_Frame) GetFloatPoints

func (*ReadResponse_Frame) GetIntegerPoints

func (m *ReadResponse_Frame) GetIntegerPoints() *ReadResponse_IntegerPointsFrame

func (*ReadResponse_Frame) GetSeries

func (*ReadResponse_Frame) GetStringPoints

func (m *ReadResponse_Frame) GetStringPoints() *ReadResponse_StringPointsFrame

func (*ReadResponse_Frame) GetUnsignedPoints

func (m *ReadResponse_Frame) GetUnsignedPoints() *ReadResponse_UnsignedPointsFrame

func (*ReadResponse_Frame) Marshal

func (m *ReadResponse_Frame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_Frame) MarshalTo

func (m *ReadResponse_Frame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame) ProtoMessage

func (*ReadResponse_Frame) ProtoMessage()

func (*ReadResponse_Frame) Reset

func (m *ReadResponse_Frame) Reset()

func (*ReadResponse_Frame) Size

func (m *ReadResponse_Frame) Size() (n int)

func (*ReadResponse_Frame) String

func (m *ReadResponse_Frame) String() string

func (*ReadResponse_Frame) Unmarshal

func (m *ReadResponse_Frame) Unmarshal(dAtA []byte) error

func (*ReadResponse_Frame) XXX_OneofFuncs

func (*ReadResponse_Frame) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ReadResponse_FrameType

type ReadResponse_FrameType int32
const (
	FrameTypeSeries ReadResponse_FrameType = 0
	FrameTypePoints ReadResponse_FrameType = 1
)

func (ReadResponse_FrameType) EnumDescriptor

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

func (ReadResponse_FrameType) String

func (x ReadResponse_FrameType) String() string

type ReadResponse_Frame_BooleanPoints

type ReadResponse_Frame_BooleanPoints struct {
	BooleanPoints *ReadResponse_BooleanPointsFrame `protobuf:"bytes,5,opt,name=boolean_points,json=booleanPoints,oneof"`
}

func (*ReadResponse_Frame_BooleanPoints) MarshalTo

func (m *ReadResponse_Frame_BooleanPoints) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_BooleanPoints) Size

func (m *ReadResponse_Frame_BooleanPoints) Size() (n int)

type ReadResponse_Frame_FloatPoints

type ReadResponse_Frame_FloatPoints struct {
	FloatPoints *ReadResponse_FloatPointsFrame `protobuf:"bytes,2,opt,name=float_points,json=floatPoints,oneof"`
}

func (*ReadResponse_Frame_FloatPoints) MarshalTo

func (m *ReadResponse_Frame_FloatPoints) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_FloatPoints) Size

func (m *ReadResponse_Frame_FloatPoints) Size() (n int)

type ReadResponse_Frame_IntegerPoints

type ReadResponse_Frame_IntegerPoints struct {
	IntegerPoints *ReadResponse_IntegerPointsFrame `protobuf:"bytes,3,opt,name=integer_points,json=integerPoints,oneof"`
}

func (*ReadResponse_Frame_IntegerPoints) MarshalTo

func (m *ReadResponse_Frame_IntegerPoints) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_IntegerPoints) Size

func (m *ReadResponse_Frame_IntegerPoints) Size() (n int)

type ReadResponse_Frame_Series

type ReadResponse_Frame_Series struct {
	Series *ReadResponse_SeriesFrame `protobuf:"bytes,1,opt,name=series,oneof"`
}

func (*ReadResponse_Frame_Series) MarshalTo

func (m *ReadResponse_Frame_Series) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_Series) Size

func (m *ReadResponse_Frame_Series) Size() (n int)

type ReadResponse_Frame_StringPoints

type ReadResponse_Frame_StringPoints struct {
	StringPoints *ReadResponse_StringPointsFrame `protobuf:"bytes,6,opt,name=string_points,json=stringPoints,oneof"`
}

func (*ReadResponse_Frame_StringPoints) MarshalTo

func (m *ReadResponse_Frame_StringPoints) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_StringPoints) Size

func (m *ReadResponse_Frame_StringPoints) Size() (n int)

type ReadResponse_Frame_UnsignedPoints

type ReadResponse_Frame_UnsignedPoints struct {
	UnsignedPoints *ReadResponse_UnsignedPointsFrame `protobuf:"bytes,4,opt,name=unsigned_points,json=unsignedPoints,oneof"`
}

func (*ReadResponse_Frame_UnsignedPoints) MarshalTo

func (m *ReadResponse_Frame_UnsignedPoints) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_UnsignedPoints) Size

func (m *ReadResponse_Frame_UnsignedPoints) Size() (n int)

type ReadResponse_IntegerPointsFrame

type ReadResponse_IntegerPointsFrame struct {
	Timestamps []int64 `protobuf:"fixed64,1,rep,packed,name=timestamps" json:"timestamps,omitempty"`
	Values     []int64 `protobuf:"varint,2,rep,packed,name=values" json:"values,omitempty"`
}

func (*ReadResponse_IntegerPointsFrame) Descriptor

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

func (*ReadResponse_IntegerPointsFrame) Marshal

func (m *ReadResponse_IntegerPointsFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_IntegerPointsFrame) MarshalTo

func (m *ReadResponse_IntegerPointsFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_IntegerPointsFrame) ProtoMessage

func (*ReadResponse_IntegerPointsFrame) ProtoMessage()

func (*ReadResponse_IntegerPointsFrame) Reset

func (*ReadResponse_IntegerPointsFrame) Size

func (m *ReadResponse_IntegerPointsFrame) Size() (n int)

func (*ReadResponse_IntegerPointsFrame) String

func (*ReadResponse_IntegerPointsFrame) Unmarshal

func (m *ReadResponse_IntegerPointsFrame) Unmarshal(dAtA []byte) error

type ReadResponse_SeriesFrame

type ReadResponse_SeriesFrame struct {
	Tags     []Tag                 `protobuf:"bytes,1,rep,name=tags" json:"tags"`
	DataType ReadResponse_DataType `protobuf:"varint,2,opt,name=data_type,json=dataType,proto3,enum=storage.ReadResponse_DataType" json:"data_type,omitempty"`
}

func (*ReadResponse_SeriesFrame) Descriptor

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

func (*ReadResponse_SeriesFrame) Marshal

func (m *ReadResponse_SeriesFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_SeriesFrame) MarshalTo

func (m *ReadResponse_SeriesFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_SeriesFrame) ProtoMessage

func (*ReadResponse_SeriesFrame) ProtoMessage()

func (*ReadResponse_SeriesFrame) Reset

func (m *ReadResponse_SeriesFrame) Reset()

func (*ReadResponse_SeriesFrame) Size

func (m *ReadResponse_SeriesFrame) Size() (n int)

func (*ReadResponse_SeriesFrame) String

func (m *ReadResponse_SeriesFrame) String() string

func (*ReadResponse_SeriesFrame) Unmarshal

func (m *ReadResponse_SeriesFrame) Unmarshal(dAtA []byte) error

type ReadResponse_StringPointsFrame

type ReadResponse_StringPointsFrame struct {
	Timestamps []int64  `protobuf:"fixed64,1,rep,packed,name=timestamps" json:"timestamps,omitempty"`
	Values     []string `protobuf:"bytes,2,rep,name=values" json:"values,omitempty"`
}

func (*ReadResponse_StringPointsFrame) Descriptor

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

func (*ReadResponse_StringPointsFrame) Marshal

func (m *ReadResponse_StringPointsFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_StringPointsFrame) MarshalTo

func (m *ReadResponse_StringPointsFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_StringPointsFrame) ProtoMessage

func (*ReadResponse_StringPointsFrame) ProtoMessage()

func (*ReadResponse_StringPointsFrame) Reset

func (m *ReadResponse_StringPointsFrame) Reset()

func (*ReadResponse_StringPointsFrame) Size

func (m *ReadResponse_StringPointsFrame) Size() (n int)

func (*ReadResponse_StringPointsFrame) String

func (*ReadResponse_StringPointsFrame) Unmarshal

func (m *ReadResponse_StringPointsFrame) Unmarshal(dAtA []byte) error

type ReadResponse_UnsignedPointsFrame

type ReadResponse_UnsignedPointsFrame struct {
	Timestamps []int64  `protobuf:"fixed64,1,rep,packed,name=timestamps" json:"timestamps,omitempty"`
	Values     []uint64 `protobuf:"varint,2,rep,packed,name=values" json:"values,omitempty"`
}

func (*ReadResponse_UnsignedPointsFrame) Descriptor

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

func (*ReadResponse_UnsignedPointsFrame) Marshal

func (m *ReadResponse_UnsignedPointsFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_UnsignedPointsFrame) MarshalTo

func (m *ReadResponse_UnsignedPointsFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_UnsignedPointsFrame) ProtoMessage

func (*ReadResponse_UnsignedPointsFrame) ProtoMessage()

func (*ReadResponse_UnsignedPointsFrame) Reset

func (*ReadResponse_UnsignedPointsFrame) Size

func (m *ReadResponse_UnsignedPointsFrame) Size() (n int)

func (*ReadResponse_UnsignedPointsFrame) String

func (*ReadResponse_UnsignedPointsFrame) Unmarshal

func (m *ReadResponse_UnsignedPointsFrame) Unmarshal(dAtA []byte) error

type ResultSet

type ResultSet struct {
	// contains filtered or unexported fields
}

func (*ResultSet) Close

func (r *ResultSet) Close()

func (*ResultSet) Cursor

func (r *ResultSet) Cursor() tsdb.Cursor

func (*ResultSet) Next

func (r *ResultSet) Next() bool

func (*ResultSet) Tags

func (r *ResultSet) Tags() models.Tags

type Service

type Service struct {
	Store      *Store
	TSDBStore  *tsdb.Store
	MetaClient StorageMetaClient
	// contains filtered or unexported fields
}

Service manages the listener and handler for an HTTP endpoint.

func NewService

func NewService(c Config) *Service

NewService returns a new instance of Service.

func (*Service) Close

func (s *Service) Close() error

func (*Service) Open

func (s *Service) Open() error

Open starts the service.

func (*Service) WithLogger

func (s *Service) WithLogger(log *zap.Logger)

WithLogger sets the logger for the service.

type StorageClient

type StorageClient interface {
	// Read performs a read operation using the given ReadRequest
	Read(ctx context.Context, in *ReadRequest) (Storage_ReadClient, error)
	// Capabilities returns a map of keys and values identifying the capabilities supported by the storage engine
	Capabilities(ctx context.Context, in *google_protobuf1.Empty) (*CapabilitiesResponse, error)
	Hints(ctx context.Context, in *google_protobuf1.Empty) (*HintsResponse, error)
}

func NewStorageClient

func NewStorageClient(cc *yarpc.ClientConn) StorageClient

type StorageMetaClient

type StorageMetaClient interface {
	Database(name string) *meta.DatabaseInfo
	ShardGroupsByTimeRange(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error)
}

type StorageServer

type StorageServer interface {
	// Read performs a read operation using the given ReadRequest
	Read(*ReadRequest, Storage_ReadServer) error
	// Capabilities returns a map of keys and values identifying the capabilities supported by the storage engine
	Capabilities(context.Context, *google_protobuf1.Empty) (*CapabilitiesResponse, error)
	Hints(context.Context, *google_protobuf1.Empty) (*HintsResponse, error)
}

type Storage_ReadClient

type Storage_ReadClient interface {
	Recv() (*ReadResponse, error)
	yarpc.ClientStream
}

type Storage_ReadServer

type Storage_ReadServer interface {
	Send(*ReadResponse) error
	yarpc.ServerStream
}

type Store

type Store struct {
	TSDBStore  *tsdb.Store
	MetaClient StorageMetaClient
	Logger     *zap.Logger
}

func NewStore

func NewStore() *Store

func (*Store) Read

func (s *Store) Read(ctx context.Context, req *ReadRequest) (*ResultSet, error)

func (*Store) WithLogger

func (s *Store) WithLogger(log *zap.Logger)

WithLogger sets the logger for the service.

type Tag

type Tag struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Tag) Descriptor

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

func (*Tag) Marshal

func (m *Tag) Marshal() (dAtA []byte, err error)

func (*Tag) MarshalTo

func (m *Tag) MarshalTo(dAtA []byte) (int, error)

func (*Tag) ProtoMessage

func (*Tag) ProtoMessage()

func (*Tag) Reset

func (m *Tag) Reset()

func (*Tag) Size

func (m *Tag) Size() (n int)

func (*Tag) String

func (m *Tag) String() string

func (*Tag) Unmarshal

func (m *Tag) Unmarshal(dAtA []byte) error

type TimestampRange

type TimestampRange struct {
	// Start defines the inclusive lower bound.
	Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// End defines the inclusive upper bound.
	End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
}

Specifies a continuous range of nanosecond timestamps.

func (*TimestampRange) Descriptor

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

func (*TimestampRange) Marshal

func (m *TimestampRange) Marshal() (dAtA []byte, err error)

func (*TimestampRange) MarshalTo

func (m *TimestampRange) MarshalTo(dAtA []byte) (int, error)

func (*TimestampRange) ProtoMessage

func (*TimestampRange) ProtoMessage()

func (*TimestampRange) Reset

func (m *TimestampRange) Reset()

func (*TimestampRange) Size

func (m *TimestampRange) Size() (n int)

func (*TimestampRange) String

func (m *TimestampRange) String() string

func (*TimestampRange) Unmarshal

func (m *TimestampRange) Unmarshal(dAtA []byte) error

Jump to

Keyboard shortcuts

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