contracts/

Jul 1, 2022

Changes in this version

type ContractDeployer

+ DeployUpkeepTranscoder func() (UpkeepTranscoder, error)

type EthereumContractDeployer

+ func (e *EthereumContractDeployer) DeployUpkeepTranscoder() (UpkeepTranscoder, error)

type EthereumKeeperRegistry

+ func (v *EthereumKeeperRegistry) Migrate(upkeepIDs []*big.Int, destinationAddress common.Address) error

+ func (v *EthereumKeeperRegistry) SetMigrationPermissions(peerAddress common.Address, permission uint8) error

+ type EthereumUpkeepTranscoder struct

+ func (v *EthereumUpkeepTranscoder) Address() string

type KeeperRegistry

+ Migrate func(upkeepIDs []*big.Int, destinationAddress common.Address) error

+ SetMigrationPermissions func(peerAddress common.Address, permission uint8) error

+ type UpkeepTranscoder interface

+ Address func() string

Jun 30, 2022

Changes in this version

type EthereumOffchainAggregator

+ func (o *EthereumOffchainAggregator) ParseEventAnswerUpdated(eventLog types.Log) (*ethereum.OffchainAggregatorAnswerUpdated, error)

type OffchainAggregator

+ ParseEventAnswerUpdated func(log types.Log) (*ethereum.OffchainAggregatorAnswerUpdated, error)

Jun 24, 2022

Changes in this version

type ContractDeployer

+ DeployKeeperRegistrar func(linkAddr string, registrarSettings KeeperRegistrarSettings) (KeeperRegistrar, error)

type EthereumContractDeployer

+ func (e *EthereumContractDeployer) DeployKeeperRegistrar(linkAddr string, registrarSettings KeeperRegistrarSettings) (KeeperRegistrar, error)

+ type EthereumKeeperRegistrar struct

+ func (v *EthereumKeeperRegistrar) Address() string

+ func (v *EthereumKeeperRegistrar) EncodeRegisterRequest(name string, email []byte, upkeepAddr string, gasLimit uint32, ...) ([]byte, error)

+ func (v *EthereumKeeperRegistrar) Fund(ethAmount *big.Float) error

+ type KeeperRegistrar interface

+ Address func() string

+ EncodeRegisterRequest func(name string, email []byte, upkeepAddr string, gasLimit uint32, ...) ([]byte, error)

+ Fund func(ethAmount *big.Float) error

type KeeperRegistrarSettings

+ AutoApproveConfigType uint8

+ AutoApproveMaxAllowed uint16

Jun 21, 2022

Changes in this version

type EthereumKeeperRegistry

+ func (v *EthereumKeeperRegistry) Pause() error

type EthereumLinkToken

+ func (l *EthereumLinkToken) LoadExistingLinkToken(address string, client blockchain.EVMClient) error

type EthereumVRFConsumerV2

+ func (v *EthereumVRFConsumerV2) LoadExistingConsumer(address string, client blockchain.EVMClient) error

type KeeperRegistry

+ Pause func() error

Jun 2, 2022

Changes in this version

type EthereumKeeperConsumerPerformance

+ func (v *EthereumKeeperConsumerPerformance) SetCheckGasToBurn(ctx context.Context, gas *big.Int) error

+ func (v *EthereumKeeperConsumerPerformance) SetPerformGasToBurn(ctx context.Context, gas *big.Int) error

type EthereumKeeperRegistry

+ func (v *EthereumKeeperRegistry) SetUpkeepGasLimit(id *big.Int, gas uint32) error

type KeeperConsumerPerformance

+ SetCheckGasToBurn func(ctx context.Context, gas *big.Int) error

+ SetPerformGasToBurn func(ctx context.Context, gas *big.Int) error

type KeeperRegistry

+ SetUpkeepGasLimit func(id *big.Int, gas uint32) error

May 25, 2022

Changes in this version

type EthereumKeeperRegistry

+ func (v *EthereumKeeperRegistry) ParseUpkeepIdFromRegisteredLog(log *types.Log) (*big.Int, error)

+ func (v *EthereumKeeperRegistry) SetConfig(config KeeperRegistrySettings) error

type KeeperRegistry

+ ParseUpkeepIdFromRegisteredLog func(log *types.Log) (*big.Int, error)

+ SetConfig func(config KeeperRegistrySettings) error

May 23, 2022

Changes in this version

type KeeperRegistryOpts

+ RegistrarAddr string

+ RegistryVersion ethereum.KeeperRegistryVersion

+ Settings KeeperRegistrySettings

+ TranscoderAddr string

type KeeperRegistrySettings

+ FlatFeeMicroLINK uint32

+ MaxPerformGas uint32

+ MinUpkeepSpend *big.Int

May 17, 2022

Changes in this version

type EthereumKeeperRegistry

+ func (v *EthereumKeeperRegistry) CancelUpkeep(id *big.Int) error

type KeeperRegistry

+ CancelUpkeep func(id *big.Int) error

May 9, 2022

Changes in this version

type ContractDeployer

+ DeployUpkeepPerformCounterRestrictive func(testRange *big.Int, averageEligibilityCadence *big.Int) (UpkeepPerformCounterRestrictive, error)

type EthereumContractDeployer

+ func (e *EthereumContractDeployer) DeployUpkeepPerformCounterRestrictive(testRange *big.Int, averageEligibilityCadence *big.Int) (UpkeepPerformCounterRestrictive, error)

+ type EthereumUpkeepPerformCounterRestrictive struct

+ func (v *EthereumUpkeepPerformCounterRestrictive) Address() string

+ func (v *EthereumUpkeepPerformCounterRestrictive) Counter(ctx context.Context) (*big.Int, error)

+ func (v *EthereumUpkeepPerformCounterRestrictive) Fund(ethAmount *big.Float) error

+ func (v *EthereumUpkeepPerformCounterRestrictive) SetSpread(testRange *big.Int, interval *big.Int) error

+ type KeeperRegistrarSettings struct

+ AllowedPerWindow uint16

+ AutoRegister bool

+ MinLinkJuels *big.Int

+ RegistryAddr string

+ WindowSizeBlocks uint32

+ type UpkeepPerformCounterRestrictive interface

+ Address func() string

+ Counter func(ctx context.Context) (*big.Int, error)

+ Fund func(ethAmount *big.Float) error

+ SetSpread func(testRange *big.Int, interval *big.Int) error

May 7, 2022

Changes in this version

+ type AFN interface

+ Address func() string

+ VoteGood func() error

type ContractDeployer

+ DeployAFN func(participants []string) (AFN, error)

+ DeployMessageExecutor func(offRampAddr string, fee bool) (MessageExecutor, error)

+ DeployNativeTokenPool func(token string, lockRate *big.Int, lockCapacity *big.Int, releaseRate *big.Int, ...) (NativeTokenPool, error)

+ DeployOffRamp func(sourceChainID *big.Int, destChainID *big.Int, tokens []string, ...) (OffRamp, error)

+ DeployOffRampRouter func(offRamps []string) (OffRampRouter, error)

+ DeployOnRamp func(routerAddr string, destChainIDs []*big.Int, tokens []string, ...) (OnRamp, error)

+ DeployOnRampRouter func() (OnRampRouter, error)

+ DeployReceiverDapp func(offRampAddr string, tokenAddr string) (ReceiverDapp, error)

+ DeploySenderDapp func(onRampRouter string, destChainID *big.Int, destReceiverAddr string) (SenderDapp, error)

+ DeploySimpleMessageReceiver func() (SimpleMessageReceiver, error)

+ DeployUpkeepCounter func(testRange *big.Int, interval *big.Int) (UpkeepCounter, error)

type EthereumContractDeployer

+ func (e *EthereumContractDeployer) DeployAFN(participants []string) (AFN, error)

+ func (e *EthereumContractDeployer) DeployMessageExecutor(offRampAddr string, fee bool) (MessageExecutor, error)

+ func (e *EthereumContractDeployer) DeployNativeTokenPool(token string, lockRate *big.Int, lockCapacity *big.Int, releaseRate *big.Int, ...) (NativeTokenPool, error)

+ func (e *EthereumContractDeployer) DeployOffRamp(sourceChainID *big.Int, destChainID *big.Int, tokens []string, ...) (OffRamp, error)

+ func (e *EthereumContractDeployer) DeployOffRampRouter(offRamps []string) (OffRampRouter, error)

+ func (e *EthereumContractDeployer) DeployOnRamp(routerAddr string, destChainIDs []*big.Int, tokens []string, ...) (OnRamp, error)

+ func (e *EthereumContractDeployer) DeployOnRampRouter() (OnRampRouter, error)

+ func (e *EthereumContractDeployer) DeployReceiverDapp(offRampAddr string, tokenAddr string) (ReceiverDapp, error)

+ func (e *EthereumContractDeployer) DeploySenderDapp(onRampRouter string, destChainID *big.Int, destReceiverAddr string) (SenderDapp, error)

+ func (e *EthereumContractDeployer) DeploySimpleMessageReceiver() (SimpleMessageReceiver, error)

+ func (e *EthereumContractDeployer) DeployUpkeepCounter(testRange *big.Int, interval *big.Int) (UpkeepCounter, error)

+ type EthereumUpkeepCounter struct

+ func (v *EthereumUpkeepCounter) Address() string

+ func (v *EthereumUpkeepCounter) Counter(ctx context.Context) (*big.Int, error)

+ func (v *EthereumUpkeepCounter) Fund(ethAmount *big.Float) error

+ func (v *EthereumUpkeepCounter) SetSpread(testRange *big.Int, interval *big.Int) error

+ type MessageExecutor interface

+ Address func() string

+ SetConfig func([]ocrConfigHelper2.OracleIdentityExtra) error

+ type NativeTokenPool interface

+ Address func() string

+ LockOrBurn func(depositorAddr string, amount *big.Int) error

+ SetOffRamp func(addr string, perms bool) error

+ SetOnRamp func(addr string, perms bool) error

+ type OffRamp interface

+ Address func() string

