pipeline

Documentation

Index

• type ModuleExecutor
• type ModuleOutputCache
  • func NewModuleOutputCache(modules []*pbsubstreams.Module) *ModuleOutputCache
• type Option
  • func WithAllowInvalidState() Option
  • func WithPartialMode() Option
  • func WithPostBlockHook(f substreams.BlockHook) Option
  • func WithPostJobHook(f substreams.PostJobHook) Option
  • func WithPreBlockHook(f substreams.BlockHook) Option
  • func WithStoresSaveInterval(seconds uint64) Option
• type Pipeline
  • func New(ctx context.Context, request *pbsubstreams.Request, ...) *Pipeline
  • func (p *Pipeline) HandlerFactory(returnFunc substreams.ReturnFunc) (bstream.Handler, error)
  • func (p *Pipeline) SynchronizeStores(ctx context.Context) error
• type PipelineOptioner
• type Printer
• type StreamFunc

Types

type ModuleExecutor

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

type ModuleOutputCache

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

func NewModuleOutputCache

func NewModuleOutputCache(modules []*pbsubstreams.Module) *ModuleOutputCache

NewModuleOutputCache will initialize an ModuleOutputCache struct

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

func WithStoresSaveInterval(seconds uint64) Option

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) HandlerFactory

func (p *Pipeline) HandlerFactory(returnFunc substreams.ReturnFunc) (bstream.Handler, error)

func (*Pipeline) SynchronizeStores

func (p *Pipeline) SynchronizeStores(ctx context.Context) error

type PipelineOptioner

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

type Printer

type Printer interface {
	Print()
}

type StreamFunc

type StreamFunc func() error