Versions in this module Expand all Collapse all v0 v0.9.4 May 21, 2019 Changes in this version + func NewLazyNode(node OpNode, controller *Controller) (OpNode, *Controller) + func ProcessSimpleBlock(node simpleOpNode, controller *Controller, queryCtx *models.QueryContext, ...) error + type BlockCache struct + func NewBlockCache() *BlockCache + func (c *BlockCache) Add(key parser.NodeID, b block.Block) error + func (c *BlockCache) Get(key parser.NodeID) (block.Block, bool) + func (c *BlockCache) Remove(key parser.NodeID) + type BoundOp interface + Bounds func() BoundSpec + type BoundSpec struct + Offset time.Duration + Range time.Duration + type Controller struct + ID parser.NodeID + func (t *Controller) AddTransform(node OpNode) + func (t *Controller) BlockBuilder(queryCtx *models.QueryContext, blockMeta block.Metadata, ...) (block.Builder, error) + func (t *Controller) HasMultipleOperations() bool + func (t *Controller) Process(queryCtx *models.QueryContext, block block.Block) error + type MetaNode interface + Meta func(meta block.Metadata) block.Metadata + SeriesMeta func(metas []block.SeriesMeta) []block.SeriesMeta + type MockOpNode struct + func NewMockOpNode(ctrl *gomock.Controller) *MockOpNode + func (m *MockOpNode) EXPECT() *MockOpNodeMockRecorder + func (m *MockOpNode) Process(arg0 *models.QueryContext, arg1 parser.NodeID, arg2 block.Block) error + type MockOpNodeMockRecorder struct + func (mr *MockOpNodeMockRecorder) Process(arg0, arg1, arg2 interface{}) *gomock.Call + type MocksimpleOpNode struct + func NewMocksimpleOpNode(ctrl *gomock.Controller) *MocksimpleOpNode + func (m *MocksimpleOpNode) EXPECT() *MocksimpleOpNodeMockRecorder + func (m *MocksimpleOpNode) Params() parser.Params + func (m *MocksimpleOpNode) ProcessBlock(queryCtx *models.QueryContext, ID parser.NodeID, b block.Block) (block.Block, error) + type MocksimpleOpNodeMockRecorder struct + func (mr *MocksimpleOpNodeMockRecorder) Params() *gomock.Call + func (mr *MocksimpleOpNodeMockRecorder) ProcessBlock(queryCtx, ID, b interface{}) *gomock.Call + type OpNode interface + Process func(queryCtx *models.QueryContext, ID parser.NodeID, block block.Block) error + type Options struct + BlockType models.FetchedBlockType + Debug bool + TimeSpec TimeSpec + type Params interface + Node func(controller *Controller, opts Options) OpNode + type SeriesNode interface + ProcessSeries func(series block.Series) (block.Series, error) + type StepNode interface + ProcessStep func(step block.Step) (block.Step, error) + type TimeSpec struct + End time.Time + Now time.Time + Start time.Time + Step time.Duration + func (ts TimeSpec) Bounds() models.Bounds
Go to main page