contracts

package
v0.0.0-...-04b42f1 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2024 License: MIT Imports: 120 Imported by: 17

README

Contracts

Contains all code to launch, and interact with smart contracts on a blockchain.

All contracts are generalized by interfaces in order to simplify test logic across different chains.

Documentation

Overview

Package contracts handles deployment, management, and interactions of smart contracts on various chains

Index

Constants

View Source 
const (
	MultiCallABI = "" /* 6240-byte string literal not displayed */
	MultiCallBIN = "" /* 7682-byte string literal not displayed */
)

Variables

This section is empty.

Functions

func Bytes32ToSlice 

func Bytes32ToSlice(a [32]byte) (r []byte)

func DecodeHexTo32ByteArray 

func DecodeHexTo32ByteArray(val string) ([32]byte, error)

todo - solve import cycle

func MultiCallLogTriggerLoadGen 

func MultiCallLogTriggerLoadGen(
	evmClient blockchain.EVMClient,
	multiCallAddress string,
	logTriggerAddress []string,
	logTriggerData [][]byte,
) (*types.Transaction, error)

func WaitForSuccessfulTxMined 

func WaitForSuccessfulTxMined(evmClient blockchain.EVMClient, tx *types.Transaction) error

Types

type APIConsumer 

type APIConsumer interface {
	Address() string
	RoundID(ctx context.Context) (*big.Int, error)
	Fund(ethAmount *big.Float) error
	Data(ctx context.Context) (*big.Int, error)
	CreateRequestTo(
		oracleAddr string,
		jobID [32]byte,
		payment *big.Int,
		url string,
		path string,
		times *big.Int,
	) error
}

func DeployAPIConsumer 

func DeployAPIConsumer(seth *seth.Client, linkAddr string) (APIConsumer, error)

type ArbitrumContractDeployer 

type ArbitrumContractDeployer struct {
	*EthereumContractDeployer
}

ArbitrumContractDeployer wraps for Arbitrum

type ArbitrumContractLoader 

type ArbitrumContractLoader struct {
	*EthereumContractLoader
}

ArbitrumContractLoader wraps for Arbitrum

type AuthorizedForwarder 

type AuthorizedForwarder interface {
	Address() string
	Owner(ctx context.Context) (string, error)
	GetAuthorizedSenders(ctx context.Context) ([]string, error)
}

AuthorizedForwarder forward requests from cll nodes eoa

type AutomationConsumerBenchmark 

type AutomationConsumerBenchmark interface {
	Address() string
	Fund(ethAmount *big.Float) error
	CheckEligible(ctx context.Context, id *big.Int, _range *big.Int, firstEligibleBuffer *big.Int) (bool, error)
	GetUpkeepCount(ctx context.Context, id *big.Int) (*big.Int, error)
}

AutomationConsumerBenchmark is a keeper consumer contract that is more complicated than the typical consumer, it's intended to only be used for benchmark tests.

type BSCContractDeployer 

type BSCContractDeployer struct {
	*EthereumContractDeployer
}

type BSCContractLoader 

type BSCContractLoader struct {
	*EthereumContractLoader
}

BSCContractLoader wraps for BSC

type BatchBlockhashStore 

type BatchBlockhashStore interface {
	Address() string
}

type BlockHashStore 

type BlockHashStore interface {
	Address() string
	GetBlockHash(ctx context.Context, blockNumber *big.Int) ([32]byte, error)
}

func DeployBlockhashStore 

func DeployBlockhashStore(seth *seth.Client) (BlockHashStore, error)

DeployBlockhashStore deploys blockhash store used with VRF contract

type Call 

type Call struct {
	Target       common.Address
	AllowFailure bool
	CallData     []byte
}

type CallWithValue 

type CallWithValue struct {
	Target       common.Address
	AllowFailure bool
	Value        *big.Int
	CallData     []byte
}

type CeloContractDeployer 

type CeloContractDeployer struct {
	*EthereumContractDeployer
}

type CeloContractLoader 

type CeloContractLoader struct {
	*EthereumContractLoader
}

CeloContractLoader wraps for Celo

type ChainlinkNodeWithForwarder 

type ChainlinkNodeWithForwarder interface {
	TrackForwarder(chainID *big.Int, address common.Address) (*client.Forwarder, *http.Response, error)
	GetConfig() client.ChainlinkConfig
}

type ChainlinkNodeWithKeysAndAddress 

type ChainlinkNodeWithKeysAndAddress interface {
	MustReadOCRKeys() (*client.OCRKeys, error)
	MustReadP2PKeys() (*client.P2PKeys, error)
	ExportEVMKeysForChain(string) ([]*client.ExportedEVMKey, error)
	PrimaryEthAddress() (string, error)
}

func ChainlinkClientToChainlinkNodeWithKeysAndAddress 

func ChainlinkClientToChainlinkNodeWithKeysAndAddress(k8sNodes []*client.ChainlinkClient) []ChainlinkNodeWithKeysAndAddress

func ChainlinkK8sClientToChainlinkNodeWithKeysAndAddress 

func ChainlinkK8sClientToChainlinkNodeWithKeysAndAddress(k8sNodes []*client.ChainlinkK8sClient) []ChainlinkNodeWithKeysAndAddress

type ContractDeployer 

type ContractDeployer interface {
	DeployAPIConsumer(linkAddr string) (APIConsumer, error)
	DeployOracle(linkAddr string) (Oracle, error)
	DeployFlags(rac string) (Flags, error)
	DeployFluxAggregatorContract(linkAddr string, fluxOptions FluxAggregatorOptions) (FluxAggregator, error)
	DeployLinkTokenContract() (LinkToken, error)
	DeployWERC20Mock() (WERC20Mock, error)
	LoadLinkToken(address common.Address) (LinkToken, error)
	DeployOffChainAggregator(linkAddr string, offchainOptions OffchainOptions) (OffchainAggregator, error)
	LoadOffChainAggregator(address *common.Address) (OffchainAggregator, error)
	DeployVRFContract() (VRF, error)
	DeployMockETHLINKFeed(answer *big.Int) (MockETHLINKFeed, error)
	DeployVRFMockETHLINKFeed(answer *big.Int) (VRFMockETHLINKFeed, error)
	LoadETHLINKFeed(address common.Address) (MockETHLINKFeed, error)
	DeployMockGasFeed(answer *big.Int) (MockGasFeed, error)
	LoadGasFeed(address common.Address) (MockGasFeed, error)
	DeployKeeperRegistrar(registryVersion eth_contracts.KeeperRegistryVersion, linkAddr string, registrarSettings KeeperRegistrarSettings) (KeeperRegistrar, error)
	LoadKeeperRegistrar(address common.Address, registryVersion eth_contracts.KeeperRegistryVersion) (KeeperRegistrar, error)
	DeployUpkeepTranscoder() (UpkeepTranscoder, error)
	LoadUpkeepTranscoder(address common.Address) (UpkeepTranscoder, error)
	DeployKeeperRegistry(opts *KeeperRegistryOpts) (KeeperRegistry, error)
	LoadKeeperRegistry(address common.Address, registryVersion eth_contracts.KeeperRegistryVersion) (KeeperRegistry, error)
	DeployKeeperConsumer(updateInterval *big.Int) (KeeperConsumer, error)
	DeployAutomationLogTriggerConsumer(testInterval *big.Int) (KeeperConsumer, error)
	DeployAutomationSimpleLogTriggerConsumer(isStreamsLookup bool) (KeeperConsumer, error)
	DeployAutomationStreamsLookupUpkeepConsumer(testRange *big.Int, interval *big.Int, useArbBlock bool, staging bool, verify bool) (KeeperConsumer, error)
	DeployAutomationLogTriggeredStreamsLookupUpkeepConsumer() (KeeperConsumer, error)
	DeployKeeperConsumerPerformance(
		testBlockRange,
		averageCadence,
		checkGasToBurn,
		performGasToBurn *big.Int,
	) (KeeperConsumerPerformance, error)
	DeployKeeperConsumerBenchmark() (AutomationConsumerBenchmark, error)
	LoadKeeperConsumerBenchmark(address common.Address) (AutomationConsumerBenchmark, error)
	DeployKeeperPerformDataChecker(expectedData []byte) (KeeperPerformDataChecker, error)
	DeployUpkeepCounter(testRange *big.Int, interval *big.Int) (UpkeepCounter, error)
	DeployUpkeepPerformCounterRestrictive(testRange *big.Int, averageEligibilityCadence *big.Int) (UpkeepPerformCounterRestrictive, error)
	DeployVRFConsumer(linkAddr string, coordinatorAddr string) (VRFConsumer, error)
	DeployVRFOwner(coordinatorAddr string) (VRFOwner, error)
	DeployVRFCoordinatorTestV2(linkAddr string, bhsAddr string, linkEthFeedAddr string) (*EthereumVRFCoordinatorTestV2, error)
	DeployVRFConsumerV2(linkAddr string, coordinatorAddr string) (VRFConsumerV2, error)
	DeployVRFv2Consumer(coordinatorAddr string) (VRFv2Consumer, error)
	DeployVRFv2LoadTestConsumer(coordinatorAddr string) (VRFv2LoadTestConsumer, error)
	DeployVRFV2WrapperLoadTestConsumer(linkAddr string, vrfV2WrapperAddr string) (VRFv2WrapperLoadTestConsumer, error)
	DeployVRFv2PlusLoadTestConsumer(coordinatorAddr string) (VRFv2PlusLoadTestConsumer, error)
	DeployVRFV2PlusWrapperLoadTestConsumer(vrfV2PlusWrapperAddr string) (VRFv2PlusWrapperLoadTestConsumer, error)
	DeployVRFCoordinator(linkAddr string, bhsAddr string) (VRFCoordinator, error)
	DeployVRFCoordinatorV2(linkAddr string, bhsAddr string, linkEthFeedAddr string) (VRFCoordinatorV2, error)
	DeployVRFCoordinatorV2_5(bhsAddr string) (VRFCoordinatorV2_5, error)
	DeployVRFCoordinatorV2PlusUpgradedVersion(bhsAddr string) (VRFCoordinatorV2PlusUpgradedVersion, error)
	DeployVRFV2Wrapper(linkAddr string, linkEthFeedAddr string, coordinatorAddr string) (VRFV2Wrapper, error)
	DeployVRFV2PlusWrapper(linkAddr string, linkEthFeedAddr string, coordinatorAddr string, subId *big.Int) (VRFV2PlusWrapper, error)
	DeployDKG() (DKG, error)
	DeployOCR2VRFCoordinator(beaconPeriodBlocksCount *big.Int, linkAddr string) (VRFCoordinatorV3, error)
	DeployVRFBeacon(vrfCoordinatorAddress string, linkAddress string, dkgAddress string, keyId string) (VRFBeacon, error)
	DeployVRFBeaconConsumer(vrfCoordinatorAddress string, beaconPeriodBlockCount *big.Int) (VRFBeaconConsumer, error)
	DeployBlockhashStore() (BlockHashStore, error)
	DeployOperatorFactory(linkAddr string) (OperatorFactory, error)
	DeployStaking(params eth_contracts.StakingPoolConstructorParams) (Staking, error)
	DeployBatchBlockhashStore(blockhashStoreAddr string) (BatchBlockhashStore, error)
	DeployFunctionsLoadTestClient(router string) (FunctionsLoadTestClient, error)
	DeployFunctionsOracleEventsMock() (FunctionsOracleEventsMock, error)
	DeployFunctionsBillingRegistryEventsMock() (FunctionsBillingRegistryEventsMock, error)
	DeployStakingEventsMock() (StakingEventsMock, error)
	DeployFunctionsV1EventsMock() (FunctionsV1EventsMock, error)
	DeployOffchainAggregatorEventsMock() (OffchainAggregatorEventsMock, error)
	DeployMockAggregatorProxy(aggregatorAddr string) (MockAggregatorProxy, error)
	DeployOffchainAggregatorV2(linkAddr string, offchainOptions OffchainOptions) (OffchainAggregatorV2, error)
	LoadOffChainAggregatorV2(address *common.Address) (OffchainAggregatorV2, error)
	DeployKeeperRegistryCheckUpkeepGasUsageWrapper(keeperRegistryAddr string) (KeeperRegistryCheckUpkeepGasUsageWrapper, error)
	DeployKeeperRegistry11Mock() (KeeperRegistry11Mock, error)
	DeployKeeperRegistrar12Mock() (KeeperRegistrar12Mock, error)
	DeployKeeperGasWrapperMock() (KeeperGasWrapperMock, error)
	DeployMercuryVerifierContract(verifierProxyAddr common.Address) (MercuryVerifier, error)
	DeployMercuryVerifierProxyContract(accessControllerAddr common.Address) (MercuryVerifierProxy, error)
	DeployMercuryFeeManager(linkAddress common.Address, nativeAddress common.Address, proxyAddress common.Address, rewardManagerAddress common.Address) (MercuryFeeManager, error)
	DeployMercuryRewardManager(linkAddress common.Address) (MercuryRewardManager, error)
	DeployLogEmitterContract() (LogEmitter, error)
	DeployMultiCallContract() (common.Address, error)
}

ContractDeployer is an interface for abstracting the contract deployment methods across network implementations

func NewContractDeployer 

func NewContractDeployer(bcClient blockchain.EVMClient, logger zerolog.Logger) (ContractDeployer, error)

NewContractDeployer returns an instance of a contract deployer based on the client type

type ContractLoader 

type ContractLoader interface {
	LoadLINKToken(address string) (LinkToken, error)
	LoadOperatorContract(address common.Address) (Operator, error)
	LoadAuthorizedForwarder(address common.Address) (AuthorizedForwarder, error)

	/* functions 1_0_0 */
	LoadFunctionsCoordinator(addr string) (FunctionsCoordinator, error)
	LoadFunctionsRouter(addr string) (FunctionsRouter, error)
	LoadFunctionsLoadTestClient(addr string) (FunctionsLoadTestClient, error)

	// Mercury
	LoadMercuryVerifier(addr common.Address) (MercuryVerifier, error)
	LoadMercuryVerifierProxy(addr common.Address) (MercuryVerifierProxy, error)
	LoadMercuryFeeManager(addr common.Address) (MercuryFeeManager, error)
	LoadMercuryRewardManager(addr common.Address) (MercuryRewardManager, error)

	LoadWERC20Mock(addr common.Address) (WERC20Mock, error)

	// VRF
	LoadVRFCoordinatorV2(addr string) (VRFCoordinatorV2, error)
	LoadVRFv2LoadTestConsumer(addr string) (VRFv2LoadTestConsumer, error)
	LoadVRFCoordinatorV2_5(addr string) (VRFCoordinatorV2_5, error)
	LoadVRFv2PlusLoadTestConsumer(addr string) (VRFv2PlusLoadTestConsumer, error)
}

ContractLoader is an interface for abstracting the contract loading methods across network implementations

func NewContractLoader 

func NewContractLoader(bcClient blockchain.EVMClient, logger zerolog.Logger) (ContractLoader, error)

NewContractLoader returns an instance of a contract Loader based on the client type

type Coordinator 

type Coordinator interface {
	ParseRandomWordsRequested(log types.Log) (*CoordinatorRandomWordsRequested, error)
	Address() string
	WaitForRandomWordsFulfilledEvent(filter RandomWordsFulfilledEventFilter) (*CoordinatorRandomWordsFulfilled, error)
	WaitForConfigSetEvent(timeout time.Duration) (*CoordinatorConfigSet, error)
}

type CoordinatorConfigSet 

type CoordinatorConfigSet struct {
	MinimumRequestConfirmations       uint16
	MaxGasLimit                       uint32
	StalenessSeconds                  uint32
	GasAfterPaymentCalculation        uint32
	FallbackWeiPerUnitLink            *big.Int
	FulfillmentFlatFeeNativePPM       uint32
	FulfillmentFlatFeeLinkDiscountPPM uint32
	NativePremiumPercentage           uint8
	LinkPremiumPercentage             uint8
	FeeConfig                         VRFCoordinatorV2FeeConfig
	Raw                               types.Log
}

type CoordinatorRandomWordsFulfilled 

type CoordinatorRandomWordsFulfilled struct {
	RequestId     *big.Int
	OutputSeed    *big.Int
	SubId         string
	Payment       *big.Int
	NativePayment bool
	Success       bool
	OnlyPremium   bool
	Raw           types.Log
}

type CoordinatorRandomWordsRequested 

type CoordinatorRandomWordsRequested struct {
	KeyHash                     [32]byte
	RequestId                   *big.Int
	PreSeed                     *big.Int
	SubId                       string
	MinimumRequestConfirmations uint16
	CallbackGasLimit            uint32
	NumWords                    uint32
	ExtraArgs                   []byte
	Sender                      common.Address
	Raw                         types.Log
}

func RetrieveRequestRandomnessLogs 

func RetrieveRequestRandomnessLogs(coordinator Coordinator, client blockchain.EVMClient, tx *types.Transaction) (*CoordinatorRandomWordsRequested, error)

type DKG 

type DKG interface {
	Address() string
	AddClient(keyID string, clientAddress string) error
	SetConfig(
		signerAddresses []common.Address,
		transmitterAddresses []common.Address,
		f uint8,
		onchainConfig []byte,
		offchainConfigVersion uint64,
		offchainConfig []byte,
	) error
	WaitForConfigSetEvent(timeout time.Duration) (*dkg.DKGConfigSet, error)
	WaitForTransmittedEvent(timeout time.Duration) (*dkg.DKGTransmitted, error)
}

type EthereumAPIConsumer 

type EthereumAPIConsumer struct {
	// contains filtered or unexported fields
}

EthereumAPIConsumer API consumer for job type "directrequest" tests

func (*EthereumAPIConsumer) Address 

func (e *EthereumAPIConsumer) Address() string

func (*EthereumAPIConsumer) CreateRequestTo 

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

CreateRequestTo creates request to an oracle for particular jobID with params

func (*EthereumAPIConsumer) Data 

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

func (*EthereumAPIConsumer) Fund 

func (e *EthereumAPIConsumer) Fund(_ *big.Float) error

func (*EthereumAPIConsumer) RoundID 

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

type EthereumAuthorizedForwarder 

type EthereumAuthorizedForwarder struct {
	// contains filtered or unexported fields
}

EthereumAuthorizedForwarder represents authorized forwarder contract

func LoadEthereumAuthorizedForwarder 

func LoadEthereumAuthorizedForwarder(seth *seth.Client, contractAddress common.Address) (EthereumAuthorizedForwarder, error)

func (*EthereumAuthorizedForwarder) Address 

func (e *EthereumAuthorizedForwarder) Address() string

func (*EthereumAuthorizedForwarder) GetAuthorizedSenders 

func (e *EthereumAuthorizedForwarder) GetAuthorizedSenders(ctx context.Context) ([]string, error)

func (*EthereumAuthorizedForwarder) Owner 

func (e *EthereumAuthorizedForwarder) Owner(_ context.Context) (string, error)

Owner return authorized forwarder owner address

type EthereumAutomationConsumerBenchmark 

type EthereumAutomationConsumerBenchmark struct {
	// contains filtered or unexported fields
}

EthereumAutomationConsumerBenchmark represents a more complicated keeper consumer contract, one intended only for Benchmark tests.

func (*EthereumAutomationConsumerBenchmark) Address 

func (v *EthereumAutomationConsumerBenchmark) Address() string

func (*EthereumAutomationConsumerBenchmark) CheckEligible 

func (v *EthereumAutomationConsumerBenchmark) CheckEligible(ctx context.Context, id *big.Int, _range *big.Int, firstEligibleBuffer *big.Int) (bool, error)

func (*EthereumAutomationConsumerBenchmark) Fund 

func (v *EthereumAutomationConsumerBenchmark) Fund(ethAmount *big.Float) error

func (*EthereumAutomationConsumerBenchmark) GetUpkeepCount 

func (v *EthereumAutomationConsumerBenchmark) GetUpkeepCount(ctx context.Context, id *big.Int) (*big.Int, error)

type EthereumAutomationLogCounterConsumer 

type EthereumAutomationLogCounterConsumer struct {
	// contains filtered or unexported fields
}

func (*EthereumAutomationLogCounterConsumer) Address 

func (v *EthereumAutomationLogCounterConsumer) Address() string

func (*EthereumAutomationLogCounterConsumer) Counter 

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

func (*EthereumAutomationLogCounterConsumer) Start 

func (v *EthereumAutomationLogCounterConsumer) Start() error

type EthereumAutomationLogTriggeredStreamsLookupUpkeepConsumer 

type EthereumAutomationLogTriggeredStreamsLookupUpkeepConsumer struct {
	// contains filtered or unexported fields
}

func (*EthereumAutomationLogTriggeredStreamsLookupUpkeepConsumer) Address 

func (v *EthereumAutomationLogTriggeredStreamsLookupUpkeepConsumer) Address() string

func (*EthereumAutomationLogTriggeredStreamsLookupUpkeepConsumer) Counter 

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

func (*EthereumAutomationLogTriggeredStreamsLookupUpkeepConsumer) Start 

func (v *EthereumAutomationLogTriggeredStreamsLookupUpkeepConsumer) Start() error

Kick off the log trigger event. The contract uses Mercury v0.2 so no need to set ParamKeys

type EthereumAutomationSimpleLogCounterConsumer 

type EthereumAutomationSimpleLogCounterConsumer struct {
	// contains filtered or unexported fields
}

func (*EthereumAutomationSimpleLogCounterConsumer) Address 

func (v *EthereumAutomationSimpleLogCounterConsumer) Address() string

func (*EthereumAutomationSimpleLogCounterConsumer) Counter 

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

func (*EthereumAutomationSimpleLogCounterConsumer) Start 

func (v *EthereumAutomationSimpleLogCounterConsumer) Start() error

type EthereumAutomationStreamsLookupUpkeepConsumer 

type EthereumAutomationStreamsLookupUpkeepConsumer struct {
	// contains filtered or unexported fields
}

func (*EthereumAutomationStreamsLookupUpkeepConsumer) Address 

func (v *EthereumAutomationStreamsLookupUpkeepConsumer) Address() string

func (*EthereumAutomationStreamsLookupUpkeepConsumer) Counter 

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

func (*EthereumAutomationStreamsLookupUpkeepConsumer) Start 

func (v *EthereumAutomationStreamsLookupUpkeepConsumer) Start() error

type EthereumBlockhashStore 

type EthereumBlockhashStore struct {
	// contains filtered or unexported fields
}

EthereumBlockhashStore represents a blockhash store for VRF contract

func (*EthereumBlockhashStore) Address 

func (v *EthereumBlockhashStore) Address() string

func (*EthereumBlockhashStore) GetBlockHash 

func (v *EthereumBlockhashStore) GetBlockHash(ctx context.Context, blockNumber *big.Int) ([32]byte, error)

type EthereumContractDeployer 

type EthereumContractDeployer struct {
	// contains filtered or unexported fields
}

EthereumContractDeployer provides the implementations for deploying ETH (EVM) based contracts

func NewEthereumContractDeployer 

func NewEthereumContractDeployer(ethClient blockchain.EVMClient, logger zerolog.Logger) *EthereumContractDeployer

NewEthereumContractDeployer returns an instantiated instance of the ETH contract deployer

func (*EthereumContractDeployer) DeployAPIConsumer 

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

DeployAPIConsumer deploys api consumer for oracle

func (*EthereumContractDeployer) DeployAutomationLogTriggerConsumer 

func (e *EthereumContractDeployer) DeployAutomationLogTriggerConsumer(testInterval *big.Int) (KeeperConsumer, error)

func (*EthereumContractDeployer) DeployAutomationLogTriggeredStreamsLookupUpkeepConsumer 

func (e *EthereumContractDeployer) DeployAutomationLogTriggeredStreamsLookupUpkeepConsumer() (KeeperConsumer, error)

func (*EthereumContractDeployer) DeployAutomationSimpleLogTriggerConsumer 

func (e *EthereumContractDeployer) DeployAutomationSimpleLogTriggerConsumer(isStreamsLookup bool) (KeeperConsumer, error)

func (*EthereumContractDeployer) DeployAutomationStreamsLookupUpkeepConsumer 

func (e *EthereumContractDeployer) DeployAutomationStreamsLookupUpkeepConsumer(testRange *big.Int, interval *big.Int, useArbBlock bool, staging bool, verify bool) (KeeperConsumer, error)

func (*EthereumContractDeployer) DeployBatchBlockhashStore 

func (e *EthereumContractDeployer) DeployBatchBlockhashStore(blockhashStoreAddr string) (BatchBlockhashStore, error)

DeployBatchBlockhashStore deploys DeployBatchBlockhashStore contract

func (*EthereumContractDeployer) DeployBlockhashStore 

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

DeployBlockhashStore deploys blockhash store used with VRF contract

func (*EthereumContractDeployer) DeployDKG 

func (e *EthereumContractDeployer) DeployDKG() (DKG, error)

DeployDKG deploys DKG contract

func (*EthereumContractDeployer) DeployFlags 

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

DeployFlags deploys flags contract

func (*EthereumContractDeployer) DeployFluxAggregatorContract 

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

DeployFluxAggregatorContract deploys the Flux Aggregator Contract on an EVM chain

func (*EthereumContractDeployer) DeployFunctionsBillingRegistryEventsMock 

func (e *EthereumContractDeployer) DeployFunctionsBillingRegistryEventsMock() (FunctionsBillingRegistryEventsMock, error)

func (*EthereumContractDeployer) DeployFunctionsLoadTestClient 

func (e *EthereumContractDeployer) DeployFunctionsLoadTestClient(router string) (FunctionsLoadTestClient, error)

func (*EthereumContractDeployer) DeployFunctionsOracleEventsMock 

func (e *EthereumContractDeployer) DeployFunctionsOracleEventsMock() (FunctionsOracleEventsMock, error)

func (*EthereumContractDeployer) DeployFunctionsV1EventsMock 

func (e *EthereumContractDeployer) DeployFunctionsV1EventsMock() (FunctionsV1EventsMock, error)

func (*EthereumContractDeployer) DeployKeeperConsumer 

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

func (*EthereumContractDeployer) DeployKeeperConsumerBenchmark 

func (e *EthereumContractDeployer) DeployKeeperConsumerBenchmark() (AutomationConsumerBenchmark, error)

func (*EthereumContractDeployer) DeployKeeperConsumerPerformance 

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

func (*EthereumContractDeployer) DeployKeeperGasWrapperMock 

func (e *EthereumContractDeployer) DeployKeeperGasWrapperMock() (KeeperGasWrapperMock, error)

func (*EthereumContractDeployer) DeployKeeperPerformDataChecker 

