medianpoc

Documentation

Index

• type DataSource
  • func (d *DataSource) Observe(ctx context.Context, reportTimestamp ocrtypes.ReportTimestamp) (*big.Int, error)
• type Plugin
  • func NewPlugin(lggr logger.Logger) *Plugin
  • func (p *Plugin) NewReportingPluginFactory(ctx context.Context, config types.ReportingPluginServiceConfig, ...) (types.ReportingPluginFactory, error)

Types

type DataSource

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

func (*DataSource) Observe

func (d *DataSource) Observe(ctx context.Context, reportTimestamp ocrtypes.ReportTimestamp) (*big.Int, error)

type Plugin

type Plugin struct {
	loop.Plugin

	reportingplugins.MedianProviderServer
	// contains filtered or unexported fields
}

func NewPlugin

func NewPlugin(lggr logger.Logger) *Plugin

func (*Plugin) NewReportingPluginFactory

func (p *Plugin) NewReportingPluginFactory(
	ctx context.Context,
	config types.ReportingPluginServiceConfig,
	provider types.MedianProvider,
	pipelineRunner types.PipelineRunnerService,
	telemetry types.TelemetryClient,
	errorLog types.ErrorLog,
) (types.ReportingPluginFactory, error)