processor

Documentation

Index

• Constants
• type ActorProcessor
• type IndexerProcessors
  • func MakeProcessors(api tasks.DataSource, indexerTasks []string) (*IndexerProcessors, error)
• type ReportProcessor
• type Result
• type StateProcessor
  • func New(api tasks.DataSource, name string, taskNames []string) (*StateProcessor, error)
  • func (sp *StateProcessor) State(ctx context.Context, current, executed *types.TipSet) (chan *Result, []string)
• type TipSetProcessor
• type TipSetsProcessor

Constants

const BuiltinTaskName = "builtin"

Types

type ActorProcessor

type ActorProcessor interface {
	// ProcessActors processes a set of actors. If error is non-nil then the processor encountered a fatal error.
	// Any data returned must be accompanied by a processing report.
	// Implementations of this interface must abort processing when their context is canceled.
	ProcessActors(ctx context.Context, current *types.TipSet, executed *types.TipSet, actors tasks.ActorStateChangeDiff) (model.Persistable, *visormodel.ProcessingReport, error)
}

type IndexerProcessors

type IndexerProcessors struct {
	TipsetProcessors  map[string]TipSetProcessor
	TipsetsProcessors map[string]TipSetsProcessor
	ActorProcessors   map[string]ActorProcessor
	ReportProcessors  map[string]ReportProcessor
}

func MakeProcessors

func MakeProcessors(api tasks.DataSource, indexerTasks []string) (*IndexerProcessors, error)

type ReportProcessor

type ReportProcessor interface {
	// ProcessTipSet processes a tipset. If error is non-nil then the processor encountered a fatal error.
	// Implementations of this interface must abort processing when their context is canceled.
	ProcessTipSet(ctx context.Context, current *types.TipSet) (visormodel.ProcessingReportList, error)
}

type Result

type Result struct {
	Task        string
	Error       error
	Report      visormodel.ProcessingReportList
	Data        model.Persistable
	StartedAt   time.Time
	CompletedAt time.Time
}

A Result is either some data to persist or an error which indicates that the task did not complete. Partial completions are possibly provided the Data contains a persistable log of the results.

type StateProcessor

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

func New

func New(api tasks.DataSource, name string, taskNames []string) (*StateProcessor, error)

func (*StateProcessor) State

func (sp *StateProcessor) State(ctx context.Context, current, executed *types.TipSet) (chan *Result, []string)

State executes its configured processors in parallel, processing the state in `current` and `executed. The return channel emits results of the state extraction closing when processing is completed. It is the responsibility of the processors to abort if its context is canceled. A list of all tasks executing is returned.

type TipSetProcessor

type TipSetProcessor interface {
	// ProcessTipSet processes a tipset. If error is non-nil then the processor encountered a fatal error.
	// Any data returned must be accompanied by a processing report.
	// Implementations of this interface must abort processing when their context is canceled.
	ProcessTipSet(ctx context.Context, current *types.TipSet) (model.Persistable, *visormodel.ProcessingReport, error)
}

type TipSetsProcessor

type TipSetsProcessor interface {
	// ProcessTipSets processes sequential tipsts (a parent and a child, or an executed and a current). If error is non-nil then the processor encountered a fatal error.
	// Any data returned must be accompanied by a processing report.
	// Implementations of this interface must abort processing when their context is canceled.
	ProcessTipSets(ctx context.Context, current *types.TipSet, executed *types.TipSet) (model.Persistable, *visormodel.ProcessingReport, error)
}