contracts

package
v0.0.0-...-692deea Latest Latest
Warning

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

Go to latest
Published: May 6, 2024 License: MIT Imports: 120 Imported by: 0

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

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 (*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 (*EthereumAutomationLogCounterConsumer) Counter

func (*EthereumAutomationLogCounterConsumer) Start

type EthereumAutomationLogTriggeredStreamsLookupUpkeepConsumer

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

func (*EthereumAutomationLogTriggeredStreamsLookupUpkeepConsumer) Address

func (*EthereumAutomationLogTriggeredStreamsLookupUpkeepConsumer) Counter

func (*EthereumAutomationLogTriggeredStreamsLookupUpkeepConsumer) Start

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 (*EthereumAutomationSimpleLogCounterConsumer) Counter

func (*EthereumAutomationSimpleLogCounterConsumer) Start

type EthereumAutomationStreamsLookupUpkeepConsumer

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

func (*EthereumAutomationStreamsLookupUpkeepConsumer) Address

func (*EthereumAutomationStreamsLookupUpkeepConsumer) Counter

func (*EthereumAutomationStreamsLookupUpkeepConsumer) Start

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 (*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 (*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

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 (*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 (*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 (*EthereumFunctionsLoadTestClient) GetStats

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 (*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 (*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 (*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 (*EthereumKeeperPerformDataCheckerConsumer) Counter

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 (*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

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 (*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 (*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 (*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

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 (*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 (*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

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 (*EthereumUpkeepPerformCounterRestrictive) Counter

func (*EthereumUpkeepPerformCounterRestrictive) Fund

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) GetFallbackWeiPerUnitLink(ctx context.Context) (*big.Int, error)

func (*EthereumVRFCoordinatorV2) GetFeeConfig

func (*EthereumVRFCoordinatorV2) GetOwner

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 (*EthereumVRFCoordinatorV2) ParseRandomWordsRequested

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

func (*EthereumVRFCoordinatorV2) ParseSubscriptionCanceled

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 (*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 (*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 (*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 (*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 (*EthereumVRFCoordinatorV2PlusUpgradedVersion) WaitForMigrationCompletedEvent

func (*EthereumVRFCoordinatorV2PlusUpgradedVersion) WaitForRandomWordsFulfilledEvent

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 (*EthereumVRFCoordinatorV2_5) WaitForRandomWordsFulfilledEvent

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 (*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 (*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 (*EthereumVRFV2PlusWrapperLoadTestConsumer) Fund

func (*EthereumVRFV2PlusWrapperLoadTestConsumer) GetLastRequestId

func (*EthereumVRFV2PlusWrapperLoadTestConsumer) GetLoadTestMetrics

func (*EthereumVRFV2PlusWrapperLoadTestConsumer) GetRequestStatus

func (*EthereumVRFV2PlusWrapperLoadTestConsumer) GetWrapper

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 (*EthereumVRFV2WrapperLoadTestConsumer) Fund

func (*EthereumVRFV2WrapperLoadTestConsumer) GetLastRequestId

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

func (*EthereumVRFV2WrapperLoadTestConsumer) GetLoadTestMetrics

func (*EthereumVRFV2WrapperLoadTestConsumer) GetRequestStatus

func (*EthereumVRFV2WrapperLoadTestConsumer) GetWrapper

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 (*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 (*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 (*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 (*EthereumVRFv2PlusLoadTestConsumer) GetCoordinator

func (*EthereumVRFv2PlusLoadTestConsumer) GetLastRequestId

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

func (*EthereumVRFv2PlusLoadTestConsumer) GetLoadTestMetrics

func (*EthereumVRFv2PlusLoadTestConsumer) GetRequestStatus

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

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 (*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

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 (*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

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

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

func (*KeeperConsumerRoundConfirmer) Wait

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 (*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 (*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 (*LegacyEthereumAuthorizedForwarder) GetAuthorizedSenders

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

func (*LegacyEthereumAuthorizedForwarder) Owner

Owner return authorized forwarder owner address

type LegacyEthereumBatchBlockhashStore

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

LegacyEthereumBatchBlockhashStore represents BatchBlockhashStore contract

func (*LegacyEthereumBatchBlockhashStore) Address

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

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 (*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

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 (*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 (*LegacyEthereumFunctionsLoadTestClient) GetStats

func (*LegacyEthereumFunctionsLoadTestClient) ResetStats

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 (*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 (*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 (*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 (*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 (*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

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 (*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

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 (*LegacyEthereumOffchainAggregatorV2) GetLatestAnswer

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

func (*LegacyEthereumOffchainAggregatorV2) GetLatestRound

func (*LegacyEthereumOffchainAggregatorV2) GetRound

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

func (*LegacyEthereumOffchainAggregatorV2) ParseEventAnswerUpdated

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 (*LegacyEthereumOperatorFactory) DeployNewOperatorAndForwarder

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

func (*LegacyEthereumOperatorFactory) ParseAuthorizedForwarderCreated

func (*LegacyEthereumOperatorFactory) ParseOperatorCreated

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 (*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

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

func (*OffchainAggregatorRoundConfirmer) Wait

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 (*OffchainAggregatorV2RoundConfirmer) ReceiveHeader

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

func (*OffchainAggregatorV2RoundConfirmer) Wait

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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