transform

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

type Controller struct {
	ID parser.NodeID
	// contains filtered or unexported fields
}

type MetaNode interface {
	// Meta provides the block metadata for the block using the input blocks' metadata as input
	Meta(meta block.Metadata) block.Metadata
	// SeriesMeta provides the series metadata for the block using the previous blocks' series metadata as input
	SeriesMeta(metas []block.SeriesMeta) []block.SeriesMeta
}

type OpNode interface {
	Process(ID parser.NodeID, block block.Block) error
}

type Options struct {
	TimeSpec TimeSpec
	Debug    bool
}

type Params interface {
	parser.Params
	Node(controller *Controller) OpNode
}

type SeriesNode interface {
	MetaNode
	ProcessSeries(series block.Series) (block.Series, error)
}

type StepNode interface {
	MetaNode
	ProcessStep(step block.Step) (block.Step, error)
}

type TimeSpec struct {
	Start time.Time
	End   time.Time
	// Now captures the current time and fixes it throughout the request, we may let people override it in the future
	Now  time.Time
	Step time.Duration
}