+ SetConfig func([]ocrConfigHelper2.OracleIdentityExtra) error

+ SetRouter func(addr string) error

+ WatchEvents func()

+ type OffRampRouter interface

+ Address func() string

+ type OnRamp interface

+ Address func() string

+ SendXChainMessage func(srcLinkAddr string, destNetworkID *big.Int, receiver string, executor string) error

+ WatchEvents func()

+ type OnRampRouter interface

+ Address func() string

+ IsChainSupported func(chain *big.Int) (bool, error)

+ SendXChainMessage func(srcLinkAddr string, destNetworkID *big.Int, receiver string, executor string) error

+ SetOnRamp func(onRampAddr string, chainID *big.Int) error

+ type ReceiverDapp interface

+ Address func() string

+ type SenderDapp interface

+ Address func() string

+ DestinationChainID func() (*big.Int, error)

+ SendMsg func(destAddr string, tokens []string, amount []*big.Int, executor string) error

+ type SimpleMessageReceiver interface

+ Address func() string

+ type UpkeepCounter interface

+ Address func() string

+ Counter func(ctx context.Context) (*big.Int, error)

+ Fund func(ethAmount *big.Float) error

+ SetSpread func(testRange *big.Int, interval *big.Int) error

May 4, 2022

Changes in this version

+ type APIConsumer interface

+ Address func() string

+ CreateRequestTo func(oracleAddr string, jobID [32]byte, payment *big.Int, url string, path string, ...) error

+ Data func(ctx context.Context) (*big.Int, error)

+ Fund func(ethAmount *big.Float) error

+ RoundID func(ctx context.Context) (*big.Int, error)

+ WatchPerfEvents func(ctx context.Context, eventChan chan<- *PerfEvent) error

+ type BlockHashStore interface

+ Address func() string

+ type ContractDeployer interface

+ DeployAPIConsumer func(linkAddr string) (APIConsumer, error)

+ DeployBlockhashStore func() (BlockHashStore, error)

+ DeployDeviationFlaggingValidator func(flags string, flaggingThreshold *big.Int) (DeviationFlaggingValidator, error)

+ DeployFlags func(rac string) (Flags, error)

+ DeployFluxAggregatorContract func(linkAddr string, fluxOptions FluxAggregatorOptions) (FluxAggregator, error)

+ DeployKeeperConsumer func(updateInterval *big.Int) (KeeperConsumer, error)

+ DeployKeeperConsumerPerformance func(testBlockRange, averageCadence, checkGasToBurn, performGasToBurn *big.Int) (KeeperConsumerPerformance, error)

+ DeployKeeperRegistry func(opts *KeeperRegistryOpts) (KeeperRegistry, error)

+ DeployLinkTokenContract func() (LinkToken, error)

+ DeployMockETHLINKFeed func(answer *big.Int) (MockETHLINKFeed, error)

+ DeployMockGasFeed func(answer *big.Int) (MockGasFeed, error)

+ DeployOffChainAggregator func(linkAddr string, offchainOptions OffchainOptions) (OffchainAggregator, error)

+ DeployOracle func(linkAddr string) (Oracle, error)

+ DeployReadAccessController func() (ReadAccessController, error)

+ DeployStorageContract func() (Storage, error)

+ DeployUpkeepRegistrationRequests func(linkAddr string, minLinkJuels *big.Int) (UpkeepRegistrar, error)

+ DeployVRFConsumer func(linkAddr string, coordinatorAddr string) (VRFConsumer, error)

+ DeployVRFConsumerV2 func(linkAddr string, coordinatorAddr string) (VRFConsumerV2, error)

+ DeployVRFContract func() (VRF, error)

+ DeployVRFCoordinator func(linkAddr string, bhsAddr string) (VRFCoordinator, error)

+ DeployVRFCoordinatorV2 func(linkAddr string, bhsAddr string, linkEthFeedAddr string) (VRFCoordinatorV2, error)

+ func NewContractDeployer(bcClient blockchain.EVMClient) (ContractDeployer, error)

+ type DeviationFlaggingValidator interface

+ Address func() string

+ type EthereumAPIConsumer struct

+ func (e *EthereumAPIConsumer) Address() string

+ func (e *EthereumAPIConsumer) CreateRequestTo(oracleAddr string, jobID [32]byte, payment *big.Int, url string, path string, ...) error

+ func (e *EthereumAPIConsumer) Data(ctx context.Context) (*big.Int, error)

+ func (e *EthereumAPIConsumer) Fund(ethAmount *big.Float) error

+ func (e *EthereumAPIConsumer) RoundID(ctx context.Context) (*big.Int, error)

+ func (e *EthereumAPIConsumer) WatchPerfEvents(ctx context.Context, eventChan chan<- *PerfEvent) error

+ type EthereumBlockhashStore struct

+ func (v *EthereumBlockhashStore) Address() string

+ type EthereumContractDeployer struct

+ func NewEthereumContractDeployer(ethClient blockchain.EVMClient) *EthereumContractDeployer

+ func (e *EthereumContractDeployer) DeployAPIConsumer(linkAddr string) (APIConsumer, error)

