Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option func(p *Pipeline)
func WithAllowInvalidState ¶
func WithAllowInvalidState() Option
func WithPartialMode ¶
func WithPartialMode() Option
func WithPostBlockHook ¶
func WithPostBlockHook(f substreams.BlockHook) Option
func WithPostJobHook ¶
func WithPostJobHook(f substreams.PostJobHook) Option
func WithPreBlockHook ¶
func WithPreBlockHook(f substreams.BlockHook) Option
func WithStoresSaveInterval ¶
type Pipeline ¶
type Pipeline struct {
// contains filtered or unexported fields
}
func New ¶
func New( ctx context.Context, request *pbsubstreams.Request, graph *manifest.ModuleGraph, blockType string, stateStore dstore.Store, wasmExtensions []wasm.WASMExtensioner, opts ...Option) *Pipeline
func (*Pipeline) BuildNative ¶
func (p *Pipeline) BuildNative(modules []*pbsubstreams.Module) error
func (*Pipeline) HandlerFactory ¶
func (p *Pipeline) HandlerFactory(returnFunc substreams.ReturnFunc) (bstream.Handler, error)
type PipelineOptioner ¶
type PipelineOptioner interface {
PipelineOptions(ctx context.Context, request *pbsubstreams.Request) []Option
}
type StreamFunc ¶
type StreamFunc func() error
Source Files
Click to show internal directories.
Click to hide internal directories.