contracts

May 3, 2022

Changes in this version

type AFN

+ VoteGood func() error

type ContractDeployer

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

+ DeployOnRampRouter func() (OnRampRouter, error)

type EthereumContractDeployer

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

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

type MessageExecutor

+ SetConfig func([]ocrConfigHelper2.OracleIdentityExtra) error

type NativeTokenPool

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

type OffRamp

+ SetConfig func([]ocrConfigHelper2.OracleIdentityExtra) error

+ SetRouter func(addr string) error

+ WatchEvents func()

+ type OffRampRouter interface

+ Address func() string

type OnRamp

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

+ WatchEvents func()

+ type OnRampRouter interface

+ Address func() string

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

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

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

type SenderDapp

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

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

Apr 29, 2022

Changes in this version

+ type KlaytnContractDeployer struct

+ type MetisContractDeployer struct

Apr 28, 2022

Changes in this version

+ type AFN interface

+ Address func() string

type ContractDeployer

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

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

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

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

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

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

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

+ DeploySimpleMessageReceiver func() (SimpleMessageReceiver, error)

type EthereumContractDeployer

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

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

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

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

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

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

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

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

+ type MessageExecutor interface

+ Address func() string

+ type NativeTokenPool interface

+ Address func() string

+ SetOffRamp func(addr string, perms bool) error

+ SetOnRamp func(addr string, perms bool) error

+ type OffRamp interface

+ Address func() string

+ type OnRamp interface

+ Address func() string

+ type ReceiverDapp interface

+ Address func() string

+ type SenderDapp interface

+ Address func() string

+ type SimpleMessageReceiver interface

+ Address func() string

Apr 19, 2022

Changes in this version

type EthereumVRFConsumerV2

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

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

type VRFConsumerV2

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

+ TopUpSubscriptionFunds func(funds *big.Int) error

Apr 19, 2022

Changes in this version

type EthereumVRFConsumerV2

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

type VRFConsumerV2

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

Apr 19, 2022

Changes in this version

type EthereumMockETHLINKFeed

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

type MockETHLINKFeed

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

Apr 18, 2022

Changes in this version

type ContractDeployer

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

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

type EthereumContractDeployer

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

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

+ type EthereumVRFConsumerV2 struct

+ func (v *EthereumVRFConsumerV2) Address() string

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

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

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

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

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

+ type EthereumVRFCoordinatorV2 struct

+ func (v *EthereumVRFCoordinatorV2) Address() string

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

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

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

+ type KeeperRegistrySettings struct

+ BlockCountPerTurn *big.Int

+ CheckGasLimit uint32

+ FallbackGasPrice *big.Int

+ FallbackLinkPrice *big.Int

+ GasCeilingMultiplier uint16

+ PaymentPremiumPPB uint32

+ StalenessSeconds *big.Int

+ type VRFConsumerV2 interface

+ Address func() string

+ CreateFundedSubscription func(funds *big.Int) error

+ CurrentSubscription func() (uint64, error)

+ Fund func(ethAmount *big.Float) error

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

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

+ type VRFCoordinatorV2 interface

+ Address func() string

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

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

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

Feb 14, 2022

Changes in this version

type ContractDeployer

+ DeployKeeperConsumerPerformance func(testBlockRange, blockCadence *big.Int) (KeeperConsumerPerformance, error)

type EthereumContractDeployer

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

+ type EthereumKeeperConsumerPerformance struct

+ func (v *EthereumKeeperConsumerPerformance) Address() string

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

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

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

+ type KeeperConsumerPerformance interface

+ Address func() string

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

+ Fund func(ethAmount *big.Float) error

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

+ type KeeperConsumerPerformanceRoundConfirmer struct

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

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

+ func (o *KeeperConsumerPerformanceRoundConfirmer) Wait() error

Jan 13, 2022

Changes in this version

type KeeperRegistryOpts

+ FlatFeeMicroLINK uint32

Jan 6, 2022

Changes in this version

type ContractDeployer

+ DeployOCRv2Flags func(lowAccessController string, raiseAccessController string) (OCRv2Flags, error)

+ DeployOCRv2Proxy func(addr string) (OCRv2Proxy, error)

+ DeployOCRv2Validator func(threshold uint32, flags string) (OCRv2Flags, error)

+ DeployOCRv2ValidatorProxy func(addr string) (OCRv2Proxy, error)

type EthereumContractDeployer

+ func (e *EthereumContractDeployer) DeployOCRv2Flags(lowAccessController string, raiseAccessController string) (OCRv2Flags, error)

+ func (e *EthereumContractDeployer) DeployOCRv2Proxy(addr string) (OCRv2Proxy, error)

+ func (e *EthereumContractDeployer) DeployOCRv2Validator(threshold uint32, flags string) (OCRv2Flags, error)

+ func (e *EthereumContractDeployer) DeployOCRv2ValidatorProxy(addr string) (OCRv2Proxy, error)

+ type OCRv2Flags interface

+ Address func() string

+ type OCRv2Proxy interface

+ Address func() string

+ ConfirmContract func(addr string) error

+ ProposeContract func(addr string) error

+ TransferOwnership func(addr string) error

+ type OCRv2Validator interface

+ Address func() string

+ type OCRv2ValidatorProxy interface

+ Address func() string

+ ConfirmContract func(addr string) error

+ ProposeContract func(addr string) error

+ TransferOwnership func(addr string) error

Jan 3, 2022

Changes in this version

type ContractDeployer

+ DeployOCRv2Store func(billingAC string) (OCRv2Store, error)

type EthereumContractDeployer

+ func (e *EthereumContractDeployer) DeployOCRv2Store(billingAC string) (OCRv2Store, error)

+ type EthereumOCRv2Store struct

+ func (e *EthereumOCRv2Store) Address() string

+ func (e *EthereumOCRv2Store) CreateFeed(granylarity int, liveLength int) error

+ func (e *EthereumOCRv2Store) GetLatestRoundData() (uint64, error)

+ func (e *EthereumOCRv2Store) ProgramAddress() string

+ func (e *EthereumOCRv2Store) SetValidatorConfig(flaggingThreshold uint32) error

+ func (e *EthereumOCRv2Store) SetWriter(writerAuthority string) error

+ func (e *EthereumOCRv2Store) TransmissionsAddress() string

+ type OCRv2Store interface

+ Address func() string

+ CreateFeed func(granylarity int, liveLength int) error

+ GetLatestRoundData func() (uint64, error)

+ ProgramAddress func() string

+ SetValidatorConfig func(flaggingThreshold uint32) error

+ SetWriter func(writerAuthority string) error

+ TransmissionsAddress func() string

Dec 17, 2021

Changes in this version

type EthereumOCRv2

+ func (e *EthereumOCRv2) GetLatestRoundData() (uint64, error)

type OCRv2

+ GetLatestRoundData func() (uint64, error)

Dec 16, 2021

Changes in this version

+ type EthereumOCRv2DeviationFlaggingValidator struct

+ func (e *EthereumOCRv2DeviationFlaggingValidator) Address() string

+ func (e *EthereumOCRv2DeviationFlaggingValidator) ProgramAddress() string

type OCRv2DeviationFlaggingValidator

+ ProgramAddress func() string

Dec 16, 2021

Changes in this version

type EthereumOCRv2

+ func (e *EthereumOCRv2) ProgramAddress() string

type OCRv2

+ ProgramAddress func() string

Dec 13, 2021

Changes in this version

type EthereumOCRv2

+ func (e *EthereumOCRv2) TransmissionsAddr() string

type OCRv2

+ TransmissionsAddr func() string

Dec 8, 2021

Changes in this version

+ type OffChainAggregatorV2Config struct

+ DeltaGrace time.Duration

+ DeltaProgress time.Duration

+ DeltaResend time.Duration

+ DeltaRound time.Duration

+ DeltaStage time.Duration

+ F int

+ MaxDurationObservation time.Duration

+ MaxDurationQuery time.Duration

+ MaxDurationReport time.Duration

+ MaxDurationShouldAcceptFinalizedReport time.Duration

+ MaxDurationShouldTransmitAcceptedReport time.Duration

+ OnchainConfig []byte

+ Oracles []ocrConfigHelper2.OracleIdentityExtra

+ RMax uint8

+ ReportingPluginConfig []byte

+ S []int

Dec 7, 2021

Changes in this version

type EthereumOCRv2

+ func (e *EthereumOCRv2) SetOffChainConfig() error

type OCRv2

+ SetOffChainConfig func() error

Dec 7, 2021

Changes in this version

type EthereumOCRv2

+ func (e *EthereumOCRv2) SetOracles(chainlinkNodes []client.Chainlink, f int) error

type OCRv2

+ SetOracles func(chainlinkNodes []client.Chainlink, f int) error

Dec 6, 2021

Changes in this version

type EthereumOCRv2

+ func (e *EthereumOCRv2) DumpState() error

type OCRv2

+ DumpState func() error

Dec 2, 2021

Changes in this version

type ContractDeployer

+ DeployOCRv2DeviationFlaggingValidator func(billingAC string) (OCRv2DeviationFlaggingValidator, error)

type EthereumContractDeployer

