client

May 3, 2022

Changes in this version

+ type CCIPBootstrapJobSpec struct

+ ChainID int

+ ContractID string

+ ContractTrackerInterval time.Duration

+ Name string

+ func (C CCIPBootstrapJobSpec) String() (string, error)

+ func (C CCIPBootstrapJobSpec) Type() string

+ type CCIPExecJobSpec struct

+ ChainID int

+ ContractID string

+ DestChainID int

+ Name string

+ OCRKeyBundleID string

+ OffRampID string

+ OnRampID string

+ P2PBootstrapPeers []P2PData

+ SourceChainID int

+ TransmitterID string

+ func (C CCIPExecJobSpec) String() (string, error)

+ func (C CCIPExecJobSpec) Type() string

+ type CCIPRelayJobSpec struct

+ ChainID int

+ ContractID string

+ DestChainID int

+ Name string

+ OCRKeyBundleID string

+ OnRampID string

+ P2PBootstrapPeers []P2PData

+ SourceChainID int

+ TransmitterID string

+ func (C CCIPRelayJobSpec) String() (string, error)

+ func (C CCIPRelayJobSpec) Type() string

type TxKey

+ Address string

+ IsFunding bool

Apr 28, 2022

Changes in this version

+ type ChainCfg struct

+ BlockHistoryEstimatorBlockDelay null.Int

+ BlockHistoryEstimatorBlockHistorySize null.Int

+ BlockHistoryEstimatorEIP1559FeeCapBufferBlocks null.Int

+ ChainType null.String

+ EthTxReaperThreshold *models.Duration

+ EthTxResendAfterThreshold *models.Duration

+ EvmEIP1559DynamicFees null.Bool

+ EvmFinalityDepth null.Int

+ EvmGasBumpPercent null.Int

+ EvmGasBumpTxDepth null.Int

+ EvmGasBumpWei *utils.Big

+ EvmGasFeeCapDefault *utils.Big

+ EvmGasLimitDefault null.Int

+ EvmGasLimitMultiplier null.Float

+ EvmGasPriceDefault *utils.Big

+ EvmGasTipCapDefault *utils.Big

+ EvmGasTipCapMinimum *utils.Big

+ EvmHeadTrackerHistoryDepth null.Int

+ EvmHeadTrackerMaxBufferSize null.Int

+ EvmHeadTrackerSamplingInterval *models.Duration

+ EvmLogBackfillBatchSize null.Int

+ EvmLogPollInterval *models.Duration

+ EvmMaxGasPriceWei *utils.Big

+ EvmNonceAutoSync null.Bool

+ EvmRPCDefaultBatchSize null.Int

+ EvmUseForwarders null.Bool

+ FlagsContractAddress null.String

+ GasEstimatorMode null.String

+ KeySpecific map[string]ChainCfg

+ LinkContractAddress null.String

+ MinIncomingConfirmations null.Int

+ MinRequiredOutgoingConfirmations null.Int

+ MinimumContractPayment *assets.Link

+ NodeNoNewHeadsThreshold *models.Duration

+ OCRObservationTimeout *models.Duration

type Chainlink

+ CreateEVMChain func(chain CreateEVMChainRequest) error

+ CreateEVMNode func(node NewEVMNode) error

+ UpdateEVMChain func(chain UpdateEVMChainRequest) error

+ type CreateEVMChainRequest struct

+ Config ChainCfg

+ ID utils.Big

+ type EVMNodeAttributes struct

+ EVMChainID string

+ EVMURL string

+ Name string

+ type NewEVMNode struct

+ EVMChainID utils.Big

+ HTTPURL null.String

+ Name string

+ SendOnly bool

+ WSURL null.String

+ type UpdateEVMChainRequest struct

+ Config ChainCfg

+ Enabled bool

+ ID string

Apr 19, 2022

Changes in this version

type VRFV2JobSpec

+ EVMChainID string

Apr 19, 2022

Changes in this version

type VRFV2JobSpec

+ FromAddress string

Apr 19, 2022

Changes in this version

+ type VRFV2JobSpec struct

+ BackOffInitialDelay time.Duration

+ BackOffMaxDelay time.Duration

+ BatchFulfillmentEnabled bool

+ CoordinatorAddress string

+ ExternalJobID string

+ MinIncomingConfirmations int

+ Name string

+ ObservationSource string

+ PublicKey string

+ func (v *VRFV2JobSpec) String() (string, error)

+ func (v *VRFV2JobSpec) Type() string

Apr 18, 2022

Changes in this version

type BlockchainClient

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

type Chainlink

+ ReadPrimaryETHKey func() (*ETHKeyData, error)

type ETHKeyAttributes

+ ChainID string

+ ETHBalance string

type EthereumClient

+ func (e *EthereumClient) EstimateTransactionGasCost() (*big.Int, error)

type EthereumMultinodeClient

+ func (e *EthereumMultinodeClient) EstimateTransactionGasCost() (*big.Int, error)

type Networks

+ func (b *Networks) AllNetworks() []BlockchainClient

+ type SingleTransactionDataWrapper struct

+ Data TransactionData

type VRFJobSpec

+ BackOffInitialDelay time.Duration

+ BackOffMaxDelay time.Duration

+ BatchFulfillmentEnabled bool

+ type VRFV2TxPipelineSpec struct

+ Address string

+ func (d *VRFV2TxPipelineSpec) String() (string, error)

+ func (d *VRFV2TxPipelineSpec) Type() string

Mar 29, 2022

Changes in this version

+ func SimulatedSoakEthereumURLs(e *environment.Environment) ([]*url.URL, error)

type Chainlink

+ func ConnectChainlinkNodesSoak(e *environment.Environment) ([]Chainlink, error)

+ CreateSolanaChain func(node *SolanaChainAttributes) (*SolanaChainCreate, error)