func (e *EthereumContractDeployer) DeployKeeperPerformDataChecker(expectedData []byte) (KeeperPerformDataChecker, error)

func (*EthereumContractDeployer) DeployKeeperRegistrar 

func (e *EthereumContractDeployer) DeployKeeperRegistrar(registryVersion eth_contracts.KeeperRegistryVersion, linkAddr string,
	registrarSettings KeeperRegistrarSettings) (KeeperRegistrar, error)

func (*EthereumContractDeployer) DeployKeeperRegistrar12Mock 

func (e *EthereumContractDeployer) DeployKeeperRegistrar12Mock() (KeeperRegistrar12Mock, error)

func (*EthereumContractDeployer) DeployKeeperRegistry 

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

func (*EthereumContractDeployer) DeployKeeperRegistry11Mock 

func (e *EthereumContractDeployer) DeployKeeperRegistry11Mock() (KeeperRegistry11Mock, error)

func (*EthereumContractDeployer) DeployKeeperRegistryCheckUpkeepGasUsageWrapper 

func (e *EthereumContractDeployer) DeployKeeperRegistryCheckUpkeepGasUsageWrapper(keeperRegistryAddr string) (KeeperRegistryCheckUpkeepGasUsageWrapper, error)

func (*EthereumContractDeployer) DeployLinkTokenContract 

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

DeployLinkTokenContract deploys a Link Token contract to an EVM chain

func (*EthereumContractDeployer) DeployLogEmitterContract 

func (e *EthereumContractDeployer) DeployLogEmitterContract() (LogEmitter, error)

func (*EthereumContractDeployer) DeployMercuryFeeManager 

func (e *EthereumContractDeployer) DeployMercuryFeeManager(linkAddress common.Address, nativeAddress common.Address, proxyAddress common.Address, rewardManagerAddress common.Address) (MercuryFeeManager, error)

func (*EthereumContractDeployer) DeployMercuryRewardManager 

func (e *EthereumContractDeployer) DeployMercuryRewardManager(linkAddress common.Address) (MercuryRewardManager, error)

func (*EthereumContractDeployer) DeployMercuryVerifierContract 

func (e *EthereumContractDeployer) DeployMercuryVerifierContract(verifierProxyAddr common.Address) (MercuryVerifier, error)

func (*EthereumContractDeployer) DeployMercuryVerifierProxyContract 

func (e *EthereumContractDeployer) DeployMercuryVerifierProxyContract(accessControllerAddr common.Address) (MercuryVerifierProxy, error)

func (*EthereumContractDeployer) DeployMockAggregatorProxy 

func (e *EthereumContractDeployer) DeployMockAggregatorProxy(aggregatorAddr string) (MockAggregatorProxy, error)

DeployMockAggregatorProxy deploys a mock aggregator proxy contract

func (*EthereumContractDeployer) DeployMockETHLINKFeed 

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

func (*EthereumContractDeployer) DeployMockGasFeed 

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

func (*EthereumContractDeployer) DeployMultiCallContract 

func (e *EthereumContractDeployer) DeployMultiCallContract() (common.Address, error)

func (*EthereumContractDeployer) DeployOCR2VRFCoordinator 

func (e *EthereumContractDeployer) DeployOCR2VRFCoordinator(beaconPeriodBlocksCount *big.Int, linkAddress string) (VRFCoordinatorV3, error)

DeployOCR2VRFCoordinator deploys CR2VRFCoordinator contract

func (*EthereumContractDeployer) DeployOffChainAggregator 

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

DeployOffChainAggregator deploys the offchain aggregation contract to the EVM chain

func (*EthereumContractDeployer) DeployOffchainAggregatorEventsMock 

func (e *EthereumContractDeployer) DeployOffchainAggregatorEventsMock() (OffchainAggregatorEventsMock, error)

func (*EthereumContractDeployer) DeployOffchainAggregatorV2 

func (e *EthereumContractDeployer) DeployOffchainAggregatorV2(
	linkAddr string,
	offchainOptions OffchainOptions,
) (OffchainAggregatorV2, error)

DeployOffChainAggregator deploys the offchain aggregation contract to the EVM chain

func (*EthereumContractDeployer) DeployOperatorFactory 

func (e *EthereumContractDeployer) DeployOperatorFactory(linkAddr string) (OperatorFactory, error)

DeployOperatorFactory deploys operator factory contract

func (*EthereumContractDeployer) DeployOracle 

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

DeployOracle deploys oracle for consumer test

func (*EthereumContractDeployer) DeployStaking 

func (e *EthereumContractDeployer) DeployStaking(params eth_contracts.StakingPoolConstructorParams) (Staking, error)

func (*EthereumContractDeployer) DeployStakingEventsMock 

func (e *EthereumContractDeployer) DeployStakingEventsMock() (StakingEventsMock, error)

func (*EthereumContractDeployer) DeployUpkeepCounter 

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

func (*EthereumContractDeployer) DeployUpkeepPerformCounterRestrictive 

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

func (*EthereumContractDeployer) DeployUpkeepTranscoder 

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

func (*EthereumContractDeployer) DeployVRFBeacon 

func (e *EthereumContractDeployer) DeployVRFBeacon(vrfCoordinatorAddress string, linkAddress string, dkgAddress string, keyId string) (VRFBeacon, error)

DeployVRFBeacon deploys DeployVRFBeacon contract

func (*EthereumContractDeployer) DeployVRFBeaconConsumer 

func (e *EthereumContractDeployer) DeployVRFBeaconConsumer(vrfCoordinatorAddress string, beaconPeriodBlockCount *big.Int) (VRFBeaconConsumer, error)

DeployVRFBeaconConsumer deploys VRFv@ consumer contract

func (*EthereumContractDeployer) DeployVRFConsumer 

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

DeployVRFConsumer deploys VRF consumer contract

func (*EthereumContractDeployer) DeployVRFConsumerV2 

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

DeployVRFConsumerV2 deploys VRFv@ consumer contract

func (*EthereumContractDeployer) DeployVRFContract 

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

DeployVRFContract deploy VRF contract

func (*EthereumContractDeployer) DeployVRFCoordinator 

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

DeployVRFCoordinator deploys VRF coordinator contract

func (*EthereumContractDeployer) DeployVRFCoordinatorTestV2 

func (e *EthereumContractDeployer) DeployVRFCoordinatorTestV2(linkAddr string, bhsAddr string, linkEthFeedAddr string) (*EthereumVRFCoordinatorTestV2, error)

func (*EthereumContractDeployer) DeployVRFCoordinatorV2 

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

DeployVRFCoordinatorV2 deploys VRFV2 coordinator contract

func (*EthereumContractDeployer) DeployVRFCoordinatorV2PlusUpgradedVersion 

func (e *EthereumContractDeployer) DeployVRFCoordinatorV2PlusUpgradedVersion(bhsAddr string) (VRFCoordinatorV2PlusUpgradedVersion, error)

func (*EthereumContractDeployer) DeployVRFCoordinatorV2_5 

func (e *EthereumContractDeployer) DeployVRFCoordinatorV2_5(bhsAddr string) (VRFCoordinatorV2_5, error)

DeployVRFCoordinatorV2_5 deploys VRFV2_5 coordinator contract

func (*EthereumContractDeployer) DeployVRFMockETHLINKFeed 

func (e *EthereumContractDeployer) DeployVRFMockETHLINKFeed(answer *big.Int) (VRFMockETHLINKFeed, error)

func (*EthereumContractDeployer) DeployVRFOwner 

func (e *EthereumContractDeployer) DeployVRFOwner(coordinatorAddr string) (VRFOwner, error)

func (*EthereumContractDeployer) DeployVRFV2PlusWrapper 

func (e *EthereumContractDeployer) DeployVRFV2PlusWrapper(linkAddr string, linkEthFeedAddr string, coordinatorAddr string, subId *big.Int) (VRFV2PlusWrapper, error)

func (*EthereumContractDeployer) DeployVRFV2PlusWrapperLoadTestConsumer 

func (e *EthereumContractDeployer) DeployVRFV2PlusWrapperLoadTestConsumer(vrfV2PlusWrapperAddr string) (VRFv2PlusWrapperLoadTestConsumer, error)

func (*EthereumContractDeployer) DeployVRFV2Wrapper 

func (e *EthereumContractDeployer) DeployVRFV2Wrapper(linkAddr string, linkEthFeedAddr string, coordinatorAddr string) (VRFV2Wrapper, error)

func (*EthereumContractDeployer) DeployVRFV2WrapperLoadTestConsumer 

func (e *EthereumContractDeployer) DeployVRFV2WrapperLoadTestConsumer(linkAddr string, vrfV2WrapperAddr string) (VRFv2WrapperLoadTestConsumer, error)

func (*EthereumContractDeployer) DeployVRFv2Consumer 

func (e *EthereumContractDeployer) DeployVRFv2Consumer(coordinatorAddr string) (VRFv2Consumer, error)

func (*EthereumContractDeployer) DeployVRFv2LoadTestConsumer 

func (e *EthereumContractDeployer) DeployVRFv2LoadTestConsumer(coordinatorAddr string) (VRFv2LoadTestConsumer, error)

DeployVRFv2LoadTestConsumer(coordinatorAddr string) (VRFv2Consumer, error)

func (*EthereumContractDeployer) DeployVRFv2PlusLoadTestConsumer 

func (e *EthereumContractDeployer) DeployVRFv2PlusLoadTestConsumer(coordinatorAddr string) (VRFv2PlusLoadTestConsumer, error)

func (*EthereumContractDeployer) DeployWERC20Mock 

func (e *EthereumContractDeployer) DeployWERC20Mock() (WERC20Mock, error)

func (*EthereumContractDeployer) LoadETHLINKFeed 

func (e *EthereumContractDeployer) LoadETHLINKFeed(address common.Address) (MockETHLINKFeed, error)

LoadETHLINKFeed returns deployed on given address EthereumMockETHLINKFeed

func (*EthereumContractDeployer) LoadGasFeed 

func (e *EthereumContractDeployer) LoadGasFeed(address common.Address) (MockGasFeed, error)

LoadGasFeed returns deployed on given address EthereumMockGASFeed

func (*EthereumContractDeployer) LoadKeeperConsumerBenchmark 

func (e *EthereumContractDeployer) LoadKeeperConsumerBenchmark(address common.Address) (AutomationConsumerBenchmark, error)

LoadKeeperConsumerBenchmark returns deployed on given address EthereumAutomationConsumerBenchmark

func (*EthereumContractDeployer) LoadKeeperRegistrar 

func (e *EthereumContractDeployer) LoadKeeperRegistrar(address common.Address, registryVersion eth_contracts.KeeperRegistryVersion) (KeeperRegistrar, error)

LoadKeeperRegistrar returns deployed on given address EthereumKeeperRegistrar

func (*EthereumContractDeployer) LoadKeeperRegistry 

func (e *EthereumContractDeployer) LoadKeeperRegistry(address common.Address, registryVersion eth_contracts.KeeperRegistryVersion) (KeeperRegistry, error)

LoadKeeperRegistry returns deployed on given address EthereumKeeperRegistry

func (*EthereumContractDeployer) LoadLinkToken 

func (e *EthereumContractDeployer) LoadLinkToken(address common.Address) (LinkToken, error)

LoadLinkToken returns deployed on given address EthereumLinkToken

func (*EthereumContractDeployer) LoadOffChainAggregator 

func (e *EthereumContractDeployer) LoadOffChainAggregator(address *common.Address) (OffchainAggregator, error)

LoadOffChainAggregator loads an already deployed offchain aggregator contract

func (*EthereumContractDeployer) LoadOffChainAggregatorV2 

func (e *EthereumContractDeployer) LoadOffChainAggregatorV2(address *common.Address) (OffchainAggregatorV2, error)

LoadOffChainAggregatorV2 loads an already deployed offchain aggregator v2 contract

func (*EthereumContractDeployer) LoadUpkeepTranscoder 

func (e *EthereumContractDeployer) LoadUpkeepTranscoder(address common.Address) (UpkeepTranscoder, error)

func (*EthereumContractDeployer) NewLinkTokenContract 

func (e *EthereumContractDeployer) NewLinkTokenContract(address common.Address) (LinkToken, error)

type EthereumContractLoader 

type EthereumContractLoader struct {
	// contains filtered or unexported fields
}

EthereumContractLoader provides the implementations for deploying ETH (EVM) based contracts

func NewEthereumContractLoader 

func NewEthereumContractLoader(ethClient blockchain.EVMClient, logger zerolog.Logger) *EthereumContractLoader

NewEthereumContractLoader returns an instantiated instance of the ETH contract Loader

func (*EthereumContractLoader) LoadAuthorizedForwarder 

func (e *EthereumContractLoader) LoadAuthorizedForwarder(address common.Address) (AuthorizedForwarder, error)

LoadAuthorizedForwarder returns deployed on given address AuthorizedForwarder contract instance

func (*EthereumContractLoader) LoadFunctionsCoordinator 

func (e *EthereumContractLoader) LoadFunctionsCoordinator(addr string) (FunctionsCoordinator, error)

LoadFunctionsCoordinator returns deployed on given address FunctionsCoordinator contract instance

func (*EthereumContractLoader) LoadFunctionsLoadTestClient 

func (e *EthereumContractLoader) LoadFunctionsLoadTestClient(addr string) (FunctionsLoadTestClient, error)

LoadFunctionsLoadTestClient returns deployed on given address FunctionsLoadTestClient contract instance

func (*EthereumContractLoader) LoadFunctionsRouter 

func (e *EthereumContractLoader) LoadFunctionsRouter(addr string) (FunctionsRouter, error)

LoadFunctionsRouter returns deployed on given address FunctionsRouter contract instance

func (*EthereumContractLoader) LoadLINKToken 

func (e *EthereumContractLoader) LoadLINKToken(addr string) (LinkToken, error)

LoadLINKToken returns deployed on given address LINK Token contract instance

func (*EthereumContractLoader) LoadMercuryFeeManager 

func (e *EthereumContractLoader) LoadMercuryFeeManager(addr common.Address) (MercuryFeeManager, error)

func (*EthereumContractLoader) LoadMercuryRewardManager 

func (e *EthereumContractLoader) LoadMercuryRewardManager(addr common.Address) (MercuryRewardManager, error)

func (*EthereumContractLoader) LoadMercuryVerifier 

func (e *EthereumContractLoader) LoadMercuryVerifier(addr common.Address) (MercuryVerifier, error)

LoadMercuryVerifier returns Verifier contract deployed on given address

func (*EthereumContractLoader) LoadMercuryVerifierProxy 

func (e *EthereumContractLoader) LoadMercuryVerifierProxy(addr common.Address) (MercuryVerifierProxy, error)

LoadMercuryVerifierProxy returns VerifierProxy contract deployed on given address

func (*EthereumContractLoader) LoadOperatorContract 

func (e *EthereumContractLoader) LoadOperatorContract(address common.Address) (Operator, error)

LoadOperatorContract returns deployed on given address Operator contract instance

func (*EthereumContractLoader) LoadVRFCoordinatorV2 

func (e *EthereumContractLoader) LoadVRFCoordinatorV2(addr string) (VRFCoordinatorV2, error)

func (*EthereumContractLoader) LoadVRFCoordinatorV2_5 

func (e *EthereumContractLoader) LoadVRFCoordinatorV2_5(addr string) (VRFCoordinatorV2_5, error)

func (*EthereumContractLoader) LoadVRFv2LoadTestConsumer 

func (e *EthereumContractLoader) LoadVRFv2LoadTestConsumer(addr string) (VRFv2LoadTestConsumer, error)

func (*EthereumContractLoader) LoadVRFv2PlusLoadTestConsumer 

func (e *EthereumContractLoader) LoadVRFv2PlusLoadTestConsumer(addr string) (VRFv2PlusLoadTestConsumer, error)

func (*EthereumContractLoader) LoadWERC20Mock 

func (e *EthereumContractLoader) LoadWERC20Mock(addr common.Address) (WERC20Mock, error)

type EthereumDKG 

type EthereumDKG struct {
	// contains filtered or unexported fields
}

EthereumDKG represents DKG contract

func (*EthereumDKG) AddClient 

func (dkgContract *EthereumDKG) AddClient(keyID string, clientAddress string) error

func (*EthereumDKG) Address 

func (dkgContract *EthereumDKG) Address() string

func (*EthereumDKG) SetConfig 

func (dkgContract *EthereumDKG) SetConfig(
	signerAddresses []common.Address,
	transmitterAddresses []common.Address,
	f uint8,
	onchainConfig []byte,
	offchainConfigVersion uint64,
	offchainConfig []byte,
) error

func (*EthereumDKG) WaitForConfigSetEvent 

func (dkgContract *EthereumDKG) WaitForConfigSetEvent(timeout time.Duration) (*dkg.DKGConfigSet, error)

func (*EthereumDKG) WaitForTransmittedEvent 

func (dkgContract *EthereumDKG) WaitForTransmittedEvent(timeout time.Duration) (*dkg.DKGTransmitted, error)

type EthereumFlags 

type EthereumFlags struct {
	// contains filtered or unexported fields
}

EthereumFlags represents flags contract

func (*EthereumFlags) Address 

func (e *EthereumFlags) Address() string

func (*EthereumFlags) GetFlag 

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

GetFlag returns boolean if a flag was set for particular address

type EthereumFluxAggregator 

type EthereumFluxAggregator struct {
	// contains filtered or unexported fields
}

EthereumFluxAggregator represents the basic flux aggregation contract

func (*EthereumFluxAggregator) Address 

func (f *EthereumFluxAggregator) Address() string

func (*EthereumFluxAggregator) Description 

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

Description returns the description of the flux aggregator contract

func (*EthereumFluxAggregator) Fund 

func (f *EthereumFluxAggregator) Fund(_ *big.Float) error

Fund sends specified currencies to the contract

func (*EthereumFluxAggregator) GetContractData 

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

GetContractData retrieves basic data for the flux aggregator contract

func (*EthereumFluxAggregator) GetOracles 

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

func (*EthereumFluxAggregator) LatestRoundData 

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

func (*EthereumFluxAggregator) LatestRoundID 

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

func (*EthereumFluxAggregator) PaymentAmount 

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

func (*EthereumFluxAggregator) RequestNewRound 

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

func (*EthereumFluxAggregator) SetOracles 

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

SetOracles allows the ability to add and/or remove oracles from the contract, and to set admins

func (*EthereumFluxAggregator) SetRequesterPermissions 

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

func (*EthereumFluxAggregator) UpdateAvailableFunds 

func (f *EthereumFluxAggregator) UpdateAvailableFunds() error

func (*EthereumFluxAggregator) WatchSubmissionReceived 

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

WatchSubmissionReceived subscribes to any submissions on a flux feed

func (*EthereumFluxAggregator) WithdrawPayment 

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

func (*EthereumFluxAggregator) WithdrawablePayment 

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

type EthereumFunctionsBillingRegistryEventsMock 

type EthereumFunctionsBillingRegistryEventsMock struct {
	// contains filtered or unexported fields
}

EthereumFunctionsBillingRegistryEventsMock represents the basic events mock contract

func (*EthereumFunctionsBillingRegistryEventsMock) Address 

func (f *EthereumFunctionsBillingRegistryEventsMock) Address() string

func (*EthereumFunctionsBillingRegistryEventsMock) BillingEnd 

func (f *EthereumFunctionsBillingRegistryEventsMock) BillingEnd(requestId [32]byte, subscriptionId uint64, signerPayment *big.Int, transmitterPayment *big.Int, totalCost *big.Int, success bool) error

func (*EthereumFunctionsBillingRegistryEventsMock) BillingStart 

func (f *EthereumFunctionsBillingRegistryEventsMock) BillingStart(requestId [32]byte, commitment functions_billing_registry_events_mock.FunctionsBillingRegistryEventsMockCommitment) error

func (*EthereumFunctionsBillingRegistryEventsMock) SubscriptionFunded 

func (f *EthereumFunctionsBillingRegistryEventsMock) SubscriptionFunded(subscriptionId uint64, oldBalance *big.Int, newBalance *big.Int) error

type EthereumFunctionsCoordinator 

type EthereumFunctionsCoordinator struct {
	// contains filtered or unexported fields
}

func (*EthereumFunctionsCoordinator) Address 

func (e *EthereumFunctionsCoordinator) Address() string

func (*EthereumFunctionsCoordinator) GetDONPublicKey 

func (e *EthereumFunctionsCoordinator) GetDONPublicKey() ([]byte, error)

func (*EthereumFunctionsCoordinator) GetThresholdPublicKey 

func (e *EthereumFunctionsCoordinator) GetThresholdPublicKey() ([]byte, error)

type EthereumFunctionsLoadStats 

type EthereumFunctionsLoadStats struct {
	LastRequestID string
	LastResponse  string
	LastError     string
	Total         uint32
	Succeeded     uint32
	Errored       uint32
	Empty         uint32
}

type EthereumFunctionsLoadTestClient 

type EthereumFunctionsLoadTestClient struct {
	// contains filtered or unexported fields
}

func (*EthereumFunctionsLoadTestClient) Address 

func (e *EthereumFunctionsLoadTestClient) Address() string

func (*EthereumFunctionsLoadTestClient) GetStats 

func (e *EthereumFunctionsLoadTestClient) GetStats() (*EthereumFunctionsLoadStats, error)

func (*EthereumFunctionsLoadTestClient) ResetStats 

func (e *EthereumFunctionsLoadTestClient) ResetStats() error

func (*EthereumFunctionsLoadTestClient) SendRequest 

func (e *EthereumFunctionsLoadTestClient) SendRequest(times uint32, source string, encryptedSecretsReferences []byte, args []string, subscriptionId uint64, jobId [32]byte) error

func (*EthereumFunctionsLoadTestClient) SendRequestWithDONHostedSecrets 

func (e *EthereumFunctionsLoadTestClient) SendRequestWithDONHostedSecrets(times uint32, source string, slotID uint8, slotVersion uint64, args []string, subscriptionId uint64, donID [32]byte) error

type EthereumFunctionsOracleEventsMock 

type EthereumFunctionsOracleEventsMock struct {
	// contains filtered or unexported fields
}

EthereumFunctionsOracleEventsMock represents the basic events mock contract

func (*EthereumFunctionsOracleEventsMock) Address 

func (f *EthereumFunctionsOracleEventsMock) Address() string

func (*EthereumFunctionsOracleEventsMock) OracleRequest 

func (f *EthereumFunctionsOracleEventsMock) OracleRequest(requestId [32]byte, requestingContract common.Address, requestInitiator common.Address, subscriptionId uint64, subscriptionOwner common.Address, data []byte) error

func (*EthereumFunctionsOracleEventsMock) OracleResponse 

func (f *EthereumFunctionsOracleEventsMock) OracleResponse(requestId [32]byte) error

func (*EthereumFunctionsOracleEventsMock) UserCallbackError 

func (f *EthereumFunctionsOracleEventsMock) UserCallbackError(requestId [32]byte, reason string) error

func (*EthereumFunctionsOracleEventsMock) UserCallbackRawError 

func (f *EthereumFunctionsOracleEventsMock) UserCallbackRawError(requestId [32]byte, lowLevelData []byte) error

type EthereumFunctionsRouter 

type EthereumFunctionsRouter struct {
	// contains filtered or unexported fields
}

func (*EthereumFunctionsRouter) Address 

func (e *EthereumFunctionsRouter) Address() string

func (*EthereumFunctionsRouter) CreateSubscriptionWithConsumer 

func (e *EthereumFunctionsRouter) CreateSubscriptionWithConsumer(consumer string) (uint64, error)

type EthereumFunctionsV1EventsMock 

type EthereumFunctionsV1EventsMock struct {
	// contains filtered or unexported fields
}

EthereumFunctionsV1EventsMock represents the basic functions v1 events mock contract

func (*EthereumFunctionsV1EventsMock) Address 

func (f *EthereumFunctionsV1EventsMock) Address() string

func (*EthereumFunctionsV1EventsMock) EmitContractUpdated 

func (f *EthereumFunctionsV1EventsMock) EmitContractUpdated(id [32]byte, from common.Address, to common.Address) error

func (*EthereumFunctionsV1EventsMock) EmitRequestNotProcessed 

func (f *EthereumFunctionsV1EventsMock) EmitRequestNotProcessed(requestId [32]byte, coordinator common.Address, transmitter common.Address, resultCode uint8) error

func (*EthereumFunctionsV1EventsMock) EmitRequestProcessed 

func (f *EthereumFunctionsV1EventsMock) EmitRequestProcessed(requestId [32]byte, subscriptionId uint64, totalCostJuels *big.Int, transmitter common.Address, resultCode uint8, response []byte, errByte []byte, callbackReturnData []byte) error

func (*EthereumFunctionsV1EventsMock) EmitRequestStart 

func (f *EthereumFunctionsV1EventsMock) EmitRequestStart(requestId [32]byte, donId [32]byte, subscriptionId uint64, subscriptionOwner common.Address, requestingContract common.Address, requestInitiator common.Address, data []byte, dataVersion uint16, callbackGasLimit uint32, estimatedTotalCostJuels *big.Int) error

func (*EthereumFunctionsV1EventsMock) EmitSubscriptionCanceled 

func (f *EthereumFunctionsV1EventsMock) EmitSubscriptionCanceled(subscriptionId uint64, fundsRecipient common.Address, fundsAmount *big.Int) error

func (*EthereumFunctionsV1EventsMock) EmitSubscriptionConsumerAdded 

func (f *EthereumFunctionsV1EventsMock) EmitSubscriptionConsumerAdded(subscriptionId uint64, consumer common.Address) error

func (*EthereumFunctionsV1EventsMock) EmitSubscriptionConsumerRemoved 

func (f *EthereumFunctionsV1EventsMock) EmitSubscriptionConsumerRemoved(subscriptionId uint64, consumer common.Address) error

func (*EthereumFunctionsV1EventsMock) EmitSubscriptionCreated 

func (f *EthereumFunctionsV1EventsMock) EmitSubscriptionCreated(subscriptionId uint64, owner common.Address) error

func (*EthereumFunctionsV1EventsMock) EmitSubscriptionFunded 

func (f *EthereumFunctionsV1EventsMock) EmitSubscriptionFunded(subscriptionId uint64, oldBalance *big.Int, newBalance *big.Int) error

func (*EthereumFunctionsV1EventsMock) EmitSubscriptionOwnerTransferRequested 

func (f *EthereumFunctionsV1EventsMock) EmitSubscriptionOwnerTransferRequested(subscriptionId uint64, from common.Address, to common.Address) error

