comm

type CallOption struct {
	Call *influxql.Call
	Ref  *influxql.VarRef
}

type Cursor interface {
	SetOps(ops []*CallOption)
	Next() (*record.Record, error)
	Close() error
	StartSpan(span *tracing.Span)
	EndSpan()
}

type Cursors []Cursor

type ExprOptions struct {
	Expr influxql.Expr
	Ref  influxql.VarRef
}

type FileInfo struct {
	MinTime    int64
	MaxTime    int64
	SeriesInfo SeriesInfoIntf
}

type KeyCursor interface {
	SetOps(ops []*CallOption)
	SinkPlan(plan hybridqp.QueryNode)
	Next() (*record.Record, SeriesInfoIntf, error)
	Name() string
	Close() error
	GetSchema() record.Schemas
	StartSpan(span *tracing.Span)
	EndSpan()
	NextAggData() (*record.Record, *FileInfo, error)
}

type KeyCursors []KeyCursor

type SeriesInfoIntf interface {
	GetSeriesKey() []byte
	GetSeriesTags() *influx.PointTags
	GetSid() uint64
	Set(sid uint64, key []byte, tags *influx.PointTags)
}

type TSIndexInfo interface {
	// SetCursors used to set the created groupCursor
	SetCursors([]KeyCursor)
	// GetCursors used to get the created groupCursor
	GetCursors() []KeyCursor
	// IsEmpty used to check whether is empty based on groupCursor.
	IsEmpty() bool
	// Ref used to add reference counting to the file of the immTables, memTables and TagSetInfos.
	Ref()
	// Unref used to release reference counting to the file of the immTables, memTables and TagSetInfos.
	Unref()
}

type TimeCutKeyCursor interface {
	KeyCursor
	UpdateTime(time int64)
}