median

package
v2.7.0-beta0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 24, 2023 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 added in v2.2.0

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

type Plugin added in v2.2.0

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

func NewPlugin added in v2.2.0

func NewPlugin(lggr logger.Logger) *Plugin

func (*Plugin) NewMedianFactory added in v2.2.0

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL