storage

package

v1.7.9 Latest Latest Go to latest Published: Oct 27, 2019 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

func (ci *CursorIterator) Next() bool

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

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 struct {
	// contains filtered or unexported fields
}

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

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

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

type Store struct {
	TSDBStore *tsdb.Store
}

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.