+ func (e *EthereumContractDeployer) DeployBlockhashStore() (BlockHashStore, error)

+ func (e *EthereumContractDeployer) DeployDeviationFlaggingValidator(flags string, flaggingThreshold *big.Int) (DeviationFlaggingValidator, error)

+ func (e *EthereumContractDeployer) DeployFlags(rac string) (Flags, error)

+ func (e *EthereumContractDeployer) DeployFluxAggregatorContract(linkAddr string, fluxOptions FluxAggregatorOptions) (FluxAggregator, error)

+ func (e *EthereumContractDeployer) DeployKeeperConsumer(updateInterval *big.Int) (KeeperConsumer, error)

+ func (e *EthereumContractDeployer) DeployKeeperConsumerPerformance(testBlockRange, averageCadence, checkGasToBurn, performGasToBurn *big.Int) (KeeperConsumerPerformance, error)

+ func (e *EthereumContractDeployer) DeployKeeperRegistry(opts *KeeperRegistryOpts) (KeeperRegistry, error)

+ func (e *EthereumContractDeployer) DeployLinkTokenContract() (LinkToken, error)

+ func (e *EthereumContractDeployer) DeployMockETHLINKFeed(answer *big.Int) (MockETHLINKFeed, error)

+ func (e *EthereumContractDeployer) DeployMockGasFeed(answer *big.Int) (MockGasFeed, error)

+ func (e *EthereumContractDeployer) DeployOffChainAggregator(linkAddr string, offchainOptions OffchainOptions) (OffchainAggregator, error)

+ func (e *EthereumContractDeployer) DeployOracle(linkAddr string) (Oracle, error)

+ func (e *EthereumContractDeployer) DeployReadAccessController() (ReadAccessController, error)

+ func (e *EthereumContractDeployer) DeployStorageContract() (Storage, error)

+ func (e *EthereumContractDeployer) DeployUpkeepRegistrationRequests(linkAddr string, minLinkJuels *big.Int) (UpkeepRegistrar, error)

+ func (e *EthereumContractDeployer) DeployVRFConsumer(linkAddr string, coordinatorAddr string) (VRFConsumer, error)

+ func (e *EthereumContractDeployer) DeployVRFConsumerV2(linkAddr string, coordinatorAddr string) (VRFConsumerV2, error)

+ func (e *EthereumContractDeployer) DeployVRFContract() (VRF, error)

+ func (e *EthereumContractDeployer) DeployVRFCoordinator(linkAddr string, bhsAddr string) (VRFCoordinator, error)

+ func (e *EthereumContractDeployer) DeployVRFCoordinatorV2(linkAddr string, bhsAddr string, linkEthFeedAddr string) (VRFCoordinatorV2, error)

+ type EthereumDeviationFlaggingValidator struct

+ func (e *EthereumDeviationFlaggingValidator) Address() string

+ type EthereumFlags struct

+ func (e *EthereumFlags) Address() string

+ func (e *EthereumFlags) GetFlag(ctx context.Context, addr string) (bool, error)

+ type EthereumFluxAggregator struct

+ func (f *EthereumFluxAggregator) Address() string

+ func (f *EthereumFluxAggregator) Description(ctxt context.Context) (string, error)

+ func (f *EthereumFluxAggregator) Fund(ethAmount *big.Float) error

+ func (f *EthereumFluxAggregator) GetContractData(ctx context.Context) (*FluxAggregatorData, error)

+ func (f *EthereumFluxAggregator) GetOracles(ctx context.Context) ([]string, error)

+ func (f *EthereumFluxAggregator) LatestRoundData(ctx context.Context) (RoundData, error)

+ func (f *EthereumFluxAggregator) LatestRoundID(ctx context.Context) (*big.Int, error)

+ func (f *EthereumFluxAggregator) PaymentAmount(ctx context.Context) (*big.Int, error)

+ func (f *EthereumFluxAggregator) RequestNewRound(ctx context.Context) error

+ func (f *EthereumFluxAggregator) SetOracles(o FluxAggregatorSetOraclesOptions) error

+ func (f *EthereumFluxAggregator) SetRequesterPermissions(ctx context.Context, addr common.Address, authorized bool, roundsDelay uint32) error

+ func (f *EthereumFluxAggregator) UpdateAvailableFunds() error

+ func (f *EthereumFluxAggregator) WatchSubmissionReceived(ctx context.Context, eventChan chan<- *SubmissionEvent) error

+ func (f *EthereumFluxAggregator) WithdrawPayment(ctx context.Context, from common.Address, to common.Address, amount *big.Int) error

+ func (f *EthereumFluxAggregator) WithdrawablePayment(ctx context.Context, addr common.Address) (*big.Int, error)

+ type EthereumKeeperConsumer struct

+ func (v *EthereumKeeperConsumer) Address() string

+ func (v *EthereumKeeperConsumer) Counter(ctx context.Context) (*big.Int, error)

+ func (v *EthereumKeeperConsumer) Fund(ethAmount *big.Float) error

+ type EthereumKeeperConsumerPerformance struct

+ func (v *EthereumKeeperConsumerPerformance) Address() string

+ func (v *EthereumKeeperConsumerPerformance) CheckEligible(ctx context.Context) (bool, error)

+ func (v *EthereumKeeperConsumerPerformance) Fund(ethAmount *big.Float) error

+ func (v *EthereumKeeperConsumerPerformance) GetUpkeepCount(ctx context.Context) (*big.Int, error)

+ type EthereumKeeperRegistry struct

+ func (v *EthereumKeeperRegistry) AddUpkeepFunds(id *big.Int, amount *big.Int) error

+ func (v *EthereumKeeperRegistry) Address() string

+ func (v *EthereumKeeperRegistry) Fund(ethAmount *big.Float) error

+ func (v *EthereumKeeperRegistry) GetKeeperInfo(ctx context.Context, keeperAddr string) (*KeeperInfo, error)

+ func (v *EthereumKeeperRegistry) GetKeeperList(ctx context.Context) ([]string, error)

+ func (v *EthereumKeeperRegistry) GetUpkeepInfo(ctx context.Context, id *big.Int) (*UpkeepInfo, error)

+ func (v *EthereumKeeperRegistry) RegisterUpkeep(target string, gasLimit uint32, admin string, checkData []byte) error

+ func (v *EthereumKeeperRegistry) SetKeepers(keepers []string, payees []string) error

+ func (v *EthereumKeeperRegistry) SetRegistrar(registrarAddr string) error

+ type EthereumLinkToken struct

+ func (l *EthereumLinkToken) Address() string

+ func (l *EthereumLinkToken) Approve(to string, amount *big.Int) error

+ func (l *EthereumLinkToken) BalanceOf(ctx context.Context, addr string) (*big.Int, error)

+ func (l *EthereumLinkToken) Fund(ethAmount *big.Float) error

+ func (l *EthereumLinkToken) Name(ctxt context.Context) (string, error)

+ func (l *EthereumLinkToken) Transfer(to string, amount *big.Int) error

+ func (l *EthereumLinkToken) TransferAndCall(to string, amount *big.Int, data []byte) error

+ type EthereumMockETHLINKFeed struct

+ func (v *EthereumMockETHLINKFeed) Address() string

+ func (v *EthereumMockETHLINKFeed) LatestRoundData() (*big.Int, error)

+ type EthereumMockGASFeed struct

+ func (v *EthereumMockGASFeed) Address() string

+ type EthereumOffchainAggregator struct

+ func (o *EthereumOffchainAggregator) Address() string

+ func (o *EthereumOffchainAggregator) Fund(ethAmount *big.Float) error

+ func (o *EthereumOffchainAggregator) GetContractData(ctxt context.Context) (*OffchainAggregatorData, error)

+ func (o *EthereumOffchainAggregator) GetLatestAnswer(ctxt context.Context) (*big.Int, error)

+ func (o *EthereumOffchainAggregator) GetLatestRound(ctxt context.Context) (*RoundData, error)

+ func (o *EthereumOffchainAggregator) RequestNewRound() error

+ func (o *EthereumOffchainAggregator) SetConfig(chainlinkNodes []client.Chainlink, ocrConfig OffChainAggregatorConfig) error

+ func (o *EthereumOffchainAggregator) SetPayees(transmitters, payees []string) error

+ type EthereumOracle struct

+ func (e *EthereumOracle) Address() string

+ func (e *EthereumOracle) Fund(ethAmount *big.Float) error

+ func (e *EthereumOracle) SetFulfillmentPermission(address string, allowed bool) error

+ type EthereumReadAccessController struct

+ func (e *EthereumReadAccessController) AddAccess(addr string) error

+ func (e *EthereumReadAccessController) Address() string

+ func (e *EthereumReadAccessController) DisableAccessCheck() error

+ type EthereumStorage struct

+ func (e *EthereumStorage) Get(ctxt context.Context) (*big.Int, error)

+ func (e *EthereumStorage) Set(value *big.Int) error

+ type EthereumUpkeepRegistrationRequests struct

+ func (v *EthereumUpkeepRegistrationRequests) Address() string

+ func (v *EthereumUpkeepRegistrationRequests) EncodeRegisterRequest(name string, email []byte, upkeepAddr string, gasLimit uint32, ...) ([]byte, error)

+ func (v *EthereumUpkeepRegistrationRequests) Fund(ethAmount *big.Float) error

+ func (v *EthereumUpkeepRegistrationRequests) SetRegistrarConfig(autoRegister bool, windowSizeBlocks uint32, allowedPerWindow uint16, ...) error

+ type EthereumVRF struct

+ func (v *EthereumVRF) Fund(ethAmount *big.Float) error

+ func (v *EthereumVRF) ProofLength(ctxt context.Context) (*big.Int, error)

+ type EthereumVRFConsumer struct

+ func (v *EthereumVRFConsumer) Address() string

+ func (v *EthereumVRFConsumer) CurrentRoundID(ctx context.Context) (*big.Int, error)

+ func (v *EthereumVRFConsumer) Fund(ethAmount *big.Float) error

+ func (v *EthereumVRFConsumer) RandomnessOutput(ctx context.Context) (*big.Int, error)

