pipeline

type BaseExecutor struct {
	// contains filtered or unexported fields
}

type DeltaGetter interface {
	GetDeltas() []*pbsubstreams.StoreDelta
}

type ErrorExecutor struct {
	// contains filtered or unexported fields
}

type ForkHandler struct {
	// contains filtered or unexported fields
}

type MapperModuleExecutor struct {
	BaseExecutor
	// contains filtered or unexported fields
}

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 Option func(p *Pipeline)

type Pipeline struct {
	// contains filtered or unexported fields
}

type PipelineOptioner interface {
	PipelineOptions(ctx context.Context, request *pbsubstreams.Request) []Option
}

type StoreModuleExecutor struct {
	BaseExecutor
	// contains filtered or unexported fields
}