Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SynchronizeStores ¶
func SynchronizeStores( ctx context.Context, grpcClient pbsubstreams.StreamClient, grpcCallOpts []grpc.CallOption, request *pbsubstreams.Request, builders map[string]*state.Builder, upToBlockNum uint64, returnFunc substreams.ReturnFunc, ) error
Types ¶
type BaseExecutor ¶
type BaseExecutor struct {
// contains filtered or unexported fields
}
type MapperModuleExecutor ¶
type MapperModuleExecutor struct {
BaseExecutor
// contains filtered or unexported fields
}
func (*MapperModuleExecutor) Name ¶
func (e *MapperModuleExecutor) Name() string
Name implements ModuleExecutor
func (*MapperModuleExecutor) String ¶
func (e *MapperModuleExecutor) String() string
type ModuleExecutor ¶
type ModuleExecutor interface {
// Name returns the name of the module as defined in the manifest.
Name() string
// String returns the module executor representation, usually its name directly.
String() string
// contains filtered or unexported methods
}
func OptimizeExecutors ¶
func OptimizeExecutors(moduleOutputCache map[string]*outputs.OutputCache, moduleExecutors []ModuleExecutor, requestedOutputStores []string) (optimizedModuleExecutors []ModuleExecutor, skipBlockSource bool)
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, outputCacheSaveBlockInterval uint64, wasmExtensions []wasm.WASMExtensioner, grpcClient pbsubstreams.StreamClient, grpcCallOpts []grpc.CallOption, opts ...Option) *Pipeline
func (*Pipeline) HandlerFactory ¶
func (p *Pipeline) HandlerFactory(returnFunc substreams.ReturnFunc, progressFunc substreams.ProgressFunc) (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) Name ¶
func (e *StoreModuleExecutor) Name() string
Name implements ModuleExecutor
func (*StoreModuleExecutor) String ¶
func (e *StoreModuleExecutor) String() string
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.