func (*EthereumFunctionsV1EventsMock) EmitSubscriptionOwnerTransferred 

func (f *EthereumFunctionsV1EventsMock) EmitSubscriptionOwnerTransferred(subscriptionId uint64, from common.Address, to common.Address) error

type EthereumKeeperConsumer 

type EthereumKeeperConsumer struct {
	// contains filtered or unexported fields
}

EthereumKeeperConsumer represents keeper consumer (upkeep) contract

func (*EthereumKeeperConsumer) Address 

func (v *EthereumKeeperConsumer) Address() string

func (*EthereumKeeperConsumer) Counter 

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

func (*EthereumKeeperConsumer) Start 

func (v *EthereumKeeperConsumer) Start() error

Just pass for non-logtrigger

type EthereumKeeperConsumerPerformance 

type EthereumKeeperConsumerPerformance struct {
	// contains filtered or unexported fields
}

EthereumKeeperConsumerPerformance represents a more complicated keeper consumer contract, one intended only for performance tests.

func (*EthereumKeeperConsumerPerformance) Address 

func (v *EthereumKeeperConsumerPerformance) Address() string

func (*EthereumKeeperConsumerPerformance) CheckEligible 

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

func (*EthereumKeeperConsumerPerformance) Fund 

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

func (*EthereumKeeperConsumerPerformance) GetUpkeepCount 

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

func (*EthereumKeeperConsumerPerformance) SetCheckGasToBurn 

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

func (*EthereumKeeperConsumerPerformance) SetPerformGasToBurn 

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

type EthereumKeeperGasWrapperMock 

type EthereumKeeperGasWrapperMock struct {
	// contains filtered or unexported fields
}

EthereumKeeperGasWrapperMock represents the basic keeper gas wrapper mock contract

func (*EthereumKeeperGasWrapperMock) Address 

func (f *EthereumKeeperGasWrapperMock) Address() string

func (*EthereumKeeperGasWrapperMock) SetMeasureCheckGasResult 

func (f *EthereumKeeperGasWrapperMock) SetMeasureCheckGasResult(result bool, payload []byte, gas *big.Int) error

type EthereumKeeperPerformDataCheckerConsumer 

type EthereumKeeperPerformDataCheckerConsumer struct {
	// contains filtered or unexported fields
}

EthereumKeeperPerformDataCheckerConsumer represents keeper perform data checker contract

func (*EthereumKeeperPerformDataCheckerConsumer) Address 

func (v *EthereumKeeperPerformDataCheckerConsumer) Address() string

func (*EthereumKeeperPerformDataCheckerConsumer) Counter 

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

func (*EthereumKeeperPerformDataCheckerConsumer) SetExpectedData 

func (v *EthereumKeeperPerformDataCheckerConsumer) SetExpectedData(_ context.Context, expectedData []byte) error

type EthereumKeeperRegistrar 

type EthereumKeeperRegistrar struct {
	// contains filtered or unexported fields
}

EthereumKeeperRegistrar corresponds to the registrar which is used to send requests to the registry when registering new upkeeps.

func (*EthereumKeeperRegistrar) Address 

func (v *EthereumKeeperRegistrar) Address() string

func (*EthereumKeeperRegistrar) EncodeRegisterRequest 

func (v *EthereumKeeperRegistrar) EncodeRegisterRequest(name string, email []byte, upkeepAddr string, gasLimit uint32, adminAddr string, checkData []byte, amount *big.Int, source uint8, senderAddr string, isLogTrigger bool, isMercury bool) ([]byte, error)

EncodeRegisterRequest encodes register request to call it through link token TransferAndCall

func (*EthereumKeeperRegistrar) Fund 

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

type EthereumKeeperRegistrar12Mock 

type EthereumKeeperRegistrar12Mock struct {
	// contains filtered or unexported fields
}

EthereumKeeperRegistrar12Mock represents the basic keeper registrar 1.2 mock contract

func (*EthereumKeeperRegistrar12Mock) Address 

func (f *EthereumKeeperRegistrar12Mock) Address() string

func (*EthereumKeeperRegistrar12Mock) EmitRegistrationApproved 

func (f *EthereumKeeperRegistrar12Mock) EmitRegistrationApproved(hash [32]byte, displayName string, upkeepId *big.Int) error

func (*EthereumKeeperRegistrar12Mock) EmitRegistrationRequested 

func (f *EthereumKeeperRegistrar12Mock) EmitRegistrationRequested(hash [32]byte, name string, encryptedEmail []byte, upkeepContract common.Address, gasLimit uint32, adminAddress common.Address, checkData []byte, amount *big.Int, source uint8) error

func (*EthereumKeeperRegistrar12Mock) SetRegistrationConfig 

func (f *EthereumKeeperRegistrar12Mock) SetRegistrationConfig(autoApproveConfigType uint8, autoApproveMaxAllowed uint32, approvedCount uint32, keeperRegistry common.Address, minLINKJuels *big.Int) error

type EthereumKeeperRegistry 

type EthereumKeeperRegistry struct {
	// contains filtered or unexported fields
}

EthereumKeeperRegistry represents keeper registry contract

func (*EthereumKeeperRegistry) AddUpkeepFunds 

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

AddUpkeepFunds adds link for particular upkeep id

func (*EthereumKeeperRegistry) Address 

func (v *EthereumKeeperRegistry) Address() string

func (*EthereumKeeperRegistry) CancelUpkeep 

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

CancelUpkeep cancels the given upkeep ID

func (*EthereumKeeperRegistry) ChainModuleAddress 

func (v *EthereumKeeperRegistry) ChainModuleAddress() common.Address

func (*EthereumKeeperRegistry) Fund 

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

func (*EthereumKeeperRegistry) GetKeeperInfo 

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

func (*EthereumKeeperRegistry) GetKeeperList 

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

GetKeeperList get list of all registered keeper addresses

func (*EthereumKeeperRegistry) GetUpkeepInfo 

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

GetUpkeepInfo gets upkeep info

func (*EthereumKeeperRegistry) Migrate 

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

Migrate performs a migration of the given upkeep ids to the specific destination passed as parameter.

func (*EthereumKeeperRegistry) ParseStaleUpkeepReportLog 

func (v *EthereumKeeperRegistry) ParseStaleUpkeepReportLog(log *types.Log) (*StaleUpkeepReportLog, error)

ParseStaleUpkeepReportLog Parses Stale upkeep report log

func (*EthereumKeeperRegistry) ParseUpkeepIdFromRegisteredLog 

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

Parses the upkeep ID from an 'UpkeepRegistered' log, returns error on any other log

func (*EthereumKeeperRegistry) ParseUpkeepPerformedLog 

func (v *EthereumKeeperRegistry) ParseUpkeepPerformedLog(log *types.Log) (*UpkeepPerformedLog, error)

Parses upkeep performed log

func (*EthereumKeeperRegistry) Pause 

func (v *EthereumKeeperRegistry) Pause() error

Pause pauses the registry.

func (*EthereumKeeperRegistry) PauseUpkeep 

func (v *EthereumKeeperRegistry) PauseUpkeep(id *big.Int) error

PauseUpkeep stops an upkeep from an upkeep

func (*EthereumKeeperRegistry) RegisterUpkeep 

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

RegisterUpkeep registers contract to perform upkeep

func (*EthereumKeeperRegistry) RegistryOwnerAddress 

func (v *EthereumKeeperRegistry) RegistryOwnerAddress() common.Address

func (*EthereumKeeperRegistry) ReorgProtectionEnabled 

func (v *EthereumKeeperRegistry) ReorgProtectionEnabled() bool

func (*EthereumKeeperRegistry) SetConfig 

func (v *EthereumKeeperRegistry) SetConfig(config KeeperRegistrySettings, ocrConfig OCRv2Config) error

func (*EthereumKeeperRegistry) SetConfigTypeSafe 

func (v *EthereumKeeperRegistry) SetConfigTypeSafe(ocrConfig OCRv2Config) error

func (*EthereumKeeperRegistry) SetKeepers 

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

func (*EthereumKeeperRegistry) SetMigrationPermissions 

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

SetMigrationPermissions sets the permissions of another registry to allow migrations between the two.

func (*EthereumKeeperRegistry) SetRegistrar 

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

func (*EthereumKeeperRegistry) SetUpkeepGasLimit 

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

SetUpkeepGasLimit sets the perform gas limit for a given upkeep ID

func (*EthereumKeeperRegistry) SetUpkeepPrivilegeConfig 

func (v *EthereumKeeperRegistry) SetUpkeepPrivilegeConfig(id *big.Int, privilegeConfig []byte) error

SetUpkeepPrivilegeConfig sets the privilege config of an upkeep (only for version 2.1)

func (*EthereumKeeperRegistry) SetUpkeepTriggerConfig 

func (v *EthereumKeeperRegistry) SetUpkeepTriggerConfig(id *big.Int, triggerConfig []byte) error

SetUpkeepTriggerConfig updates the trigger config of an upkeep (only for version 2.1)

func (*EthereumKeeperRegistry) UnpauseUpkeep 

func (v *EthereumKeeperRegistry) UnpauseUpkeep(id *big.Int) error

UnpauseUpkeep get list of all registered keeper addresses

func (*EthereumKeeperRegistry) UpdateCheckData 

func (v *EthereumKeeperRegistry) UpdateCheckData(id *big.Int, newCheckData []byte) error

UpdateCheckData updates the check data of an upkeep

type EthereumKeeperRegistry11Mock 

type EthereumKeeperRegistry11Mock struct {
	// contains filtered or unexported fields
}

EthereumKeeperRegistry11Mock represents the basic keeper registry 1.1 mock contract

func (*EthereumKeeperRegistry11Mock) Address 

func (f *EthereumKeeperRegistry11Mock) Address() string

func (*EthereumKeeperRegistry11Mock) EmitFundsAdded 

func (f *EthereumKeeperRegistry11Mock) EmitFundsAdded(id *big.Int, from common.Address, amount *big.Int) error

func (*EthereumKeeperRegistry11Mock) EmitFundsWithdrawn 

func (f *EthereumKeeperRegistry11Mock) EmitFundsWithdrawn(id *big.Int, amount *big.Int, to common.Address) error

func (*EthereumKeeperRegistry11Mock) EmitKeepersUpdated 

func (f *EthereumKeeperRegistry11Mock) EmitKeepersUpdated(keepers []common.Address, payees []common.Address) error

func (*EthereumKeeperRegistry11Mock) EmitUpkeepCanceled 

func (f *EthereumKeeperRegistry11Mock) EmitUpkeepCanceled(id *big.Int, atBlockHeight uint64) error

func (*EthereumKeeperRegistry11Mock) EmitUpkeepPerformed 

func (f *EthereumKeeperRegistry11Mock) EmitUpkeepPerformed(id *big.Int, success bool, from common.Address, payment *big.Int, performData []byte) error

func (*EthereumKeeperRegistry11Mock) EmitUpkeepRegistered 

func (f *EthereumKeeperRegistry11Mock) EmitUpkeepRegistered(id *big.Int, executeGas uint32, admin common.Address) error

func (*EthereumKeeperRegistry11Mock) SetCanceledUpkeepList 

func (f *EthereumKeeperRegistry11Mock) SetCanceledUpkeepList(canceledUpkeepList []*big.Int) error

func (*EthereumKeeperRegistry11Mock) SetCheckUpkeepData 

func (f *EthereumKeeperRegistry11Mock) SetCheckUpkeepData(id *big.Int, performData []byte, maxLinkPayment *big.Int, gasLimit *big.Int, adjustedGasWei *big.Int, linkEth *big.Int) error

func (*EthereumKeeperRegistry11Mock) SetConfig 

func (f *EthereumKeeperRegistry11Mock) SetConfig(paymentPremiumPPB uint32, flatFeeMicroLink uint32, blockCountPerTurn *big.Int, checkGasLimit uint32, stalenessSeconds *big.Int, gasCeilingMultiplier uint16, fallbackGasPrice *big.Int, fallbackLinkPrice *big.Int) error

func (*EthereumKeeperRegistry11Mock) SetKeeperList 

func (f *EthereumKeeperRegistry11Mock) SetKeeperList(keepers []common.Address) error

func (*EthereumKeeperRegistry11Mock) SetMinBalance 

func (f *EthereumKeeperRegistry11Mock) SetMinBalance(id *big.Int, minBalance *big.Int) error

func (*EthereumKeeperRegistry11Mock) SetPerformUpkeepSuccess 

func (f *EthereumKeeperRegistry11Mock) SetPerformUpkeepSuccess(id *big.Int, success bool) error

func (*EthereumKeeperRegistry11Mock) SetUpkeep 

func (f *EthereumKeeperRegistry11Mock) SetUpkeep(id *big.Int, target common.Address, executeGas uint32, balance *big.Int, admin common.Address, maxValidBlocknumber uint64, lastKeeper common.Address, checkData []byte) error

func (*EthereumKeeperRegistry11Mock) SetUpkeepCount 

func (f *EthereumKeeperRegistry11Mock) SetUpkeepCount(upkeepCount *big.Int) error

type EthereumKeeperRegistryCheckUpkeepGasUsageWrapper 

type EthereumKeeperRegistryCheckUpkeepGasUsageWrapper struct {
	// contains filtered or unexported fields
}

EthereumKeeperRegistryCheckUpkeepGasUsageWrapper represents a gas wrapper for keeper registry

func (*EthereumKeeperRegistryCheckUpkeepGasUsageWrapper) Address 

func (e *EthereumKeeperRegistryCheckUpkeepGasUsageWrapper) Address() string

type EthereumLinkToken 

type EthereumLinkToken struct {
	// contains filtered or unexported fields
}

EthereumLinkToken represents a LinkToken address

func DeployLinkTokenContract 

func DeployLinkTokenContract(l zerolog.Logger, client *seth.Client) (*EthereumLinkToken, error)

func (*EthereumLinkToken) Address 

func (l *EthereumLinkToken) Address() string

func (*EthereumLinkToken) Approve 

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

func (*EthereumLinkToken) BalanceOf 

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

func (*EthereumLinkToken) Fund 

func (l *EthereumLinkToken) Fund(_ *big.Float) error

Fund the LINK Token contract with ETH to distribute the token

func (*EthereumLinkToken) Name 

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

Name returns the name of the link token

func (*EthereumLinkToken) Transfer 

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

func (*EthereumLinkToken) TransferAndCall 

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

type EthereumMercuryFeeManager 

type EthereumMercuryFeeManager struct {
	// contains filtered or unexported fields
}

func (*EthereumMercuryFeeManager) Address 

func (e *EthereumMercuryFeeManager) Address() common.Address

func (*EthereumMercuryFeeManager) UpdateSubscriberDiscount 

func (e *EthereumMercuryFeeManager) UpdateSubscriberDiscount(subscriber common.Address, feedId [32]byte, token common.Address, discount uint64) (*types.Transaction, error)

type EthereumMercuryRewardManager 

type EthereumMercuryRewardManager struct {
	// contains filtered or unexported fields
}

func (*EthereumMercuryRewardManager) Address 

func (e *EthereumMercuryRewardManager) Address() common.Address

func (*EthereumMercuryRewardManager) SetFeeManager 

func (e *EthereumMercuryRewardManager) SetFeeManager(feeManager common.Address) (*types.Transaction, error)

type EthereumMercuryVerifier 

type EthereumMercuryVerifier struct {
	// contains filtered or unexported fields
}

func (*EthereumMercuryVerifier) Address 

func (e *EthereumMercuryVerifier) Address() common.Address

func (*EthereumMercuryVerifier) LatestConfigDetails 

func (e *EthereumMercuryVerifier) LatestConfigDetails(ctx context.Context, feedId [32]byte) (verifier.LatestConfigDetails, error)

func (*EthereumMercuryVerifier) SetConfig 

func (e *EthereumMercuryVerifier) SetConfig(feedId [32]byte, signers []common.Address, offchainTransmitters [][32]byte, f uint8, onchainConfig []byte, offchainConfigVersion uint64, offchainConfig []byte, recipientAddressesAndWeights []verifier.CommonAddressAndWeight) (*types.Transaction, error)

func (*EthereumMercuryVerifier) Verify 

func (e *EthereumMercuryVerifier) Verify(signedReport []byte, sender common.Address) error

type EthereumMercuryVerifierProxy 

type EthereumMercuryVerifierProxy struct {
	// contains filtered or unexported fields
}

func (*EthereumMercuryVerifierProxy) Address 

func (e *EthereumMercuryVerifierProxy) Address() common.Address

func (*EthereumMercuryVerifierProxy) InitializeVerifier 

func (e *EthereumMercuryVerifierProxy) InitializeVerifier(verifierAddress common.Address) (*types.Transaction, error)

func (*EthereumMercuryVerifierProxy) SetFeeManager 

func (e *EthereumMercuryVerifierProxy) SetFeeManager(feeManager common.Address) (*types.Transaction, error)

func (*EthereumMercuryVerifierProxy) Verify 

func (e *EthereumMercuryVerifierProxy) Verify(signedReport []byte, parameterPayload []byte, value *big.Int) (*types.Transaction, error)

func (*EthereumMercuryVerifierProxy) VerifyBulk 

func (e *EthereumMercuryVerifierProxy) VerifyBulk(signedReports [][]byte, parameterPayload []byte, value *big.Int) (*types.Transaction, error)

type EthereumMockAggregatorProxy 

type EthereumMockAggregatorProxy struct {
	// contains filtered or unexported fields
}

EthereumMockAggregatorProxy represents mock aggregator proxy contract

func (*EthereumMockAggregatorProxy) Address 

func (e *EthereumMockAggregatorProxy) Address() string

func (*EthereumMockAggregatorProxy) Aggregator 

func (e *EthereumMockAggregatorProxy) Aggregator() (common.Address, error)

func (*EthereumMockAggregatorProxy) UpdateAggregator 

func (e *EthereumMockAggregatorProxy) UpdateAggregator(aggregator common.Address) error

type EthereumMockETHLINKFeed 

type EthereumMockETHLINKFeed struct {
	// contains filtered or unexported fields
}

EthereumMockETHLINKFeed represents mocked ETH/LINK feed contract

func (*EthereumMockETHLINKFeed) Address 

func (v *EthereumMockETHLINKFeed) Address() string

func (*EthereumMockETHLINKFeed) LatestRoundData 

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

func (*EthereumMockETHLINKFeed) LatestRoundDataUpdatedAt 

func (v *EthereumMockETHLINKFeed) LatestRoundDataUpdatedAt() (*big.Int, error)

type EthereumMockGASFeed 

type EthereumMockGASFeed struct {
	// contains filtered or unexported fields
}

EthereumMockGASFeed represents mocked Gas feed contract

func (*EthereumMockGASFeed) Address 

func (v *EthereumMockGASFeed) Address() string

type EthereumOffchainAggregator 

type EthereumOffchainAggregator struct {
	// contains filtered or unexported fields
}

EthereumOffchainAggregator represents the offchain aggregation contract

func DeployOffchainAggregator 

func DeployOffchainAggregator(l zerolog.Logger, seth *seth.Client, linkTokenAddress common.Address, offchainOptions OffchainOptions) (EthereumOffchainAggregator, error)

func LoadOffchainAggregator 

func LoadOffchainAggregator(l zerolog.Logger, seth *seth.Client, contractAddress common.Address) (EthereumOffchainAggregator, error)

func (*EthereumOffchainAggregator) Address 

func (o *EthereumOffchainAggregator) Address() string

func (*EthereumOffchainAggregator) GetLatestAnswer 

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

GetLatestAnswer returns the latest answer from the OCR contract

func (*EthereumOffchainAggregator) GetLatestRound 

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

GetLatestRound returns data from the latest round

func (*EthereumOffchainAggregator) GetRound 

func (o *EthereumOffchainAggregator) GetRound(ctx context.Context, roundID *big.Int) (*RoundData, error)

GetRound retrieves an OCR round by the round ID

func (*EthereumOffchainAggregator) LatestRoundDataUpdatedAt 

func (o *EthereumOffchainAggregator) LatestRoundDataUpdatedAt() (*big.Int, error)

func (*EthereumOffchainAggregator) ParseEventAnswerUpdated 

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

ParseEventAnswerUpdated parses the log for event AnswerUpdated

func (*EthereumOffchainAggregator) RequestNewRound 

func (o *EthereumOffchainAggregator) RequestNewRound() error

RequestNewRound requests the OCR contract to create a new round

func (*EthereumOffchainAggregator) SetConfig 

func (o *EthereumOffchainAggregator) SetConfig(
	chainlinkNodes []ChainlinkNodeWithKeysAndAddress,
	ocrConfig OffChainAggregatorConfig,
	transmitters []common.Address,
) error

SetConfig sets the payees and the offchain reporting protocol configuration

func (*EthereumOffchainAggregator) SetPayees 

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

SetPayees sets wallets for the contract to pay out to?

type EthereumOffchainAggregatorEventsMock 

type EthereumOffchainAggregatorEventsMock struct {
	// contains filtered or unexported fields
}

EthereumOffchainAggregatorEventsMock represents the basic events mock contract

func (*EthereumOffchainAggregatorEventsMock) Address 

func (f *EthereumOffchainAggregatorEventsMock) Address() string

func (*EthereumOffchainAggregatorEventsMock) ConfigSet 

func (f *EthereumOffchainAggregatorEventsMock) ConfigSet(previousConfigBlockNumber uint32, configCount uint64, signers []common.Address, transmitters []common.Address, threshold uint8, encodedConfigVersion uint64, encoded []byte) error

func (*EthereumOffchainAggregatorEventsMock) NewTransmission 

func (f *EthereumOffchainAggregatorEventsMock) NewTransmission(aggregatorRoundId uint32, answer *big.Int, transmitter common.Address, observations []*big.Int, observers []byte, rawReportContext [32]byte) error

type EthereumOffchainAggregatorV2 

type EthereumOffchainAggregatorV2 struct {
	// contains filtered or unexported fields
}

func DeployOffchainAggregatorV2 

func DeployOffchainAggregatorV2(l zerolog.Logger, seth *seth.Client, linkTokenAddress common.Address, offchainOptions OffchainOptions) (EthereumOffchainAggregatorV2, error)

func LoadOffChainAggregatorV2 

func LoadOffChainAggregatorV2(l zerolog.Logger, seth *seth.Client, contractAddress common.Address) (EthereumOffchainAggregatorV2, error)

func (*EthereumOffchainAggregatorV2) Address 

func (e *EthereumOffchainAggregatorV2) Address() string

func (*EthereumOffchainAggregatorV2) GetLatestAnswer 

func (e *EthereumOffchainAggregatorV2) GetLatestAnswer(ctx context.Context) (*big.Int, error)

func (*EthereumOffchainAggregatorV2) GetLatestRound 

func (e *EthereumOffchainAggregatorV2) GetLatestRound(ctx context.Context) (*RoundData, error)

func (*EthereumOffchainAggregatorV2) GetRound 

func (e *EthereumOffchainAggregatorV2) GetRound(ctx context.Context, roundID *big.Int) (*RoundData, error)

func (*EthereumOffchainAggregatorV2) ParseEventAnswerUpdated 

func (e *EthereumOffchainAggregatorV2) ParseEventAnswerUpdated(log types.Log) (*ocr2aggregator.OCR2AggregatorAnswerUpdated, error)

func (*EthereumOffchainAggregatorV2) RequestNewRound 

func (e *EthereumOffchainAggregatorV2) RequestNewRound() error

func (*EthereumOffchainAggregatorV2) SetConfig 

func (e *EthereumOffchainAggregatorV2) SetConfig(ocrConfig *OCRv2Config) error

func (*EthereumOffchainAggregatorV2) SetPayees 

func (e *EthereumOffchainAggregatorV2) SetPayees(transmitters, payees []string) error

type EthereumOperator 

type EthereumOperator struct {
	// contains filtered or unexported fields
}

EthereumOperator represents operator contract

func LoadEthereumOperator 

func LoadEthereumOperator(logger zerolog.Logger, seth *seth.Client, contractAddress common.Address) (EthereumOperator, error)

func (*EthereumOperator) AcceptAuthorizedReceivers 

func (e *EthereumOperator) AcceptAuthorizedReceivers(forwarders []common.Address, eoa []common.Address) error

func (*EthereumOperator) Address 

func (e *EthereumOperator) Address() string

type EthereumOperatorFactory 

type EthereumOperatorFactory struct {
	// contains filtered or unexported fields
}

LegacyEthereumOperatorFactory represents operator factory contract

func DeployEthereumOperatorFactory 

func DeployEthereumOperatorFactory(seth *seth.Client, linkTokenAddress common.Address) (EthereumOperatorFactory, error)

func (*EthereumOperatorFactory) Address 

func (e *EthereumOperatorFactory) Address() string

func (*EthereumOperatorFactory) DeployNewOperatorAndForwarder 

func (e *EthereumOperatorFactory) DeployNewOperatorAndForwarder() (*types.Transaction, error)

func (*EthereumOperatorFactory) ParseAuthorizedForwarderCreated 

func (e *EthereumOperatorFactory) ParseAuthorizedForwarderCreated(eventLog types.Log) (*operator_factory.OperatorFactoryAuthorizedForwarderCreated, error)

func (*EthereumOperatorFactory) ParseOperatorCreated 

func (e *EthereumOperatorFactory) ParseOperatorCreated(eventLog types.Log) (*operator_factory.OperatorFactoryOperatorCreated, error)

type EthereumOracle 

type EthereumOracle struct {
	// contains filtered or unexported fields
}

EthereumOracle oracle for "directrequest" job tests

func (*EthereumOracle) Address 

func (e *EthereumOracle) Address() string

func (*EthereumOracle) Fund 

func (e *EthereumOracle) Fund(_ *big.Float) error

func (*EthereumOracle) SetFulfillmentPermission 

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

SetFulfillmentPermission sets fulfillment permission for particular address

type EthereumStaking 

type EthereumStaking struct {
	// contains filtered or unexported fields
}

EthereumStaking

func (*EthereumStaking) AddOperators 

func (f *EthereumStaking) AddOperators(operators []common.Address) error

func (*EthereumStaking) Address 

func (f *EthereumStaking) Address() string

func (*EthereumStaking) Fund 

func (f *EthereumStaking) Fund(ethAmount *big.Float) error

Fund sends specified currencies to the contract

func (*EthereumStaking) RaiseAlert 

func (f *EthereumStaking) RaiseAlert() error

func (*EthereumStaking) RemoveOperators 

func (f *EthereumStaking) RemoveOperators(operators []common.Address) error

func (*EthereumStaking) SetFeedOperators 

func (f *EthereumStaking) SetFeedOperators(operators []common.Address) error

func (*EthereumStaking) SetMerkleRoot 

func (f *EthereumStaking) SetMerkleRoot(newMerkleRoot [32]byte) error

func (*EthereumStaking) Start 

func (f *EthereumStaking) Start(amount *big.Int, initialRewardRate *big.Int) error

type EthereumStakingEventsMock 

type EthereumStakingEventsMock struct {
	// contains filtered or unexported fields
}

EthereumStakingEventsMock represents the basic events mock contract

func (*EthereumStakingEventsMock) Address 

func (f *EthereumStakingEventsMock) Address() string

func (*EthereumStakingEventsMock) AlertRaised 

func (f *EthereumStakingEventsMock) AlertRaised(alerter common.Address, roundId *big.Int, rewardAmount *big.Int) error

func (*EthereumStakingEventsMock) FeedOperatorsSet 

func (f *EthereumStakingEventsMock) FeedOperatorsSet(feedOperators []common.Address) error

func (*EthereumStakingEventsMock) MaxCommunityStakeAmountIncreased 

func (f *EthereumStakingEventsMock) MaxCommunityStakeAmountIncreased(maxStakeAmount *big.Int) error

func (*EthereumStakingEventsMock) MaxOperatorStakeAmountIncreased 

func (f *EthereumStakingEventsMock) MaxOperatorStakeAmountIncreased(maxStakeAmount *big.Int) error

func (*EthereumStakingEventsMock) OperatorAdded 

func (f *EthereumStakingEventsMock) OperatorAdded(operator common.Address) error

func (*EthereumStakingEventsMock) OperatorRemoved 

func (f *EthereumStakingEventsMock) OperatorRemoved(operator common.Address, amount *big.Int) error

func (*EthereumStakingEventsMock) PoolSizeIncreased 

func (f *EthereumStakingEventsMock) PoolSizeIncreased(maxPoolSize *big.Int) error

func (*EthereumStakingEventsMock) RewardInitialized 

func (f *EthereumStakingEventsMock) RewardInitialized(rate *big.Int, available *big.Int, startTimestamp *big.Int, endTimestamp *big.Int) error

func (*EthereumStakingEventsMock) Staked 

func (f *EthereumStakingEventsMock) Staked(staker common.Address, newStake *big.Int, totalStake *big.Int) error

type EthereumUpkeepCounter 

type EthereumUpkeepCounter struct {
	// contains filtered or unexported fields
}

EthereumUpkeepCounter represents keeper consumer (upkeep) counter contract

func (*EthereumUpkeepCounter) Address 

func (v *EthereumUpkeepCounter) Address() string

func (*EthereumUpkeepCounter) Counter 

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

func (*EthereumUpkeepCounter) Fund 

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

func (*EthereumUpkeepCounter) SetSpread 

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

func (*EthereumUpkeepCounter) Start 

func (v *EthereumUpkeepCounter) Start() error

Just pass for non-logtrigger

type EthereumUpkeepPerformCounterRestrictive 

type EthereumUpkeepPerformCounterRestrictive struct {
	// contains filtered or unexported fields
}

EthereumUpkeepPerformCounterRestrictive represents keeper consumer (upkeep) counter contract

func (*EthereumUpkeepPerformCounterRestrictive) Address 

func (v *EthereumUpkeepPerformCounterRestrictive) Address() string

func (*EthereumUpkeepPerformCounterRestrictive) Counter 

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

func (*EthereumUpkeepPerformCounterRestrictive) Fund 

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

func (*EthereumUpkeepPerformCounterRestrictive) SetSpread 

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

type EthereumUpkeepTranscoder 

type EthereumUpkeepTranscoder struct {
	// contains filtered or unexported fields
}

EthereumUpkeepTranscoder represents the transcoder which is used to perform migrations of upkeeps from one registry to another.

func (*EthereumUpkeepTranscoder) Address 

func (v *EthereumUpkeepTranscoder) Address() string

type EthereumVRF 

type EthereumVRF struct {
	// contains filtered or unexported fields
}

EthereumVRF represents a VRF contract

func (*EthereumVRF) Fund 

func (v *EthereumVRF) Fund(_ *big.Float) error

Fund sends specified currencies to the contract

func (*EthereumVRF) ProofLength 

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

ProofLength returns the PROOFLENGTH call from the VRF contract

type EthereumVRFBeacon 

type EthereumVRFBeacon struct {
	// contains filtered or unexported fields
}

EthereumVRFBeacon represents VRFBeacon contract

func (*EthereumVRFBeacon) Address 

func (beacon *EthereumVRFBeacon) Address() string

func (*EthereumVRFBeacon) LatestConfigDigestAndEpoch 

func (beacon *EthereumVRFBeacon) LatestConfigDigestAndEpoch(ctx context.Context) (vrf_beacon.LatestConfigDigestAndEpoch,
	error)

func (*EthereumVRFBeacon) SetConfig 

func (beacon *EthereumVRFBeacon) SetConfig(
	signerAddresses []common.Address,
	transmitterAddresses []common.Address,
	f uint8,
	onchainConfig []byte,
	offchainConfigVersion uint64,
	offchainConfig []byte,
) error

func (*EthereumVRFBeacon) SetPayees 

func (beacon *EthereumVRFBeacon) SetPayees(transmitterAddresses []common.Address, payeesAddresses []common.Address) error

func (*EthereumVRFBeacon) WaitForConfigSetEvent 

func (beacon *EthereumVRFBeacon) WaitForConfigSetEvent(timeout time.Duration) (*vrf_beacon.VRFBeaconConfigSet, error)

func (*EthereumVRFBeacon) WaitForNewTransmissionEvent 

func (beacon *EthereumVRFBeacon) WaitForNewTransmissionEvent(timeout time.Duration) (*vrf_beacon.VRFBeaconNewTransmission, error)

type EthereumVRFBeaconConsumer 

type EthereumVRFBeaconConsumer struct {
	// contains filtered or unexported fields
}

EthereumVRFBeaconConsumer represents VRFBeaconConsumer contract

func (*EthereumVRFBeaconConsumer) Address 

func (consumer *EthereumVRFBeaconConsumer) Address() string

func (*EthereumVRFBeaconConsumer) GetRandomnessByRequestId 

func (consumer *EthereumVRFBeaconConsumer) GetRandomnessByRequestId(ctx context.Context, requestID *big.Int, numWordIndex *big.Int) (*big.Int, error)

func (*EthereumVRFBeaconConsumer) GetRequestIdsBy 

func (consumer *EthereumVRFBeaconConsumer) GetRequestIdsBy(ctx context.Context, nextBeaconOutputHeight *big.Int, confDelay *big.Int) (*big.Int, error)

func (*EthereumVRFBeaconConsumer) IBeaconPeriodBlocks 

func (consumer *EthereumVRFBeaconConsumer) IBeaconPeriodBlocks(ctx context.Context) (*big.Int, error)

func (*EthereumVRFBeaconConsumer) RedeemRandomness 

func (consumer *EthereumVRFBeaconConsumer) RedeemRandomness(
	subID, requestID *big.Int,
) error

func (*EthereumVRFBeaconConsumer) RequestRandomness 

func (consumer *EthereumVRFBeaconConsumer) RequestRandomness(
	numWords uint16,
	subID, confirmationDelayArg *big.Int,
) (*types.Receipt, error)

func (*EthereumVRFBeaconConsumer) RequestRandomnessFulfillment 

func (consumer *EthereumVRFBeaconConsumer) RequestRandomnessFulfillment(
	numWords uint16,
	subID, confirmationDelayArg *big.Int,
	requestGasLimit uint32,
	callbackGasLimit uint32,
	arguments []byte,
) (*types.Receipt, error)

type EthereumVRFConsumer 

type EthereumVRFConsumer struct {
	// contains filtered or unexported fields
}

EthereumVRFConsumer represents VRF consumer contract

func (*EthereumVRFConsumer) Address 

func (v *EthereumVRFConsumer) Address() string

func (*EthereumVRFConsumer) CurrentRoundID 

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

CurrentRoundID helper roundID counter in consumer to check when all randomness requests are finished

func (*EthereumVRFConsumer) Fund 

func (v *EthereumVRFConsumer) Fund(_ *big.Float) error

func (*EthereumVRFConsumer) RandomnessOutput 

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

RandomnessOutput get VRF randomness output

func (*EthereumVRFConsumer) RequestRandomness 

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

RequestRandomness requests VRF randomness

type EthereumVRFConsumerV2 

type EthereumVRFConsumerV2 struct {
	// contains filtered or unexported fields
}

EthereumVRFConsumerV2 represents VRFv2 consumer contract

func (*EthereumVRFConsumerV2) Address 

func (v *EthereumVRFConsumerV2) Address() string

func (*EthereumVRFConsumerV2) CreateFundedSubscription 

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

CreateFundedSubscription create funded subscription for VRFv2 randomness

func (*EthereumVRFConsumerV2) CurrentSubscription 

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

CurrentSubscription get current VRFv2 subscription

func (*EthereumVRFConsumerV2) Fund 

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

func (*EthereumVRFConsumerV2) GasAvailable 

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

GasAvailable get available gas after randomness fulfilled

func (*EthereumVRFConsumerV2) GetAllRandomWords 

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

GetAllRandomWords get all VRFv2 randomness output words

func (*EthereumVRFConsumerV2) LoadExistingConsumer 

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

LoadExistingConsumer loads an EthereumVRFConsumerV2 with a specified address

func (*EthereumVRFConsumerV2) RandomnessOutput 

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

RandomnessOutput get VRFv2 randomness output (word)

func (*EthereumVRFConsumerV2) RequestRandomness 

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

RequestRandomness request VRFv2 random words

func (*EthereumVRFConsumerV2) TopUpSubscriptionFunds 

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

TopUpSubscriptionFunds add funds to a VRFv2 subscription

type EthereumVRFCoordinator 

type EthereumVRFCoordinator struct {
	// contains filtered or unexported fields
}

EthereumVRFCoordinator represents VRF coordinator contract

func (*EthereumVRFCoordinator) Address 

func (v *EthereumVRFCoordinator) Address() string

func (*EthereumVRFCoordinator) HashOfKey 

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

HashOfKey get a hash of proving key to use it as a request ID part for VRF

func (*EthereumVRFCoordinator) RegisterProvingKey 

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

RegisterProvingKey register VRF proving key

type EthereumVRFCoordinatorTestV2 

type EthereumVRFCoordinatorTestV2 struct {
	// contains filtered or unexported fields
}

func (*EthereumVRFCoordinatorTestV2) Address 

func (v *EthereumVRFCoordinatorTestV2) Address() string

type EthereumVRFCoordinatorV2 

type EthereumVRFCoordinatorV2 struct {
	// contains filtered or unexported fields
}

EthereumVRFCoordinatorV2 represents VRFV2 coordinator contract

func (*EthereumVRFCoordinatorV2) AddConsumer 

func (v *EthereumVRFCoordinatorV2) AddConsumer(subId uint64, consumerAddress string) error

func (*EthereumVRFCoordinatorV2) Address 

func (v *EthereumVRFCoordinatorV2) Address() string

func (*EthereumVRFCoordinatorV2) CancelSubscription 

func (v *EthereumVRFCoordinatorV2) CancelSubscription(subID uint64, to common.Address) (*types.Transaction, error)

CancelSubscription cancels subscription by Sub owner, return funds to specified address, checks if pending requests for a sub exist

func (*EthereumVRFCoordinatorV2) CreateSubscription 

func (v *EthereumVRFCoordinatorV2) CreateSubscription() (*types.Transaction, error)

func (*EthereumVRFCoordinatorV2) FindSubscriptionID 

func (v *EthereumVRFCoordinatorV2) FindSubscriptionID(subID uint64) (uint64, error)

func (*EthereumVRFCoordinatorV2) GetConfig 

func (v *EthereumVRFCoordinatorV2) GetConfig(ctx context.Context) (vrf_coordinator_v2.GetConfig, error)
func (v *EthereumVRFCoordinatorV2) GetFallbackWeiPerUnitLink(ctx context.Context) (*big.Int, error)

func (*EthereumVRFCoordinatorV2) GetFeeConfig 

func (v *EthereumVRFCoordinatorV2) GetFeeConfig(ctx context.Context) (vrf_coordinator_v2.GetFeeConfig, error)

func (*EthereumVRFCoordinatorV2) GetOwner 

func (v *EthereumVRFCoordinatorV2) GetOwner(ctx context.Context) (common.Address, error)

func (*EthereumVRFCoordinatorV2) GetRequestConfig 

func (v *EthereumVRFCoordinatorV2) GetRequestConfig(ctx context.Context) (GetRequestConfig, error)

func (*EthereumVRFCoordinatorV2) GetSubscription 

func (v *EthereumVRFCoordinatorV2) GetSubscription(ctx context.Context, subID uint64) (Subscription, error)

func (*EthereumVRFCoordinatorV2) HashOfKey 

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

func (*EthereumVRFCoordinatorV2) OracleWithdraw 

func (v *EthereumVRFCoordinatorV2) OracleWithdraw(recipient common.Address, amount *big.Int) error

func (*EthereumVRFCoordinatorV2) OwnerCancelSubscription 

func (v *EthereumVRFCoordinatorV2) OwnerCancelSubscription(subID uint64) (*types.Transaction, error)

OwnerCancelSubscription cancels subscription, return funds to the subscription owner, down not check if pending requests for a sub exist, outstanding requests may fail onchain

func (*EthereumVRFCoordinatorV2) ParseLog 

func (v *EthereumVRFCoordinatorV2) ParseLog(log types.Log) (generated.AbigenLog, error)

func (*EthereumVRFCoordinatorV2) ParseRandomWordsRequested 

func (v *EthereumVRFCoordinatorV2) ParseRandomWordsRequested(log types.Log) (*CoordinatorRandomWordsRequested, error)

func (*EthereumVRFCoordinatorV2) ParseSubscriptionCanceled 

func (v *EthereumVRFCoordinatorV2) ParseSubscriptionCanceled(log types.Log) (*vrf_coordinator_v2.VRFCoordinatorV2SubscriptionCanceled, error)

func (*EthereumVRFCoordinatorV2) PendingRequestsExist 

func (v *EthereumVRFCoordinatorV2) PendingRequestsExist(ctx context.Context, subID uint64) (bool, error)

func (*EthereumVRFCoordinatorV2) RegisterProvingKey 

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

func (*EthereumVRFCoordinatorV2) SetConfig 

func (v *EthereumVRFCoordinatorV2) SetConfig(minimumRequestConfirmations uint16, maxGasLimit uint32, stalenessSeconds uint32, gasAfterPaymentCalculation uint32, fallbackWeiPerUnitLink *big.Int, feeConfig vrf_coordinator_v2.VRFCoordinatorV2FeeConfig) error

func (*EthereumVRFCoordinatorV2) TransferOwnership 

func (v *EthereumVRFCoordinatorV2) TransferOwnership(to common.Address) error

func (*EthereumVRFCoordinatorV2) WaitForConfigSetEvent 

func (v *EthereumVRFCoordinatorV2) WaitForConfigSetEvent(timeout time.Duration) (*CoordinatorConfigSet, error)

func (*EthereumVRFCoordinatorV2) WaitForRandomWordsFulfilledEvent 

func (v *EthereumVRFCoordinatorV2) WaitForRandomWordsFulfilledEvent(filter RandomWordsFulfilledEventFilter) (*CoordinatorRandomWordsFulfilled, error)

func (*EthereumVRFCoordinatorV2) WaitForRandomWordsRequestedEvent 

func (v *EthereumVRFCoordinatorV2) WaitForRandomWordsRequestedEvent(keyHash [][32]byte, subID []uint64, sender []common.Address, timeout time.Duration) (*vrf_coordinator_v2.VRFCoordinatorV2RandomWordsRequested, error)

func (*EthereumVRFCoordinatorV2) WaitForSubscriptionCanceledEvent 

func (v *EthereumVRFCoordinatorV2) WaitForSubscriptionCanceledEvent(subID []uint64, timeout time.Duration) (*vrf_coordinator_v2.VRFCoordinatorV2SubscriptionCanceled, error)

func (*EthereumVRFCoordinatorV2) WaitForSubscriptionConsumerAdded 

func (v *EthereumVRFCoordinatorV2) WaitForSubscriptionConsumerAdded(subID []uint64, timeout time.Duration) (*vrf_coordinator_v2.VRFCoordinatorV2SubscriptionConsumerAdded, error)

func (*EthereumVRFCoordinatorV2) WaitForSubscriptionConsumerRemoved 

func (v *EthereumVRFCoordinatorV2) WaitForSubscriptionConsumerRemoved(subID []uint64, timeout time.Duration) (*vrf_coordinator_v2.VRFCoordinatorV2SubscriptionConsumerRemoved, error)

func (*EthereumVRFCoordinatorV2) WaitForSubscriptionCreatedEvent 

func (v *EthereumVRFCoordinatorV2) WaitForSubscriptionCreatedEvent(subID []uint64, timeout time.Duration) (*vrf_coordinator_v2.VRFCoordinatorV2SubscriptionCreated, error)

func (*EthereumVRFCoordinatorV2) WaitForSubscriptionFunded 

func (v *EthereumVRFCoordinatorV2) WaitForSubscriptionFunded(subID []uint64, timeout time.Duration) (*vrf_coordinator_v2.VRFCoordinatorV2SubscriptionFunded, error)

type EthereumVRFCoordinatorV2PlusUpgradedVersion 

type EthereumVRFCoordinatorV2PlusUpgradedVersion struct {
	// contains filtered or unexported fields
}

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) AddConsumer 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) AddConsumer(subId *big.Int, consumerAddress string) error

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) Address 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) Address() string

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) CreateSubscription 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) CreateSubscription() error

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) FindSubscriptionID 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) FindSubscriptionID() (*big.Int, error)

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) FundSubscriptionWithNative 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) FundSubscriptionWithNative(subId *big.Int, nativeTokenAmount *big.Int) error

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) GetActiveSubscriptionIds 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) GetActiveSubscriptionIds(ctx context.Context, startIndex *big.Int, maxCount *big.Int) ([]*big.Int, error)

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) GetLinkTotalBalance 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) GetLinkTotalBalance(ctx context.Context) (*big.Int, error)

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) GetNativeTokenTotalBalance 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) GetNativeTokenTotalBalance(ctx context.Context) (*big.Int, error)

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) GetSubscription 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) GetSubscription(ctx context.Context, subID *big.Int) (vrf_v2plus_upgraded_version.GetSubscription, error)

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) HashOfKey 

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

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) Migrate 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) Migrate(subId *big.Int, coordinatorAddress string) error

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) ParseRandomWordsRequested 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) ParseRandomWordsRequested(log types.Log) (*CoordinatorRandomWordsRequested, error)

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) RegisterMigratableCoordinator 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) RegisterMigratableCoordinator(migratableCoordinatorAddress string) error

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) RegisterProvingKey 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) RegisterProvingKey(
	publicProvingKey [2]*big.Int,
	gasLaneMaxGas uint64,
) error

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) SetConfig 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) SetConfig(
	minimumRequestConfirmations uint16,
	maxGasLimit uint32,
	stalenessSeconds uint32,
	gasAfterPaymentCalculation uint32,
	fallbackWeiPerUnitLink *big.Int,
	fulfillmentFlatFeeNativePPM uint32,
	fulfillmentFlatFeeLinkDiscountPPM uint32,
	nativePremiumPercentage uint8,
	linkPremiumPercentage uint8,
) error

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) SetLINKAndLINKNativeFeed 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) SetLINKAndLINKNativeFeed(linkAddress string, linkNativeFeedAddress string) error

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) WaitForConfigSetEvent 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) WaitForConfigSetEvent(timeout time.Duration) (*CoordinatorConfigSet, error)

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) WaitForMigrationCompletedEvent 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) WaitForMigrationCompletedEvent(timeout time.Duration) (*vrf_v2plus_upgraded_version.VRFCoordinatorV2PlusUpgradedVersionMigrationCompleted, error)

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) WaitForRandomWordsFulfilledEvent 

func (v *EthereumVRFCoordinatorV2PlusUpgradedVersion) WaitForRandomWordsFulfilledEvent(filter RandomWordsFulfilledEventFilter) (*CoordinatorRandomWordsFulfilled, error)

type EthereumVRFCoordinatorV2_5 

type EthereumVRFCoordinatorV2_5 struct {
	// contains filtered or unexported fields
}

func (*EthereumVRFCoordinatorV2_5) AddConsumer 

func (v *EthereumVRFCoordinatorV2_5) AddConsumer(subId *big.Int, consumerAddress string) error

func (*EthereumVRFCoordinatorV2_5) Address 

func (v *EthereumVRFCoordinatorV2_5) Address() string

func (*EthereumVRFCoordinatorV2_5) CancelSubscription 

func (v *EthereumVRFCoordinatorV2_5) CancelSubscription(subID *big.Int, to common.Address) (*types.Transaction, error)

CancelSubscription cancels subscription by Sub owner, return funds to specified address, checks if pending requests for a sub exist

func (*EthereumVRFCoordinatorV2_5) CreateSubscription 

func (v *EthereumVRFCoordinatorV2_5) CreateSubscription() (*types.Transaction, error)

func (*EthereumVRFCoordinatorV2_5) FindSubscriptionID 

func (v *EthereumVRFCoordinatorV2_5) FindSubscriptionID(subID *big.Int) (*big.Int, error)

func (*EthereumVRFCoordinatorV2_5) FundSubscriptionWithNative 

func (v *EthereumVRFCoordinatorV2_5) FundSubscriptionWithNative(subId *big.Int, nativeTokenAmount *big.Int) error

func (*EthereumVRFCoordinatorV2_5) GetActiveSubscriptionIds 

func (v *EthereumVRFCoordinatorV2_5) GetActiveSubscriptionIds(ctx context.Context, startIndex *big.Int, maxCount *big.Int) ([]*big.Int, error)

func (*EthereumVRFCoordinatorV2_5) GetLinkTotalBalance 

func (v *EthereumVRFCoordinatorV2_5) GetLinkTotalBalance(ctx context.Context) (*big.Int, error)

func (*EthereumVRFCoordinatorV2_5) GetNativeTokenTotalBalance 

func (v *EthereumVRFCoordinatorV2_5) GetNativeTokenTotalBalance(ctx context.Context) (*big.Int, error)

func (*EthereumVRFCoordinatorV2_5) GetSubscription 

func (v *EthereumVRFCoordinatorV2_5) GetSubscription(ctx context.Context, subID *big.Int) (Subscription, error)

func (*EthereumVRFCoordinatorV2_5) HashOfKey 

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

func (*EthereumVRFCoordinatorV2_5) Migrate 

func (v *EthereumVRFCoordinatorV2_5) Migrate(subId *big.Int, coordinatorAddress string) error

func (*EthereumVRFCoordinatorV2_5) OwnerCancelSubscription 

func (v *EthereumVRFCoordinatorV2_5) OwnerCancelSubscription(subID *big.Int) (*types.Transaction, error)

OwnerCancelSubscription cancels subscription by Coordinator owner return funds to sub owner, does not check if pending requests for a sub exist

func (*EthereumVRFCoordinatorV2_5) ParseRandomWordsRequested 

func (v *EthereumVRFCoordinatorV2_5) ParseRandomWordsRequested(log types.Log) (*CoordinatorRandomWordsRequested, error)

func (*EthereumVRFCoordinatorV2_5) PendingRequestsExist 

func (v *EthereumVRFCoordinatorV2_5) PendingRequestsExist(ctx context.Context, subID *big.Int) (bool, error)

func (*EthereumVRFCoordinatorV2_5) RegisterMigratableCoordinator 

func (v *EthereumVRFCoordinatorV2_5) RegisterMigratableCoordinator(migratableCoordinatorAddress string) error

func (*EthereumVRFCoordinatorV2_5) RegisterProvingKey 

func (v *EthereumVRFCoordinatorV2_5) RegisterProvingKey(
	publicProvingKey [2]*big.Int,
	gasLaneMaxGas uint64,
) error

func (*EthereumVRFCoordinatorV2_5) SetConfig 

func (v *EthereumVRFCoordinatorV2_5) SetConfig(
	minimumRequestConfirmations uint16,
	maxGasLimit uint32,
	stalenessSeconds uint32,
	gasAfterPaymentCalculation uint32,
	fallbackWeiPerUnitLink *big.Int,
	fulfillmentFlatFeeNativePPM uint32,
	fulfillmentFlatFeeLinkDiscountPPM uint32,
	nativePremiumPercentage uint8,
	linkPremiumPercentage uint8) error

func (*EthereumVRFCoordinatorV2_5) SetLINKAndLINKNativeFeed 

func (v *EthereumVRFCoordinatorV2_5) SetLINKAndLINKNativeFeed(linkAddress string, linkNativeFeedAddress string) error

func (*EthereumVRFCoordinatorV2_5) WaitForConfigSetEvent 

func (v *EthereumVRFCoordinatorV2_5) WaitForConfigSetEvent(timeout time.Duration) (*CoordinatorConfigSet, error)

func (*EthereumVRFCoordinatorV2_5) WaitForMigrationCompletedEvent 

func (v *EthereumVRFCoordinatorV2_5) WaitForMigrationCompletedEvent(timeout time.Duration) (*vrf_coordinator_v2_5.VRFCoordinatorV25MigrationCompleted, error)

func (*EthereumVRFCoordinatorV2_5) WaitForRandomWordsFulfilledEvent 

func (v *EthereumVRFCoordinatorV2_5) WaitForRandomWordsFulfilledEvent(filter RandomWordsFulfilledEventFilter) (*CoordinatorRandomWordsFulfilled, error)

func (*EthereumVRFCoordinatorV2_5) WaitForSubscriptionCanceledEvent 

func (v *EthereumVRFCoordinatorV2_5) WaitForSubscriptionCanceledEvent(subID *big.Int, timeout time.Duration) (*vrf_coordinator_v2_5.VRFCoordinatorV25SubscriptionCanceled, error)

func (*EthereumVRFCoordinatorV2_5) WaitForSubscriptionCreatedEvent 

func (v *EthereumVRFCoordinatorV2_5) WaitForSubscriptionCreatedEvent(timeout time.Duration) (*vrf_coordinator_v2_5.VRFCoordinatorV25SubscriptionCreated, error)

func (*EthereumVRFCoordinatorV2_5) Withdraw 

func (v *EthereumVRFCoordinatorV2_5) Withdraw(recipient common.Address) error

func (*EthereumVRFCoordinatorV2_5) WithdrawNative 

func (v *EthereumVRFCoordinatorV2_5) WithdrawNative(recipient common.Address) error

