Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

storage

package

Go to main page

Versions in this module

v1

v1.5.0

Mar 6, 2018

Changes in this version

type ReadRequest

+ Trace map[string]string

+ type StorageMetaClient interface

+ Database func(name string) *meta.DatabaseInfo

+ ShardGroupsByTimeRange func(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error)

v1.4.3

Jan 30, 2018

v1.4.1

Nov 14, 2017

v1.4.0

Nov 13, 2017

Changes in this version

+ const DefaultBindAddress

+ var Aggregate_AggregateType_name = map[int32]string

+ var Aggregate_AggregateType_value = map[string]int32

+ var BooleanEmptyBatchCursor tsdb.BooleanBatchCursor = &booleanEmptyBatchCursor

+ var ErrIntOverflowPredicate = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowStorage = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthPredicate = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthStorage = fmt.Errorf("proto: negative length found during unmarshaling")

+ var FloatEmptyBatchCursor tsdb.FloatBatchCursor = &floatEmptyBatchCursor

+ var IntegerEmptyBatchCursor tsdb.IntegerBatchCursor = &integerEmptyBatchCursor

+ var Node_Comparison_name = map[int32]string

+ var Node_Comparison_value = map[string]int32

+ var Node_Logical_name = map[int32]string

+ var Node_Logical_value = map[string]int32

+ var Node_Type_name = map[int32]string

+ var Node_Type_value = map[string]int32

+ var ReadResponse_DataType_name = map[int32]string

+ var ReadResponse_DataType_value = map[string]int32

+ var ReadResponse_FrameType_name = map[int32]string

+ var ReadResponse_FrameType_value = map[string]int32

+ var StringEmptyBatchCursor tsdb.StringBatchCursor = &stringEmptyBatchCursor

+ var UnsignedEmptyBatchCursor tsdb.UnsignedBatchCursor = &unsignedEmptyBatchCursor

+ func HasFieldKey(expr influxql.Expr) bool

+ func HasFieldKeyOrValue(expr influxql.Expr) bool

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

+ func PredicateToExprString(p *Predicate) string

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

+ func RewriteExprRemoveFieldKeyAndValue(expr influxql.Expr) influxql.Expr

+ func RewriteExprRemoveFieldValue(expr influxql.Expr) influxql.Expr

+ func WalkNode(v NodeVisitor, node *Node)

+ type Aggregate struct

+ Type Aggregate_AggregateType

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

+ func (*Aggregate) ProtoMessage()

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

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

+ func (m *Aggregate) Reset()

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

+ func (m *Aggregate) String() string

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

+ type Aggregate_AggregateType int32

+ const AggregateTypeCount

+ const AggregateTypeNone

+ const AggregateTypeSum

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

+ func (x Aggregate_AggregateType) String() string

+ type CapabilitiesResponse struct

+ Caps map[string]string

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

+ func (*CapabilitiesResponse) ProtoMessage()

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

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

+ func (m *CapabilitiesResponse) Reset()

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

+ func (m *CapabilitiesResponse) String() string

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

+ type Config struct

+ BindAddress string

+ Enabled bool

+ LogEnabled bool

+ func NewConfig() Config

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

+ type HintsResponse struct

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

+ func (*HintsResponse) ProtoMessage()

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

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

+ func (m *HintsResponse) Reset()

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

+ func (m *HintsResponse) String() string

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

+ type Node struct

+ Children []*Node

+ NodeType Node_Type

+ Value isNode_Value

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

+ func (*Node) ProtoMessage()

+ func (*Node) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *Node) GetBooleanValue() bool

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

+ func (m *Node) GetComparison() Node_Comparison

+ func (m *Node) GetFieldRefValue() string

+ func (m *Node) GetFloatValue() float64

+ func (m *Node) GetIntegerValue() int64

+ func (m *Node) GetLogical() Node_Logical

+ func (m *Node) GetNodeType() Node_Type

+ func (m *Node) GetRegexValue() string

+ func (m *Node) GetStringValue() string

+ func (m *Node) GetTagRefValue() string

+ func (m *Node) GetUnsignedValue() uint64

+ func (m *Node) GetValue() isNode_Value

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

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

+ func (m *Node) Reset()

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

+ func (m *Node) String() string

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

+ type NodeVisitor interface

+ Visit func(*Node) NodeVisitor

+ type Node_BooleanValue struct