+ func (e *EthereumContractDeployer) DeployOCRv2DeviationFlaggingValidator(billingAC string) (OCRv2DeviationFlaggingValidator, error)

+ type EthereumOCRv2 struct

+ func (e *EthereumOCRv2) Address() string

+ func (e *EthereumOCRv2) AuthorityAddr(s string) (string, error)

+ func (e *EthereumOCRv2) GetContractData(ctx context.Context) (*OffchainAggregatorData, error)

+ func (e *EthereumOCRv2) GetLatestConfigDetails() (map[string]interface{}, error)

+ func (e *EthereumOCRv2) GetOwedPayment(transmitterAddr string) (map[string]interface{}, error)

+ func (e *EthereumOCRv2) GetRoundData(roundID uint32) (map[string]interface{}, error)

+ func (e *EthereumOCRv2) RequestNewRound() error

+ func (e *EthereumOCRv2) SetBilling(price uint32, controller OCRv2AccessController) error

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

+ func (e *EthereumOCRv2) SetValidatorConfig(flaggingThreshold uint32, validator OCRv2DeviationFlaggingValidator) error

+ func (e *EthereumOCRv2) TransferOwnership(to string) error

type OCRv2

+ AuthorityAddr func(string) (string, error)

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

+ RequestNewRound func() error

+ SetValidatorConfig func(flaggingThreshold uint32, validator OCRv2DeviationFlaggingValidator) error

+ type OCRv2DeviationFlaggingValidator interface

+ Address func() string

Nov 24, 2021

Changes in this version

type EthereumLinkToken

+ func (l *EthereumLinkToken) Deploy() (LinkToken, error)

Oct 22, 2021

Changes in this version

type ContractDeployer

+ DeployOCRv2 func(fromWallet client.BlockchainWallet, paymentControllerAddr string, ...) (OCRv2, error)

+ DeployOCRv2AccessController func(fromWallet client.BlockchainWallet) (OCRv2AccessController, error)

type EthereumContractDeployer

+ func (e *EthereumContractDeployer) DeployOCRv2(fromWallet client.BlockchainWallet, paymentControllerAddr string, ...) (OCRv2, error)

+ func (e *EthereumContractDeployer) DeployOCRv2AccessController(fromWallet client.BlockchainWallet) (OCRv2AccessController, error)

+ type OCRv2 interface

+ Address func() string

+ GetLatestConfigDetails func() (map[string]interface{}, error)

+ GetOwedPayment func(transmitterAddr string) (map[string]interface{}, error)

+ GetRoundData func(roundID uint32) (map[string]interface{}, error)

+ SetBilling func(fromWallet client.BlockchainWallet, observationPayment uint32, ...) error

+ SetConfig func(fromWallet client.BlockchainWallet) error

+ TransferOwnership func(fromWallet client.BlockchainWallet, to string) error

+ type OCRv2AccessController interface

+ AddAccess func(fromWallet client.BlockchainWallet, addr string) error

+ Address func() string

+ HasAccess func(to string) (bool, error)

+ RemoveAccess func(fromWallet client.BlockchainWallet, addr string) error

+ type TerraContractDeployer struct

+ func NewTerraContractDeployer(client *client.TerraLCDClient) *TerraContractDeployer

+ func (t *TerraContractDeployer) Balance(fromWallet client.BlockchainWallet) (*big.Float, error)

+ func (t *TerraContractDeployer) CalculateETHForTXs(fromWallet client.BlockchainWallet, networkConfig *config.NetworkConfig, ...) (*big.Float, error)

+ func (t *TerraContractDeployer) DeployAPIConsumer(fromWallet client.BlockchainWallet, linkAddr string) (APIConsumer, error)

+ func (t *TerraContractDeployer) DeployBlockhashStore(fromWallet client.BlockchainWallet) (BlockHashStore, error)

+ func (t *TerraContractDeployer) DeployDeviationFlaggingValidator(fromWallet client.BlockchainWallet, flags string, flaggingThreshold *big.Int) (DeviationFlaggingValidator, error)

+ func (t *TerraContractDeployer) DeployFlags(fromWallet client.BlockchainWallet, rac string) (Flags, error)

+ func (t *TerraContractDeployer) DeployFluxAggregatorContract(fromWallet client.BlockchainWallet, fluxOptions FluxAggregatorOptions) (FluxAggregator, error)

+ func (t *TerraContractDeployer) DeployKeeperConsumer(fromWallet client.BlockchainWallet, updateInterval *big.Int) (KeeperConsumer, error)

+ func (t *TerraContractDeployer) DeployKeeperRegistry(fromWallet client.BlockchainWallet, opts *KeeperRegistryOpts) (KeeperRegistry, error)

