Documentation
¶
Index ¶
- type Engine
- func (e *Engine) Close()
- 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(block *bstream.Block, clock *pbsubstreams.Clock, cursor *bstream.Cursor) (execout.ExecutionOutput, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Engine ¶
type Engine struct {
// contains filtered or unexported fields
}
TODO(abourget): this is now something like an execout.LifecycleWriter ?
pipeline.Lifecycle ? to hold also the *pbsubstreams.ModuleOutput so that `ForkHandler` disappears in the end?
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)
Source Files
Click to show internal directories.
Click to hide internal directories.