+ CreateSolanaNode func(node *SolanaNodeAttributes) (*SolanaNodeCreate, error)

type MockserverClient

+ func ConnectMockServerSoak(e *environment.Environment) (*MockserverClient, error)

type NetworkRegistry

+ func NewDefaultNetworkRegistry() *NetworkRegistry

+ func NewSoakNetworkRegistry() *NetworkRegistry

+ type SolanaChain struct

+ Attributes SolanaChainAttributes

+ type SolanaChainAttributes struct

+ ChainID string

+ Config SolanaChainConfig

+ type SolanaChainConfig struct

+ BlockRate null.String

+ Commitment null.String

+ ConfirmPollPeriod null.String

+ OCR2CachePollPeriod null.String

+ OCR2CacheTTL null.String

+ SkipPreflight null.Bool

+ TxTimeout null.String

+ type SolanaChainCreate struct

+ Data SolanaChain

+ type SolanaNode struct

+ Attributes SolanaNodeAttributes

+ type SolanaNodeAttributes struct

+ Name string

+ SolanaChainID string

+ SolanaURL string

+ type SolanaNodeCreate struct

+ Data SolanaNode

type TerraChainAttributes

+ FCDURL string

Feb 24, 2022

Changes in this version

type OCR2TaskJobSpec

+ PluginType string

Feb 18, 2022

Changes in this version

type OCR2TaskJobSpec

+ JobType string

Feb 14, 2022

Changes in this version

type BlockchainClient

+ GetDefaultWallet func() *EthereumWallet

type Chainlink

+ ReadTransactionAttempts func() (*TransactionsData, error)

+ ReadTransactions func() (*TransactionsData, error)

+ SendNativeToken func(amount *big.Int, fromAddress, toAddress string) (interface{}, error)

type EthereumClient

+ func (e *EthereumClient) GetDefaultWallet() *EthereumWallet

type EthereumMultinodeClient

+ func (e *EthereumMultinodeClient) GetDefaultWallet() *EthereumWallet

+ type SendEtherRequest struct

+ AllowHigherAmounts bool

+ Amount string

+ DestinationAddress string

+ EVMChainID int

+ FromAddress string

+ type TransactionAttributes struct

+ ChainID string

+ Data string

+ From string

+ GasLimit string

+ GasPrice string

+ Hash string

+ Nonce string

+ RawHex string

+ SentAt string

+ State string

+ To string

+ Value string

+ type TransactionData struct

+ Attributes TransactionAttributes

+ ID string

+ Type string

+ type TransactionsData struct

+ Data []TransactionData

+ Meta TransactionsMetaData

+ type TransactionsMetaData struct

+ Count int

Feb 10, 2022

Changes in this version

type PostgresConnector

+ func ConnectChainlinkDBByCharts(e *environment.Environment, charts []string) ([]*PostgresConnector, error)

+ func ConnectChainlinkDBs(e *environment.Environment) ([]*PostgresConnector, error)

Feb 9, 2022

Changes in this version

type Chainlink

+ DB func() *PostgresConnector

type ChainlinkConfig

+ PG *PostgresConfig

+ type PostgresConfig struct

+ DBName string

+ Host string

+ Password string

+ Port string

+ User string

+ type PostgresConnector struct

+ Cfg *PostgresConfig

+ func NewPostgresConnector(cfg *PostgresConfig) (*PostgresConnector, error)

Jan 26, 2022

Changes in this version

+ type CSAKey struct

+ Data CSAKeyData

+ type CSAKeyAttributes struct

+ PublicKey string

+ Version int

+ type CSAKeyData struct

+ Attributes CSAKeyAttributes

+ ID string

+ Type string

+ type CSAKeys struct

+ Data []CSAKeyData

type Chainlink

+ CreateCSAKey func() (*CSAKey, error)

+ ReadCSAKeys func() (*CSAKeys, error)

Jan 25, 2022

Changes in this version

type Chainlink

+ CreateTerraChain func(node *TerraChainAttributes) (*TerraChainCreate, error)

+ type TerraChain struct

+ Attributes TerraChainAttributes

+ type TerraChainAttributes struct

+ ChainID string

+ Config TerraChainConfig

+ type TerraChainConfig struct

+ BlockRate null.String

+ BlocksUntilTxTimeout null.Int

+ ConfirmPollPeriod null.String

+ FallbackGasPriceULuna null.String

+ GasLimitMultiplier null.Float

+ MaxMsgsPerBatch null.Int

+ type TerraChainCreate struct

+ Data TerraChain

Jan 20, 2022

Changes in this version

type BlockchainClient

+ ContractsDeployed func() bool

type EthereumClient

+ func (e *EthereumClient) ContractsDeployed() bool

type EthereumMultinodeClient

+ func (e *EthereumMultinodeClient) ContractsDeployed() bool

Jan 18, 2022

Changes in this version

type Chainlink

+ CreateTerraNode func(node *TerraNodeAttributes) (*TerraNodeCreate, error)

+ type TerraNode struct

+ Attributes TerraNodeAttributes

+ type TerraNodeAttributes struct

+ FCDURL string

+ Name string

+ TendermintURL string

+ TerraChainID string

+ type TerraNodeCreate struct

+ Data TerraNode

Jan 13, 2022

Changes in this version

+ const LiveEthTestNetwork

+ const SimulatedEthNetwork

+ func LiveEthTestnetURLs(e *environment.Environment) ([]*url.URL, error)

+ func SimulatedEthereumURLs(e *environment.Environment) ([]*url.URL, error)

type BlockchainClient

+ GetNetworkType func() string

type EthereumClient

+ func (e *EthereumClient) GetNetworkType() string

type EthereumMultinodeClient

+ func (e *EthereumMultinodeClient) GetNetworkType() string

