cache

Documentation

Index

• type Engine
  • func NewEngine(ctx context.Context, execOutWriters map[string]*execout.Writer, ...) (*Engine, error)
  • func (e *Engine) EndOfStream(lastFinalClock *pbsubstreams.Clock) error
  • func (e *Engine) HandleFinal(clock *pbsubstreams.Clock) error
  • func (e *Engine) HandleStalled(clock *pbsubstreams.Clock) error
  • func (e *Engine) HandleUndo(clock *pbsubstreams.Clock)
  • func (e *Engine) NewBuffer(optionalBlock *pbbstream.Block, clock *pbsubstreams.Clock, ...) (execout.ExecutionOutput, error)

Types

type Engine

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

Engine manages the reversible segments and keeps track of the execution output between each module's.

Upon Finality, it writes it to some output cache files.

func NewEngine

func NewEngine(ctx context.Context, execOutWriters map[string]*execout.Writer, blockType string, existingExecOuts map[string]*execout.File, indexWriters map[string]*index.Writer) (*Engine, error)

func (*Engine) EndOfStream

func (e *Engine) EndOfStream(lastFinalClock *pbsubstreams.Clock) error

func (*Engine) HandleFinal

func (e *Engine) HandleFinal(clock *pbsubstreams.Clock) error

func (*Engine) HandleStalled

func (e *Engine) HandleStalled(clock *pbsubstreams.Clock) error

func (*Engine) HandleUndo

func (e *Engine) HandleUndo(clock *pbsubstreams.Clock)

func (*Engine) NewBuffer

func (e *Engine) NewBuffer(optionalBlock *pbbstream.Block, clock *pbsubstreams.Clock, cursor *bstream.Cursor) (execout.ExecutionOutput, error)