Versions in this module Expand all Collapse all v0 v0.0.21 Oct 31, 2022 Changes in this version + var NotFound = errors.New("inputs module value not found") + type CacheEngine interface + EndOfStream func(blockNum uint64) error + HandleFinal func(clock *pbsubstreams.Clock) error + HandleUndo func(clock *pbsubstreams.Clock, moduleName string) + Init func(modules *manifest.ModuleHashes) error + NewExecOutput func(blockType string, block *bstream.Block, clock *pbsubstreams.Clock, ...) (ExecutionOutput, error) + func NewNoOpCache() CacheEngine + type ExecOutputMap struct + func NewExecOutputMap(blockType string, block *bstream.Block, clock *pbsubstreams.Clock) (*ExecOutputMap, error) + func (i *ExecOutputMap) Clock() *pbsubstreams.Clock + func (i *ExecOutputMap) Get(moduleName string) (value []byte, cached bool, err error) + func (i *ExecOutputMap) Set(moduleName string, value []byte) (err error) + type ExecutionOutput interface + type ExecutionOutputGetter interface + Clock func() *pbsubstreams.Clock + Get func(name string) (value []byte, cached bool, err error) + type ExecutionOutputSetter interface + Set func(name string, value []byte) (err error) + type NoOpCache struct + func (n *NoOpCache) EndOfStream(blockNum uint64) error + func (n *NoOpCache) HandleFinal(clock *pbsubstreams.Clock) error + func (n *NoOpCache) HandleUndo(clock *pbsubstreams.Clock, moduleName string) + func (n *NoOpCache) Init(modules *manifest.ModuleHashes) error + func (n *NoOpCache) NewBlock(blockRef bstream.BlockRef, step bstream.StepType) error + func (n *NoOpCache) NewExecOutput(blockType string, block *bstream.Block, clock *pbsubstreams.Clock, ...) (ExecutionOutput, error)
Go to main page