Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunModule ¶
func RunModule(ctx context.Context, executor ModuleExecutor, execOutput execout.ExecutionOutput) (*pbsubstreams.ModuleOutput, error)
Types ¶
type BaseExecutor ¶
type BaseExecutor struct {
// contains filtered or unexported fields
}
type ErrorExecutor ¶
type ErrorExecutor struct {
// contains filtered or unexported fields
}
func (*ErrorExecutor) Error ¶
func (e *ErrorExecutor) Error() string
type MapperModuleExecutor ¶
type MapperModuleExecutor struct {
BaseExecutor
// contains filtered or unexported fields
}
func NewMapperModuleExecutor ¶
func NewMapperModuleExecutor(baseExecutor *BaseExecutor, outputType string) *MapperModuleExecutor
func (*MapperModuleExecutor) Name ¶
func (e *MapperModuleExecutor) Name() string
Name implements ModuleExecutor
func (*MapperModuleExecutor) Reset ¶
func (e *MapperModuleExecutor) Reset()
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
// Reset the wasm instance, avoid propagating logs.
Reset()
// contains filtered or unexported methods
}
type StoreModuleExecutor ¶
type StoreModuleExecutor struct {
BaseExecutor
// contains filtered or unexported fields
}
func NewStoreModuleExecutor ¶
func NewStoreModuleExecutor(baseExecutor *BaseExecutor, outputStore store.DeltaAccessor) *StoreModuleExecutor
func (*StoreModuleExecutor) Name ¶
func (e *StoreModuleExecutor) Name() string
func (*StoreModuleExecutor) Reset ¶
func (e *StoreModuleExecutor) Reset()
func (*StoreModuleExecutor) String ¶
func (e *StoreModuleExecutor) String() string
Click to show internal directories.
Click to hide internal directories.