+ func (t *TerraContractDeployer) DeployLinkTokenContract(fromWallet client.BlockchainWallet) (LinkToken, error)

+ func (t *TerraContractDeployer) DeployMockETHLINKFeed(fromWallet client.BlockchainWallet, answer *big.Int) (MockETHLINKFeed, error)

+ func (t *TerraContractDeployer) DeployMockGasFeed(fromWallet client.BlockchainWallet, answer *big.Int) (MockGasFeed, error)

+ func (t *TerraContractDeployer) DeployOCRv2(fromWallet client.BlockchainWallet, paymentControllerAddr string, ...) (OCRv2, error)

+ func (t *TerraContractDeployer) DeployOCRv2AccessController(fromWallet client.BlockchainWallet) (OCRv2AccessController, error)

+ func (t *TerraContractDeployer) DeployOffChainAggregator(fromWallet client.BlockchainWallet, offchainOptions OffchainOptions) (OffchainAggregator, error)

+ func (t *TerraContractDeployer) DeployOracle(fromWallet client.BlockchainWallet, linkAddr string) (Oracle, error)

+ func (t *TerraContractDeployer) DeployReadAccessController(fromWallet client.BlockchainWallet) (ReadAccessController, error)

+ func (t *TerraContractDeployer) DeployStorageContract(fromWallet client.BlockchainWallet) (Storage, error)

+ func (t *TerraContractDeployer) DeployUpkeepRegistrationRequests(fromWallet client.BlockchainWallet, linkAddr string, minLinkJuels *big.Int) (UpkeepRegistrar, error)

+ func (t *TerraContractDeployer) DeployVRFConsumer(fromWallet client.BlockchainWallet, linkAddr string, coordinatorAddr string) (VRFConsumer, error)

+ func (t *TerraContractDeployer) DeployVRFContract(fromWallet client.BlockchainWallet) (VRF, error)

+ func (t *TerraContractDeployer) DeployVRFCoordinator(fromWallet client.BlockchainWallet, linkAddr string, bhsAddr string) (VRFCoordinator, error)

+ type TerraWASMAccessController struct

+ func (t *TerraWASMAccessController) AddAccess(fromWallet client.BlockchainWallet, to string) error

+ func (t *TerraWASMAccessController) Address() string

+ func (t *TerraWASMAccessController) HasAccess(to string) (bool, error)

+ func (t *TerraWASMAccessController) RemoveAccess(fromWallet client.BlockchainWallet, to string) error

+ type TerraWASMLinkToken struct

+ func (t *TerraWASMLinkToken) Address() string

+ func (t *TerraWASMLinkToken) Approve(fromWallet client.BlockchainWallet, to string, amount *big.Int) error

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

+ func (t *TerraWASMLinkToken) Fund(fromWallet client.BlockchainWallet, ethAmount *big.Float) error

+ func (t *TerraWASMLinkToken) Name(ctx context.Context) (string, error)

+ func (t *TerraWASMLinkToken) Transfer(fromWallet client.BlockchainWallet, to string, amount *big.Int) error

+ func (t *TerraWASMLinkToken) TransferAndCall(fromWallet client.BlockchainWallet, to string, amount *big.Int, data []byte) error

+ type TerraWASMOCRv2 struct

+ func (t *TerraWASMOCRv2) Address() string

+ func (t *TerraWASMOCRv2) GetLatestConfigDetails() (map[string]interface{}, error)

+ func (t *TerraWASMOCRv2) GetOwedPayment(transmitter string) (map[string]interface{}, error)

+ func (t *TerraWASMOCRv2) GetRoundData(roundID uint32) (map[string]interface{}, error)

+ func (t *TerraWASMOCRv2) SetBilling(fromWallet client.BlockchainWallet, observationPayment uint32, ...) error

+ func (t *TerraWASMOCRv2) SetConfig(fromWallet client.BlockchainWallet) error

+ func (t *TerraWASMOCRv2) TransferOwnership(fromWallet client.BlockchainWallet, to string) error

Oct 14, 2021

Changes in this version

type APIConsumer

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

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

type EthereumAPIConsumer

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

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

type EthereumVRFConsumer

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

+ type PerfEvent struct

+ BlockTimestamp *big.Int

+ Contract DeviationFlaggingValidator

+ RequestID [32]byte

+ Round *big.Int

+ type RunlogRoundConfirmer struct

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

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

+ func (o *RunlogRoundConfirmer) Wait() error

type VRFConsumer

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

Oct 5, 2021

Changes in this version

type ContractDeployer

+ Balance func(fromWallet client.BlockchainWallet) (*big.Float, error)

