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(functionsOracleArgs, thresholdOracleArgs, s4OracleArgs *libocr2.OCR2OracleArgs, ...) ([]job.ServiceCtx, error)
- type FunctionsReportingPluginFactory
- type FunctionsServicesConfig
Constants ¶
View Source
const ( FunctionsBridgeName string = "ea_bridge" FunctionsS4Namespace string = "functions" MaxAdapterResponseBytes int64 = 1_000_000 )
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(gwcCfg *connector.ConnectorConfig, ethKeystore keystore.Eth, chainID *big.Int, s4Storage s4.Storage, allowlist gwFunctions.OnchainAllowlist, rateLimiter *hc.RateLimiter, lggr logger.Logger) (connector.GatewayConnector, error)
func NewFunctionsServices ¶ added in v2.1.0
func NewFunctionsServices(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.
Types ¶
type FunctionsReportingPluginFactory ¶ added in v2.1.0
type FunctionsReportingPluginFactory struct {
Logger commontypes.Logger
PluginORM functions.ORM
JobID uuid.UUID
ContractVersion uint32
}
func (FunctionsReportingPluginFactory) NewReportingPlugin ¶ added in v2.1.0
func (f FunctionsReportingPluginFactory) NewReportingPlugin(rpConfig types.ReportingPluginConfig) (types.ReportingPlugin, types.ReportingPluginInfo, error)
NewReportingPlugin complies with ReportingPluginFactory
type FunctionsServicesConfig ¶ added in v2.1.0
type FunctionsServicesConfig struct {
Job job.Job
JobORM job.ORM
BridgeORM bridges.ORM
QConfig pg.QConfig
DB *sqlx.DB
Chain evm.Chain
ContractID string
Logger logger.Logger
MailMon *utils.MailboxMonitor
URLsMonEndpoint commontypes.MonitoringEndpoint
EthKeystore keystore.Eth
LogPollerWrapper evmrelayTypes.LogPollerWrapper
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.