package storage

import "github.com/influxdata/influxdb/cmd/influx_tools/internal/storage"

Index ¶

• type CursorIterator
• func (ci *CursorIterator) Cursor() tsdb.Cursor
• func (ci *CursorIterator) Next() bool
• type MetaClient
• type ReadRequest
• type ResultSet
• func (r *ResultSet) Close()
• func (r *ResultSet) CursorIterator() *CursorIterator
• func (r *ResultSet) Field() []byte
• func (r *ResultSet) FieldType() influxql.DataType
• func (r *ResultSet) Name() []byte
• func (r *ResultSet) Next() bool
• func (r *ResultSet) Tags() models.Tags
• type Store
• func (s *Store) Read(ctx context.Context, req *ReadRequest) (*ResultSet, error)

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.

Source Files ¶

resultset.go series_cursor.go store.go