conduit

type Completed interface {
	// OnComplete is called by the Conduit framework when the pipeline
	// finishes processing a round. It will not be invoked unless all plugins
	// have successfully processed the given round.
	OnComplete(input data.BlockData) error
}

type OnCompleteFunc func(input data.BlockData) error

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

type PluginMetrics interface {
	// ProvideMetrics is called by the Conduit framework after the `Init`
	// phase, and before the pipeline starts. The metric collectors are
	// provided to the metrics endpoint which is optionally enabled in the
	// Conduit configuration file.
	ProvideMetrics(subsystem string) []prometheus.Collector
}

type ProvideMetricsFunc func() []prometheus.Collector

type RoundRequestor interface {
	// RoundRequest is called by the Conduit framework prior to `Init`.
	// This allows plugins with specific round requirements to override
	// the automatic round tracking provided by the Conduit pipeline.
	//
	// There are a few cases where this can be problematic. In these cases
	// an error will be generated and Conduit will fail to launch:
	// 1. Conduit is launched with --next-round-override
	// 2. Multiple plugins request a round override and the requested
	//    rounds are different.
	//
	// If it becomes common for multiple round overrides to be provided,
	// we will add an option to select which override to use. For example,
	// the override rule could be "command-line", "oldest", or the name
	// of a plugin which should be preferred.
	RoundRequest(config plugins.PluginConfig) (uint64, error)
}