median

Documentation

Index

• func NewMedianServices(ctx context.Context, jb job.Job, isNewlyCreatedJob bool, relayer loop.Relayer, ...) (srvs []job.ServiceCtx, err error)
• type MedianConfig
  • func NewMedianConfig(jobPipelineMaxSuccessfulRuns uint64, pluginProcessCfg plugins.RegistrarConfig) MedianConfig
• type Plugin
  • func NewPlugin(lggr logger.Logger) *Plugin
  • func (p *Plugin) NewMedianFactory(ctx context.Context, provider types.MedianProvider, ...) (loop.ReportingPluginFactory, error)

Functions

func NewMedianServices

func NewMedianServices(ctx context.Context,
	jb job.Job,
	isNewlyCreatedJob bool,
	relayer loop.Relayer,
	pipelineRunner pipeline.Runner,
	runResults chan *pipeline.Run,
	lggr logger.Logger,
	argsNoPlugin libocr.OCR2OracleArgs,
	cfg MedianConfig,
	chEnhancedTelem chan ocrcommon.EnhancedTelemetryData,
	errorLog loop.ErrorLog,

) (srvs []job.ServiceCtx, err error)

Types

type MedianConfig

type MedianConfig interface {
	JobPipelineMaxSuccessfulRuns() uint64
	plugins.RegistrarConfig
}

func NewMedianConfig

func NewMedianConfig(jobPipelineMaxSuccessfulRuns uint64, pluginProcessCfg plugins.RegistrarConfig) MedianConfig

type Plugin

type Plugin struct {
	plugins.Base
	// contains filtered or unexported fields
}

func NewPlugin

func NewPlugin(lggr logger.Logger) *Plugin

func (*Plugin) NewMedianFactory

func (p *Plugin) NewMedianFactory(ctx context.Context, provider types.MedianProvider, dataSource, juelsPerFeeCoin median.DataSource, errorLog loop.ErrorLog) (loop.ReportingPluginFactory, error)