functions

package
v2.12.1-mercury-06182024 Latest Latest
Warning

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

Go to latest
Published: Jun 18, 2024 License: MIT Imports: 38 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

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

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

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

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

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

func (FunctionsReportingPluginFactory) NewReportingPlugin added in v2.1.0

NewReportingPlugin complies with ReportingPluginFactory

type FunctionsServicesConfig added in v2.1.0

type FunctionsServicesConfig struct {
	Job               job.Job
	JobORM            job.ORM
	BridgeORM         bridges.ORM
	DS                sqlutil.DataSource
	Chain             legacyevm.Chain
	ContractID        string
	Logger            logger.Logger
	MailMon           *mailbox.Monitor
	URLsMonEndpoint   commontypes.MonitoringEndpoint
	EthKeystore       keystore.Eth
	ThresholdKeyShare []byte
	LogPollerWrapper  evmrelayTypes.LogPollerWrapper
}

Directories

Path Synopsis
integration_tests

Jump to

Keyboard shortcuts

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