Jan 5, 2022

Changes in this version

type BasicHTTPClient

+ func (em *BasicHTTPClient) Do(method, endpoint string, body interface{}, obj interface{}, ...) (*http.Response, error)

type Chainlink

+ func ConnectChainlinkNodes(e *environment.Environment) ([]Chainlink, error)

+ func ConnectChainlinkNodesByCharts(e *environment.Environment, charts []string) ([]Chainlink, error)

type HttpInitializer

+ Id string

type KeeperJobSpec

+ MinIncomingConfirmations int

+ ObservationSource string

type MockserverClient

+ func ConnectMockServer(e *environment.Environment) (*MockserverClient, error)

Dec 14, 2021

Changes in this version

type P2PData

+ RemotePort string

Dec 13, 2021

Changes in this version

type OCR2KeyAttributes

+ OnChainPublicKey string

Dec 9, 2021

Changes in this version

type Chainlink

+ CreateOCR2Key func(chain string) (*OCR2Key, error)

+ CreateTxKey func(chain string) (*TxKey, error)

+ DeleteOCR2Key func(id string) error

+ DeleteTxKey func(chain, id string) error

+ ReadOCR2Keys func() (*OCR2Keys, error)

+ ReadTxKeys func(chain string) (*TxKeys, error)

+ type OCR2Key struct

+ Data OCR2KeyData

+ type OCR2KeyAttributes struct

+ ChainType string

+ ConfigPublicKey string

+ OffChainPublicKey string

+ OnChainSigningAddress string

+ type OCR2KeyData struct

+ Attributes OCR2KeyAttributes

+ ID string

+ Type string

+ type OCR2Keys struct

+ Data []OCR2KeyData

+ type OCR2TaskJobSpec struct

+ BlockChainTimeout time.Duration

+ ContractConfirmations int

+ ContractID string

+ IsBootstrapPeer bool

+ JuelsPerFeeCoinSource string

+ MonitoringEndpoint string

+ Name string

+ OCRKeyBundleID string

+ ObservationSource string

+ P2PBootstrapPeers []P2PData

+ P2PPeerID string

+ Relay string

+ RelayConfig string

+ TrackerPollInterval time.Duration

+ TrackerSubscribeInterval time.Duration

+ TransmitterID string

+ func (o *OCR2TaskJobSpec) String() (string, error)

+ func (o *OCR2TaskJobSpec) Type() string

+ type TxKey struct

+ Data TxKeyData

+ type TxKeyAttributes struct

+ PublicKey string

+ type TxKeyData struct

+ Attributes TxKeyAttributes

+ ID string

+ Type string

+ type TxKeys struct

+ Data []TxKeyData

Dec 3, 2021

Changes in this version

+ func ObservationSourceKeeperDefault() string

+ type KeeperV1JobSpec struct

+ ContractAddress string

+ FromAddress string

+ Name string

+ func (k *KeeperV1JobSpec) String() (string, error)

+ func (k *KeeperV1JobSpec) Type() string

+ type KeeperV2JobSpec struct

+ ContractAddress string

+ ExternalJobID string

+ FromAddress string

+ MinIncomingConfirmations int

+ Name string

+ ObservationSource string

+ func (k *KeeperV2JobSpec) String() (string, error)

+ func (k *KeeperV2JobSpec) Type() string

type VRFJobSpec

+ MinIncomingConfirmations int

Dec 3, 2021

Changes in this version

type BlockchainClient

+ GetChainID func() int64

type EthereumClient

+ func (e *EthereumClient) GetChainID() int64

type EthereumMultinodeClient

+ func (e *EthereumMultinodeClient) GetChainID() int64

Nov 24, 2021

Changes in this version

+ const ETHNetworkType

+ func EthereumMultiNodeURLs(e *environment.Environment) ([]*url.URL, error)

+ func UnmarshalNetworkConfig(config map[string]interface{}, obj interface{}) error

type BlockchainClient

+ func NewEthereumMultiNodeClient(_ string, networkConfig map[string]interface{}, urls []*url.URL) (BlockchainClient, error)

+ EstimateCostForChainlinkOperations func(amountOfOperations int) (*big.Float, error)

+ LoadWallets func(ns interface{}) error

+ SetWallet func(num int) error

+ SwitchNode func(node int) error

+ type BlockchainClientURLFn func(e *environment.Environment) ([]*url.URL, error)

type Chainlink

+ func NewChainlinkClients(e *environment.Environment) ([]Chainlink, error)

+ func NewChainlinkClientsByCharts(e *environment.Environment, charts []string) ([]Chainlink, error)

type EthereumClient

+ DefaultWallet *EthereumWallet

+ NetworkConfig *config.ETHNetwork

+ Wallets []*EthereumWallet

+ func (e *EthereumClient) EstimateCostForChainlinkOperations(amountOfOperations int) (*big.Float, error)

+ func (e *EthereumClient) LoadWallets(cfg interface{}) error

+ func (e *EthereumClient) SetWallet(num int) error

+ func (e *EthereumClient) SwitchNode(_ int) error

+ type EthereumMultinodeClient struct

+ Clients []*EthereumClient

+ DefaultClient *EthereumClient

+ func (e *EthereumMultinodeClient) AddHeaderEventSubscription(key string, subscriber HeaderEventSubscription)

+ func (e *EthereumMultinodeClient) BlockNumber(ctx context.Context) (uint64, error)

+ func (e *EthereumMultinodeClient) Close() error

+ func (e *EthereumMultinodeClient) DeleteHeaderEventSubscription(key string)

+ func (e *EthereumMultinodeClient) EstimateCostForChainlinkOperations(amountOfOperations int) (*big.Float, error)

+ func (e *EthereumMultinodeClient) Fund(toAddress string, nativeAmount *big.Float) error