+ func (v *EthereumVRFConsumer) RequestRandomness(hash [32]byte, fee *big.Int) error

+ func (v *EthereumVRFConsumer) WatchPerfEvents(ctx context.Context, eventChan chan<- *PerfEvent) error

+ type EthereumVRFConsumerV2 struct

+ func (v *EthereumVRFConsumerV2) Address() string

+ func (v *EthereumVRFConsumerV2) CreateFundedSubscription(funds *big.Int) error

+ func (v *EthereumVRFConsumerV2) CurrentSubscription() (uint64, error)

+ func (v *EthereumVRFConsumerV2) Fund(ethAmount *big.Float) error

+ func (v *EthereumVRFConsumerV2) GasAvailable() (*big.Int, error)

+ func (v *EthereumVRFConsumerV2) GetAllRandomWords(ctx context.Context, num int) ([]*big.Int, error)

+ func (v *EthereumVRFConsumerV2) RandomnessOutput(ctx context.Context, arg0 *big.Int) (*big.Int, error)

+ func (v *EthereumVRFConsumerV2) RequestRandomness(hash [32]byte, subID uint64, confs uint16, gasLimit uint32, numWords uint32) error

+ func (v *EthereumVRFConsumerV2) TopUpSubscriptionFunds(funds *big.Int) error

+ type EthereumVRFCoordinator struct

+ func (v *EthereumVRFCoordinator) Address() string

+ func (v *EthereumVRFCoordinator) HashOfKey(ctx context.Context, pubKey [2]*big.Int) ([32]byte, error)

+ func (v *EthereumVRFCoordinator) RegisterProvingKey(fee *big.Int, oracleAddr string, publicProvingKey [2]*big.Int, jobID [32]byte) error

+ type EthereumVRFCoordinatorV2 struct

+ func (v *EthereumVRFCoordinatorV2) Address() string

+ func (v *EthereumVRFCoordinatorV2) HashOfKey(ctx context.Context, pubKey [2]*big.Int) ([32]byte, error)

+ func (v *EthereumVRFCoordinatorV2) RegisterProvingKey(oracleAddr string, publicProvingKey [2]*big.Int) error

+ func (v *EthereumVRFCoordinatorV2) SetConfig(minimumRequestConfirmations uint16, maxGasLimit uint32, ...) error

+ type Flags interface

+ Address func() string

+ GetFlag func(ctx context.Context, addr string) (bool, error)

+ type FluxAggregator interface

+ Address func() string

+ Description func(ctxt context.Context) (string, error)

+ Fund func(ethAmount *big.Float) error

+ GetContractData func(ctxt context.Context) (*FluxAggregatorData, error)

+ GetOracles func(ctx context.Context) ([]string, error)

+ LatestRoundData func(ctx context.Context) (RoundData, error)

+ LatestRoundID func(ctx context.Context) (*big.Int, error)

+ PaymentAmount func(ctx context.Context) (*big.Int, error)

+ RequestNewRound func(ctx context.Context) error

+ SetOracles func(opts FluxAggregatorSetOraclesOptions) error

+ SetRequesterPermissions func(ctx context.Context, addr common.Address, authorized bool, roundsDelay uint32) error

+ UpdateAvailableFunds func() error

+ WatchSubmissionReceived func(ctx context.Context, eventChan chan<- *SubmissionEvent) error

+ WithdrawPayment func(ctx context.Context, from common.Address, to common.Address, amount *big.Int) error

+ WithdrawablePayment func(ctx context.Context, addr common.Address) (*big.Int, error)

+ type FluxAggregatorData struct

+ AllocatedFunds *big.Int

+ AvailableFunds *big.Int

+ LatestRoundData RoundData

+ Oracles []common.Address

+ type FluxAggregatorOptions struct

+ Decimals uint8

+ Description string

+ MaxSubValue *big.Int

+ MinSubValue *big.Int

+ PaymentAmount *big.Int

+ Timeout uint32

+ Validator common.Address

+ func DefaultFluxAggregatorOptions() FluxAggregatorOptions

+ type FluxAggregatorRoundConfirmer struct

+ func NewFluxAggregatorRoundConfirmer(contract FluxAggregator, roundID *big.Int, timeout time.Duration) *FluxAggregatorRoundConfirmer

+ func (f *FluxAggregatorRoundConfirmer) ReceiveBlock(block blockchain.NodeBlock) error

+ func (f *FluxAggregatorRoundConfirmer) Wait() error

+ type FluxAggregatorSetOraclesOptions struct

+ AddList []common.Address

+ AdminList []common.Address

+ MaxSubmissions uint32

+ MinSubmissions uint32

+ RemoveList []common.Address

+ RestartDelayRounds uint32

+ type JobByInstance struct

+ ID string

+ Instance string

+ type KeeperConsumer interface

+ Address func() string

+ Counter func(ctx context.Context) (*big.Int, error)

+ Fund func(ethAmount *big.Float) error

+ type KeeperConsumerPerformance interface

+ Address func() string

+ CheckEligible func(ctx context.Context) (bool, error)

