execout

package
v0.0.21 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 31, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var NotFound = errors.New("inputs module value not found")

Functions

This section is empty.

Types

type CacheEngine

type CacheEngine interface {
	NewExecOutput(blockType string, block *bstream.Block, clock *pbsubstreams.Clock, cursor *bstream.Cursor) (ExecutionOutput, error)
	Init(modules *manifest.ModuleHashes) error

	EndOfStream(blockNum uint64) error
	HandleFinal(clock *pbsubstreams.Clock) error
	HandleUndo(clock *pbsubstreams.Clock, moduleName string)
}

func NewNoOpCache

func NewNoOpCache() CacheEngine

type ExecOutputMap

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

func NewExecOutputMap

func NewExecOutputMap(blockType string, block *bstream.Block, clock *pbsubstreams.Clock) (*ExecOutputMap, error)

func (*ExecOutputMap) Clock

func (i *ExecOutputMap) Clock() *pbsubstreams.Clock

func (*ExecOutputMap) Get

func (i *ExecOutputMap) Get(moduleName string) (value []byte, cached bool, err error)

func (*ExecOutputMap) Set

func (i *ExecOutputMap) Set(moduleName string, value []byte) (err error)

type ExecutionOutput

type ExecutionOutput interface {
	ExecutionOutputGetter
	ExecutionOutputSetter
}

ExecutionOutput Execution output for a given graph at a given block

type ExecutionOutputGetter

type ExecutionOutputGetter interface {
	Clock() *pbsubstreams.Clock
	Get(name string) (value []byte, cached bool, err error)
}

type ExecutionOutputSetter

type ExecutionOutputSetter interface {
	Set(name string, value []byte) (err error)
}

type NoOpCache

type NoOpCache struct {
}

func (*NoOpCache) EndOfStream

func (n *NoOpCache) EndOfStream(blockNum uint64) error

func (*NoOpCache) HandleFinal

func (n *NoOpCache) HandleFinal(clock *pbsubstreams.Clock) error

func (*NoOpCache) HandleUndo

func (n *NoOpCache) HandleUndo(clock *pbsubstreams.Clock, moduleName string)

func (*NoOpCache) Init

func (n *NoOpCache) Init(modules *manifest.ModuleHashes) error

func (*NoOpCache) NewBlock

func (n *NoOpCache) NewBlock(blockRef bstream.BlockRef, step bstream.StepType) error

func (*NoOpCache) NewExecOutput

func (n *NoOpCache) NewExecOutput(blockType string, block *bstream.Block, clock *pbsubstreams.Clock, cursor *bstream.Cursor) (ExecutionOutput, error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL