transform

Documentation

Index

• type BlockBuilder
• type Controller
  • func (t *Controller) AddTransform(node OpNode)
  • func (t *Controller) BlockBuilder(blockMeta storage.BlockMetadata) (BlockBuilder, error)
  • func (t *Controller) Process(block storage.Block) error
• type OpNode
• type Options

Types

type BlockBuilder

type BlockBuilder interface {
	AppendValue(index int, value float64)
	Build() storage.Block
}

BlockBuilder builds a new block

type Controller

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

Controller controls the caching and forwarding the request to downstream.

func (*Controller) AddTransform

func (t *Controller) AddTransform(node OpNode)

AddTransform adds a dependent transformation to the controller

func (*Controller) BlockBuilder

func (t *Controller) BlockBuilder(blockMeta storage.BlockMetadata) (BlockBuilder, error)

BlockBuilder returns a BlockBuilder instance with associated metadata nolint: unparam

func (*Controller) Process

func (t *Controller) Process(block storage.Block) error

Process performs processing on the underlying transforms

type OpNode

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

OpNode represents the execution node

type Options

type Options struct {
	Now time.Time
}

Options to create transform nodes