executor

type ExecutionContext interface {
	Shards(entity tsdb.Entity) ([]tsdb.Shard, error)
	Shard(id common.ShardID) (tsdb.Shard, error)
	ParseTagFamily(family string, item tsdb.Item) (*modelv1.TagFamily, error)
}

type MIterator interface {
	Next() bool

	Current() []*measurev1.DataPoint

	Close() error
}

type MeasureExecutable interface {
	Execute(MeasureExecutionContext) (MIterator, error)
}

type MeasureExecutionContext interface {
	ExecutionContext
	ParseField(name string, item tsdb.Item) (*measurev1.DataPoint_Field, error)
}

type StreamExecutable interface {
	Execute(StreamExecutionContext) ([]*streamv1.Element, error)
}

type StreamExecutionContext interface {
	ExecutionContext
	ParseElementID(item tsdb.Item) (string, error)
}