pipeline

Documentation

Index

• type Pipeline
  • func NewPipeline(o PipelineOpts) *Pipeline
  • func (md *Pipeline) Run(ctx context.Context, blockNumber uint64) error
• type PipelineOpts

Types

type Pipeline

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

func NewPipeline

func NewPipeline(o PipelineOpts) *Pipeline

func (*Pipeline) Run

func (md *Pipeline) Run(ctx context.Context, blockNumber uint64) error

Run is the task executor which runs in its own goroutine and does the following: 1. Fetches the block and all transactional data 2. Passes the block through all filters 3. Commits the block to store as successfully processed

Note: - Blocks are processed atomically, a failure in-between will process the block from the start - Therefore, any side effect/event sink in the filter should support dedup

type PipelineOpts

type PipelineOpts struct {
	BlockFetcher fetch.Fetch
	Filters      []filter.Filter
	Logg         logf.Logger
	Store        store.Store[pgx.Rows]
}