+ CalculateETHForTXs func(fromWallet client.BlockchainWallet, networkConfig *config.NetworkConfig, ...) (*big.Float, error)

type EthereumContractDeployer

+ func (e *EthereumContractDeployer) Balance(fromWallet client.BlockchainWallet) (*big.Float, error)

+ func (e *EthereumContractDeployer) CalculateETHForTXs(fromWallet client.BlockchainWallet, networkConfig *config.NetworkConfig, ...) (*big.Float, error)

type EthereumVRFConsumer

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

+ type KeeperConsumerRoundConfirmer struct

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

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

+ func (o *KeeperConsumerRoundConfirmer) Wait() error

type VRFConsumer

+ Address func() string

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

+ type VRFConsumerRoundConfirmer struct

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

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

+ func (f *VRFConsumerRoundConfirmer) Wait() error

Sep 2, 2021

Changes in this version

+ const DAGAwaitTimeout

+ func AwaitMining(c client.BlockchainClient) error

+ func Unzip(src string, dest string) ([]string, error)

+ type ArtifactSourceType int

+ const DefaultBindPkg

+ const ExternalArtifact

+ const LocalArtifact

+ type ContractBuilder interface

+ Compile func(targets []*ContractTarget) error

+ GenerateBindings func(targets []*ContractTarget) error

+ Targets func() ([]*ContractTarget, error)

+ UpdateExternalSources func() error

+ type ContractTarget struct

+ Contracts []string

+ ExternalRepoDir string

+ SourceType ArtifactSourceType

+ Version string

+ type EthereumContractBuilder struct

+ Cfg *config.EthereumSources

+ S3 *S3Downloader

+ func NewEthereumContractBuilder(cfg *config.EthereumSources) *EthereumContractBuilder

+ func (b *EthereumContractBuilder) ArtifactSourcePath(t *ContractTarget) (string, error)

+ func (b *EthereumContractBuilder) Compile(_ []*ContractTarget) error

+ func (b *EthereumContractBuilder) ExtractArtifact(path string) error

+ func (b *EthereumContractBuilder) FindArtifact(rootPath string, name string) (string, error)

+ func (b *EthereumContractBuilder) GenerateBindings(targets []*ContractTarget) error

+ func (b *EthereumContractBuilder) Targets() ([]*ContractTarget, error)

+ func (b *EthereumContractBuilder) UpdateExternalSources() error

+ type NextBlockConfirmer struct

+ func NewNextBlockConfirmer() *NextBlockConfirmer

+ func (f *NextBlockConfirmer) ReceiveBlock(_ *types.Block) error

+ func (f *NextBlockConfirmer) Wait() error

+ type S3Downloader struct

+ Bucket string

+ Downloader *s3manager.Downloader

+ Region string

+ Session *session.Session

+ func NewS3Downloader(cfg config.ExternalSources) *S3Downloader

+ func (d *S3Downloader) UpdateSources(cfg config.ExternalSources) error

Aug 30, 2021

Changes in this version

+ type APIConsumer interface

+ Address func() string

+ CreateRequestTo func(fromWallet client.BlockchainWallet, oracleAddr string, jobID [32]byte, ...) error

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

