storage

package
v1.7.3 Latest Latest
Warning

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

Go to latest
Published: Jan 13, 2019 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CursorIterator

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

func (*CursorIterator) Cursor

func (ci *CursorIterator) Cursor() tsdb.Cursor

func (*CursorIterator) Next

func (ci *CursorIterator) Next() bool

type MetaClient

type MetaClient interface {
	ShardGroupsByTimeRange(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error)
}

type ReadRequest

type ReadRequest struct {
	Database string
	RP       string
	Shards   []*tsdb.Shard
	Start    int64 // start time
	End      int64 // end time
}

Request message for Storage.Read.

type ResultSet

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

func (*ResultSet) Close

func (r *ResultSet) Close()

func (*ResultSet) CursorIterator

func (r *ResultSet) CursorIterator() *CursorIterator

func (*ResultSet) Field

func (r *ResultSet) Field() []byte

func (*ResultSet) FieldType

func (r *ResultSet) FieldType() influxql.DataType

func (*ResultSet) Name

func (r *ResultSet) Name() []byte

func (*ResultSet) Next

func (r *ResultSet) Next() bool

Next moves to the result set forward to the next series key.

func (*ResultSet) Tags

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

type Store

type Store struct {
	TSDBStore *tsdb.Store
}

func (*Store) Read

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

Read creates a ResultSet that reads all points with a timestamp ts, such that start ≤ ts < end.

Jump to

Keyboard shortcuts

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