Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseExecutor ¶
type BaseExecutor struct {
// contains filtered or unexported fields
}
type MapperModuleExecutor ¶
type MapperModuleExecutor struct {
*BaseExecutor
// contains filtered or unexported fields
}
func (*MapperModuleExecutor) String ¶
func (e *MapperModuleExecutor) String() string
type ModuleExecutor ¶
type ModuleExecutor interface {
String() string
// contains filtered or unexported methods
}
func OptimizeExecutors ¶
func OptimizeExecutors(moduleOutputCache map[string]*outputCache, moduleExecutors []ModuleExecutor, requestedOutputStores []string) (optimizedModuleExecutors []ModuleExecutor, skipBlockSource bool)
type ModulesOutputCache ¶
type ModulesOutputCache struct {
// contains filtered or unexported fields
}
func NewModuleOutputCache ¶
func NewModuleOutputCache() *ModulesOutputCache
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, baseStateStore dstore.Store, baseOutputCacheStore dstore.Store, wasmExtensions []wasm.WASMExtensioner, blocksFunc func(ctx context.Context, r *pbsubstreams.Request) error, opts ...Option) *Pipeline
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 StoreModuleExecutor ¶
type StoreModuleExecutor struct {
*BaseExecutor
// contains filtered or unexported fields
}
func (*StoreModuleExecutor) String ¶
func (e *StoreModuleExecutor) String() string
Source Files
Click to show internal directories.
Click to hide internal directories.