+ Fund func(ethAmount *big.Float) error

+ GetUpkeepCount func(ctx context.Context) (*big.Int, error)

+ type KeeperConsumerPerformanceRoundConfirmer struct

+ func NewKeeperConsumerPerformanceRoundConfirmer(contract KeeperConsumerPerformance, expectedBlockCadence int64, ...) *KeeperConsumerPerformanceRoundConfirmer

+ func (o *KeeperConsumerPerformanceRoundConfirmer) ReceiveBlock(receivedBlock blockchain.NodeBlock) error

+ func (o *KeeperConsumerPerformanceRoundConfirmer) Wait() error

+ type KeeperConsumerRoundConfirmer struct

+ func NewKeeperConsumerRoundConfirmer(contract KeeperConsumer, counterValue int, timeout time.Duration) *KeeperConsumerRoundConfirmer

+ func (o *KeeperConsumerRoundConfirmer) ReceiveBlock(_ blockchain.NodeBlock) error

+ func (o *KeeperConsumerRoundConfirmer) Wait() error

+ type KeeperInfo struct

+ Active bool

+ Balance *big.Int

+ Payee string

+ type KeeperRegistry interface

+ AddUpkeepFunds func(id *big.Int, amount *big.Int) error

+ Address func() string

+ Fund func(ethAmount *big.Float) error

+ GetKeeperInfo func(ctx context.Context, keeperAddr string) (*KeeperInfo, error)

+ GetKeeperList func(ctx context.Context) ([]string, error)

+ GetUpkeepInfo func(ctx context.Context, id *big.Int) (*UpkeepInfo, error)

+ RegisterUpkeep func(target string, gasLimit uint32, admin string, checkData []byte) error

+ SetKeepers func(keepers []string, payees []string) error

+ SetRegistrar func(registrarAddr string) error

+ type KeeperRegistryOpts struct

+ BlockCountPerTurn *big.Int

+ CheckGasLimit uint32

+ ETHFeedAddr string

+ FallbackGasPrice *big.Int

+ FallbackLinkPrice *big.Int

+ FlatFeeMicroLINK uint32

+ GasCeilingMultiplier uint16

+ GasFeedAddr string

+ LinkAddr string

+ PaymentPremiumPPB uint32

+ StalenessSeconds *big.Int

+ type KeeperRegistrySettings struct

+ BlockCountPerTurn *big.Int

+ CheckGasLimit uint32

+ FallbackGasPrice *big.Int

+ FallbackLinkPrice *big.Int

+ GasCeilingMultiplier uint16

+ PaymentPremiumPPB uint32

+ StalenessSeconds *big.Int

+ type KlaytnContractDeployer struct

+ type LinkToken interface

+ Address func() string

+ Approve func(to string, amount *big.Int) error

+ BalanceOf func(ctx context.Context, addr string) (*big.Int, error)

+ Name func(context.Context) (string, error)

+ Transfer func(to string, amount *big.Int) error

+ TransferAndCall func(to string, amount *big.Int, data []byte) error

+ type MetisContractDeployer struct

+ type MockETHLINKFeed interface

+ Address func() string

+ LatestRoundData func() (*big.Int, error)

+ type MockGasFeed interface

+ Address func() string

+ type OffChainAggregatorConfig struct

+ AlphaPPB uint64

+ DeltaC time.Duration

+ DeltaGrace time.Duration

+ DeltaProgress time.Duration

+ DeltaResend time.Duration

+ DeltaRound time.Duration

+ DeltaStage time.Duration

+ F int

+ N int

+ OracleIdentities []ocrConfigHelper.OracleIdentityExtra

+ RMax uint8

+ S []int

+ func DefaultOffChainAggregatorConfig(numberNodes int) OffChainAggregatorConfig

+ type OffChainAggregatorV2Config struct

+ DeltaGrace time.Duration

+ DeltaProgress time.Duration

+ DeltaResend time.Duration

+ DeltaRound time.Duration

+ DeltaStage time.Duration

+ F int

+ MaxDurationObservation time.Duration

+ MaxDurationQuery time.Duration

+ MaxDurationReport time.Duration

+ MaxDurationShouldAcceptFinalizedReport time.Duration

+ MaxDurationShouldTransmitAcceptedReport time.Duration

+ OnchainConfig []byte

+ Oracles []ocrConfigHelper2.OracleIdentityExtra

+ RMax uint8

+ ReportingPluginConfig []byte

+ S []int

+ type OffchainAggregator interface

+ Address func() string

+ Fund func(nativeAmount *big.Float) error

+ GetContractData func(ctxt context.Context) (*OffchainAggregatorData, error)

+ GetLatestAnswer func(ctxt context.Context) (*big.Int, error)

+ GetLatestRound func(ctxt context.Context) (*RoundData, error)

+ RequestNewRound func() error

+ SetConfig func(chainlinkNodes []client.Chainlink, ocrConfig OffChainAggregatorConfig) error

+ SetPayees func([]string, []string) error

+ type OffchainAggregatorData struct

+ LatestRoundData RoundData

+ type OffchainAggregatorRoundConfirmer struct