+ BooleanValue bool

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

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

+ type Node_Comparison int32

+ const ComparisonEqual

+ const ComparisonGreater

+ const ComparisonGreaterEqual

+ const ComparisonLess

+ const ComparisonLessEqual

+ const ComparisonNotEqual

+ const ComparisonNotRegex

+ const ComparisonRegex

+ const ComparisonStartsWith

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

+ func (x Node_Comparison) String() string

+ type Node_Comparison_ struct

+ Comparison Node_Comparison

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

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

+ type Node_FieldRefValue struct

+ FieldRefValue string

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

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

+ type Node_FloatValue struct

+ FloatValue float64

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

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

+ type Node_IntegerValue struct

+ IntegerValue int64

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

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

+ type Node_Logical int32

+ const LogicalAnd

+ const LogicalOr

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

+ func (x Node_Logical) String() string

+ type Node_Logical_ struct

+ Logical Node_Logical

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

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

+ type Node_RegexValue struct

+ RegexValue string

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

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

+ type Node_StringValue struct

+ StringValue string

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

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

+ type Node_TagRefValue struct

+ TagRefValue string

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

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

+ type Node_Type int32

+ const NodeTypeComparisonExpression

+ const NodeTypeFieldRef

+ const NodeTypeLiteral

+ const NodeTypeLogicalExpression

+ const NodeTypeParenExpression

+ const NodeTypeTagRef

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

+ func (x Node_Type) String() string

+ type Node_UnsignedValue struct

+ UnsignedValue uint64

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

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

+ type Predicate struct

+ Root *Node

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

+ func (*Predicate) ProtoMessage()

+ func (m *Predicate) GetRoot() *Node

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

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

+ func (m *Predicate) Reset()

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

+ func (m *Predicate) String() string

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

+ type ReadRequest struct

+ Aggregate *Aggregate

+ Database string

+ Descending bool

+ Grouping []string

+ PointsLimit uint64

+ Predicate *Predicate

+ SeriesLimit uint64

+ SeriesOffset uint64

+ TimestampRange TimestampRange

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

+ func (*ReadRequest) ProtoMessage()

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

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

+ func (m *ReadRequest) Reset()

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

+ func (m *ReadRequest) String() string

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

+ type ReadResponse struct

+ Frames []ReadResponse_Frame

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

+ func (*ReadResponse) ProtoMessage()

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

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

+ func (m *ReadResponse) Reset()

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

+ func (m *ReadResponse) String() string

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

+ type ReadResponse_BooleanPointsFrame struct

+ Timestamps []int64

+ Values []bool

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

+ func (*ReadResponse_BooleanPointsFrame) ProtoMessage()

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

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

+ func (m *ReadResponse_BooleanPointsFrame) Reset()

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

+ func (m *ReadResponse_BooleanPointsFrame) String() string

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

+ type ReadResponse_DataType int32

+ const DataTypeBoolean

+ const DataTypeFloat

+ const DataTypeInteger

+ const DataTypeString

+ const DataTypeUnsigned

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

+ func (x ReadResponse_DataType) String() string

+ type ReadResponse_FloatPointsFrame struct

+ Timestamps []int64

+ Values []float64

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

+ func (*ReadResponse_FloatPointsFrame) ProtoMessage()

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

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

+ func (m *ReadResponse_FloatPointsFrame) Reset()

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

+ func (m *ReadResponse_FloatPointsFrame) String() string

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

+ type ReadResponse_Frame struct

+ Data isReadResponse_Frame_Data

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

+ func (*ReadResponse_Frame) ProtoMessage()

+ func (*ReadResponse_Frame) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *ReadResponse_Frame) GetBooleanPoints() *ReadResponse_BooleanPointsFrame

+ func (m *ReadResponse_Frame) GetData() isReadResponse_Frame_Data

+ func (m *ReadResponse_Frame) GetFloatPoints() *ReadResponse_FloatPointsFrame

+ func (m *ReadResponse_Frame) GetIntegerPoints() *ReadResponse_IntegerPointsFrame

+ func (m *ReadResponse_Frame) GetSeries() *ReadResponse_SeriesFrame

+ func (m *ReadResponse_Frame) GetStringPoints() *ReadResponse_StringPointsFrame

+ func (m *ReadResponse_Frame) GetUnsignedPoints() *ReadResponse_UnsignedPointsFrame

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

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

