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(ctx context.Context, pluginConfig *config.PluginConfig, ...) (connector.GatewayConnector, error)
• func NewFunctionsServices(ctx context.Context, ...) ([]job.ServiceCtx, error)
• func ShouldIncludeCoordinator(requestCoordinator *common.Address, reportCoordinator *common.Address) (*common.Address, error)
• type FunctionsReportingPluginFactory
  • func (f FunctionsReportingPluginFactory) NewReportingPlugin(rpConfig types.ReportingPluginConfig) (types.ReportingPlugin, types.ReportingPluginInfo, error)
• type FunctionsServicesConfig

Constants

const (
	FunctionsBridgeName                   string = "ea_bridge"
	FunctionsS4Namespace                  string = "functions"
	MaxAdapterResponseBytes               int64  = 1_000_000
	DefaultOffchainTransmitterChannelSize uint32 = 1000
	DefaultMaxAdapterRetry                int    = 3
	DefaultExponentialBackoffBase                = 5 * time.Second
)

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(ctx context.Context, pluginConfig *config.PluginConfig, ethKeystore keystore.Eth, chainID *big.Int, s4Storage s4.Storage, allowlist gwAllowlist.OnchainAllowlist, rateLimiter *hc.RateLimiter, subscriptions gwSubscriptions.OnchainSubscriptions, listener functions.FunctionsListener, offchainTransmitter functions.OffchainTransmitter, lggr logger.Logger) (connector.GatewayConnector, error)

func NewFunctionsServices

func NewFunctionsServices(ctx context.Context, functionsOracleArgs, thresholdOracleArgs, s4OracleArgs *libocr2.OCR2OracleArgs, conf *FunctionsServicesConfig) ([]job.ServiceCtx, error)

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

func ShouldIncludeCoordinator

func ShouldIncludeCoordinator(requestCoordinator *common.Address, reportCoordinator *common.Address) (*common.Address, error)

Check if requestCoordinator can be included together with reportCoordinator. Return new reportCoordinator (if previous was nil) and error.

Types

type FunctionsReportingPluginFactory

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

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
	QConfig           pg.QConfig
	DB                *sqlx.DB
	Chain             legacyevm.Chain
	ContractID        string
	Logger            logger.Logger
	MailMon           *mailbox.Monitor
	URLsMonEndpoint   commontypes.MonitoringEndpoint
	EthKeystore       keystore.Eth
	ThresholdKeyShare []byte
	LogPollerWrapper  evmrelayTypes.LogPollerWrapper
}