+ func (e *EthereumMultinodeClient) GasStats() *GasStats

+ func (e *EthereumMultinodeClient) Get() interface{}

+ func (e *EthereumMultinodeClient) GetClients() []BlockchainClient

+ func (e *EthereumMultinodeClient) GetNetworkName() string

+ func (e *EthereumMultinodeClient) HeaderHashByNumber(ctx context.Context, bn *big.Int) (string, error)

+ func (e *EthereumMultinodeClient) HeaderTimestampByNumber(ctx context.Context, bn *big.Int) (uint64, error)

+ func (e *EthereumMultinodeClient) LoadWallets(cfg interface{}) error

+ func (e *EthereumMultinodeClient) ParallelTransactions(enabled bool)

+ func (e *EthereumMultinodeClient) SetID(id int)

+ func (e *EthereumMultinodeClient) SetWallet(num int) error

+ func (e *EthereumMultinodeClient) SwitchNode(clientID int) error

+ func (e *EthereumMultinodeClient) WaitForEvents() error

type MockserverClient

+ func NewMockServerClientFromEnv(e *environment.Environment) (*MockserverClient, error)

+ func (em *MockserverClient) SetValuePath(path string, v int) error

+ type NetworkRegistry struct

+ func NewNetworkRegistry() *NetworkRegistry

+ func (n *NetworkRegistry) GetNetworks(env *environment.Environment) (*Networks, error)

+ func (n *NetworkRegistry) RegisterNetwork(networkType string, fn NewBlockchainClientFn, urlFn BlockchainClientURLFn)

+ type Networks struct

+ Default BlockchainClient

+ func (b *Networks) Get(index int) (BlockchainClient, error)

+ func (b *Networks) SetDefault(index int) error

+ func (b *Networks) Teardown() error

+ type NewBlockchainClientFn func(networkName string, networkConfig map[string]interface{}, urls []*url.URL) (BlockchainClient, error)

Nov 11, 2021

Changes in this version

type Chainlink

+ CreateVRFKey func() (*VRFKey, error)

type MockserverClient

+ func (em *MockserverClient) SetVariable(v int) error

type VRFKey

+ Data VRFKeyData

+ type VRFKeyData struct

+ Attributes VRFKeyAttributes

+ ID string

+ Type string

Nov 8, 2021

Changes in this version

+ type KafkaRestClient struct

+ Config *KafkaRestConfig

+ func NewKafkaRestClient(cfg *KafkaRestConfig) *KafkaRestClient

+ func (krc *KafkaRestClient) GetTopics() ([]string, error)

+ type KafkaRestConfig struct

+ URL string

Oct 29, 2021

Changes in this version

type BlockchainNetwork

+ func NewEthereumNetwork(ID string, networkConfig config.NetworkConfig) (BlockchainNetwork, error)

+ WSEnabled func() bool

+ type EIServiceConfig struct

+ URL string

type EthereumNetwork

+ func (e *EthereumNetwork) WSEnabled() bool

type Wallets

+ DefaultWallet int

+ Wallets []BlockchainWallet

Oct 22, 2021

Changes in this version

+ const BlockchainTypeTerra

+ const DefaultBroadcastMode

+ const DefaultTerraTXTimeout

+ const EventAttrKeyCodeID

+ const EventAttrKeyContractAddress

+ const NetworkTypeTerraLocal

type BlockchainWallet

+ RawPrivateKey func() interface{}

type EthereumWallet

+ func (e *EthereumWallet) RawPrivateKey() interface{}

+ type TerraLCDClient struct

+ BroadcastMode tx.BroadcastMode

+ Config *config.NetworkConfig

+ ID int

+ RootAddr []byte

+ RootPrivKey key.PrivKey

+ Sequence uint64

+ func NewTerraClient(network BlockchainNetwork) (*TerraLCDClient, error)

+ func (c *TerraLCDClient) AddHeaderEventSubscription(key string, subscriber HeaderEventSubscription)

+ func (c *TerraLCDClient) BlockNumber(ctx context.Context) (uint64, error)

+ func (c *TerraLCDClient) CalculateTxGas(gasUsedValue *big.Int) (*big.Float, error)

+ func (c *TerraLCDClient) Close() error

+ func (c *TerraLCDClient) DeleteHeaderEventSubscription(key string)

+ func (c *TerraLCDClient) DeployWASMCode(fromWallet BlockchainWallet, path string) (uint64, error)

+ func (c *TerraLCDClient) Fund(fromWallet BlockchainWallet, toAddress string, ...) error

+ func (c *TerraLCDClient) GasStats() *GasStats

+ func (c *TerraLCDClient) Get() interface{}

+ func (c *TerraLCDClient) GetClients() []BlockchainClient

+ func (c *TerraLCDClient) GetEventAttrValue(tx *sdkTypes.TxResponse, attrKey string) (string, error)

+ func (c *TerraLCDClient) GetID() int

+ func (c *TerraLCDClient) GetNetworkName() string

+ func (c *TerraLCDClient) HeaderHashByNumber(ctx context.Context, bn *big.Int) (string, error)

+ func (c *TerraLCDClient) HeaderTimestampByNumber(ctx context.Context, bn *big.Int) (uint64, error)

+ func (c *TerraLCDClient) Instantiate(fromWallet BlockchainWallet, codeID uint64, instMsg interface{}) (string, error)

+ func (c *TerraLCDClient) ParallelTransactions(enabled bool)

+ func (c *TerraLCDClient) SendTX(txOpts client.CreateTxOptions) (*sdkTypes.TxResponse, error)

+ func (c *TerraLCDClient) SetDefaultClient(clientID int) error

+ func (c *TerraLCDClient) SetID(id int)

+ func (c *TerraLCDClient) SuggestGasPrice(ctx context.Context) (*big.Int, error)

+ func (c *TerraLCDClient) WaitForEvents() error

+ type TerraNetwork struct

+ func (t *TerraNetwork) ChainID() *big.Int

+ func (t *TerraNetwork) ClusterURL() string

+ func (t *TerraNetwork) Config() *config.NetworkConfig

+ func (t *TerraNetwork) FluxMonitorSubmissionGasUsed() (*big.Int, error)

+ func (t *TerraNetwork) ID() string

+ func (t *TerraNetwork) LocalURL() string

+ func (t *TerraNetwork) RemotePort() uint16

+ func (t *TerraNetwork) SetClusterURL(s string)

+ func (t *TerraNetwork) SetLocalURL(s string)

+ func (t *TerraNetwork) SetURLs(urls []string)

+ func (t *TerraNetwork) Type() string

+ func (t *TerraNetwork) Wallets() (BlockchainWallets, error)

+ func (t TerraNetwork) URLs() []string

+ type TerraWallet struct

+ func NewTerraWallet(mnemonic string) (*TerraWallet, error)

+ func (e *TerraWallet) Address() string

+ func (e *TerraWallet) PrivateKey() string

+ func (e *TerraWallet) RawPrivateKey() interface{}

Oct 21, 2021

Changes in this version

type WebhookJobSpec

+ Initiator string

+ InitiatorSpec string

+ Name string

Oct 14, 2021

Changes in this version

type BlockchainClient

+ GetNetworkName func() string

type BlockchainNetwork

+ func DefaultNetworkFromConfig(conf *config.Config) (BlockchainNetwork, error)

+ func DefaultNetworksFromConfig(conf *config.Config) ([]BlockchainNetwork, error)

+ ClusterURL func() string

+ LocalURL func() string

+ RemotePort func() uint16

+ SetClusterURL func(string)

+ SetLocalURL func(string)

+ type DecodeLogTaskRun struct

+ Fee int

+ JobID []int

+ KeyHash []int

+ RequestID []byte

+ Sender string

type EthereumClient

+ func (e *EthereumClient) GetNetworkName() string

type EthereumClients

+ func (e *EthereumClients) GetNetworkName() string

type EthereumNetwork

+ func (e *EthereumNetwork) ClusterURL() string

+ func (e *EthereumNetwork) LocalURL() string

+ func (e *EthereumNetwork) RemotePort() uint16

+ func (e *EthereumNetwork) SetClusterURL(newURL string)

+ func (e *EthereumNetwork) SetLocalURL(newURL string)

+ type MultiNetworkInit func(conf *config.Config) ([]BlockchainNetwork, error)

type RunsAttributesResponse

+ TaskRuns []TaskRun

+ type TaskRun struct

+ CreatedAt time.Time

+ DotID string

+ Error interface{}

+ FinishedAt time.Time

+ Output string

+ Type string

Oct 5, 2021

Changes in this version

+ const BlockchainTypeEVMMultinode

+ const ETH

+ const GWei

+ const NetworkGethPerformance

+ type AdapterResponse struct

+ Data AdapterResult

+ Error interface{}

+ Id string

+ type AdapterResult struct

+ Result int

type BlockchainClient

+ GasStats func() *GasStats

+ GetClients func() []BlockchainClient

+ GetID func() int

+ HeaderHashByNumber func(ctx context.Context, bn *big.Int) (string, error)

+ SetDefaultClient func(clientID int) error

+ SetID func(id int)

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

type BlockchainNetwork

+ SetURLs func(urls []string)

+ URLs func() []string

type BlockchainNetworkInit

+ func NewNetworkFromConfigWithDefault(networkID string) BlockchainNetworkInit

+ type ContractInfoJSON struct

+ ContractAddress string

+ ContractVersion int

+ Path string

+ Status string

type EthereumClient

+ ID int

+ func (e *EthereumClient) GasStats() *GasStats

+ func (e *EthereumClient) GetClients() []BlockchainClient

+ func (e *EthereumClient) GetID() int

+ func (e *EthereumClient) HeaderHashByNumber(ctx context.Context, bn *big.Int) (string, error)

+ func (e *EthereumClient) SetDefaultClient(_ int) error

+ func (e *EthereumClient) SetID(id int)

+ func (e *EthereumClient) SuggestGasPrice(ctx context.Context) (*big.Int, error)

+ type EthereumClients struct

+ Clients []*EthereumClient

+ DefaultClient *EthereumClient

+ func NewEthereumClients(network BlockchainNetwork) (*EthereumClients, error)

+ func (e *EthereumClients) AddHeaderEventSubscription(key string, subscriber HeaderEventSubscription)

+ func (e *EthereumClients) BlockNumber(ctx context.Context) (uint64, error)

+ func (e *EthereumClients) CalculateTxGas(gasUsedValue *big.Int) (*big.Float, error)

+ func (e *EthereumClients) Close() error

+ func (e *EthereumClients) DeleteHeaderEventSubscription(key string)

+ func (e *EthereumClients) Fund(fromWallet BlockchainWallet, toAddress string, ...) error

+ func (e *EthereumClients) GasStats() *GasStats

+ func (e *EthereumClients) Get() interface{}

+ func (e *EthereumClients) GetClients() []BlockchainClient

+ func (e *EthereumClients) GetID() int

+ func (e *EthereumClients) HeaderHashByNumber(ctx context.Context, bn *big.Int) (string, error)

+ func (e *EthereumClients) HeaderTimestampByNumber(ctx context.Context, bn *big.Int) (uint64, error)

+ func (e *EthereumClients) ParallelTransactions(enabled bool)

+ func (e *EthereumClients) SetDefaultClient(clientID int) error

+ func (e *EthereumClients) SetID(id int)

+ func (e *EthereumClients) SuggestGasPrice(ctx context.Context) (*big.Int, error)

+ func (e *EthereumClients) WaitForEvents() error

type EthereumNetwork

+ func (e *EthereumNetwork) SetURLs(urls []string)

+ func (e *EthereumNetwork) URLs() []string

+ type ExplorerConfig struct

+ AdminPassword string

+ AdminUsername string

+ URL string

+ type GasStats struct

+ ClientTXs []TXGasData

+ NodeID int

+ SeenHashes map[string]bool

+ TotalGasUsed int64

+ func NewGasStats(nodeID int) *GasStats

+ func (g *GasStats) AddClientTXData(data TXGasData)

+ func (g *GasStats) PrintStats()

+ type HttpInitializer struct

+ Request HttpRequest

+ Response HttpResponse

+ type HttpRequest struct

+ Path string

+ type HttpResponse struct

+ Body interface{}

+ type MockserverClient struct

+ Config *MockserverConfig

+ func NewMockserverClient(cfg *MockserverConfig) *MockserverClient

+ func (em *MockserverClient) ClearExpectation(body interface{}) error

+ func (em *MockserverClient) PutExpectations(body interface{}) error

+ type MockserverConfig struct

+ ClusterURL string

+ LocalURL string

+ type NodeBlock struct

+ NodeID int

+ type NodeInfoJSON struct

+ ID string

+ NodeAddress []string

+ type PathSelector struct

+ Path string

type Prometheus

+ func (p *Prometheus) GetAlerts() (v1.AlertsResult, error)

+ func (p *Prometheus) GetQuery(query string) (model.Value, error)

+ type TXGasData struct

+ CumulativeGasUsed uint64

+ GasLimit uint64

+ GasPrice uint64

+ GasUsed uint64

+ TXHash string

+ Value uint64

Sep 8, 2021

Changes in this version

type BasicHTTPClient

+ Header http.Header

type ExplorerClient

+ func NewExplorerClient(cfg *config.ExplorerConfig) *ExplorerClient

+ func (em *ExplorerClient) PostAdminNodes(nodeName string) (NodeAccessKeys, error)

+ type Name struct

+ Name string

+ type NodeAccessKeys struct

+ AccessKey string

+ ID string

+ Secret string

Aug 30, 2021

Changes in this version

+ const BlockchainTypeEVM

+ const QueryAllCPUBusyPercentage

+ const QueryMemoryUsage

+ var ErrNotFound = errors.New("unexpected response code, got 404")

+ var ErrUnprocessableEntity = errors.New("unexpected response code, got 422")

+ var OneEth = big.NewFloat(1e18)

+ var OneGWei = big.NewInt(1e9)

+ var OneLINK = big.NewFloat(1e18)

+ func ObservationSourceSpecBridge(bta BridgeTypeAttributes) string

+ func ObservationSourceSpecHTTP(url string) string

+ type BasicHTTPClient struct

+ BaseURL string

+ Cookies []*http.Cookie

+ HttpClient *http.Client

+ func NewBasicHTTPClient(c *http.Client, baseURL string) *BasicHTTPClient

+ type BlockchainClient interface

+ AddHeaderEventSubscription func(key string, subscriber HeaderEventSubscription)

+ BlockNumber func(ctx context.Context) (uint64, error)

+ CalculateTxGas func(gasUsedValue *big.Int) (*big.Float, error)

+ Close func() error

+ DeleteHeaderEventSubscription func(key string)

+ Fund func(fromWallet BlockchainWallet, toAddress string, ...) error

+ Get func() interface{}

+ HeaderTimestampByNumber func(ctx context.Context, bn *big.Int) (uint64, error)

+ ParallelTransactions func(enabled bool)

+ WaitForEvents func() error

+ func NewBlockchainClient(network BlockchainNetwork) (BlockchainClient, error)

+ type BlockchainNetwork interface

+ ChainID func() *big.Int

+ Config func() *config.NetworkConfig

+ ID func() string

+ SetURL func(string)

+ Type func() string

+ URL func() string

+ Wallets func() (BlockchainWallets, error)

+ func NewNetworkFromConfig(conf *config.Config) (BlockchainNetwork, error)

+ type BlockchainNetworkInit func(conf *config.Config) (BlockchainNetwork, error)

+ type BlockchainWallet interface

+ Address func() string

+ PrivateKey func() string

+ type BlockchainWallets interface

+ All func() []BlockchainWallet

+ Default func() BlockchainWallet

+ SetDefault func(i int) error

+ Wallet func(i int) (BlockchainWallet, error)

+ type BridgeType struct

+ Data BridgeTypeData

+ type BridgeTypeAttributes struct

+ Name string

+ RequestData string

+ URL string

+ type BridgeTypeData struct

+ Attributes BridgeTypeAttributes

+ type Chainlink interface

+ CreateBridge func(bta *BridgeTypeAttributes) error

+ CreateEI func(eia *EIAttributes) (*EIKeyCreate, error)

+ CreateJob func(spec JobSpec) (*Job, error)

+ CreateJobRaw func(spec string) (*Job, error)

+ CreateOCRKey func() (*OCRKey, error)

+ CreateP2PKey func() (*P2PKey, error)

+ CreateSpec func(spec string) (*Spec, error)

+ DeleteBridge func(name string) error

+ DeleteEI func(name string) error

+ DeleteJob func(id string) error

+ DeleteOCRKey func(id string) error

+ DeleteP2PKey func(id int) error

+ DeleteSpec func(id string) error

+ PrimaryEthAddress func() (string, error)

+ ReadBridge func(name string) (*BridgeType, error)

+ ReadEIs func() (*EIKeys, error)

+ ReadETHKeys func() (*ETHKeys, error)

+ ReadJob func(id string) (*Response, error)

+ ReadJobs func() (*ResponseSlice, error)

+ ReadOCRKeys func() (*OCRKeys, error)

+ ReadP2PKeys func() (*P2PKeys, error)

+ ReadRunsByJob func(jobID string) (*JobRunsResponse, error)

+ ReadSpec func(id string) (*Response, error)

+ ReadVRFKeys func() (*VRFKeys, error)

+ RemoteIP func() string

+ SetClient func(client *http.Client)

+ SetPageSize func(size int)

+ SetSessionCookie func() error

+ URL func() string

+ func NewChainlink(c *ChainlinkConfig, httpClient *http.Client) (Chainlink, error)

+ type ChainlinkConfig struct

+ Email string

+ Password string

+ RemoteIP string

+ URL string

+ type ContractDeployer func(auth *bind.TransactOpts, backend bind.ContractBackend) (common.Address, *types.Transaction, interface{}, error)

+ type CronJobSpec struct

+ ObservationSource string

+ Schedule string

+ func (c *CronJobSpec) String() (string, error)

+ func (c *CronJobSpec) Type() string

+ type DirectRequestJobSpec struct

+ ContractAddress string

+ ExternalJobID string

+ Name string

+ ObservationSource string

+ func (d *DirectRequestJobSpec) String() (string, error)

+ func (d *DirectRequestJobSpec) Type() string

+ type DirectRequestTxPipelineSpec struct

+ BridgeTypeAttributes BridgeTypeAttributes

+ DataPath string

+ func (d *DirectRequestTxPipelineSpec) String() (string, error)

+ func (d *DirectRequestTxPipelineSpec) Type() string

+ type EIAttributes struct

+ AccessKey string

+ IncomingAccessKey string

+ Name string

+ OutgoingSecret string

+ OutgoingToken string

+ Secret string

+ URL string

+ type EIKey struct

+ Attributes EIAttributes

+ type EIKeyCreate struct

+ Data EIKey

+ type EIKeys struct

+ Data []EIKey

+ type ETHKey struct

+ Data ETHKeyData

+ type ETHKeyAttributes struct

+ Address string

+ type ETHKeyData struct

+ Attributes ETHKeyAttributes

+ type ETHKeys struct

+ Data []ETHKeyData

+ type EthereumClient struct

+ BorrowNonces bool

+ Client *ethclient.Client

+ Network BlockchainNetwork

+ NonceMu *sync.Mutex

+ Nonces map[string]uint64

+ func NewEthereumClient(network BlockchainNetwork) (*EthereumClient, error)

+ func (e *EthereumClient) AddHeaderEventSubscription(key string, subscriber HeaderEventSubscription)

+ func (e *EthereumClient) BlockNumber(ctx context.Context) (uint64, error)

+ func (e *EthereumClient) BorrowedNonces(n bool)

+ func (e *EthereumClient) CalculateTxGas(gasUsed *big.Int) (*big.Float, error)

+ func (e *EthereumClient) Close() error

+ func (e *EthereumClient) DeleteHeaderEventSubscription(key string)

+ func (e *EthereumClient) DeployContract(fromWallet BlockchainWallet, contractName string, deployer ContractDeployer) (*common.Address, *types.Transaction, interface{}, error)

+ func (e *EthereumClient) Fund(fromWallet BlockchainWallet, toAddress string, ...) error

+ func (e *EthereumClient) Get() interface{}

+ func (e *EthereumClient) GetHeaderSubscriptions() map[string]HeaderEventSubscription

+ func (e *EthereumClient) GetNonce(ctx context.Context, addr common.Address) (uint64, error)

+ func (e *EthereumClient) HeaderTimestampByNumber(ctx context.Context, bn *big.Int) (uint64, error)

+ func (e *EthereumClient) ParallelTransactions(enabled bool)

+ func (e *EthereumClient) ProcessTransaction(txHash common.Hash) error

+ func (e *EthereumClient) SendTransaction(from BlockchainWallet, to common.Address, value *big.Float, data []byte) (common.Hash, error)

+ func (e *EthereumClient) TransactionCallMessage(from BlockchainWallet, to common.Address, value *big.Int, data []byte) (*ethereum.CallMsg, error)

+ func (e *EthereumClient) TransactionOpts(from BlockchainWallet, to common.Address, value *big.Int, data []byte) (*bind.TransactOpts, error)

+ func (e *EthereumClient) WaitForEvents() error

+ type EthereumNetwork struct

+ func (e *EthereumNetwork) ChainID() *big.Int

+ func (e *EthereumNetwork) Config() *config.NetworkConfig

+ func (e *EthereumNetwork) FluxMonitorSubmissionGasUsed() (*big.Int, error)

+ func (e *EthereumNetwork) ID() string

+ func (e *EthereumNetwork) SetURL(newURL string)

+ func (e *EthereumNetwork) Type() string

+ func (e *EthereumNetwork) URL() string

+ func (e *EthereumNetwork) Wallets() (BlockchainWallets, error)

+ type EthereumWallet struct

+ func NewEthereumWallet(pk string) (*EthereumWallet, error)

+ func (e *EthereumWallet) Address() string

+ func (e *EthereumWallet) PrivateKey() string

+ type ExplorerClient struct

+ Config *config.ExplorerMockConfig

+ func NewExplorerMockClient(cfg *config.ExplorerMockConfig) *ExplorerClient

+ func (em *ExplorerClient) Count() (*explorer.MessagesCount, error)

+ func (em *ExplorerClient) Messages() (*explorer.Messages, error)

+ type FluxMonitorJobSpec struct

+ AbsoluteThreshold float32

+ ContractAddress string

+ IdleTimerDisabled bool

+ IdleTimerPeriod time.Duration

+ MaxTaskDuration time.Duration

+ Name string

+ ObservationSource string

+ PollTimerDisabled bool