type EthereumVRFCoordinatorV3 

type EthereumVRFCoordinatorV3 struct {
	// contains filtered or unexported fields
}

EthereumVRFCoordinatorV3 represents VRFCoordinatorV3 contract

func (*EthereumVRFCoordinatorV3) AddConsumer 

func (coordinator *EthereumVRFCoordinatorV3) AddConsumer(subId *big.Int, consumerAddress string) error

func (*EthereumVRFCoordinatorV3) Address 

func (coordinator *EthereumVRFCoordinatorV3) Address() string

func (*EthereumVRFCoordinatorV3) CreateSubscription 

func (coordinator *EthereumVRFCoordinatorV3) CreateSubscription() error

func (*EthereumVRFCoordinatorV3) FindSubscriptionID 

func (coordinator *EthereumVRFCoordinatorV3) FindSubscriptionID() (*big.Int, error)

func (*EthereumVRFCoordinatorV3) SetConfig 

func (coordinator *EthereumVRFCoordinatorV3) SetConfig(maxCallbackGasLimit uint32, maxCallbackArgumentsLength uint32) error

func (*EthereumVRFCoordinatorV3) SetProducer 

func (coordinator *EthereumVRFCoordinatorV3) SetProducer(producerAddress string) error

type EthereumVRFMockETHLINKFeed 

type EthereumVRFMockETHLINKFeed struct {
	// contains filtered or unexported fields
}

func (*EthereumVRFMockETHLINKFeed) Address 

func (v *EthereumVRFMockETHLINKFeed) Address() string

func (*EthereumVRFMockETHLINKFeed) LatestRoundData 

func (v *EthereumVRFMockETHLINKFeed) LatestRoundData() (*big.Int, error)

func (*EthereumVRFMockETHLINKFeed) LatestRoundDataUpdatedAt 

func (v *EthereumVRFMockETHLINKFeed) LatestRoundDataUpdatedAt() (*big.Int, error)

func (*EthereumVRFMockETHLINKFeed) SetBlockTimestampDeduction 

func (v *EthereumVRFMockETHLINKFeed) SetBlockTimestampDeduction(blockTimestampDeduction *big.Int) error

type EthereumVRFOwner 

type EthereumVRFOwner struct {
	// contains filtered or unexported fields
}

func (*EthereumVRFOwner) AcceptVRFOwnership 

func (v *EthereumVRFOwner) AcceptVRFOwnership() error

func (*EthereumVRFOwner) Address 

func (v *EthereumVRFOwner) Address() string

func (*EthereumVRFOwner) OwnerCancelSubscription 

func (v *EthereumVRFOwner) OwnerCancelSubscription(subID uint64) (*types.Transaction, error)

func (*EthereumVRFOwner) SetAuthorizedSenders 

func (v *EthereumVRFOwner) SetAuthorizedSenders(senders []common.Address) error

func (*EthereumVRFOwner) WaitForRandomWordsForcedEvent 

func (v *EthereumVRFOwner) WaitForRandomWordsForcedEvent(requestIDs []*big.Int, subIds []uint64, senders []common.Address, timeout time.Duration) (*vrf_owner.VRFOwnerRandomWordsForced, error)

type EthereumVRFV2PlusWrapper 

type EthereumVRFV2PlusWrapper struct {
	// contains filtered or unexported fields
}

func (*EthereumVRFV2PlusWrapper) Address 

func (v *EthereumVRFV2PlusWrapper) Address() string

func (*EthereumVRFV2PlusWrapper) Coordinator 

func (v *EthereumVRFV2PlusWrapper) Coordinator(ctx context.Context) (common.Address, error)

func (*EthereumVRFV2PlusWrapper) GetSubID 

func (v *EthereumVRFV2PlusWrapper) GetSubID(ctx context.Context) (*big.Int, error)

func (*EthereumVRFV2PlusWrapper) SetConfig 

func (v *EthereumVRFV2PlusWrapper) SetConfig(wrapperGasOverhead uint32,
	coordinatorGasOverheadNative uint32,
	coordinatorGasOverheadLink uint32,
	coordinatorGasOverheadPerWord uint16,
	wrapperNativePremiumPercentage uint8,
	wrapperLinkPremiumPercentage uint8,
	keyHash [32]byte,
	maxNumWords uint8,
	stalenessSeconds uint32,
	fallbackWeiPerUnitLink *big.Int,
	fulfillmentFlatFeeNativePPM uint32,
	fulfillmentFlatFeeLinkDiscountPPM uint32,
) error

type EthereumVRFV2PlusWrapperLoadTestConsumer 

type EthereumVRFV2PlusWrapperLoadTestConsumer struct {
	// contains filtered or unexported fields
}

func (*EthereumVRFV2PlusWrapperLoadTestConsumer) Address 

func (v *EthereumVRFV2PlusWrapperLoadTestConsumer) Address() string

func (*EthereumVRFV2PlusWrapperLoadTestConsumer) Fund 

func (v *EthereumVRFV2PlusWrapperLoadTestConsumer) Fund(ethAmount *big.Float) error

func (*EthereumVRFV2PlusWrapperLoadTestConsumer) GetLastRequestId 

func (v *EthereumVRFV2PlusWrapperLoadTestConsumer) GetLastRequestId(ctx context.Context) (*big.Int, error)

func (*EthereumVRFV2PlusWrapperLoadTestConsumer) GetLoadTestMetrics 

func (v *EthereumVRFV2PlusWrapperLoadTestConsumer) GetLoadTestMetrics(ctx context.Context) (*VRFLoadTestMetrics, error)

func (*EthereumVRFV2PlusWrapperLoadTestConsumer) GetRequestStatus 

func (v *EthereumVRFV2PlusWrapperLoadTestConsumer) GetRequestStatus(ctx context.Context, requestID *big.Int) (vrfv2plus_wrapper_load_test_consumer.GetRequestStatus, error)

func (*EthereumVRFV2PlusWrapperLoadTestConsumer) GetWrapper 

func (v *EthereumVRFV2PlusWrapperLoadTestConsumer) GetWrapper(ctx context.Context) (common.Address, error)

func (*EthereumVRFV2PlusWrapperLoadTestConsumer) RequestRandomness 

func (v *EthereumVRFV2PlusWrapperLoadTestConsumer) RequestRandomness(
	coordinator Coordinator,
	requestConfirmations uint16,
	callbackGasLimit uint32,
	numWords uint32,
	requestCount uint16,
) (*CoordinatorRandomWordsRequested, error)

func (*EthereumVRFV2PlusWrapperLoadTestConsumer) RequestRandomnessNative 

func (v *EthereumVRFV2PlusWrapperLoadTestConsumer) RequestRandomnessNative(
	coordinator Coordinator,
	requestConfirmations uint16,
	callbackGasLimit uint32,
	numWords uint32,
	requestCount uint16,
) (*CoordinatorRandomWordsRequested, error)

type EthereumVRFV2Wrapper 

type EthereumVRFV2Wrapper struct {
	// contains filtered or unexported fields
}

func (*EthereumVRFV2Wrapper) Address 

func (v *EthereumVRFV2Wrapper) Address() string

func (*EthereumVRFV2Wrapper) GetSubID 

func (v *EthereumVRFV2Wrapper) GetSubID(ctx context.Context) (uint64, error)

func (*EthereumVRFV2Wrapper) SetConfig 

func (v *EthereumVRFV2Wrapper) SetConfig(wrapperGasOverhead uint32, coordinatorGasOverhead uint32, wrapperPremiumPercentage uint8, keyHash [32]byte, maxNumWords uint8) error

type EthereumVRFV2WrapperLoadTestConsumer 

type EthereumVRFV2WrapperLoadTestConsumer struct {
	// contains filtered or unexported fields
}

func (*EthereumVRFV2WrapperLoadTestConsumer) Address 

func (v *EthereumVRFV2WrapperLoadTestConsumer) Address() string

func (*EthereumVRFV2WrapperLoadTestConsumer) Fund 

func (v *EthereumVRFV2WrapperLoadTestConsumer) Fund(ethAmount *big.Float) error

func (*EthereumVRFV2WrapperLoadTestConsumer) GetLastRequestId 

func (v *EthereumVRFV2WrapperLoadTestConsumer) GetLastRequestId(ctx context.Context) (*big.Int, error)

func (*EthereumVRFV2WrapperLoadTestConsumer) GetLoadTestMetrics 

func (v *EthereumVRFV2WrapperLoadTestConsumer) GetLoadTestMetrics(ctx context.Context) (*VRFLoadTestMetrics, error)

func (*EthereumVRFV2WrapperLoadTestConsumer) GetRequestStatus 

func (v *EthereumVRFV2WrapperLoadTestConsumer) GetRequestStatus(ctx context.Context, requestID *big.Int) (vrfv2_wrapper_load_test_consumer.GetRequestStatus, error)

func (*EthereumVRFV2WrapperLoadTestConsumer) GetWrapper 

func (v *EthereumVRFV2WrapperLoadTestConsumer) GetWrapper(ctx context.Context) (common.Address, error)

func (*EthereumVRFV2WrapperLoadTestConsumer) RequestRandomness 

func (v *EthereumVRFV2WrapperLoadTestConsumer) RequestRandomness(coordinator Coordinator, requestConfirmations uint16, callbackGasLimit uint32, numWords uint32, requestCount uint16) (*CoordinatorRandomWordsRequested, error)

type EthereumVRFv2Consumer 

type EthereumVRFv2Consumer struct {
	// contains filtered or unexported fields
}

EthereumVRFv2Consumer represents VRFv2 consumer contract

func (*EthereumVRFv2Consumer) Address 

func (v *EthereumVRFv2Consumer) Address() string

func (*EthereumVRFv2Consumer) GetLastRequestId 

func (v *EthereumVRFv2Consumer) GetLastRequestId(ctx context.Context) (*big.Int, error)

func (*EthereumVRFv2Consumer) GetRequestStatus 

func (v *EthereumVRFv2Consumer) GetRequestStatus(ctx context.Context, requestID *big.Int) (vrf_v2_consumer_wrapper.GetRequestStatus, error)

func (*EthereumVRFv2Consumer) RequestRandomness 

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

RequestRandomness request VRFv2 random words

type EthereumVRFv2LoadTestConsumer 

type EthereumVRFv2LoadTestConsumer struct {
	// contains filtered or unexported fields
}

EthereumVRFv2LoadTestConsumer represents VRFv2 consumer contract for performing Load Tests

func (*EthereumVRFv2LoadTestConsumer) Address 

func (v *EthereumVRFv2LoadTestConsumer) Address() string

func (*EthereumVRFv2LoadTestConsumer) GetLastRequestId 

func (v *EthereumVRFv2LoadTestConsumer) GetLastRequestId(ctx context.Context) (*big.Int, error)

func (*EthereumVRFv2LoadTestConsumer) GetLoadTestMetrics 

func (v *EthereumVRFv2LoadTestConsumer) GetLoadTestMetrics(ctx context.Context) (*VRFLoadTestMetrics, error)

func (*EthereumVRFv2LoadTestConsumer) GetRequestStatus 

func (v *EthereumVRFv2LoadTestConsumer) GetRequestStatus(ctx context.Context, requestID *big.Int) (vrf_load_test_with_metrics.GetRequestStatus, error)

func (*EthereumVRFv2LoadTestConsumer) RequestRandomWordsWithForceFulfill 

func (v *EthereumVRFv2LoadTestConsumer) RequestRandomWordsWithForceFulfill(
	coordinator Coordinator,
	keyHash [32]byte,
	requestConfirmations uint16,
	callbackGasLimit uint32,
	numWords uint32,
	requestCount uint16,
	subTopUpAmount *big.Int,
	linkAddress common.Address,
) (*CoordinatorRandomWordsRequested, error)

func (*EthereumVRFv2LoadTestConsumer) RequestRandomness 

func (v *EthereumVRFv2LoadTestConsumer) RequestRandomness(
	coordinator Coordinator,
	keyHash [32]byte,
	subID uint64,
	requestConfirmations uint16,
	callbackGasLimit uint32,
	numWords uint32,
	requestCount uint16,
) (*CoordinatorRandomWordsRequested, error)

func (*EthereumVRFv2LoadTestConsumer) ResetMetrics 

func (v *EthereumVRFv2LoadTestConsumer) ResetMetrics() error

type EthereumVRFv2PlusLoadTestConsumer 

type EthereumVRFv2PlusLoadTestConsumer struct {
	// contains filtered or unexported fields
}

EthereumVRFv2PlusLoadTestConsumer represents VRFv2Plus consumer contract for performing Load Tests

func (*EthereumVRFv2PlusLoadTestConsumer) Address 

func (v *EthereumVRFv2PlusLoadTestConsumer) Address() string

func (*EthereumVRFv2PlusLoadTestConsumer) GetCoordinator 

func (v *EthereumVRFv2PlusLoadTestConsumer) GetCoordinator(ctx context.Context) (common.Address, error)

func (*EthereumVRFv2PlusLoadTestConsumer) GetLastRequestId 

func (v *EthereumVRFv2PlusLoadTestConsumer) GetLastRequestId(ctx context.Context) (*big.Int, error)

func (*EthereumVRFv2PlusLoadTestConsumer) GetLoadTestMetrics 

func (v *EthereumVRFv2PlusLoadTestConsumer) GetLoadTestMetrics(ctx context.Context) (*VRFLoadTestMetrics, error)

func (*EthereumVRFv2PlusLoadTestConsumer) GetRequestStatus 

func (v *EthereumVRFv2PlusLoadTestConsumer) GetRequestStatus(ctx context.Context, requestID *big.Int) (vrf_v2plus_load_test_with_metrics.GetRequestStatus, error)

func (*EthereumVRFv2PlusLoadTestConsumer) RequestRandomness 

func (v *EthereumVRFv2PlusLoadTestConsumer) RequestRandomness(
	coordinator Coordinator,
	keyHash [32]byte, subID *big.Int,
	requestConfirmations uint16,
	callbackGasLimit uint32,
	nativePayment bool,
	numWords uint32,
	requestCount uint16,
) (*CoordinatorRandomWordsRequested, error)

func (*EthereumVRFv2PlusLoadTestConsumer) ResetMetrics 

func (v *EthereumVRFv2PlusLoadTestConsumer) ResetMetrics() error

type EthereumWERC20Mock 

type EthereumWERC20Mock struct {
	// contains filtered or unexported fields
}

func (*EthereumWERC20Mock) Address 

func (e *EthereumWERC20Mock) Address() common.Address

func (*EthereumWERC20Mock) Approve 

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

func (*EthereumWERC20Mock) BalanceOf 

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

func (*EthereumWERC20Mock) Mint 

func (e *EthereumWERC20Mock) Mint(account common.Address, amount *big.Int) (*types.Transaction, error)

func (*EthereumWERC20Mock) Transfer 

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

type FantomContractDeployer 

type FantomContractDeployer struct {
	*EthereumContractDeployer
}

type FantomContractLoader 

type FantomContractLoader struct {
	*EthereumContractLoader
}

FantomContractLoader wraps for Fantom

type Flags 

type Flags interface {
	Address() string
	GetFlag(ctx context.Context, addr string) (bool, error)
}

Flags flags contract interface

type FluxAggregator 

type FluxAggregator interface {
	Address() string
	Fund(ethAmount *big.Float) error
	LatestRoundID(ctx context.Context) (*big.Int, error)
	LatestRoundData(ctx context.Context) (flux_aggregator_wrapper.LatestRoundData, error)
	GetContractData(ctxt context.Context) (*FluxAggregatorData, error)
	UpdateAvailableFunds() error
	PaymentAmount(ctx context.Context) (*big.Int, error)
	RequestNewRound(ctx context.Context) error
	WithdrawPayment(ctx context.Context, from common.Address, to common.Address, amount *big.Int) error
	WithdrawablePayment(ctx context.Context, addr common.Address) (*big.Int, error)
	GetOracles(ctx context.Context) ([]string, error)
	SetOracles(opts FluxAggregatorSetOraclesOptions) error
	Description(ctxt context.Context) (string, error)
	SetRequesterPermissions(ctx context.Context, addr common.Address, authorized bool, roundsDelay uint32) error
	WatchSubmissionReceived(ctx context.Context, eventChan chan<- *SubmissionEvent) error
}

func DeployFluxAggregatorContract 

func DeployFluxAggregatorContract(
	seth *seth.Client,
	linkAddr string,
	fluxOptions FluxAggregatorOptions,
) (FluxAggregator, error)

DeployFluxAggregatorContract deploys the Flux Aggregator Contract on an EVM chain

type FluxAggregatorData 

type FluxAggregatorData struct {
	AllocatedFunds  *big.Int         // The amount of payment yet to be withdrawn by oracles
	AvailableFunds  *big.Int         // The amount of future funding available to oracles
	LatestRoundData RoundData        // Data about the latest round
	Oracles         []common.Address // Addresses of oracles on the contract
}

type FluxAggregatorOptions 

type FluxAggregatorOptions struct {
	PaymentAmount *big.Int       // The amount of LINK paid to each oracle per submission, in wei (units of 10⁻¹⁸ LINK)
	Timeout       uint32         // The number of seconds after the previous round that are allowed to lapse before allowing an oracle to skip an unfinished round
	Validator     common.Address // An optional contract address for validating external validation of answers
	MinSubValue   *big.Int       // An immutable check for a lower bound of what submission values are accepted from an oracle
	MaxSubValue   *big.Int       // An immutable check for an upper bound of what submission values are accepted from an oracle
	Decimals      uint8          // The number of decimals to offset the answer by
	Description   string         // A short description of what is being reported
}

func DefaultFluxAggregatorOptions 

func DefaultFluxAggregatorOptions() FluxAggregatorOptions

DefaultFluxAggregatorOptions produces some basic defaults for a flux aggregator contract

type FluxAggregatorRoundConfirmer 

type FluxAggregatorRoundConfirmer struct {
	// contains filtered or unexported fields
}

FluxAggregatorRoundConfirmer is a header subscription that awaits for a certain flux round to be completed

func NewFluxAggregatorRoundConfirmer 

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

NewFluxAggregatorRoundConfirmer provides a new instance of a FluxAggregatorRoundConfirmer

func (*FluxAggregatorRoundConfirmer) Complete 

func (f *FluxAggregatorRoundConfirmer) Complete() bool

func (*FluxAggregatorRoundConfirmer) ReceiveHeader 

func (f *FluxAggregatorRoundConfirmer) ReceiveHeader(header blockchain.NodeHeader) error

ReceiveHeader will query the latest FluxAggregator round and check to see whether the round has confirmed

func (*FluxAggregatorRoundConfirmer) Wait 

func (f *FluxAggregatorRoundConfirmer) Wait() error

Wait is a blocking function that will wait until the round has confirmed, and timeout if the deadline has passed

type FluxAggregatorSetOraclesOptions 

type FluxAggregatorSetOraclesOptions struct {
	AddList            []common.Address // oracle addresses to add
	RemoveList         []common.Address // oracle addresses to remove
	AdminList          []common.Address // oracle addresses to become admin
	MinSubmissions     uint32           // min amount of submissions in round
	MaxSubmissions     uint32           // max amount of submissions in round
	RestartDelayRounds uint32           // rounds to wait after oracles has changed
}

type FunctionsBillingRegistryEventsMock 

type FunctionsBillingRegistryEventsMock interface {
	Address() string
	SubscriptionFunded(subscriptionId uint64, oldBalance *big.Int, newBalance *big.Int) error
	BillingStart(requestId [32]byte, commitment functions_billing_registry_events_mock.FunctionsBillingRegistryEventsMockCommitment) error
	BillingEnd(requestId [32]byte, subscriptionId uint64, signerPayment *big.Int, transmitterPayment *big.Int, totalCost *big.Int, success bool) error
}

type FunctionsCoordinator 

type FunctionsCoordinator interface {
	Address() string
	GetThresholdPublicKey() ([]byte, error)
	GetDONPublicKey() ([]byte, error)
}

func LoadFunctionsCoordinator 

func LoadFunctionsCoordinator(seth *seth.Client, addr string) (FunctionsCoordinator, error)

type FunctionsLoadTestClient 

type FunctionsLoadTestClient interface {
	Address() string
	ResetStats() error
	GetStats() (*EthereumFunctionsLoadStats, error)
	SendRequest(times uint32, source string, encryptedSecretsReferences []byte, args []string, subscriptionId uint64, jobId [32]byte) error
	SendRequestWithDONHostedSecrets(times uint32, source string, slotID uint8, slotVersion uint64, args []string, subscriptionId uint64, donID [32]byte) error
}

func DeployFunctionsLoadTestClient 

func DeployFunctionsLoadTestClient(seth *seth.Client, router string) (FunctionsLoadTestClient, error)

func LoadFunctionsLoadTestClient 

func LoadFunctionsLoadTestClient(seth *seth.Client, addr string) (FunctionsLoadTestClient, error)

LoadFunctionsLoadTestClient returns deployed on given address FunctionsLoadTestClient contract instance

type FunctionsOracleEventsMock 

type FunctionsOracleEventsMock interface {
	Address() string
	OracleResponse(requestId [32]byte) error
	OracleRequest(requestId [32]byte, requestingContract common.Address, requestInitiator common.Address, subscriptionId uint64, subscriptionOwner common.Address, data []byte) error
	UserCallbackError(requestId [32]byte, reason string) error
	UserCallbackRawError(requestId [32]byte, lowLevelData []byte) error
}

type FunctionsRouter 

type FunctionsRouter interface {
	Address() string
	CreateSubscriptionWithConsumer(consumer string) (uint64, error)
}

func LoadFunctionsRouter 

func LoadFunctionsRouter(l zerolog.Logger, seth *seth.Client, addr string) (FunctionsRouter, error)

type FunctionsV1EventsMock 

type FunctionsV1EventsMock interface {
	Address() string
	EmitRequestProcessed(requestId [32]byte, subscriptionId uint64, totalCostJuels *big.Int, transmitter common.Address, resultCode uint8, response []byte, errByte []byte, callbackReturnData []byte) error
	EmitRequestStart(requestId [32]byte, donId [32]byte, subscriptionId uint64, subscriptionOwner common.Address, requestingContract common.Address, requestInitiator common.Address, data []byte, dataVersion uint16, callbackGasLimit uint32, estimatedTotalCostJuels *big.Int) error
	EmitSubscriptionCanceled(subscriptionId uint64, fundsRecipient common.Address, fundsAmount *big.Int) error
	EmitSubscriptionConsumerAdded(subscriptionId uint64, consumer common.Address) error
	EmitSubscriptionConsumerRemoved(subscriptionId uint64, consumer common.Address) error
	EmitSubscriptionCreated(subscriptionId uint64, owner common.Address) error
	EmitSubscriptionFunded(subscriptionId uint64, oldBalance *big.Int, newBalance *big.Int) error
	EmitSubscriptionOwnerTransferred(subscriptionId uint64, from common.Address, to common.Address) error
	EmitSubscriptionOwnerTransferRequested(subscriptionId uint64, from common.Address, to common.Address) error
	EmitRequestNotProcessed(requestId [32]byte, coordinator common.Address, transmitter common.Address, resultCode uint8) error
	EmitContractUpdated(id [32]byte, from common.Address, to common.Address) error
}

func DeployFunctionsV1EventsMock 

func DeployFunctionsV1EventsMock(client *seth.Client) (FunctionsV1EventsMock, error)

DeployFunctionsV1EventsMock deploys a new instance of the FunctionsV1EventsMock contract

type GetRequestConfig 

type GetRequestConfig struct {
	MinimumRequestConfirmations uint16
	MaxGasLimit                 uint32
	ProvingKeyHashes            [32]byte
}

type GnosisContractDeployer 

type GnosisContractDeployer struct {
	*EthereumContractDeployer
}

type GnosisContractLoader 

type GnosisContractLoader struct {
	*EthereumContractLoader
}

GnosisContractLoader wraps for Gnosis

type JobByInstance 

type JobByInstance struct {
	ID       string
	Instance string
}

JobByInstance helper struct to match job + instance ID

type KeeperConsumer 

type KeeperConsumer interface {
	Address() string
	Counter(ctx context.Context) (*big.Int, error)
	Start() error
}

type KeeperConsumerBenchmarkRoundConfirmer 

type KeeperConsumerBenchmarkRoundConfirmer struct {
	// contains filtered or unexported fields
}

KeeperConsumerBenchmarkRoundConfirmer is a header subscription that awaits for a round of upkeeps

func NewKeeperConsumerBenchmarkRoundConfirmer 

func NewKeeperConsumerBenchmarkRoundConfirmer(
	contract AutomationConsumerBenchmark,
	registry KeeperRegistry,
	upkeepID *big.Int,
	blockRange int64,
	upkeepSLA int64,
	metricsReporter *testreporters.KeeperBenchmarkTestReporter,
	upkeepIndex int64,
	firstEligibleBuffer int64,
	logger zerolog.Logger,
) *KeeperConsumerBenchmarkRoundConfirmer

NewKeeperConsumerBenchmarkRoundConfirmer provides a new instance of a KeeperConsumerBenchmarkRoundConfirmer Used to track and log benchmark test results for keepers

func (*KeeperConsumerBenchmarkRoundConfirmer) Complete 

func (o *KeeperConsumerBenchmarkRoundConfirmer) Complete() bool

func (*KeeperConsumerBenchmarkRoundConfirmer) ReceiveHeader 

func (o *KeeperConsumerBenchmarkRoundConfirmer) ReceiveHeader(receivedHeader blockchain.NodeHeader) error

ReceiveHeader will query the latest Keeper round and check to see whether the round has confirmed

func (*KeeperConsumerBenchmarkRoundConfirmer) Wait 

func (o *KeeperConsumerBenchmarkRoundConfirmer) Wait() error

Wait is a blocking function that will wait until the round has confirmed, and timeout if the deadline has passed

type KeeperConsumerPerformance 

type KeeperConsumerPerformance interface {
	Address() string
	Fund(ethAmount *big.Float) error
	CheckEligible(ctx context.Context) (bool, error)
	GetUpkeepCount(ctx context.Context) (*big.Int, error)
	SetCheckGasToBurn(ctx context.Context, gas *big.Int) error
	SetPerformGasToBurn(ctx context.Context, gas *big.Int) error
}

KeeperConsumerPerformance is a keeper consumer contract that is more complicated than the typical consumer, it's intended to only be used for performance tests.

type KeeperConsumerPerformanceRoundConfirmer 

type KeeperConsumerPerformanceRoundConfirmer struct {
	// contains filtered or unexported fields
}

KeeperConsumerPerformanceRoundConfirmer is a header subscription that awaits for a round of upkeeps

func NewKeeperConsumerPerformanceRoundConfirmer 

func NewKeeperConsumerPerformanceRoundConfirmer(
	contract KeeperConsumerPerformance,
	expectedBlockCadence int64,
	blockRange int64,
	metricsReporter *testreporters.KeeperBlockTimeTestReporter,
	logger zerolog.Logger,
) *KeeperConsumerPerformanceRoundConfirmer

NewKeeperConsumerPerformanceRoundConfirmer provides a new instance of a KeeperConsumerPerformanceRoundConfirmer Used to track and log performance test results for keepers

func (*KeeperConsumerPerformanceRoundConfirmer) Complete 

func (o *KeeperConsumerPerformanceRoundConfirmer) Complete() bool

func (*KeeperConsumerPerformanceRoundConfirmer) ReceiveHeader 

func (o *KeeperConsumerPerformanceRoundConfirmer) ReceiveHeader(receivedHeader blockchain.NodeHeader) error

ReceiveHeader will query the latest Keeper round and check to see whether the round has confirmed

func (*KeeperConsumerPerformanceRoundConfirmer) Wait 

func (o *KeeperConsumerPerformanceRoundConfirmer) Wait() error

Wait is a blocking function that will wait until the round has confirmed, and timeout if the deadline has passed

type KeeperConsumerRoundConfirmer 

type KeeperConsumerRoundConfirmer struct {
	// contains filtered or unexported fields
}

KeeperConsumerRoundConfirmer is a header subscription that awaits for a round of upkeeps

func NewKeeperConsumerRoundConfirmer 

func NewKeeperConsumerRoundConfirmer(
	contract KeeperConsumer,
	counterValue int,
	timeout time.Duration,
	logger zerolog.Logger,
) *KeeperConsumerRoundConfirmer

NewKeeperConsumerRoundConfirmer provides a new instance of a KeeperConsumerRoundConfirmer

func (*KeeperConsumerRoundConfirmer) ReceiveHeader 

func (o *KeeperConsumerRoundConfirmer) ReceiveHeader(_ blockchain.NodeHeader) error

ReceiveHeader will query the latest Keeper round and check to see whether the round has confirmed

func (*KeeperConsumerRoundConfirmer) Wait 

func (o *KeeperConsumerRoundConfirmer) Wait() error

Wait is a blocking function that will wait until the round has confirmed, and timeout if the deadline has passed

type KeeperGasWrapperMock 

type KeeperGasWrapperMock interface {
	Address() string
	SetMeasureCheckGasResult(result bool, payload []byte, gas *big.Int) error
}

func DeployKeeperGasWrapperMock 

func DeployKeeperGasWrapperMock(client *seth.Client) (KeeperGasWrapperMock, error)

type KeeperInfo 

type KeeperInfo struct {
	Payee   string
	Active  bool
	Balance *big.Int
}

KeeperInfo keeper status and balance info

type KeeperPerformDataChecker 

type KeeperPerformDataChecker interface {
	Address() string
	Counter(ctx context.Context) (*big.Int, error)
	SetExpectedData(ctx context.Context, expectedData []byte) error
}

type KeeperRegistrar 

type KeeperRegistrar interface {
	Address() string

	EncodeRegisterRequest(name string, email []byte, upkeepAddr string, gasLimit uint32, adminAddr string, checkData []byte, amount *big.Int, source uint8, senderAddr string, isLogTrigger bool, isMercury bool) ([]byte, error)

	Fund(ethAmount *big.Float) error
}

type KeeperRegistrar12Mock 

type KeeperRegistrar12Mock interface {
	Address() string
	EmitRegistrationRequested(hash [32]byte, name string, encryptedEmail []byte, upkeepContract common.Address, gasLimit uint32, adminAddress common.Address, checkData []byte, amount *big.Int, source uint8) error
	EmitRegistrationApproved(hash [32]byte, displayName string, upkeepId *big.Int) error
	SetRegistrationConfig(_autoApproveConfigType uint8, _autoApproveMaxAllowed uint32, _approvedCount uint32, _keeperRegistry common.Address, _minLINKJuels *big.Int) error
}

func DeployKeeperRegistrar12Mock 

func DeployKeeperRegistrar12Mock(client *seth.Client) (KeeperRegistrar12Mock, error)

type KeeperRegistrarSettings 

type KeeperRegistrarSettings struct {
	AutoApproveConfigType uint8
	AutoApproveMaxAllowed uint16
	RegistryAddr          string
	MinLinkJuels          *big.Int
}

KeeperRegistrarSettings represents settings for registrar contract

type KeeperRegistry 

type KeeperRegistry interface {
	Address() string
	Fund(ethAmount *big.Float) error
	SetConfig(config KeeperRegistrySettings, ocrConfig OCRv2Config) error
	SetConfigTypeSafe(ocrConfig OCRv2Config) error
	SetRegistrar(registrarAddr string) error
	AddUpkeepFunds(id *big.Int, amount *big.Int) error
	GetUpkeepInfo(ctx context.Context, id *big.Int) (*UpkeepInfo, error)
	GetKeeperInfo(ctx context.Context, keeperAddr string) (*KeeperInfo, error)
	SetKeepers(keepers []string, payees []string, ocrConfig OCRv2Config) error
	GetKeeperList(ctx context.Context) ([]string, error)
	RegisterUpkeep(target string, gasLimit uint32, admin string, checkData []byte) error
	CancelUpkeep(id *big.Int) error
	SetUpkeepGasLimit(id *big.Int, gas uint32) error
	ParseUpkeepPerformedLog(log *types.Log) (*UpkeepPerformedLog, error)
	ParseStaleUpkeepReportLog(log *types.Log) (*StaleUpkeepReportLog, error)
	ParseUpkeepIdFromRegisteredLog(log *types.Log) (*big.Int, error)
	Pause() error
	Migrate(upkeepIDs []*big.Int, destinationAddress common.Address) error
	SetMigrationPermissions(peerAddress common.Address, permission uint8) error
	PauseUpkeep(id *big.Int) error
	UnpauseUpkeep(id *big.Int) error
	UpdateCheckData(id *big.Int, newCheckData []byte) error
	SetUpkeepTriggerConfig(id *big.Int, triggerConfig []byte) error
	SetUpkeepPrivilegeConfig(id *big.Int, privilegeConfig []byte) error
	RegistryOwnerAddress() common.Address
	ChainModuleAddress() common.Address
	ReorgProtectionEnabled() bool
}

type KeeperRegistry11Mock 

type KeeperRegistry11Mock interface {
	Address() string
	EmitUpkeepPerformed(id *big.Int, success bool, from common.Address, payment *big.Int, performData []byte) error
	EmitUpkeepCanceled(id *big.Int, atBlockHeight uint64) error
	EmitFundsWithdrawn(id *big.Int, amount *big.Int, to common.Address) error
	EmitKeepersUpdated(keepers []common.Address, payees []common.Address) error
	EmitUpkeepRegistered(id *big.Int, executeGas uint32, admin common.Address) error
	EmitFundsAdded(id *big.Int, from common.Address, amount *big.Int) error
	SetUpkeepCount(_upkeepCount *big.Int) error
	SetCanceledUpkeepList(_canceledUpkeepList []*big.Int) error
	SetKeeperList(_keepers []common.Address) error
	SetConfig(_paymentPremiumPPB uint32, _flatFeeMicroLink uint32, _blockCountPerTurn *big.Int, _checkGasLimit uint32, _stalenessSeconds *big.Int, _gasCeilingMultiplier uint16, _fallbackGasPrice *big.Int, _fallbackLinkPrice *big.Int) error
	SetUpkeep(id *big.Int, _target common.Address, _executeGas uint32, _balance *big.Int, _admin common.Address, _maxValidBlocknumber uint64, _lastKeeper common.Address, _checkData []byte) error
	SetMinBalance(id *big.Int, minBalance *big.Int) error
	SetCheckUpkeepData(id *big.Int, performData []byte, maxLinkPayment *big.Int, gasLimit *big.Int, adjustedGasWei *big.Int, linkEth *big.Int) error
	SetPerformUpkeepSuccess(id *big.Int, success bool) error
}

func DeployKeeperRegistry11Mock 

func DeployKeeperRegistry11Mock(client *seth.Client) (KeeperRegistry11Mock, error)

type KeeperRegistryCheckUpkeepGasUsageWrapper 

type KeeperRegistryCheckUpkeepGasUsageWrapper interface {
	Address() string
}

type KeeperRegistryOpts 

type KeeperRegistryOpts struct {
	RegistryVersion ethereum.KeeperRegistryVersion
	LinkAddr        string
	ETHFeedAddr     string
	GasFeedAddr     string
	TranscoderAddr  string
	RegistrarAddr   string
	Settings        KeeperRegistrySettings
}

KeeperRegistryOpts opts to deploy keeper registry version

type KeeperRegistrySettings 

type KeeperRegistrySettings struct {
	PaymentPremiumPPB    uint32   // payment premium rate oracles receive on top of being reimbursed for gas, measured in parts per billion
	FlatFeeMicroLINK     uint32   // flat fee charged for each upkeep
	BlockCountPerTurn    *big.Int // number of blocks each oracle has during their turn to perform upkeep before it will be the next keeper's turn to submit
	CheckGasLimit        uint32   // gas limit when checking for upkeep
	StalenessSeconds     *big.Int // number of seconds that is allowed for feed data to be stale before switching to the fallback pricing
	GasCeilingMultiplier uint16   // multiplier to apply to the fast gas feed price when calculating the payment ceiling for keepers
	MinUpkeepSpend       *big.Int // minimum spend required by an upkeep before they can withdraw funds
	MaxPerformGas        uint32   // max gas allowed for an upkeep within perform
	FallbackGasPrice     *big.Int // gas price used if the gas price feed is stale
	FallbackLinkPrice    *big.Int // LINK price used if the LINK price feed is stale
	MaxCheckDataSize     uint32
	MaxPerformDataSize   uint32
	MaxRevertDataSize    uint32
	RegistryVersion      ethereum.KeeperRegistryVersion
}

KeeperRegistrySettings represents the settings to fine tune keeper registry

func (*KeeperRegistrySettings) Create21OnchainConfig 

func (rcs *KeeperRegistrySettings) Create21OnchainConfig(registrar string, registryOwnerAddress common.Address) i_keeper_registry_master_wrapper_2_1.IAutomationV21PlusCommonOnchainConfigLegacy

func (*KeeperRegistrySettings) Create22OnchainConfig 

func (rcs *KeeperRegistrySettings) Create22OnchainConfig(registrar string, registryOwnerAddress, chainModuleAddress common.Address, reorgProtectionEnabled bool) i_automation_registry_master_wrapper_2_2.AutomationRegistryBase22OnchainConfig

func (*KeeperRegistrySettings) Encode20OnchainConfig 

func (rcs *KeeperRegistrySettings) Encode20OnchainConfig(registrar string) []byte

type KlaytnContractDeployer 

type KlaytnContractDeployer struct {
	*EthereumContractDeployer
}

KlaytnContractDeployer wraps ethereum contract deployments for Klaytn

type KlaytnContractLoader 

type KlaytnContractLoader struct {
	*EthereumContractLoader
}

KlaytnContractLoader wraps ethereum contract deployments for Klaytn

type KromaContractDeployer 

type KromaContractDeployer struct {
	*EthereumContractDeployer
}

type LegacyEthereumAPIConsumer 

type LegacyEthereumAPIConsumer struct {
	// contains filtered or unexported fields
}

LegacyEthereumAPIConsumer API consumer for job type "directrequest" tests

func (*LegacyEthereumAPIConsumer) Address 

func (e *LegacyEthereumAPIConsumer) Address() string

func (*LegacyEthereumAPIConsumer) CreateRequestTo 

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

CreateRequestTo creates request to an oracle for particular jobID with params

func (*LegacyEthereumAPIConsumer) Data 

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

func (*LegacyEthereumAPIConsumer) Fund 

func (e *LegacyEthereumAPIConsumer) Fund(ethAmount *big.Float) error

func (*LegacyEthereumAPIConsumer) RoundID 

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

type LegacyEthereumAuthorizedForwarder 

type LegacyEthereumAuthorizedForwarder struct {
	// contains filtered or unexported fields
}

LegacyEthereumAuthorizedForwarder represents authorized forwarder contract Deprecated: we are moving away from blockchain.EVMClient, use EthereumAuthorizedForwarder instead

func (*LegacyEthereumAuthorizedForwarder) Address 

func (e *LegacyEthereumAuthorizedForwarder) Address() string

func (*LegacyEthereumAuthorizedForwarder) GetAuthorizedSenders 

func (e *LegacyEthereumAuthorizedForwarder) GetAuthorizedSenders(ctx context.Context) ([]string, error)

func (*LegacyEthereumAuthorizedForwarder) Owner 

func (e *LegacyEthereumAuthorizedForwarder) Owner(ctx context.Context) (string, error)

Owner return authorized forwarder owner address

type LegacyEthereumBatchBlockhashStore 

type LegacyEthereumBatchBlockhashStore struct {
	// contains filtered or unexported fields
}

LegacyEthereumBatchBlockhashStore represents BatchBlockhashStore contract

func (*LegacyEthereumBatchBlockhashStore) Address 

func (v *LegacyEthereumBatchBlockhashStore) Address() string

type LegacyEthereumBlockhashStore 

type LegacyEthereumBlockhashStore struct {
	// contains filtered or unexported fields
}

LegacyEthereumBlockhashStore represents a blockhash store for VRF contract

func (*LegacyEthereumBlockhashStore) Address 

func (v *LegacyEthereumBlockhashStore) Address() string

func (*LegacyEthereumBlockhashStore) GetBlockHash 

func (v *LegacyEthereumBlockhashStore) GetBlockHash(ctx context.Context, blockNumber *big.Int) ([32]byte, error)

type LegacyEthereumFluxAggregator 

type LegacyEthereumFluxAggregator struct {
	// contains filtered or unexported fields
}

LegacyEthereumFluxAggregator represents the basic flux aggregation contract

func (*LegacyEthereumFluxAggregator) Address 

func (f *LegacyEthereumFluxAggregator) Address() string

func (*LegacyEthereumFluxAggregator) Description 

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

Description returns the description of the flux aggregator contract

func (*LegacyEthereumFluxAggregator) Fund 

func (f *LegacyEthereumFluxAggregator) Fund(ethAmount *big.Float) error

Fund sends specified currencies to the contract

func (*LegacyEthereumFluxAggregator) GetContractData 

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

GetContractData retrieves basic data for the flux aggregator contract

func (*LegacyEthereumFluxAggregator) GetOracles 

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

func (*LegacyEthereumFluxAggregator) LatestRoundData 

func (f *LegacyEthereumFluxAggregator) LatestRoundData(ctx context.Context) (flux_aggregator_wrapper.LatestRoundData, error)

func (*LegacyEthereumFluxAggregator) LatestRoundID 

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

func (*LegacyEthereumFluxAggregator) PaymentAmount 

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

func (*LegacyEthereumFluxAggregator) RequestNewRound 

func (f *LegacyEthereumFluxAggregator) RequestNewRound(_ context.Context) error

func (*LegacyEthereumFluxAggregator) SetOracles 

func (f *LegacyEthereumFluxAggregator) SetOracles(o FluxAggregatorSetOraclesOptions) error

SetOracles allows the ability to add and/or remove oracles from the contract, and to set admins

func (*LegacyEthereumFluxAggregator) SetRequesterPermissions 

func (f *LegacyEthereumFluxAggregator) SetRequesterPermissions(_ context.Context, addr common.Address, authorized bool, roundsDelay uint32) error

func (*LegacyEthereumFluxAggregator) UpdateAvailableFunds 

func (f *LegacyEthereumFluxAggregator) UpdateAvailableFunds() error

func (*LegacyEthereumFluxAggregator) WatchSubmissionReceived 

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

WatchSubmissionReceived subscribes to any submissions on a flux feed

func (*LegacyEthereumFluxAggregator) WithdrawPayment 

func (f *LegacyEthereumFluxAggregator) WithdrawPayment(
	_ context.Context,
	from common.Address,
	to common.Address,
	amount *big.Int) error

func (*LegacyEthereumFluxAggregator) WithdrawablePayment 

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

type LegacyEthereumFunctionsCoordinator 

type LegacyEthereumFunctionsCoordinator struct {
	// contains filtered or unexported fields
}

func (*LegacyEthereumFunctionsCoordinator) Address 

func (e *LegacyEthereumFunctionsCoordinator) Address() string

func (*LegacyEthereumFunctionsCoordinator) GetDONPublicKey 

func (e *LegacyEthereumFunctionsCoordinator) GetDONPublicKey() ([]byte, error)

func (*LegacyEthereumFunctionsCoordinator) GetThresholdPublicKey 

func (e *LegacyEthereumFunctionsCoordinator) GetThresholdPublicKey() ([]byte, error)

type LegacyEthereumFunctionsLoadTestClient 

type LegacyEthereumFunctionsLoadTestClient struct {
	// contains filtered or unexported fields
}

func (*LegacyEthereumFunctionsLoadTestClient) Address 

func (e *LegacyEthereumFunctionsLoadTestClient) Address() string

func (*LegacyEthereumFunctionsLoadTestClient) GetStats 

func (e *LegacyEthereumFunctionsLoadTestClient) GetStats() (*EthereumFunctionsLoadStats, error)

func (*LegacyEthereumFunctionsLoadTestClient) ResetStats 

func (e *LegacyEthereumFunctionsLoadTestClient) ResetStats() error

func (*LegacyEthereumFunctionsLoadTestClient) SendRequest 

func (e *LegacyEthereumFunctionsLoadTestClient) SendRequest(times uint32, source string, encryptedSecretsReferences []byte, args []string, subscriptionId uint64, jobId [32]byte) error

func (*LegacyEthereumFunctionsLoadTestClient) SendRequestWithDONHostedSecrets 

func (e *LegacyEthereumFunctionsLoadTestClient) SendRequestWithDONHostedSecrets(times uint32, source string, slotID uint8, slotVersion uint64, args []string, subscriptionId uint64, donID [32]byte) error

type LegacyEthereumFunctionsRouter 

type LegacyEthereumFunctionsRouter struct {
	// contains filtered or unexported fields
}

func (*LegacyEthereumFunctionsRouter) Address 

func (e *LegacyEthereumFunctionsRouter) Address() string

func (*LegacyEthereumFunctionsRouter) CreateSubscriptionWithConsumer 

func (e *LegacyEthereumFunctionsRouter) CreateSubscriptionWithConsumer(consumer string) (uint64, error)

type LegacyEthereumFunctionsV1EventsMock 

type LegacyEthereumFunctionsV1EventsMock struct {
	// contains filtered or unexported fields
}

LegacyEthereumFunctionsV1EventsMock represents the basic functions v1 events mock contract

func (*LegacyEthereumFunctionsV1EventsMock) Address 

func (f *LegacyEthereumFunctionsV1EventsMock) Address() string

func (*LegacyEthereumFunctionsV1EventsMock) EmitContractUpdated 

func (f *LegacyEthereumFunctionsV1EventsMock) EmitContractUpdated(id [32]byte, from common.Address, to common.Address) error

func (*LegacyEthereumFunctionsV1EventsMock) EmitRequestNotProcessed 

func (f *LegacyEthereumFunctionsV1EventsMock) EmitRequestNotProcessed(requestId [32]byte, coordinator common.Address, transmitter common.Address, resultCode uint8) error

func (*LegacyEthereumFunctionsV1EventsMock) EmitRequestProcessed 

func (f *LegacyEthereumFunctionsV1EventsMock) EmitRequestProcessed(requestId [32]byte, subscriptionId uint64, totalCostJuels *big.Int, transmitter common.Address, resultCode uint8, response []byte, errByte []byte, callbackReturnData []byte) error

func (*LegacyEthereumFunctionsV1EventsMock) EmitRequestStart 

func (f *LegacyEthereumFunctionsV1EventsMock) EmitRequestStart(requestId [32]byte, donId [32]byte, subscriptionId uint64, subscriptionOwner common.Address, requestingContract common.Address, requestInitiator common.Address, data []byte, dataVersion uint16, callbackGasLimit uint32, estimatedTotalCostJuels *big.Int) error

