storage

Documentation

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.