+ func (m *ReadResponse_Frame) Reset()

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

+ func (m *ReadResponse_Frame) String() string

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

+ type ReadResponse_FrameType int32

+ const FrameTypePoints

+ const FrameTypeSeries

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

+ func (x ReadResponse_FrameType) String() string

+ type ReadResponse_Frame_BooleanPoints struct

+ BooleanPoints *ReadResponse_BooleanPointsFrame

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

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

+ type ReadResponse_Frame_FloatPoints struct

+ FloatPoints *ReadResponse_FloatPointsFrame

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

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

+ type ReadResponse_Frame_IntegerPoints struct

+ IntegerPoints *ReadResponse_IntegerPointsFrame

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

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

+ type ReadResponse_Frame_Series struct

+ Series *ReadResponse_SeriesFrame

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

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

+ type ReadResponse_Frame_StringPoints struct

+ StringPoints *ReadResponse_StringPointsFrame

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

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

+ type ReadResponse_Frame_UnsignedPoints struct

+ UnsignedPoints *ReadResponse_UnsignedPointsFrame

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

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

+ type ReadResponse_IntegerPointsFrame struct

+ Timestamps []int64

+ Values []int64

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

+ func (*ReadResponse_IntegerPointsFrame) ProtoMessage()

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

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

+ func (m *ReadResponse_IntegerPointsFrame) Reset()

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

+ func (m *ReadResponse_IntegerPointsFrame) String() string

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

+ type ReadResponse_SeriesFrame struct

+ DataType ReadResponse_DataType

+ Tags []Tag

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

+ func (*ReadResponse_SeriesFrame) ProtoMessage()

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

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

+ func (m *ReadResponse_SeriesFrame) Reset()

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

+ func (m *ReadResponse_SeriesFrame) String() string

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

+ type ReadResponse_StringPointsFrame struct

+ Timestamps []int64

+ Values []string

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

+ func (*ReadResponse_StringPointsFrame) ProtoMessage()

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

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

+ func (m *ReadResponse_StringPointsFrame) Reset()

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

+ func (m *ReadResponse_StringPointsFrame) String() string

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

+ type ReadResponse_UnsignedPointsFrame struct

+ Timestamps []int64

+ Values []uint64

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

+ func (*ReadResponse_UnsignedPointsFrame) ProtoMessage()

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

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

+ func (m *ReadResponse_UnsignedPointsFrame) Reset()

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

+ func (m *ReadResponse_UnsignedPointsFrame) String() string

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

+ type ResultSet struct

+ func (r *ResultSet) Close()

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

+ func (r *ResultSet) Next() bool

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

+ type Service struct

+ MetaClient interface{ ... }

+ Store *Store

+ TSDBStore *tsdb.Store

+ func NewService(c Config) *Service

+ func (s *Service) Close() error

+ func (s *Service) Open() error

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

+ type StorageClient interface

+ Capabilities func(ctx context.Context, in *google_protobuf1.Empty) (*CapabilitiesResponse, error)

+ Hints func(ctx context.Context, in *google_protobuf1.Empty) (*HintsResponse, error)

+ Read func(ctx context.Context, in *ReadRequest) (Storage_ReadClient, error)

+ func NewStorageClient(cc *yarpc.ClientConn) StorageClient

+ type StorageServer interface

+ Capabilities func(context.Context, *google_protobuf1.Empty) (*CapabilitiesResponse, error)

+ Hints func(context.Context, *google_protobuf1.Empty) (*HintsResponse, error)

+ Read func(*ReadRequest, Storage_ReadServer) error

+ type Storage_ReadClient interface

+ Recv func() (*ReadResponse, error)

+ type Storage_ReadServer interface

+ Send func(*ReadResponse) error

+ type Store struct

+ Logger zap.Logger

+ MetaClient interface{ ... }

+ TSDBStore *tsdb.Store

+ func NewStore() *Store

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

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

+ type Tag struct

+ Key []byte

+ Value []byte

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

+ func (*Tag) ProtoMessage()

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

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

+ func (m *Tag) Reset()

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

+ func (m *Tag) String() string

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

+ type TimestampRange struct

+ End int64

+ Start int64

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

+ func (*TimestampRange) ProtoMessage()

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

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

+ func (m *TimestampRange) Reset()

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

+ func (m *TimestampRange) String() string

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