+ func NewOffchainAggregatorRoundConfirmer(contract OffchainAggregator, roundID *big.Int, timeout time.Duration, ...) *OffchainAggregatorRoundConfirmer

+ func (o *OffchainAggregatorRoundConfirmer) ReceiveBlock(_ blockchain.NodeBlock) error

+ func (o *OffchainAggregatorRoundConfirmer) Wait() error

+ type OffchainOptions struct

+ BillingAccessController common.Address

+ Decimals uint8

+ Description string

+ LinkGweiPerObservation uint32

+ LinkGweiPerTransmission uint32

+ MaximumAnswer *big.Int

+ MaximumGasPrice uint32

+ MicroLinkPerEth uint32

+ MinimumAnswer *big.Int

+ ReasonableGasPrice uint32

+ RequesterAccessController common.Address

+ func DefaultOffChainAggregatorOptions() OffchainOptions

+ type Oracle interface

+ Address func() string

+ Fund func(ethAmount *big.Float) error

+ SetFulfillmentPermission func(address string, allowed bool) error

+ type PerfEvent struct

+ BlockTimestamp *big.Int

+ Contract DeviationFlaggingValidator

+ RequestID [32]byte

+ Round *big.Int

+ type ReadAccessController interface

+ AddAccess func(addr string) error

+ Address func() string

+ DisableAccessCheck func() error

+ type RoundData struct

+ Answer *big.Int

+ AnsweredInRound *big.Int

+ RoundId *big.Int

+ StartedAt *big.Int

+ UpdatedAt *big.Int

+ type RunlogRoundConfirmer struct

+ func NewRunlogRoundConfirmer(contract APIConsumer, roundID *big.Int, timeout time.Duration) *RunlogRoundConfirmer

+ func (o *RunlogRoundConfirmer) ReceiveBlock(_ blockchain.NodeBlock) error

+ func (o *RunlogRoundConfirmer) Wait() error

+ type Storage interface

+ Get func(ctxt context.Context) (*big.Int, error)

+ Set func(*big.Int) error

+ type SubmissionEvent struct

+ BlockNumber uint64

+ Contract common.Address

+ Oracle common.Address

+ Round uint32

+ Submission *big.Int

+ type UpkeepInfo struct

+ Admin string

+ Balance *big.Int

+ CheckData []byte

+ ExecuteGas uint32

+ LastKeeper string

+ MaxValidBlocknumber uint64

+ Target string

+ type UpkeepRegistrar interface

+ Address func() string

+ EncodeRegisterRequest func(name string, email []byte, upkeepAddr string, gasLimit uint32, ...) ([]byte, error)

+ Fund func(ethAmount *big.Float) error

+ SetRegistrarConfig func(autoRegister bool, windowSizeBlocks uint32, allowedPerWindow uint16, ...) error

+ type VRF interface

+ Fund func(ethAmount *big.Float) error

+ ProofLength func(context.Context) (*big.Int, error)

+ type VRFConsumer interface

+ Address func() string

+ CurrentRoundID func(ctx context.Context) (*big.Int, error)

+ Fund func(ethAmount *big.Float) error

+ RandomnessOutput func(ctx context.Context) (*big.Int, error)

+ RequestRandomness func(hash [32]byte, fee *big.Int) error

+ WatchPerfEvents func(ctx context.Context, eventChan chan<- *PerfEvent) error

+ type VRFConsumerRoundConfirmer struct

+ func NewVRFConsumerRoundConfirmer(contract VRFConsumer, roundID *big.Int, timeout time.Duration) *VRFConsumerRoundConfirmer

+ func (f *VRFConsumerRoundConfirmer) ReceiveBlock(block blockchain.NodeBlock) error

+ func (f *VRFConsumerRoundConfirmer) Wait() error

+ type VRFConsumerV2 interface

+ Address func() string

+ CreateFundedSubscription func(funds *big.Int) error

+ CurrentSubscription func() (uint64, error)

+ Fund func(ethAmount *big.Float) error

+ GasAvailable func() (*big.Int, error)

+ GetAllRandomWords func(ctx context.Context, num int) ([]*big.Int, error)

+ RandomnessOutput func(ctx context.Context, arg0 *big.Int) (*big.Int, error)

+ RequestRandomness func(hash [32]byte, subID uint64, confs uint16, gasLimit uint32, numWords uint32) error

+ TopUpSubscriptionFunds func(funds *big.Int) error

+ type VRFCoordinator interface

+ Address func() string

+ HashOfKey func(ctx context.Context, pubKey [2]*big.Int) ([32]byte, error)

+ RegisterProvingKey func(fee *big.Int, oracleAddr string, publicProvingKey [2]*big.Int, jobID [32]byte) error

+ type VRFCoordinatorV2 interface

+ Address func() string

+ HashOfKey func(ctx context.Context, pubKey [2]*big.Int) ([32]byte, error)

+ RegisterProvingKey func(oracleAddr string, publicProvingKey [2]*big.Int) error

+ SetConfig func(minimumRequestConfirmations uint16, maxGasLimit uint32, ...) error