func (*LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionCanceled 

func (f *LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionCanceled(subscriptionId uint64, fundsRecipient common.Address, fundsAmount *big.Int) error

func (*LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionConsumerAdded 

func (f *LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionConsumerAdded(subscriptionId uint64, consumer common.Address) error

func (*LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionConsumerRemoved 

func (f *LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionConsumerRemoved(subscriptionId uint64, consumer common.Address) error

func (*LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionCreated 

func (f *LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionCreated(subscriptionId uint64, owner common.Address) error

func (*LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionFunded 

func (f *LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionFunded(subscriptionId uint64, oldBalance *big.Int, newBalance *big.Int) error

func (*LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionOwnerTransferRequested 

func (f *LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionOwnerTransferRequested(subscriptionId uint64, from common.Address, to common.Address) error

func (*LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionOwnerTransferred 

func (f *LegacyEthereumFunctionsV1EventsMock) EmitSubscriptionOwnerTransferred(subscriptionId uint64, from common.Address, to common.Address) error

type LegacyEthereumKeeperGasWrapperMock 

type LegacyEthereumKeeperGasWrapperMock struct {
	// contains filtered or unexported fields
}

LegacyEthereumKeeperGasWrapperMock represents the basic keeper gas wrapper mock contract

func (*LegacyEthereumKeeperGasWrapperMock) Address 

func (f *LegacyEthereumKeeperGasWrapperMock) Address() string

func (*LegacyEthereumKeeperGasWrapperMock) SetMeasureCheckGasResult 

func (f *LegacyEthereumKeeperGasWrapperMock) SetMeasureCheckGasResult(result bool, payload []byte, gas *big.Int) error

type LegacyEthereumKeeperRegistrar12Mock 

type LegacyEthereumKeeperRegistrar12Mock struct {
	// contains filtered or unexported fields
}

LegacyEthereumKeeperRegistrar12Mock represents the basic keeper registrar 1.2 mock contract

func (*LegacyEthereumKeeperRegistrar12Mock) Address 

func (f *LegacyEthereumKeeperRegistrar12Mock) Address() string

func (*LegacyEthereumKeeperRegistrar12Mock) EmitRegistrationApproved 

func (f *LegacyEthereumKeeperRegistrar12Mock) EmitRegistrationApproved(hash [32]byte, displayName string, upkeepId *big.Int) error

func (*LegacyEthereumKeeperRegistrar12Mock) EmitRegistrationRequested 

func (f *LegacyEthereumKeeperRegistrar12Mock) EmitRegistrationRequested(hash [32]byte, name string, encryptedEmail []byte, upkeepContract common.Address, gasLimit uint32, adminAddress common.Address, checkData []byte, amount *big.Int, source uint8) error

func (*LegacyEthereumKeeperRegistrar12Mock) SetRegistrationConfig 

func (f *LegacyEthereumKeeperRegistrar12Mock) SetRegistrationConfig(_autoApproveConfigType uint8, _autoApproveMaxAllowed uint32, _approvedCount uint32, _keeperRegistry common.Address, _minLINKJuels *big.Int) error

type LegacyEthereumKeeperRegistry11Mock 

type LegacyEthereumKeeperRegistry11Mock struct {
	// contains filtered or unexported fields
}

LegacyEthereumKeeperRegistry11Mock represents the basic keeper registry 1.1 mock contract

func (*LegacyEthereumKeeperRegistry11Mock) Address 

func (f *LegacyEthereumKeeperRegistry11Mock) Address() string

func (*LegacyEthereumKeeperRegistry11Mock) EmitFundsAdded 

func (f *LegacyEthereumKeeperRegistry11Mock) EmitFundsAdded(id *big.Int, from common.Address, amount *big.Int) error

func (*LegacyEthereumKeeperRegistry11Mock) EmitFundsWithdrawn 

func (f *LegacyEthereumKeeperRegistry11Mock) EmitFundsWithdrawn(id *big.Int, amount *big.Int, to common.Address) error

func (*LegacyEthereumKeeperRegistry11Mock) EmitKeepersUpdated 

func (f *LegacyEthereumKeeperRegistry11Mock) EmitKeepersUpdated(keepers []common.Address, payees []common.Address) error

func (*LegacyEthereumKeeperRegistry11Mock) EmitUpkeepCanceled 

func (f *LegacyEthereumKeeperRegistry11Mock) EmitUpkeepCanceled(id *big.Int, atBlockHeight uint64) error

func (*LegacyEthereumKeeperRegistry11Mock) EmitUpkeepPerformed 

func (f *LegacyEthereumKeeperRegistry11Mock) EmitUpkeepPerformed(id *big.Int, success bool, from common.Address, payment *big.Int, performData []byte) error

func (*LegacyEthereumKeeperRegistry11Mock) EmitUpkeepRegistered 

func (f *LegacyEthereumKeeperRegistry11Mock) EmitUpkeepRegistered(id *big.Int, executeGas uint32, admin common.Address) error

func (*LegacyEthereumKeeperRegistry11Mock) SetCanceledUpkeepList 

func (f *LegacyEthereumKeeperRegistry11Mock) SetCanceledUpkeepList(_canceledUpkeepList []*big.Int) error

func (*LegacyEthereumKeeperRegistry11Mock) SetCheckUpkeepData 

func (f *LegacyEthereumKeeperRegistry11Mock) SetCheckUpkeepData(id *big.Int, performData []byte, maxLinkPayment *big.Int, gasLimit *big.Int, adjustedGasWei *big.Int, linkEth *big.Int) error

func (*LegacyEthereumKeeperRegistry11Mock) SetConfig 

func (f *LegacyEthereumKeeperRegistry11Mock) SetConfig(_paymentPremiumPPB uint32, _flatFeeMicroLink uint32, _blockCountPerTurn *big.Int, _checkGasLimit uint32, _stalenessSeconds *big.Int, _gasCeilingMultiplier uint16, _fallbackGasPrice *big.Int, _fallbackLinkPrice *big.Int) error

func (*LegacyEthereumKeeperRegistry11Mock) SetKeeperList 

func (f *LegacyEthereumKeeperRegistry11Mock) SetKeeperList(_keepers []common.Address) error

func (*LegacyEthereumKeeperRegistry11Mock) SetMinBalance 

func (f *LegacyEthereumKeeperRegistry11Mock) SetMinBalance(id *big.Int, minBalance *big.Int) error

func (*LegacyEthereumKeeperRegistry11Mock) SetPerformUpkeepSuccess 

func (f *LegacyEthereumKeeperRegistry11Mock) SetPerformUpkeepSuccess(id *big.Int, success bool) error

func (*LegacyEthereumKeeperRegistry11Mock) SetUpkeep 

func (f *LegacyEthereumKeeperRegistry11Mock) SetUpkeep(id *big.Int, _target common.Address, _executeGas uint32, _balance *big.Int, _admin common.Address, _maxValidBlocknumber uint64, _lastKeeper common.Address, _checkData []byte) error

func (*LegacyEthereumKeeperRegistry11Mock) SetUpkeepCount 

func (f *LegacyEthereumKeeperRegistry11Mock) SetUpkeepCount(_upkeepCount *big.Int) error

type LegacyEthereumLinkToken 

type LegacyEthereumLinkToken struct {
	// contains filtered or unexported fields
}

LegacyEthereumLinkToken represents a LinkToken address

func (*LegacyEthereumLinkToken) Address 

func (l *LegacyEthereumLinkToken) Address() string

func (*LegacyEthereumLinkToken) Approve 

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

func (*LegacyEthereumLinkToken) BalanceOf 

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

func (*LegacyEthereumLinkToken) Fund 

func (l *LegacyEthereumLinkToken) Fund(ethAmount *big.Float) error

Fund the LINK Token contract with ETH to distribute the token

func (*LegacyEthereumLinkToken) Name 

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

Name returns the name of the link token

func (*LegacyEthereumLinkToken) Transfer 

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

func (*LegacyEthereumLinkToken) TransferAndCall 

func (l *LegacyEthereumLinkToken) TransferAndCall(to string, amount *big.Int, data []byte) (*types.Transaction, error)

type LegacyEthereumOffchainAggregator 

type LegacyEthereumOffchainAggregator struct {
	// contains filtered or unexported fields
}

LegacyEthereumOffchainAggregator represents the offchain aggregation contract Deprecated: we are moving away from blockchain.EVMClient, use EthereumOffchainAggregator instead

func (*LegacyEthereumOffchainAggregator) Address 

func (o *LegacyEthereumOffchainAggregator) Address() string

func (*LegacyEthereumOffchainAggregator) GetLatestAnswer 

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

GetLatestAnswer returns the latest answer from the OCR contract

func (*LegacyEthereumOffchainAggregator) GetLatestRound 

func (o *LegacyEthereumOffchainAggregator) GetLatestRound(ctx context.Context) (*RoundData, error)

GetLatestRound returns data from the latest round

func (*LegacyEthereumOffchainAggregator) GetRound 

func (o *LegacyEthereumOffchainAggregator) GetRound(ctx context.Context, roundID *big.Int) (*RoundData, error)

GetRound retrieves an OCR round by the round ID

func (*LegacyEthereumOffchainAggregator) LatestRoundDataUpdatedAt 

func (o *LegacyEthereumOffchainAggregator) LatestRoundDataUpdatedAt() (*big.Int, error)

func (*LegacyEthereumOffchainAggregator) ParseEventAnswerUpdated 

func (o *LegacyEthereumOffchainAggregator) ParseEventAnswerUpdated(eventLog types.Log) (*offchainaggregator.OffchainAggregatorAnswerUpdated, error)

ParseEventAnswerUpdated parses the log for event AnswerUpdated

func (*LegacyEthereumOffchainAggregator) RequestNewRound 

func (o *LegacyEthereumOffchainAggregator) RequestNewRound() error

RequestNewRound requests the OCR contract to create a new round

func (*LegacyEthereumOffchainAggregator) SetConfig 

func (o *LegacyEthereumOffchainAggregator) SetConfig(
	chainlinkNodes []ChainlinkNodeWithKeysAndAddress,
	ocrConfig OffChainAggregatorConfig,
	transmitters []common.Address,
) error

SetConfig sets the payees and the offchain reporting protocol configuration

func (*LegacyEthereumOffchainAggregator) SetPayees 

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

SetPayees sets wallets for the contract to pay out to?

type LegacyEthereumOffchainAggregatorV2 deprecated 

type LegacyEthereumOffchainAggregatorV2 struct {
	// contains filtered or unexported fields
}

Deprecated: we are moving away from blockchain.EVMClient, use EthereumOffchainAggregatorV2 instead

func (*LegacyEthereumOffchainAggregatorV2) Address 

func (e *LegacyEthereumOffchainAggregatorV2) Address() string

func (*LegacyEthereumOffchainAggregatorV2) GetLatestAnswer 

func (e *LegacyEthereumOffchainAggregatorV2) GetLatestAnswer(ctx context.Context) (*big.Int, error)

func (*LegacyEthereumOffchainAggregatorV2) GetLatestRound 

func (e *LegacyEthereumOffchainAggregatorV2) GetLatestRound(ctx context.Context) (*RoundData, error)

func (*LegacyEthereumOffchainAggregatorV2) GetRound 

func (e *LegacyEthereumOffchainAggregatorV2) GetRound(ctx context.Context, roundID *big.Int) (*RoundData, error)

func (*LegacyEthereumOffchainAggregatorV2) ParseEventAnswerUpdated 

func (e *LegacyEthereumOffchainAggregatorV2) ParseEventAnswerUpdated(log types.Log) (*ocr2aggregator.OCR2AggregatorAnswerUpdated, error)

func (*LegacyEthereumOffchainAggregatorV2) RequestNewRound 

func (e *LegacyEthereumOffchainAggregatorV2) RequestNewRound() error

func (*LegacyEthereumOffchainAggregatorV2) SetConfig 

func (e *LegacyEthereumOffchainAggregatorV2) SetConfig(ocrConfig *OCRv2Config) error

func (*LegacyEthereumOffchainAggregatorV2) SetPayees 

func (e *LegacyEthereumOffchainAggregatorV2) SetPayees(transmitters, payees []string) error

type LegacyEthereumOperator 

type LegacyEthereumOperator struct {
	// contains filtered or unexported fields
}

LegacyEthereumOperator represents operator contract Deprecated: we are moving away from blockchain.EVMClient, use EthereumOperator instead

func (*LegacyEthereumOperator) AcceptAuthorizedReceivers 

func (e *LegacyEthereumOperator) AcceptAuthorizedReceivers(forwarders []common.Address, eoa []common.Address) error

func (*LegacyEthereumOperator) Address 

func (e *LegacyEthereumOperator) Address() string

type LegacyEthereumOperatorFactory 

type LegacyEthereumOperatorFactory struct {
	// contains filtered or unexported fields
}

LegacyEthereumOperatorFactory represents operator factory contract Deprecated: we are moving away from blockchain.EVMClient, use EthereumOperatorFactory instead

func (*LegacyEthereumOperatorFactory) Address 

func (e *LegacyEthereumOperatorFactory) Address() string

func (*LegacyEthereumOperatorFactory) DeployNewOperatorAndForwarder 

func (e *LegacyEthereumOperatorFactory) DeployNewOperatorAndForwarder() (*types.Transaction, error)

func (*LegacyEthereumOperatorFactory) ParseAuthorizedForwarderCreated 

func (e *LegacyEthereumOperatorFactory) ParseAuthorizedForwarderCreated(eventLog types.Log) (*operator_factory.OperatorFactoryAuthorizedForwarderCreated, error)

func (*LegacyEthereumOperatorFactory) ParseOperatorCreated 

func (e *LegacyEthereumOperatorFactory) ParseOperatorCreated(eventLog types.Log) (*operator_factory.OperatorFactoryOperatorCreated, error)

type LegacyEthereumOracle 

type LegacyEthereumOracle struct {
	// contains filtered or unexported fields
}

LegacyEthereumOracle oracle for "directrequest" job tests

func (*LegacyEthereumOracle) Address 

func (e *LegacyEthereumOracle) Address() string

func (*LegacyEthereumOracle) Fund 

func (e *LegacyEthereumOracle) Fund(ethAmount *big.Float) error

func (*LegacyEthereumOracle) SetFulfillmentPermission 

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

SetFulfillmentPermission sets fulfillment permission for particular address

type LegacyEthereumStakingEventsMock 

type LegacyEthereumStakingEventsMock struct {
	// contains filtered or unexported fields
}

LegacyEthereumStakingEventsMock represents the basic events mock contract

func (*LegacyEthereumStakingEventsMock) Address 

func (f *LegacyEthereumStakingEventsMock) Address() string

func (*LegacyEthereumStakingEventsMock) AlertRaised 

func (f *LegacyEthereumStakingEventsMock) AlertRaised(alerter common.Address, roundId *big.Int, rewardAmount *big.Int) error

func (*LegacyEthereumStakingEventsMock) FeedOperatorsSet 

func (f *LegacyEthereumStakingEventsMock) FeedOperatorsSet(feedOperators []common.Address) error

func (*LegacyEthereumStakingEventsMock) MaxCommunityStakeAmountIncreased 

func (f *LegacyEthereumStakingEventsMock) MaxCommunityStakeAmountIncreased(maxStakeAmount *big.Int) error

func (*LegacyEthereumStakingEventsMock) MaxOperatorStakeAmountIncreased 

func (f *LegacyEthereumStakingEventsMock) MaxOperatorStakeAmountIncreased(maxStakeAmount *big.Int) error

func (*LegacyEthereumStakingEventsMock) OperatorAdded 

func (f *LegacyEthereumStakingEventsMock) OperatorAdded(operator common.Address) error

func (*LegacyEthereumStakingEventsMock) OperatorRemoved 

func (f *LegacyEthereumStakingEventsMock) OperatorRemoved(operator common.Address, amount *big.Int) error

func (*LegacyEthereumStakingEventsMock) PoolSizeIncreased 

func (f *LegacyEthereumStakingEventsMock) PoolSizeIncreased(maxPoolSize *big.Int) error

func (*LegacyEthereumStakingEventsMock) RewardInitialized 

func (f *LegacyEthereumStakingEventsMock) RewardInitialized(rate *big.Int, available *big.Int, startTimestamp *big.Int, endTimestamp *big.Int) error

func (*LegacyEthereumStakingEventsMock) Staked 

func (f *LegacyEthereumStakingEventsMock) Staked(staker common.Address, newStake *big.Int, totalStake *big.Int) error

type LegacyEthereumVRF 

type LegacyEthereumVRF struct {
	// contains filtered or unexported fields
}

LegacyEthereumVRF represents a VRF contract

func (*LegacyEthereumVRF) Fund 

func (v *LegacyEthereumVRF) Fund(ethAmount *big.Float) error

Fund sends specified currencies to the contract

func (*LegacyEthereumVRF) ProofLength 

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

ProofLength returns the PROOFLENGTH call from the VRF contract

type LegacyEthereumVRFConsumer 

type LegacyEthereumVRFConsumer struct {
	// contains filtered or unexported fields
}

LegacyEthereumVRFConsumer represents VRF consumer contract

func (*LegacyEthereumVRFConsumer) Address 

func (v *LegacyEthereumVRFConsumer) Address() string

func (*LegacyEthereumVRFConsumer) CurrentRoundID 

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

CurrentRoundID helper roundID counter in consumer to check when all randomness requests are finished

func (*LegacyEthereumVRFConsumer) Fund 

func (v *LegacyEthereumVRFConsumer) Fund(ethAmount *big.Float) error

func (*LegacyEthereumVRFConsumer) RandomnessOutput 

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

RandomnessOutput get VRF randomness output

func (*LegacyEthereumVRFConsumer) RequestRandomness 

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

RequestRandomness requests VRF randomness

type LegacyEthereumVRFCoordinator 

type LegacyEthereumVRFCoordinator struct {
	// contains filtered or unexported fields
}

LegacyEthereumVRFCoordinator represents VRF coordinator contract

func (*LegacyEthereumVRFCoordinator) Address 

func (v *LegacyEthereumVRFCoordinator) Address() string

func (*LegacyEthereumVRFCoordinator) HashOfKey 

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

HashOfKey get a hash of proving key to use it as a request ID part for VRF

func (*LegacyEthereumVRFCoordinator) RegisterProvingKey 

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

RegisterProvingKey register VRF proving key

type LineaContractDeployer 

type LineaContractDeployer struct {
	*EthereumContractDeployer
}

type LineaContractLoader 

type LineaContractLoader struct {
	*EthereumContractLoader
}

LineaContractLoader wraps for Linea

type LinkToken 

type LinkToken interface {
	Address() string
	Approve(to string, amount *big.Int) error
	Transfer(to string, amount *big.Int) error
	BalanceOf(ctx context.Context, addr string) (*big.Int, error)
	TransferAndCall(to string, amount *big.Int, data []byte) (*types.Transaction, error)
	Name(context.Context) (string, error)
}

type LoadTestRequestStatus 

type LoadTestRequestStatus struct {
	Fulfilled   bool
	RandomWords []*big.Int
}

type LogEmitter 

type LogEmitter interface {
	Address() common.Address
	EmitLogInts(ints []int) (*types.Transaction, error)
	EmitLogIntsIndexed(ints []int) (*types.Transaction, error)
	EmitLogIntMultiIndexed(ints int, ints2 int, count int) (*types.Transaction, error)
	EmitLogStrings(strings []string) (*types.Transaction, error)
	EmitLogInt(payload int) (*types.Transaction, error)
	EmitLogIntIndexed(payload int) (*types.Transaction, error)
	EmitLogString(strings string) (*types.Transaction, error)
}

type LogEmitterContract 

type LogEmitterContract struct {
	// contains filtered or unexported fields
}

func (*LogEmitterContract) Address 

func (e *LogEmitterContract) Address() common.Address

func (*LogEmitterContract) EmitLogInt 

func (e *LogEmitterContract) EmitLogInt(payload int) (*types.Transaction, error)

func (*LogEmitterContract) EmitLogIntIndexed 

func (e *LogEmitterContract) EmitLogIntIndexed(payload int) (*types.Transaction, error)

func (*LogEmitterContract) EmitLogIntMultiIndexed 

func (e *LogEmitterContract) EmitLogIntMultiIndexed(ints int, ints2 int, count int) (*types.Transaction, error)

func (*LogEmitterContract) EmitLogInts 

func (e *LogEmitterContract) EmitLogInts(ints []int) (*types.Transaction, error)

func (*LogEmitterContract) EmitLogIntsIndexed 

func (e *LogEmitterContract) EmitLogIntsIndexed(ints []int) (*types.Transaction, error)

func (*LogEmitterContract) EmitLogString 

func (e *LogEmitterContract) EmitLogString(strings string) (*types.Transaction, error)

func (*LogEmitterContract) EmitLogStrings 

func (e *LogEmitterContract) EmitLogStrings(strings []string) (*types.Transaction, error)

type MercuryFeeManager 

type MercuryFeeManager interface {
	Address() common.Address
	UpdateSubscriberDiscount(subscriber common.Address, feedId [32]byte, token common.Address, discount uint64) (*types.Transaction, error)
}

type MercuryRewardManager 

type MercuryRewardManager interface {
	Address() common.Address
	SetFeeManager(feeManager common.Address) (*types.Transaction, error)
}

type MercuryVerifier 

type MercuryVerifier interface {
	Address() common.Address
	Verify(signedReport []byte, sender common.Address) error
	SetConfig(feedId [32]byte, signers []common.Address, offchainTransmitters [][32]byte, f uint8, onchainConfig []byte, offchainConfigVersion uint64, offchainConfig []byte, recipientAddressesAndWeights []verifier.CommonAddressAndWeight) (*types.Transaction, error)
	LatestConfigDetails(ctx context.Context, feedId [32]byte) (verifier.LatestConfigDetails, error)
}

type MercuryVerifierProxy 

type MercuryVerifierProxy interface {
	Address() common.Address
	InitializeVerifier(verifierAddress common.Address) (*types.Transaction, error)
	Verify(signedReport []byte, parameterPayload []byte, value *big.Int) (*types.Transaction, error)
	VerifyBulk(signedReports [][]byte, parameterPayload []byte, value *big.Int) (*types.Transaction, error)
	SetFeeManager(feeManager common.Address) (*types.Transaction, error)
}

type MetisContractDeployer 

type MetisContractDeployer struct {
	*EthereumContractDeployer
}

MetisContractDeployer wraps ethereum contract deployments for Metis

type MetisContractLoader 

type MetisContractLoader struct {
	*EthereumContractLoader
}

MetisContractLoader wraps ethereum contract deployments for Metis

type MockAggregatorProxy 

type MockAggregatorProxy interface {
	Address() string
	UpdateAggregator(aggregator common.Address) error
	Aggregator() (common.Address, error)
}

type MockETHLINKFeed 

type MockETHLINKFeed interface {
	Address() string
	LatestRoundData() (*big.Int, error)
	LatestRoundDataUpdatedAt() (*big.Int, error)
}

type MockGasFeed 

type MockGasFeed interface {
	Address() string
}

type OCRv2Config 

type OCRv2Config struct {
	Signers               []common.Address
	Transmitters          []common.Address
	F                     uint8
	OnchainConfig         []byte
	TypedOnchainConfig21  i_keeper_registry_master_wrapper_2_1.IAutomationV21PlusCommonOnchainConfigLegacy
	TypedOnchainConfig22  i_automation_registry_master_wrapper_2_2.AutomationRegistryBase22OnchainConfig
	OffchainConfigVersion uint64
	OffchainConfig        []byte
}

OCRv2Config represents the config for the OCRv2 contract

type OffChainAggregatorConfig 

type OffChainAggregatorConfig struct {
	DeltaProgress    time.Duration // The duration in which a leader must achieve progress or be replaced
	DeltaResend      time.Duration // The interval at which nodes resend NEWEPOCH messages
	DeltaRound       time.Duration // The duration after which a new round is started
	DeltaGrace       time.Duration // The duration of the grace period during which delayed oracles can still submit observations
	DeltaC           time.Duration // Limits how often updates are transmitted to the contract as long as the median isn’t changing by more then AlphaPPB
	AlphaPPB         uint64        // Allows larger changes of the median to be reported immediately, bypassing DeltaC
	DeltaStage       time.Duration // Used to stagger stages of the transmission protocol. Multiple Ethereum blocks must be mineable in this period
	RMax             uint8         // The maximum number of rounds in an epoch
	S                []int         // Transmission Schedule
	F                int           // The allowed number of "bad" oracles
	N                int           // The number of oracles
	OracleIdentities []ocrConfigHelper.OracleIdentityExtra
}

https://uploads-ssl.webflow.com/5f6b7190899f41fb70882d08/603651a1101106649eef6a53_chainlink-ocr-protocol-paper-02-24-20.pdf

func DefaultOffChainAggregatorConfig 

func DefaultOffChainAggregatorConfig(numberNodes int) OffChainAggregatorConfig

DefaultOffChainAggregatorConfig returns some base defaults for configuring an OCR contract

type OffChainAggregatorV2Config 

type OffChainAggregatorV2Config struct {
	DeltaProgress                           time.Duration
	DeltaResend                             time.Duration
	DeltaRound                              time.Duration
	DeltaGrace                              time.Duration
	DeltaStage                              time.Duration
	RMax                                    uint8
	S                                       []int
	Oracles                                 []ocrConfigHelper2.OracleIdentityExtra
	ReportingPluginConfig                   []byte
	MaxDurationQuery                        time.Duration
	MaxDurationObservation                  time.Duration
	MaxDurationReport                       time.Duration
	MaxDurationShouldAcceptFinalizedReport  time.Duration
	MaxDurationShouldTransmitAcceptedReport time.Duration
	F                                       int
	OnchainConfig                           []byte
}

type OffChainAggregatorWithRounds 

type OffChainAggregatorWithRounds interface {
	Address() string
	GetLatestRound(ctx context.Context) (*RoundData, error)
	RequestNewRound() error
}

func V1OffChainAgrregatorToOffChainAggregatorWithRounds 

func V1OffChainAgrregatorToOffChainAggregatorWithRounds(contracts []OffchainAggregator) []OffChainAggregatorWithRounds

func V2OffChainAgrregatorToOffChainAggregatorWithRounds 

func V2OffChainAgrregatorToOffChainAggregatorWithRounds(contracts []OffchainAggregatorV2) []OffChainAggregatorWithRounds

type OffchainAggregator 

type OffchainAggregator interface {
	Address() string
	SetConfig(chainlinkNodes []ChainlinkNodeWithKeysAndAddress, ocrConfig OffChainAggregatorConfig, transmitters []common.Address) error
	SetPayees([]string, []string) error
	RequestNewRound() error
	GetLatestAnswer(ctx context.Context) (*big.Int, error)
	GetLatestRound(ctx context.Context) (*RoundData, error)
	GetRound(ctx context.Context, roundID *big.Int) (*RoundData, error)
	ParseEventAnswerUpdated(log types.Log) (*offchainaggregator.OffchainAggregatorAnswerUpdated, error)
	LatestRoundDataUpdatedAt() (*big.Int, error)
}

type OffchainAggregatorData 

type OffchainAggregatorData struct {
	LatestRoundData RoundData // Data about the latest round
}

type OffchainAggregatorEventsMock 

type OffchainAggregatorEventsMock interface {
	Address() string
	ConfigSet(previousConfigBlockNumber uint32, configCount uint64, signers []common.Address, transmitters []common.Address, threshold uint8, encodedConfigVersion uint64, encoded []byte) error
	NewTransmission(aggregatorRoundId uint32, answer *big.Int, transmitter common.Address, observations []*big.Int, observers []byte, rawReportContext [32]byte) error
}

type OffchainAggregatorRoundConfirmer 

type OffchainAggregatorRoundConfirmer struct {
	// contains filtered or unexported fields
}

OffchainAggregatorRoundConfirmer is a header subscription that awaits for a certain OCR round to be completed

func NewOffchainAggregatorRoundConfirmer 

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

NewOffchainAggregatorRoundConfirmer provides a new instance of a OffchainAggregatorRoundConfirmer

func (*OffchainAggregatorRoundConfirmer) Complete 

func (o *OffchainAggregatorRoundConfirmer) Complete() bool

func (*OffchainAggregatorRoundConfirmer) ReceiveHeader 

func (o *OffchainAggregatorRoundConfirmer) ReceiveHeader(_ blockchain.NodeHeader) error

ReceiveHeader will query the latest OffchainAggregator round and check to see whether the round has confirmed

func (*OffchainAggregatorRoundConfirmer) Wait 

func (o *OffchainAggregatorRoundConfirmer) Wait() error

Wait is a blocking function that will wait until the round has confirmed, and timeout if the deadline has passed

type OffchainAggregatorV2 

type OffchainAggregatorV2 interface {
	Address() string
	RequestNewRound() error
	SetConfig(ocrConfig *OCRv2Config) error
	SetPayees(transmitters, payees []string) error
	GetLatestAnswer(ctx context.Context) (*big.Int, error)
	GetLatestRound(ctx context.Context) (*RoundData, error)
	GetRound(ctx context.Context, roundID *big.Int) (*RoundData, error)
	ParseEventAnswerUpdated(log types.Log) (*ocr2aggregator.OCR2AggregatorAnswerUpdated, error)
}

type OffchainAggregatorV2RoundConfirmer 

type OffchainAggregatorV2RoundConfirmer struct {
	// contains filtered or unexported fields
}

OffchainAggregatorRoundConfirmer is a header subscription that awaits for a certain OCR round to be completed

func NewOffchainAggregatorV2RoundConfirmer 

func NewOffchainAggregatorV2RoundConfirmer(
	contract OffchainAggregatorV2,
	roundID *big.Int,
	timeout time.Duration,
	logger zerolog.Logger,
) *OffchainAggregatorV2RoundConfirmer

NewOffchainAggregatorRoundConfirmer provides a new instance of a OffchainAggregatorRoundConfirmer

func (*OffchainAggregatorV2RoundConfirmer) Complete 

func (o *OffchainAggregatorV2RoundConfirmer) Complete() bool

func (*OffchainAggregatorV2RoundConfirmer) ReceiveHeader 

func (o *OffchainAggregatorV2RoundConfirmer) ReceiveHeader(_ blockchain.NodeHeader) error

ReceiveHeader will query the latest OffchainAggregator round and check to see whether the round has confirmed

func (*OffchainAggregatorV2RoundConfirmer) Wait 

func (o *OffchainAggregatorV2RoundConfirmer) Wait() error

Wait is a blocking function that will wait until the round has confirmed, and timeout if the deadline has passed

type OffchainOptions 

type OffchainOptions struct {
	MaximumGasPrice           uint32         // The highest gas price for which transmitter will be compensated
	ReasonableGasPrice        uint32         // The transmitter will receive reward for gas prices under this value
	MicroLinkPerEth           uint32         // The reimbursement per ETH of gas cost, in 1e-6LINK units
	LinkGweiPerObservation    uint32         // The reward to the oracle for contributing an observation to a successfully transmitted report, in 1e-9LINK units
	LinkGweiPerTransmission   uint32         // The reward to the transmitter of a successful report, in 1e-9LINK units
	MinimumAnswer             *big.Int       // The lowest answer the median of a report is allowed to be
	MaximumAnswer             *big.Int       // The highest answer the median of a report is allowed to be
	BillingAccessController   common.Address // The access controller for billing admin functions
	RequesterAccessController common.Address // The access controller for requesting new rounds
	Decimals                  uint8          // Answers are stored in fixed-point format, with this many digits of precision
	Description               string         // A short description of what is being reported
}

func DefaultOffChainAggregatorOptions 

func DefaultOffChainAggregatorOptions() OffchainOptions

DefaultOffChainAggregatorOptions returns some base defaults for deploying an OCR contract

type Operator 

type Operator interface {
	Address() string
	AcceptAuthorizedReceivers(forwarders []common.Address, eoa []common.Address) error
}

Operator operates forwarders

type OperatorFactory 

type OperatorFactory interface {
	Address() string
	DeployNewOperatorAndForwarder() (*types.Transaction, error)
	ParseAuthorizedForwarderCreated(log types.Log) (*operator_factory.OperatorFactoryAuthorizedForwarderCreated, error)
	ParseOperatorCreated(log types.Log) (*operator_factory.OperatorFactoryOperatorCreated, error)
}

OperatorFactory creates Operator contracts for node operators

type OptimismContractDeployer 

type OptimismContractDeployer struct {
	*EthereumContractDeployer
}

OptimismContractDeployer wraps for Optimism

type OptimismContractLoader 

type OptimismContractLoader struct {
	*EthereumContractLoader
}

OptimismContractLoader wraps for Optimism

type Oracle 

type Oracle interface {
	Address() string
	Fund(ethAmount *big.Float) error
	SetFulfillmentPermission(address string, allowed bool) error
}

func DeployOracle 

func DeployOracle(seth *seth.Client, linkAddr string) (Oracle, error)

type PolygonContractDeployer 

type PolygonContractDeployer struct {
	*EthereumContractDeployer
}

type PolygonContractLoader 

type PolygonContractLoader struct {
	*EthereumContractLoader
}

PolygonContractLoader wraps for Polygon

type PolygonZKEVMContractLoader 

type PolygonZKEVMContractLoader struct {
	*EthereumContractLoader
}

PolygonZKEVMContractLoader wraps for Polygon zkEVM

type PolygonZkEvmContractDeployer 

type PolygonZkEvmContractDeployer struct {
	*EthereumContractDeployer
}

type PolygonZkEvmContractLoader 

type PolygonZkEvmContractLoader struct {
	*EthereumContractLoader
}

type QuorumContractDeployer 

type QuorumContractDeployer struct {
	*EthereumContractDeployer
}

type RSKContractDeployer 

type RSKContractDeployer struct {
	*EthereumContractDeployer
}

RSKContractDeployer wraps for RSK

type RandomWordsFulfilledEventFilter 

type RandomWordsFulfilledEventFilter struct {
	RequestIds []*big.Int
	SubIDs     []*big.Int
	Timeout    time.Duration
}

type ReadAccessController 

type ReadAccessController interface {
	Address() string
	AddAccess(addr string) error
	DisableAccessCheck() error
}

ReadAccessController is read/write access controller, just named by interface

type RequestStatus 

type RequestStatus struct {
	Fulfilled   bool
	RandomWords []*big.Int
}

type Result 

type Result struct {
	Success    bool
	ReturnData []byte
}

type RoundData 

type RoundData struct {
	RoundId         *big.Int
	Answer          *big.Int
	StartedAt       *big.Int
	UpdatedAt       *big.Int
	AnsweredInRound *big.Int
}

type RunlogRoundConfirmer 

type RunlogRoundConfirmer struct {
	// contains filtered or unexported fields
}

RunlogRoundConfirmer is a header subscription that awaits for a certain Runlog round to be completed

func NewRunlogRoundConfirmer 

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

NewRunlogRoundConfirmer provides a new instance of a RunlogRoundConfirmer

func (*RunlogRoundConfirmer) ReceiveHeader 

func (o *RunlogRoundConfirmer) ReceiveHeader(_ blockchain.NodeHeader) error

ReceiveHeader will query the latest Runlog round and check to see whether the round has confirmed

func (*RunlogRoundConfirmer) Wait 

func (o *RunlogRoundConfirmer) Wait() error

Wait is a blocking function that will wait until the round has confirmed, and timeout if the deadline has passed

type ScrollContractDeployer 

type ScrollContractDeployer struct {
	*EthereumContractDeployer
}

type ScrollContractLoader 

type ScrollContractLoader struct {
	*EthereumContractLoader
}

ScrollContractLoader wraps for Scroll

type Staking 

type Staking interface {
	Address() string
	Fund(ethAmount *big.Float) error
	AddOperators(operators []common.Address) error
	RemoveOperators(operators []common.Address) error
	SetFeedOperators(operators []common.Address) error
	RaiseAlert() error
	Start(amount *big.Int, initialRewardRate *big.Int) error
	SetMerkleRoot(newMerkleRoot [32]byte) error
}

type StakingEventsMock 

type StakingEventsMock interface {
	Address() string
	PoolSizeIncreased(maxPoolSize *big.Int) error
	MaxCommunityStakeAmountIncreased(maxStakeAmount *big.Int) error
	MaxOperatorStakeAmountIncreased(maxStakeAmount *big.Int) error
	RewardInitialized(rate *big.Int, available *big.Int, startTimestamp *big.Int, endTimestamp *big.Int) error
	AlertRaised(alerter common.Address, roundId *big.Int, rewardAmount *big.Int) error
	Staked(staker common.Address, newStake *big.Int, totalStake *big.Int) error
	OperatorAdded(operator common.Address) error
	OperatorRemoved(operator common.Address, amount *big.Int) error
	FeedOperatorsSet(feedOperators []common.Address) error
}

func DeployStakingEventsMock 

func DeployStakingEventsMock(client *seth.Client) (StakingEventsMock, error)

type StaleUpkeepReportLog 

type StaleUpkeepReportLog struct {
	Id *big.Int
}

type Storage 

type Storage interface {
	Get(ctxt context.Context) (*big.Int, error)
	Set(*big.Int) error
}

type SubmissionEvent 

type SubmissionEvent struct {
	Contract    common.Address
	Submission  *big.Int
	Round       uint32
	BlockNumber uint64
	Oracle      common.Address
}

type Subscription 

type Subscription struct {
	Balance       *big.Int
	NativeBalance *big.Int
	ReqCount      uint64
	SubOwner      common.Address
	Consumers     []common.Address
}

type UpkeepCounter 

type UpkeepCounter interface {
	Address() string
	Fund(ethAmount *big.Float) error
	Counter(ctx context.Context) (*big.Int, error)
	SetSpread(testRange *big.Int, interval *big.Int) error
	Start() error
}

type UpkeepInfo 

type UpkeepInfo struct {
	Target                 string
	ExecuteGas             uint32
	CheckData              []byte
	Balance                *big.Int
	LastKeeper             string
	Admin                  string
	MaxValidBlocknumber    uint64
	LastPerformBlockNumber uint32
	AmountSpent            *big.Int
	Paused                 bool
	OffchainConfig         []byte
}

UpkeepInfo keeper target info

type UpkeepPerformCounterRestrictive 

type UpkeepPerformCounterRestrictive interface {
	Address() string
	Fund(ethAmount *big.Float) error
	Counter(ctx context.Context) (*big.Int, error)
	SetSpread(testRange *big.Int, interval *big.Int) error
}

type UpkeepPerformedLog 

type UpkeepPerformedLog struct {
	Id      *big.Int
	Success bool
	From    common.Address
}

type UpkeepTranscoder 

type UpkeepTranscoder interface {
	Address() string
}

type VRF 

type VRF interface {
	Fund(ethAmount *big.Float) error
	ProofLength(context.Context) (*big.Int, error)
}

func DeployVRFv1Contract 

func DeployVRFv1Contract(seth *seth.Client) (VRF, error)

DeployVRFContract deploy VRFv1 contract

type VRFBeacon 

type VRFBeacon interface {
	Address() string
	SetPayees(transmitterAddresses []common.Address, payeesAddresses []common.Address) error
	SetConfig(
		signerAddresses []common.Address,
		transmitterAddresses []common.Address,
		f uint8,
		onchainConfig []byte,
		offchainConfigVersion uint64,
		offchainConfig []byte,
	) error
	WaitForConfigSetEvent(timeout time.Duration) (*vrf_beacon.VRFBeaconConfigSet, error)
	WaitForNewTransmissionEvent(timeout time.Duration) (*vrf_beacon.VRFBeaconNewTransmission, error)
	LatestConfigDigestAndEpoch(ctx context.Context) (vrf_beacon.LatestConfigDigestAndEpoch,
		error)
}

type VRFBeaconConsumer 

type VRFBeaconConsumer interface {
	Address() string
	RequestRandomness(
		numWords uint16,
		subID, confirmationDelayArg *big.Int,
	) (*types.Receipt, error)
	RedeemRandomness(subID, requestID *big.Int) error
	RequestRandomnessFulfillment(
		numWords uint16,
		subID, confirmationDelayArg *big.Int,
		requestGasLimit,
		callbackGasLimit uint32,
		arguments []byte,
	) (*types.Receipt, error)
	IBeaconPeriodBlocks(ctx context.Context) (*big.Int, error)
	GetRequestIdsBy(ctx context.Context, nextBeaconOutputHeight *big.Int, confDelay *big.Int) (*big.Int, error)
	GetRandomnessByRequestId(ctx context.Context, requestID *big.Int, numWordIndex *big.Int) (*big.Int, error)
}

type VRFConsumer 

type VRFConsumer interface {
	Address() string
	RequestRandomness(hash [32]byte, fee *big.Int) error
	CurrentRoundID(ctx context.Context) (*big.Int, error)
	RandomnessOutput(ctx context.Context) (*big.Int, error)
	Fund(ethAmount *big.Float) error
}

func DeployVRFConsumer 

func DeployVRFConsumer(seth *seth.Client, linkAddr, coordinatorAddr string) (VRFConsumer, error)

DeployVRFConsumer deploys VRF consumer contract

type VRFConsumerRoundConfirmer 

type VRFConsumerRoundConfirmer struct {
	// contains filtered or unexported fields
}

VRFConsumerRoundConfirmer is a header subscription that awaits for a certain VRF round to be completed

func NewVRFConsumerRoundConfirmer 

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

NewVRFConsumerRoundConfirmer provides a new instance of a NewVRFConsumerRoundConfirmer

func (*VRFConsumerRoundConfirmer) ReceiveHeader 

func (f *VRFConsumerRoundConfirmer) ReceiveHeader(header blockchain.NodeHeader) error

ReceiveHeader will query the latest VRFConsumer round and check to see whether the round has confirmed

func (*VRFConsumerRoundConfirmer) Wait 

func (f *VRFConsumerRoundConfirmer) Wait() error

Wait is a blocking function that will wait until the round has confirmed, and timeout if the deadline has passed

type VRFConsumerV2 

type VRFConsumerV2 interface {
	Address() string
	CurrentSubscription() (uint64, error)
	CreateFundedSubscription(funds *big.Int) error
	TopUpSubscriptionFunds(funds *big.Int) error
	RequestRandomness(hash [32]byte, subID uint64, confs uint16, gasLimit uint32, numWords uint32) error
	RandomnessOutput(ctx context.Context, arg0 *big.Int) (*big.Int, error)
	GetAllRandomWords(ctx context.Context, num int) ([]*big.Int, error)
	GasAvailable() (*big.Int, error)
	Fund(ethAmount *big.Float) error
}

type VRFCoordinator 

type VRFCoordinator interface {
	RegisterProvingKey(
		fee *big.Int,
		oracleAddr string,
		publicProvingKey [2]*big.Int,
		jobID [32]byte,
	) error
	HashOfKey(ctx context.Context, pubKey [2]*big.Int) ([32]byte, error)
	Address() string
}

func DeployVRFCoordinator 

func DeployVRFCoordinator(seth *seth.Client, linkAddr, bhsAddr string) (VRFCoordinator, error)

DeployVRFCoordinator deploys VRF coordinator contract

type VRFCoordinatorV2 

type VRFCoordinatorV2 interface {
	GetRequestConfig(ctx context.Context) (GetRequestConfig, error)
	GetConfig(ctx context.Context) (vrf_coordinator_v2.GetConfig, error)
	GetFallbackWeiPerUnitLink(ctx context.Context) (*big.Int, error)
	GetFeeConfig(ctx context.Context) (vrf_coordinator_v2.GetFeeConfig, error)
	SetConfig(
		minimumRequestConfirmations uint16,
		maxGasLimit uint32,
		stalenessSeconds uint32,
		gasAfterPaymentCalculation uint32,
		fallbackWeiPerUnitLink *big.Int,
		feeConfig vrf_coordinator_v2.VRFCoordinatorV2FeeConfig,
	) error
	RegisterProvingKey(
		oracleAddr string,
		publicProvingKey [2]*big.Int,
	) error
	TransferOwnership(to common.Address) error
	HashOfKey(ctx context.Context, pubKey [2]*big.Int) ([32]byte, error)
	CreateSubscription() (*types.Transaction, error)
	AddConsumer(subId uint64, consumerAddress string) error
	Address() string
	GetSubscription(ctx context.Context, subID uint64) (Subscription, error)
	GetOwner(ctx context.Context) (common.Address, error)
	PendingRequestsExist(ctx context.Context, subID uint64) (bool, error)
	OwnerCancelSubscription(subID uint64) (*types.Transaction, error)
	ParseSubscriptionCanceled(log types.Log) (*vrf_coordinator_v2.VRFCoordinatorV2SubscriptionCanceled, error)
	ParseRandomWordsRequested(log types.Log) (*CoordinatorRandomWordsRequested, error)
	ParseLog(log types.Log) (generated.AbigenLog, error)
	CancelSubscription(subID uint64, to common.Address) (*types.Transaction, error)
	FindSubscriptionID(subID uint64) (uint64, error)
	WaitForRandomWordsFulfilledEvent(filter RandomWordsFulfilledEventFilter) (*CoordinatorRandomWordsFulfilled, error)
	WaitForRandomWordsRequestedEvent(keyHash [][32]byte, subID []uint64, sender []common.Address, timeout time.Duration) (*vrf_coordinator_v2.VRFCoordinatorV2RandomWordsRequested, error)
	WaitForSubscriptionCanceledEvent(subID []uint64, timeout time.Duration) (*vrf_coordinator_v2.VRFCoordinatorV2SubscriptionCanceled, error)
	WaitForSubscriptionConsumerAdded(subID []uint64, timeout time.Duration) (*vrf_coordinator_v2.VRFCoordinatorV2SubscriptionConsumerAdded, error)
	WaitForSubscriptionConsumerRemoved(subID []uint64, timeout time.Duration) (*vrf_coordinator_v2.VRFCoordinatorV2SubscriptionConsumerRemoved, error)
	WaitForSubscriptionCreatedEvent(subID []uint64, timeout time.Duration) (*vrf_coordinator_v2.VRFCoordinatorV2SubscriptionCreated, error)
	WaitForSubscriptionFunded(subID []uint64, timeout time.Duration) (*vrf_coordinator_v2.VRFCoordinatorV2SubscriptionFunded, error)
	WaitForConfigSetEvent(timeout time.Duration) (*CoordinatorConfigSet, error)
	OracleWithdraw(recipient common.Address, amount *big.Int) error
}

type VRFCoordinatorV2FeeConfig 

type VRFCoordinatorV2FeeConfig struct {
	FulfillmentFlatFeeLinkPPMTier1 uint32
	FulfillmentFlatFeeLinkPPMTier2 uint32
	FulfillmentFlatFeeLinkPPMTier3 uint32
	FulfillmentFlatFeeLinkPPMTier4 uint32
	FulfillmentFlatFeeLinkPPMTier5 uint32
	ReqsForTier2                   *big.Int
	ReqsForTier3                   *big.Int
	ReqsForTier4                   *big.Int
	ReqsForTier5                   *big.Int
}

type VRFCoordinatorV2PlusUpgradedVersion 

type VRFCoordinatorV2PlusUpgradedVersion interface {
	SetLINKAndLINKNativeFeed(
		link string,
		linkNativeFeed string,
	) error
	SetConfig(
		minimumRequestConfirmations uint16,
		maxGasLimit uint32,
		stalenessSeconds uint32,
		gasAfterPaymentCalculation uint32,
		fallbackWeiPerUnitLink *big.Int,
		fulfillmentFlatFeeNativePPM uint32,
		fulfillmentFlatFeeLinkDiscountPPM uint32,
		nativePremiumPercentage uint8,
		linkPremiumPercentage uint8,
	) error
	RegisterProvingKey(
		publicProvingKey [2]*big.Int,
		gasLaneMaxGasPrice uint64,
	) error
	HashOfKey(ctx context.Context, pubKey [2]*big.Int) ([32]byte, error)
	CreateSubscription() error
	GetNativeTokenTotalBalance(ctx context.Context) (*big.Int, error)
	GetLinkTotalBalance(ctx context.Context) (*big.Int, error)
	Migrate(subId *big.Int, coordinatorAddress string) error
	RegisterMigratableCoordinator(migratableCoordinatorAddress string) error
	AddConsumer(subId *big.Int, consumerAddress string) error
	FundSubscriptionWithNative(subId *big.Int, nativeTokenAmount *big.Int) error
	Address() string
	GetSubscription(ctx context.Context, subID *big.Int) (vrf_v2plus_upgraded_version.GetSubscription, error)
	GetActiveSubscriptionIds(ctx context.Context, startIndex *big.Int, maxCount *big.Int) ([]*big.Int, error)
	FindSubscriptionID() (*big.Int, error)
	WaitForRandomWordsFulfilledEvent(filter RandomWordsFulfilledEventFilter) (*CoordinatorRandomWordsFulfilled, error)
	WaitForMigrationCompletedEvent(timeout time.Duration) (*vrf_v2plus_upgraded_version.VRFCoordinatorV2PlusUpgradedVersionMigrationCompleted, error)
	ParseRandomWordsRequested(log types.Log) (*CoordinatorRandomWordsRequested, error)
	WaitForConfigSetEvent(timeout time.Duration) (*CoordinatorConfigSet, error)
}

type VRFCoordinatorV2_5 

type VRFCoordinatorV2_5 interface {
	SetLINKAndLINKNativeFeed(
		link string,
		linkNativeFeed string,
	) error
	SetConfig(
		minimumRequestConfirmations uint16,
		maxGasLimit uint32,
		stalenessSeconds uint32,
		gasAfterPaymentCalculation uint32,
		fallbackWeiPerUnitLink *big.Int,
		fulfillmentFlatFeeNativePPM uint32,
		fulfillmentFlatFeeLinkDiscountPPM uint32,
		nativePremiumPercentage uint8,
		linkPremiumPercentage uint8,
	) error
	RegisterProvingKey(
		publicProvingKey [2]*big.Int,
		gasLaneMaxGas uint64,
	) error
	HashOfKey(ctx context.Context, pubKey [2]*big.Int) ([32]byte, error)
	CreateSubscription() (*types.Transaction, error)
	GetActiveSubscriptionIds(ctx context.Context, startIndex *big.Int, maxCount *big.Int) ([]*big.Int, error)
	Migrate(subId *big.Int, coordinatorAddress string) error
	RegisterMigratableCoordinator(migratableCoordinatorAddress string) error
	AddConsumer(subId *big.Int, consumerAddress string) error
	FundSubscriptionWithNative(subId *big.Int, nativeTokenAmount *big.Int) error
	Address() string
	PendingRequestsExist(ctx context.Context, subID *big.Int) (bool, error)
	GetSubscription(ctx context.Context, subID *big.Int) (Subscription, error)
	OwnerCancelSubscription(subID *big.Int) (*types.Transaction, error)
	CancelSubscription(subID *big.Int, to common.Address) (*types.Transaction, error)
	Withdraw(recipient common.Address) error
	WithdrawNative(recipient common.Address) error
	GetNativeTokenTotalBalance(ctx context.Context) (*big.Int, error)
	GetLinkTotalBalance(ctx context.Context) (*big.Int, error)
	FindSubscriptionID(subID *big.Int) (*big.Int, error)
	WaitForSubscriptionCreatedEvent(timeout time.Duration) (*vrf_coordinator_v2_5.VRFCoordinatorV25SubscriptionCreated, error)
	WaitForSubscriptionCanceledEvent(subID *big.Int, timeout time.Duration) (*vrf_coordinator_v2_5.VRFCoordinatorV25SubscriptionCanceled, error)
	WaitForRandomWordsFulfilledEvent(filter RandomWordsFulfilledEventFilter) (*CoordinatorRandomWordsFulfilled, error)
	WaitForMigrationCompletedEvent(timeout time.Duration) (*vrf_coordinator_v2_5.VRFCoordinatorV25MigrationCompleted, error)
	ParseRandomWordsRequested(log types.Log) (*CoordinatorRandomWordsRequested, error)
	WaitForConfigSetEvent(timeout time.Duration) (*CoordinatorConfigSet, error)
}

type VRFCoordinatorV3 

type VRFCoordinatorV3 interface {
	Address() string
	SetProducer(producerAddress string) error
	CreateSubscription() error
	FindSubscriptionID() (*big.Int, error)
	AddConsumer(subId *big.Int, consumerAddress string) error
	SetConfig(maxCallbackGasLimit, maxCallbackArgumentsLength uint32) error
}

type VRFLoadTestMetrics 

type VRFLoadTestMetrics struct {
	RequestCount                         *big.Int
	FulfilmentCount                      *big.Int
	AverageFulfillmentInMillions         *big.Int
	SlowestFulfillment                   *big.Int
	FastestFulfillment                   *big.Int
	P90FulfillmentBlockTime              float64
	P95FulfillmentBlockTime              float64
	AverageResponseTimeInSecondsMillions *big.Int
	SlowestResponseTimeInSeconds         *big.Int
	FastestResponseTimeInSeconds         *big.Int
}

type VRFMockETHLINKFeed 

type VRFMockETHLINKFeed interface {
	Address() string
	LatestRoundData() (*big.Int, error)
	LatestRoundDataUpdatedAt() (*big.Int, error)
	SetBlockTimestampDeduction(blockTimestampDeduction *big.Int) error
}

type VRFOwner 

type VRFOwner interface {
	Address() string
	SetAuthorizedSenders(senders []common.Address) error
	AcceptVRFOwnership() error
	WaitForRandomWordsForcedEvent(requestIDs []*big.Int, subIds []uint64, senders []common.Address, timeout time.Duration) (*vrf_owner.VRFOwnerRandomWordsForced, error)
	OwnerCancelSubscription(subID uint64) (*types.Transaction, error)
}

type VRFV2PlusWrapper 

type VRFV2PlusWrapper interface {
	Address() string
	SetConfig(
		wrapperGasOverhead uint32,
		coordinatorGasOverheadNative uint32,
		coordinatorGasOverheadLink uint32,
		coordinatorGasOverheadPerWord uint16,
		wrapperNativePremiumPercentage uint8,
		wrapperLinkPremiumPercentage uint8,
		keyHash [32]byte, maxNumWords uint8,
		stalenessSeconds uint32,
		fallbackWeiPerUnitLink *big.Int,
		fulfillmentFlatFeeNativePPM uint32,
		fulfillmentFlatFeeLinkDiscountPPM uint32,
	) error
	GetSubID(ctx context.Context) (*big.Int, error)
	Coordinator(ctx context.Context) (common.Address, error)
}

type VRFV2Wrapper 

type VRFV2Wrapper interface {
	Address() string
	SetConfig(wrapperGasOverhead uint32, coordinatorGasOverhead uint32, wrapperPremiumPercentage uint8, keyHash [32]byte, maxNumWords uint8) error
	GetSubID(ctx context.Context) (uint64, error)
}

type VRFv2Consumer 

type VRFv2Consumer interface {
	Address() string
	RequestRandomness(hash [32]byte, subID uint64, confs uint16, gasLimit uint32, numWords uint32) error
	GetRequestStatus(ctx context.Context, requestID *big.Int) (vrf_v2_consumer_wrapper.GetRequestStatus, error)
	GetLastRequestId(ctx context.Context) (*big.Int, error)
}

type VRFv2LoadTestConsumer 

type VRFv2LoadTestConsumer interface {
	Address() string
	RequestRandomness(
		coordinator Coordinator,
		keyHash [32]byte,
		subID uint64,
		requestConfirmations uint16,
		callbackGasLimit uint32,
		numWords uint32,
		requestCount uint16,
	) (*CoordinatorRandomWordsRequested, error)
	RequestRandomWordsWithForceFulfill(
		coordinator Coordinator,
		keyHash [32]byte,
		requestConfirmations uint16,
		callbackGasLimit uint32,
		numWords uint32,
		requestCount uint16,
		subTopUpAmount *big.Int,
		linkAddress common.Address,
	) (*CoordinatorRandomWordsRequested, error)
	GetRequestStatus(ctx context.Context, requestID *big.Int) (vrf_load_test_with_metrics.GetRequestStatus, error)
	GetLastRequestId(ctx context.Context) (*big.Int, error)
	GetLoadTestMetrics(ctx context.Context) (*VRFLoadTestMetrics, error)
	ResetMetrics() error
}

type VRFv2PlusLoadTestConsumer 

type VRFv2PlusLoadTestConsumer interface {
	Address() string
	RequestRandomness(
		coordinator Coordinator,
		keyHash [32]byte, subID *big.Int,
		requestConfirmations uint16,
		callbackGasLimit uint32,
		nativePayment bool,
		numWords uint32,
		requestCount uint16,
	) (*CoordinatorRandomWordsRequested, error)
	GetRequestStatus(ctx context.Context, requestID *big.Int) (vrf_v2plus_load_test_with_metrics.GetRequestStatus, error)
	GetLastRequestId(ctx context.Context) (*big.Int, error)
	GetLoadTestMetrics(ctx context.Context) (*VRFLoadTestMetrics, error)
	GetCoordinator(ctx context.Context) (common.Address, error)
	ResetMetrics() error
}

type VRFv2PlusWrapperLoadTestConsumer 

type VRFv2PlusWrapperLoadTestConsumer interface {
	Address() string
	Fund(ethAmount *big.Float) error
	RequestRandomness(
		coordinator Coordinator,
		requestConfirmations uint16,
		callbackGasLimit uint32,
		numWords uint32,
		requestCount uint16,
	) (*CoordinatorRandomWordsRequested, error)
	RequestRandomnessNative(
		coordinator Coordinator,
		requestConfirmations uint16,
		callbackGasLimit uint32,
		numWords uint32,
		requestCount uint16,
	) (*CoordinatorRandomWordsRequested, error)
	GetRequestStatus(ctx context.Context, requestID *big.Int) (vrfv2plus_wrapper_load_test_consumer.GetRequestStatus, error)
	GetLastRequestId(ctx context.Context) (*big.Int, error)
	GetWrapper(ctx context.Context) (common.Address, error)
	GetLoadTestMetrics(ctx context.Context) (*VRFLoadTestMetrics, error)
}

type VRFv2WrapperLoadTestConsumer 

type VRFv2WrapperLoadTestConsumer interface {
	Address() string
	Fund(ethAmount *big.Float) error
	RequestRandomness(coordinator Coordinator, requestConfirmations uint16, callbackGasLimit uint32, numWords uint32, requestCount uint16) (*CoordinatorRandomWordsRequested, error)
	GetRequestStatus(ctx context.Context, requestID *big.Int) (vrfv2_wrapper_load_test_consumer.GetRequestStatus, error)
	GetLastRequestId(ctx context.Context) (*big.Int, error)
	GetWrapper(ctx context.Context) (common.Address, error)
	GetLoadTestMetrics(ctx context.Context) (*VRFLoadTestMetrics, error)
}

type WERC20Mock 

type WERC20Mock interface {
	Address() common.Address
	BalanceOf(ctx context.Context, addr string) (*big.Int, error)
	Approve(to string, amount *big.Int) error
	Transfer(to string, amount *big.Int) error
	Mint(account common.Address, amount *big.Int) (*types.Transaction, error)
}

type WeMixContractDeployer 

type WeMixContractDeployer struct {
	*EthereumContractDeployer
}

type WeMixContractLoader 

type WeMixContractLoader struct {
	*EthereumContractLoader
}

WeMixContractLoader wraps for WeMix

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.