functions

Documentation

Index

• Constants
• func Aggregate(aggMethod config.AggregationMethod, observations []*encoding.ProcessedRequest) (*encoding.ProcessedRequest, error)
• func CanAggregate(N int, F int, observations []*encoding.ProcessedRequest) bool
• func NewConnector(gwcCfg *connector.ConnectorConfig, ethKeystore keystore.Eth, chainID *big.Int, ...) (connector.GatewayConnector, error)
• func NewFunctionsServices(sharedOracleArgs *libocr2.OCR2OracleArgs, conf *FunctionsServicesConfig) ([]job.ServiceCtx, error)
• type FunctionsReportingPluginFactory
  • func (f FunctionsReportingPluginFactory) NewReportingPlugin(rpConfig types.ReportingPluginConfig) (types.ReportingPlugin, types.ReportingPluginInfo, error)
• type FunctionsServicesConfig

Constants

const (
	FunctionsBridgeName     string = "ea_bridge"
	MaxAdapterResponseBytes int64  = 1_000_000
)

Functions

func Aggregate

func Aggregate(aggMethod config.AggregationMethod, observations []*encoding.ProcessedRequest) (*encoding.ProcessedRequest, error)

func CanAggregate

func CanAggregate(N int, F int, observations []*encoding.ProcessedRequest) bool

func NewConnector

func NewConnector(gwcCfg *connector.ConnectorConfig, ethKeystore keystore.Eth, chainID *big.Int, lggr logger.Logger) (connector.GatewayConnector, error)

func NewFunctionsServices

func NewFunctionsServices(sharedOracleArgs *libocr2.OCR2OracleArgs, conf *FunctionsServicesConfig) ([]job.ServiceCtx, error)

Create all OCR2 plugin Oracles and all extra services needed to run a Functions job.

Types

type FunctionsReportingPluginFactory

type FunctionsReportingPluginFactory struct {
	Logger    commontypes.Logger
	PluginORM functions.ORM
	JobID     uuid.UUID
}

func (FunctionsReportingPluginFactory) NewReportingPlugin

func (f FunctionsReportingPluginFactory) NewReportingPlugin(rpConfig types.ReportingPluginConfig) (types.ReportingPlugin, types.ReportingPluginInfo, error)

NewReportingPlugin complies with ReportingPluginFactory

type FunctionsServicesConfig

type FunctionsServicesConfig struct {
	Job             job.Job
	JobORM          job.ORM
	BridgeORM       bridges.ORM
	OCR2JobConfig   pg.QConfig
	DB              *sqlx.DB
	Chain           evm.Chain
	ContractID      string
	Lggr            logger.Logger
	MailMon         *utils.MailboxMonitor
	URLsMonEndpoint commontypes.MonitoringEndpoint
	EthKeystore     keystore.Eth
}