+ Fund func(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

+ type BlockHashStore interface

+ Address func() string

+ type ContractDeployer interface

+ DeployAPIConsumer func(fromWallet client.BlockchainWallet, linkAddr string) (APIConsumer, error)

+ DeployBlockhashStore func(fromWallet client.BlockchainWallet) (BlockHashStore, error)

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

+ DeployFlags func(fromWallet client.BlockchainWallet, rac string) (Flags, error)

+ DeployFluxAggregatorContract func(fromWallet client.BlockchainWallet, fluxOptions FluxAggregatorOptions) (FluxAggregator, error)

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

+ DeployKeeperRegistry func(fromWallet client.BlockchainWallet, opts *KeeperRegistryOpts) (KeeperRegistry, error)

+ DeployLinkTokenContract func(fromWallet client.BlockchainWallet) (LinkToken, error)

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

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

+ DeployOffChainAggregator func(fromWallet client.BlockchainWallet, offchainOptions OffchainOptions) (OffchainAggregator, error)

+ DeployOracle func(fromWallet client.BlockchainWallet, linkAddr string) (Oracle, error)

+ DeployReadAccessController func(fromWallet client.BlockchainWallet) (ReadAccessController, error)

+ DeployStorageContract func(fromWallet client.BlockchainWallet) (Storage, error)

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

+ DeployVRFConsumer func(fromWallet client.BlockchainWallet, linkAddr string, coordinatorAddr string) (VRFConsumer, error)

+ DeployVRFContract func(fromWallet client.BlockchainWallet) (VRF, error)

+ DeployVRFCoordinator func(fromWallet client.BlockchainWallet, linkAddr string, bhsAddr string) (VRFCoordinator, error)

+ func NewContractDeployer(bcClient client.BlockchainClient) (ContractDeployer, error)

+ type DeviationFlaggingValidator interface

+ Address func() string

+ type EthereumAPIConsumer struct

+ func (e *EthereumAPIConsumer) Address() string

+ func (e *EthereumAPIConsumer) CreateRequestTo(fromWallet client.BlockchainWallet, oracleAddr string, jobID [32]byte, ...) error

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

+ func (e *EthereumAPIConsumer) Fund(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

+ type EthereumBlockhashStore struct

+ func (v *EthereumBlockhashStore) Address() string

+ type EthereumContractDeployer struct

+ func NewEthereumContractDeployer(ethClient *client.EthereumClient) *EthereumContractDeployer

+ func (e *EthereumContractDeployer) DeployAPIConsumer(fromWallet client.BlockchainWallet, linkAddr string) (APIConsumer, error)

+ func (e *EthereumContractDeployer) DeployBlockhashStore(fromWallet client.BlockchainWallet) (BlockHashStore, error)

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

+ func (e *EthereumContractDeployer) DeployFlags(fromWallet client.BlockchainWallet, rac string) (Flags, error)

+ func (e *EthereumContractDeployer) DeployFluxAggregatorContract(fromWallet client.BlockchainWallet, fluxOptions FluxAggregatorOptions) (FluxAggregator, error)

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

+ func (e *EthereumContractDeployer) DeployKeeperRegistry(fromWallet client.BlockchainWallet, opts *KeeperRegistryOpts) (KeeperRegistry, error)

+ func (e *EthereumContractDeployer) DeployLinkTokenContract(fromWallet client.BlockchainWallet) (LinkToken, error)

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

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

+ func (e *EthereumContractDeployer) DeployOffChainAggregator(fromWallet client.BlockchainWallet, offchainOptions OffchainOptions) (OffchainAggregator, error)

+ func (e *EthereumContractDeployer) DeployOracle(fromWallet client.BlockchainWallet, linkAddr string) (Oracle, error)

+ func (e *EthereumContractDeployer) DeployReadAccessController(fromWallet client.BlockchainWallet) (ReadAccessController, error)

+ func (e *EthereumContractDeployer) DeployStorageContract(fromWallet client.BlockchainWallet) (Storage, error)

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

+ func (e *EthereumContractDeployer) DeployVRFConsumer(fromWallet client.BlockchainWallet, linkAddr string, coordinatorAddr string) (VRFConsumer, error)

+ func (e *EthereumContractDeployer) DeployVRFContract(fromWallet client.BlockchainWallet) (VRF, error)

+ func (e *EthereumContractDeployer) DeployVRFCoordinator(fromWallet client.BlockchainWallet, linkAddr string, bhsAddr string) (VRFCoordinator, error)

+ type EthereumDeviationFlaggingValidator struct

+ func (e *EthereumDeviationFlaggingValidator) Address() string

+ type EthereumFlags struct

+ func (e *EthereumFlags) Address() string

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

+ type EthereumFluxAggregator struct

+ func (f *EthereumFluxAggregator) Address() string

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

+ func (f *EthereumFluxAggregator) Fund(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

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

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

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

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

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

+ func (f *EthereumFluxAggregator) RequestNewRound(ctx context.Context, fromWallet client.BlockchainWallet) error

+ func (f *EthereumFluxAggregator) SetOracles(fromWallet client.BlockchainWallet, o FluxAggregatorSetOraclesOptions) error

+ func (f *EthereumFluxAggregator) SetRequesterPermissions(ctx context.Context, fromWallet client.BlockchainWallet, addr common.Address, ...) error

+ func (f *EthereumFluxAggregator) UpdateAvailableFunds(ctx context.Context, fromWallet client.BlockchainWallet) error

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

+ func (f *EthereumFluxAggregator) WithdrawPayment(ctx context.Context, caller client.BlockchainWallet, from common.Address, ...) error

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

+ type EthereumKeeperConsumer struct

+ func (v *EthereumKeeperConsumer) Address() string

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

+ func (v *EthereumKeeperConsumer) Fund(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

+ type EthereumKeeperRegistry struct

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

+ func (v *EthereumKeeperRegistry) Address() string

+ func (v *EthereumKeeperRegistry) Fund(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

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

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

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

+ func (v *EthereumKeeperRegistry) RegisterUpkeep(fromWallet client.BlockchainWallet, target string, gasLimit uint32, ...) error

+ func (v *EthereumKeeperRegistry) SetKeepers(fromWallet client.BlockchainWallet, keepers []string, payees []string) error

+ func (v *EthereumKeeperRegistry) SetRegistrar(fromWallet client.BlockchainWallet, registrarAddr string) error

+ type EthereumLinkToken struct

+ func (l *EthereumLinkToken) Address() string

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

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

+ func (l *EthereumLinkToken) Fund(fromWallet client.BlockchainWallet, ethAmount *big.Float) error

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

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

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

+ type EthereumMockETHLINKFeed struct

+ func (v *EthereumMockETHLINKFeed) Address() string

+ type EthereumMockGASFeed struct

+ func (v *EthereumMockGASFeed) Address() string

+ type EthereumOffchainAggregator struct

+ func (o *EthereumOffchainAggregator) Address() string

+ func (o *EthereumOffchainAggregator) Fund(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

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

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

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

+ func (o *EthereumOffchainAggregator) Link(ctxt context.Context) (common.Address, error)

+ func (o *EthereumOffchainAggregator) RequestNewRound(fromWallet client.BlockchainWallet) error

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

+ func (o *EthereumOffchainAggregator) SetPayees(fromWallet client.BlockchainWallet, transmitters, payees []common.Address) error

+ type EthereumOracle struct

+ func (e *EthereumOracle) Address() string

+ func (e *EthereumOracle) Fund(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

+ func (e *EthereumOracle) SetFulfillmentPermission(fromWallet client.BlockchainWallet, address string, allowed bool) error

+ type EthereumReadAccessController struct

+ func (e *EthereumReadAccessController) AddAccess(fromWallet client.BlockchainWallet, addr string) error

+ func (e *EthereumReadAccessController) Address() string

+ func (e *EthereumReadAccessController) DisableAccessCheck(fromWallet client.BlockchainWallet) error

+ type EthereumStorage struct

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

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

+ type EthereumUpkeepRegistrationRequests struct

+ func (v *EthereumUpkeepRegistrationRequests) Address() string

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

+ func (v *EthereumUpkeepRegistrationRequests) Fund(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

+ func (v *EthereumUpkeepRegistrationRequests) SetRegistrarConfig(fromWallet client.BlockchainWallet, autoRegister bool, windowSizeBlocks uint32, ...) error

+ type EthereumVRF struct

+ func (v *EthereumVRF) Fund(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

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

+ type EthereumVRFConsumer struct

+ func (v *EthereumVRFConsumer) Address() string

+ func (v *EthereumVRFConsumer) Fund(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

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

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

+ type EthereumVRFCoordinator struct

+ func (v *EthereumVRFCoordinator) Address() string

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

+ func (v *EthereumVRFCoordinator) RegisterProvingKey(fromWallet client.BlockchainWallet, fee *big.Int, oracleAddr string, ...) error

+ type Flags interface

+ Address func() string

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

+ type FluxAggregator interface

+ Address func() string

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

+ Fund func(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

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

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

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

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

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

+ RequestNewRound func(ctx context.Context, fromWallet client.BlockchainWallet) error

+ SetOracles func(client.BlockchainWallet, FluxAggregatorSetOraclesOptions) error

+ SetRequesterPermissions func(ctx context.Context, fromWallet client.BlockchainWallet, addr common.Address, ...) error

+ UpdateAvailableFunds func(ctx context.Context, fromWallet client.BlockchainWallet) error

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

+ WithdrawPayment func(ctx context.Context, caller client.BlockchainWallet, from common.Address, ...) error

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

+ type FluxAggregatorData struct

+ AllocatedFunds *big.Int

+ AvailableFunds *big.Int

+ LatestRoundData RoundData

+ Oracles []common.Address

+ type FluxAggregatorOptions struct

+ Decimals uint8

+ Description string

+ MaxSubValue *big.Int

+ MinSubValue *big.Int

+ PaymentAmount *big.Int

+ Timeout uint32

+ Validator common.Address

+ func DefaultFluxAggregatorOptions() FluxAggregatorOptions

+ type FluxAggregatorRoundConfirmer struct

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

+ func (f *FluxAggregatorRoundConfirmer) ReceiveBlock(block *types.Block) error

+ func (f *FluxAggregatorRoundConfirmer) Wait() error

+ type FluxAggregatorSetOraclesOptions struct

+ AddList []common.Address

+ AdminList []common.Address

+ MaxSubmissions uint32

+ MinSubmissions uint32

+ RemoveList []common.Address

+ RestartDelayRounds uint32

+ type JobByInstance struct

+ ID string

+ Instance string

+ type KeeperConsumer interface

+ Address func() string

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

+ Fund func(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

+ type KeeperInfo struct

+ Active bool

+ Balance *big.Int

+ Payee string

+ type KeeperRegistry interface

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

+ Address func() string

+ Fund func(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

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

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

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

+ RegisterUpkeep func(fromWallet client.BlockchainWallet, target string, gasLimit uint32, ...) error

+ SetKeepers func(fromWallet client.BlockchainWallet, keepers []string, payees []string) error

+ SetRegistrar func(fromWallet client.BlockchainWallet, registrarAddr string) error

+ type KeeperRegistryOpts struct

+ BlockCountPerTurn *big.Int

+ CheckGasLimit uint32

+ ETHFeedAddr string

+ FallbackGasPrice *big.Int

+ FallbackLinkPrice *big.Int

+ GasCeilingMultiplier uint16

+ GasFeedAddr string

+ LinkAddr string

+ PaymentPremiumPPB uint32

+ StalenessSeconds *big.Int

+ type LinkToken interface

+ Address func() string

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

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

+ Fund func(fromWallet client.BlockchainWallet, ethAmount *big.Float) error

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

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

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

+ type MockETHLINKFeed interface

+ Address func() string

+ type MockGasFeed interface

+ Address func() string

+ type OffChainAggregatorConfig struct

+ AlphaPPB uint64

+ DeltaC time.Duration

+ DeltaGrace time.Duration

+ DeltaProgress time.Duration

+ DeltaResend time.Duration

+ DeltaRound time.Duration

+ DeltaStage time.Duration

+ F int

+ N int

+ OracleIdentities []ocrConfigHelper.OracleIdentityExtra

+ RMax uint8

+ S []int

+ func DefaultOffChainAggregatorConfig(numberNodes int) OffChainAggregatorConfig

+ type OffchainAggregator interface

+ Address func() string

+ Fund func(fromWallet client.BlockchainWallet, nativeAmount, linkAmount *big.Float) error

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

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

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

+ Link func(ctxt context.Context) (common.Address, error)

+ RequestNewRound func(fromWallet client.BlockchainWallet) error

+ SetConfig func(fromWallet client.BlockchainWallet, chainlinkNodes []client.Chainlink, ...) error

+ SetPayees func(client.BlockchainWallet, []common.Address, []common.Address) error

+ type OffchainAggregatorData struct

+ LatestRoundData RoundData

+ type OffchainAggregatorRoundConfirmer struct

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

+ func (o *OffchainAggregatorRoundConfirmer) ReceiveBlock(_ *types.Block) error

+ func (o *OffchainAggregatorRoundConfirmer) Wait() error

+ type OffchainOptions struct

+ BillingAccessController common.Address

+ Decimals uint8

+ Description string

+ LinkGweiPerObservation uint32

+ LinkGweiPerTransmission uint32

+ MaximumAnswer *big.Int

+ MaximumGasPrice uint32

+ MicroLinkPerEth uint32

+ MinimumAnswer *big.Int

+ ReasonableGasPrice uint32

+ RequesterAccessController common.Address

+ func DefaultOffChainAggregatorOptions() OffchainOptions

+ type Oracle interface

+ Address func() string

+ Fund func(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

+ SetFulfillmentPermission func(fromWallet client.BlockchainWallet, address string, allowed bool) error

+ type ReadAccessController interface

+ AddAccess func(fromWallet client.BlockchainWallet, addr string) error

+ Address func() string

+ DisableAccessCheck func(fromWallet client.BlockchainWallet) error

+ type RoundData struct

+ Answer *big.Int

+ AnsweredInRound *big.Int

+ RoundId *big.Int

+ StartedAt *big.Int

+ UpdatedAt *big.Int

+ type Storage interface

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

+ Set func(*big.Int) error

+ type SubmissionEvent struct

+ BlockNumber uint64

+ Contract common.Address

+ Oracle common.Address

+ Round uint32

+ Submission *big.Int

+ type UpkeepInfo struct

+ Admin string

+ Balance *big.Int

+ CheckData []byte

+ ExecuteGas uint32

+ LastKeeper string

+ MaxValidBlocknumber uint64

+ Target string

+ type UpkeepRegistrar interface

+ Address func() string

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

+ Fund func(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

+ SetRegistrarConfig func(fromWallet client.BlockchainWallet, autoRegister bool, windowSizeBlocks uint32, ...) error

+ type VRF interface

+ Fund func(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

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

+ type VRFConsumer interface

+ Fund func(fromWallet client.BlockchainWallet, ethAmount, linkAmount *big.Float) error

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

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

+ type VRFCoordinator interface

+ Address func() string

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

+ RegisterProvingKey func(fromWallet client.BlockchainWallet, fee *big.Int, oracleAddr string, ...) error