Documentation ¶
Index ¶
- func BuildRequestDetails(request *pbsubstreams.Request, isSubRequest bool, ...) (req *reqctx.RequestDetails, err error)
- func NewStoreBoundary(interval uint64, requestStartBlockNum uint64, requestStopBlock uint64) *storeBoundary
- type ForkHandler
- type Option
- type Pipeline
- func (p *Pipeline) GetStoreMap() store.Map
- func (p *Pipeline) InitStoresAndBackprocess(ctx context.Context) (err error)
- func (p *Pipeline) InitWASM(ctx context.Context) (err error)
- func (p *Pipeline) OnStreamTerminated(ctx context.Context, streamSrv Trailable, err error) error
- func (p *Pipeline) ProcessBlock(block *bstream.Block, obj interface{}) (err error)
- type PipelineOptioner
- type Stores
- type Trailable
- type UndoHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildRequestDetails ¶ added in v0.1.0
func BuildRequestDetails(request *pbsubstreams.Request, isSubRequest bool, isOutputModule reqctx.IsOutputModuleFunc, getRecentFinalBlock getRecentFinalBlockFunc) (req *reqctx.RequestDetails, err error)
func NewStoreBoundary ¶ added in v0.0.21
Types ¶
type ForkHandler ¶ added in v0.0.20
type ForkHandler struct {
// contains filtered or unexported fields
}
TODO(abourget): The scope of this object and the Engine
are not pretty similar, to keep track of certain pieces of info that are reversible, and handle the back and forth between undos and redos. Perhaps what we could have here, is have those undo handlers live on the Pipeline (where it makes sense) and have some nested structs handle
func NewForkHandler ¶ added in v0.0.21
func NewForkHandler() *ForkHandler
type Option ¶
type Option func(p *Pipeline)
func WithPostBlockHook ¶
func WithPostBlockHook(f substreams.BlockHook) Option
func WithPostJobHook ¶
func WithPostJobHook(f substreams.PostJobHook) Option
func WithPreBlockHook ¶
func WithPreBlockHook(f substreams.BlockHook) Option
type Pipeline ¶
type Pipeline struct {
// contains filtered or unexported fields
}
func (*Pipeline) GetStoreMap ¶ added in v0.1.0
func (*Pipeline) InitStoresAndBackprocess ¶ added in v0.2.0
func (*Pipeline) OnStreamTerminated ¶ added in v0.1.0
OnStreamTerminated performs flush of store and setting trailers when the stream terminated gracefully from our point of view. If the stream terminated gracefully, we return `nil` otherwise, the original is returned.
type PipelineOptioner ¶
type PipelineOptioner interface {
PipelineOptions(ctx context.Context, request *pbsubstreams.Request) []Option
}
type Stores ¶ added in v0.1.0
func (*Stores) SetStoreMap ¶ added in v0.1.0
type UndoHandler ¶ added in v0.0.21
type UndoHandler func(clock *pbsubstreams.Clock, moduleOutputs []*pbsubstreams.ModuleOutput)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.