execout

Documentation

Index

• Variables
• type CacheEngine
  • func NewNoOpCache() CacheEngine
• type ExecOutputMap
  • 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
• type ExecutionOutputGetter
• type ExecutionOutputSetter
• type NoOpCache
  • 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)

Variables

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

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)