+ PollTimerPeriod time.Duration

+ Precision int

+ Threshold float32

+ func (f *FluxMonitorJobSpec) String() (string, error)

+ func (f *FluxMonitorJobSpec) Type() string

+ type GasUsedEstimations interface

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

+ type HeaderEventSubscription interface

+ ReceiveBlock func(header *types.Block) error

+ Wait func() error

+ type InstantConfirmations struct

+ func (i *InstantConfirmations) ReceiveBlock(*types.Block) error

+ func (i *InstantConfirmations) Wait() error

+ type Job struct

+ Data JobData

+ type JobData struct

+ ID string

+ type JobForm struct

+ TOML string

+ type JobRunsResponse struct

+ Data []RunsResponseData

+ Meta RunsMetaResponse

+ type JobSpec interface

+ String func() (string, error)

+ Type func() string

+ type KeeperJobSpec struct

+ ContractAddress string

+ FromAddress string

+ Name string

+ func (k *KeeperJobSpec) String() (string, error)

+ func (k *KeeperJobSpec) Type() string

+ type OCRBootstrapJobSpec struct

+ BlockChainTimeout time.Duration

+ ContractAddress string

+ ContractConfirmations int

+ IsBootstrapPeer bool

+ Name string

+ P2PBootstrapPeers []string

+ P2PPeerID string

+ TrackerPollInterval time.Duration

+ TrackerSubscribeInterval time.Duration

+ func (o *OCRBootstrapJobSpec) String() (string, error)

+ func (o *OCRBootstrapJobSpec) Type() string

+ type OCRKey struct

+ Data OCRKeyData

+ type OCRKeyAttributes struct

+ ConfigPublicKey string

+ OffChainPublicKey string

+ OnChainSigningAddress string

+ type OCRKeyData struct

+ Attributes OCRKeyAttributes

+ ID string

+ type OCRKeys struct

+ Data []OCRKeyData

+ type OCRTaskJobSpec struct

+ BlockChainTimeout time.Duration

+ ContractAddress string

+ ContractConfirmations int

+ IsBootstrapPeer bool

+ KeyBundleID string

+ MonitoringEndpoint string

+ Name string

+ ObservationSource string

+ P2PBootstrapPeers []Chainlink

+ P2PPeerID string

+ TrackerPollInterval time.Duration

+ TrackerSubscribeInterval time.Duration

+ TransmitterAddress string

+ func (o *OCRTaskJobSpec) String() (string, error)

+ func (o *OCRTaskJobSpec) Type() string

+ type P2PData struct

+ PeerID string

+ RemoteIP string

+ type P2PKey struct

+ Data P2PKeyData

+ type P2PKeyAttributes struct

+ ID int

+ PeerID string

+ PublicKey string

+ type P2PKeyData struct

+ Attributes P2PKeyAttributes

+ type P2PKeys struct

+ Data []P2PKeyData

+ type PipelineSpec struct

+ BridgeTypeAttributes BridgeTypeAttributes

+ DataPath string

+ func (d *PipelineSpec) String() (string, error)

+ func (d *PipelineSpec) Type() string

+ type Prometheus struct

+ func NewPrometheusClient(url string) (*Prometheus, error)

+ func (p *Prometheus) CPUBusyPercentage() (float64, error)

+ func (p *Prometheus) MemoryUsage() (float64, error)

+ func (p *Prometheus) ResourcesSummary() (float64, float64, error)

+ type ResourcesSummary struct

+ CPUPercentage float64

+ MemoryUsage float64

+ type Response struct

+ Data map[string]interface{}

+ type ResponseSlice struct

+ Data []map[string]interface{}

+ type RunInputs struct

+ Parse int

+ type RunsAttributesResponse struct

+ CreatedAt time.Time

+ Errors []interface{}

+ FinishedAt time.Time

+ Inputs RunInputs

+ Meta interface{}

+ type RunsMetaResponse struct

+ Count int

+ type RunsResponseData struct

+ Attributes RunsAttributesResponse

+ ID string

+ Type string

+ type Session struct

+ Email string

+ Password string

+ type Spec struct

+ Data SpecData

+ type SpecData struct

+ ID string

+ type SpecForm struct

+ TOML string

+ type TransactionConfirmer struct

+ func NewTransactionConfirmer(eth *EthereumClient, txHash common.Hash, minConfirmations int) *TransactionConfirmer

+ func (t *TransactionConfirmer) ReceiveBlock(block *types.Block) error

+ func (t *TransactionConfirmer) Wait() error

+ type VRFJobSpec struct

+ Confirmations int

+ CoordinatorAddress string

+ ExternalJobID string

+ Name string

+ ObservationSource string

+ PublicKey string

+ func (v *VRFJobSpec) String() (string, error)

+ func (v *VRFJobSpec) Type() string

+ type VRFKey struct

+ Attributes VRFKeyAttributes

+ ID string

+ Type string

+ type VRFKeyAttributes struct

+ Compressed string

+ CreatedAt time.Time

+ DeletedAt interface{}

+ Hash string

+ Uncompressed string

+ UpdatedAt time.Time

+ type VRFKeys struct

+ Data []VRFKey

+ type VRFTxPipelineSpec struct

+ Address string

+ func (d *VRFTxPipelineSpec) String() (string, error)

+ func (d *VRFTxPipelineSpec) Type() string

+ type Wallets struct

+ func (w *Wallets) All() []BlockchainWallet

+ func (w *Wallets) Default() BlockchainWallet

+ func (w *Wallets) SetDefault(i int) error

+ func (w *Wallets) Wallet(i int) (BlockchainWallet, error)

+ type WebhookJobSpec struct

+ ObservationSource string

+ func (w *WebhookJobSpec) String() (string, error)

+ func (w *WebhookJobSpec) Type() string