client

Aug 22, 2024

Changes in this version

+ type AWSSecret string

+ func (s AWSSecret) GoString() string

+ func (s AWSSecret) MarshalJSON() ([]byte, error)

+ func (s AWSSecret) MarshalText() ([]byte, error)

+ func (s AWSSecret) String() string

+ func (s AWSSecret) Value() string

+ type AWSSecretsManager struct

+ Client *secretsmanager.Client

+ RequestTimeout time.Duration

+ func NewAWSSecretsManager(requestTimeout time.Duration) (*AWSSecretsManager, error)

+ func (sm *AWSSecretsManager) CreateSecret(key string, val string, override bool) error

+ func (sm *AWSSecretsManager) GetSecret(key string) (AWSSecret, error)

+ func (sm *AWSSecretsManager) RemoveSecret(key string, noRecovery bool) error

Aug 5, 2024

Changes in this version

type MockserverConfig

+ Headers map[string]string

Jun 11, 2024

Changes in this version

type RPCClient

+ func (m *RPCClient) BlockNumber() (int64, error)

Apr 29, 2024

Changes in this version

type RPCClient

+ func (m *RPCClient) ModulateBaseFeeOverDuration(lggr zerolog.Logger, startingBaseFee int64, percentage float64, ...) error

Apr 16, 2024

Changes in this version

+ type AnvilContainer struct

+ URL string

+ func StartAnvil(params []string) (*AnvilContainer, error)

+ type CurrentBlockResponse struct

+ Result string

+ type GethContainer struct

+ URL string

+ type RPCClient struct

+ URL string

+ func NewRPCClient(url string) *RPCClient

+ func (m *RPCClient) AnvilDropTransaction(params []interface{}) error

+ func (m *RPCClient) AnvilMine(params []interface{}) error

+ func (m *RPCClient) AnvilSetAutoMine(flag bool) error

+ func (m *RPCClient) AnvilSetBlockGasLimit(params []interface{}) error

+ func (m *RPCClient) AnvilSetMinGasPrice(params []interface{}) error

+ func (m *RPCClient) AnvilSetNextBlockBaseFeePerGas(params []interface{}) error

+ func (m *RPCClient) AnvilTxPoolStatus(params []interface{}) (*TxStatusResponse, error)

+ func (m *RPCClient) GethSetHead(blocksBack int) error

Mar 27, 2024

Changes in this version

+ type AnvilClient struct

+ URL string

+ func NewAnvilClient(url string) *AnvilClient

+ func (m *AnvilClient) Mine(params []interface{}) error

+ func (m *AnvilClient) SetAutoMine(flag bool) error

+ func (m *AnvilClient) TxPoolStatus(params []interface{}) (*TxStatusResponse, error)

+ type RemoteAnvilMiner struct

+ Client *AnvilClient

+ func NewRemoteAnvilMiner(url string) *RemoteAnvilMiner

+ func (m *RemoteAnvilMiner) MineBatch(capacity int64, checkInterval time.Duration, sendInterval time.Duration)

+ func (m *RemoteAnvilMiner) MinePeriodically(interval time.Duration)

+ func (m *RemoteAnvilMiner) Stop()

+ type TxStatusResponse struct

+ Result struct{ ... }

Mar 15, 2024

Changes in this version

+ const WITHOUT_TOKEN

type GithubClient

+ func (g *GithubClient) ListLatestReleases(org, repository string, count int) ([]*github.RepositoryRelease, error)

Jan 18, 2024

Changes in this version

type MockserverClient

+ func (em *MockserverClient) SetAnyValueResponse(path string, v interface{}) error

Jan 9, 2024

Changes in this version

+ type GithubClient struct

+ func NewGithubClient(token string) *GithubClient

+ func (g *GithubClient) ListLatestCLCoreReleases(count int) ([]*github.RepositoryRelease, error)

+ func (g *GithubClient) ListLatestCLCoreTags(count int) ([]*github.RepositoryTag, error)

Nov 7, 2023

Changes in this version

type PostgresConfig

+ SSLMode string

Sep 28, 2023

Changes in this version

type MockserverClient

+ func (em *MockserverClient) SetStringValuePath(path string, stringValue string) error

Jul 31, 2023

Changes in this version

type MockserverClient

+ func ConnectMockServerURL(url string) (*MockserverClient, error)

+ func (em *MockserverClient) LocalURL() string

Feb 24, 2023

Changes in this version

+ type ExtendedLokiClient interface

+ AllHandleResults func() []PromtailSendResult

+ HandleStruct func(ls model.LabelSet, t time.Time, st interface{}) error

+ LastHandleResult func() PromtailSendResult

+ func NewMockPromtailClient() ExtendedLokiClient

+ type LocalLogger struct

+ func (m *LocalLogger) Log(kvars ...interface{}) error

+ type LokiClient struct

+ func NewLokiClient(extCfg *LokiConfig) (*LokiClient, error)

+ func (m *LokiClient) AllHandleResults() []PromtailSendResult

+ func (m *LokiClient) Handle(ls model.LabelSet, t time.Time, s string) error

+ func (m *LokiClient) HandleStruct(ls model.LabelSet, t time.Time, st interface{}) error

+ func (m *LokiClient) LastHandleResult() PromtailSendResult

+ func (m *LokiClient) Stop()

+ type LokiConfig struct

+ BatchSize int

+ BatchWait time.Duration

+ Timeout time.Duration

+ Token string

+ URL string

+ func NewDefaultLokiConfig(url string, token string) *LokiConfig

+ type MockPromtailClient struct

+ OnHandleEntry api.EntryHandlerFunc

+ Results []PromtailSendResult

+ func (c *MockPromtailClient) AllHandleResults() []PromtailSendResult

+ func (c *MockPromtailClient) Handle(labels model.LabelSet, time time.Time, entry string) error

+ func (c *MockPromtailClient) HandleStruct(ls model.LabelSet, t time.Time, st interface{}) error

+ func (c *MockPromtailClient) LastHandleResult() PromtailSendResult

+ func (c *MockPromtailClient) Stop()

+ type PromtailSendResult struct

+ Entry string

+ Labels model.LabelSet

+ Time time.Time

Feb 21, 2023

Changes in this version

+ type HttpInitializerTemplate struct

+ Id string

+ Request HttpRequest

+ Response HttpResponseTemplate

+ type HttpResponseTemplate struct

+ Template string

+ TemplateType string

type MockserverClient

+ func (em *MockserverClient) SetRandomValuePath(path string) error

Sep 20, 2022

Changes in this version

+ const DefaultCallTimeout

+ const DefaultStatsPollInterval

+ const UntilStopDuration

+ var ErrCallTimeout = errors.New("generator request call timeout")

+ var ErrHoldRPS = errors.New("HoldRPS must be > 0")

+ var ErrIncreaseAfterDuration = errors.New("IncreaseAfter must be > 1sec")

+ var ErrIncreaseRPS = errors.New("IncreaseRPS must be > 0")

+ var ErrNoCfg = errors.New("config is nil")

+ var ErrNoGun = errors.New("no gun implementation provided")

+ var ErrStartRPS = errors.New("StartRPS must be > 0")

+ var ErrStaticRPS = errors.New("static RPS must be > 0")

+ type CallResult struct

+ Data interface{}

+ Duration time.Duration

+ Error error

+ type GeneratorStats struct

+ CallTimeout atomic.Int64

+ Failed atomic.Int64

+ Success atomic.Int64

+ type LoadGenerator struct

+ func NewLoadGenerator(cfg *LoadGeneratorConfig) (*LoadGenerator, error)

+ func (l *LoadGenerator) Errors() []error

+ func (l *LoadGenerator) GetData() *ResponseData

+ func (l *LoadGenerator) PrintStats()

+ func (l *LoadGenerator) Run()

+ func (l *LoadGenerator) Stats() *GeneratorStats

+ func (l *LoadGenerator) Stop() (interface{}, bool)

+ func (l *LoadGenerator) Wait() (interface{}, bool)

+ type LoadGeneratorConfig struct

+ CallFailThreshold int64

+ CallTimeout time.Duration

+ CallTimeoutThreshold int64

+ Duration time.Duration

+ Gun LoadTestable

+ RPS int

+ Schedule *LoadSchedule

+ SharedData interface{}

+ StatsPollInterval time.Duration

+ func (lgc *LoadGeneratorConfig) Validate() error

+ type LoadSchedule struct

+ HoldRPS int

+ IncreaseAfter time.Duration

+ IncreaseRPS int

+ StartRPS int

+ func (ls *LoadSchedule) Validate() error

+ type LoadTestable interface

+ Call func(data interface{}) CallResult

+ type MockGun struct

+ Data []string

+ func NewMockGun(cfg *MockGunConfig) *MockGun

+ func (m *MockGun) Call(data interface{}) CallResult

+ type MockGunConfig struct

+ CallSleep time.Duration

+ Fail bool

+ VerifySleep time.Duration

type PostgresConnector

+ func ConnectDB(nodeNum int, e *environment.Environment) (*PostgresConnector, error)

+ type ResponseData struct

+ FailResponses []CallResult

+ OKData []interface{}

+ OKResponses []CallResult

Aug 31, 2022

Changes in this version

type MockserverClient

+ func (em *MockserverClient) SetAnyValuePath(path string, v interface{}) error

Aug 8, 2022

Changes in this version

+ type Node struct

+ ChainID string

+ CreatedAt time.Time

+ ID int32

+ Name string

+ URL string

+ UpdatedAt time.Time

+ type NodeKeysBundle struct

+ OCR2Key client.OCR2Key

+ P2PKeys client.P2PKeys

+ PeerID string

+ TXKey client.TxKey

+ func CreateNodeKeysBundle(nodes []*client.Chainlink, chainName string) ([]NodeKeysBundle, error)

Aug 1, 2022

Changes in this version

type ExplorerClient

+ APIClient *resty.Client

type KafkaRestClient

+ APIClient *resty.Client

type MockserverClient

+ APIClient *resty.Client

Jun 20, 2022

Changes in this version

type Chainlink

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

type DirectRequestJobSpec

+ MinIncomingConfirmations string

Jun 2, 2022

Changes in this version

type Chainlink

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

type OCR2TaskJobSpec

+ P2PV2Bootstrappers []P2PData

May 12, 2022

Changes in this version

type Chainlink

+ ExportVRFKey func(keyId string) (*VRFExportKey, error)

+ ImportVRFKey func(vrfExportKey *VRFExportKey) (*VRFKey, error)

+ Profile func(profileTime time.Duration, profileFunction func(Chainlink)) (*ChainlinkProfileResults, error)

+ type ChainlinkProfileResult struct

+ Data []byte

+ Type string

+ type ChainlinkProfileResults struct

+ ActualRunSeconds int

+ NodeIndex int

+ Reports []*ChainlinkProfileResult

+ ScheduledProfileSeconds int

+ func NewBlankChainlinkProfileResults() *ChainlinkProfileResults

+ type VRFExportKey struct

+ PublicKey string

+ VrfKey struct{ ... }

May 7, 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 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 TxKey

+ Address string

+ IsFunding bool

+ type UpdateEVMChainRequest struct

+ Config ChainCfg

+ Enabled bool

+ ID string

May 4, 2022

Changes in this version

+ const QueryAllCPUBusyPercentage

+ const QueryMemoryUsage

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

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

+ var OneLINK = big.NewFloat(1e18)

+ func ObservationSourceKeeperDefault() string

+ func ObservationSourceSpecBridge(bta BridgeTypeAttributes) string

+ func ObservationSourceSpecHTTP(url string) string

+ type AdapterResponse struct

+ Data AdapterResult

+ Error interface{}

+ Id string

+ type AdapterResult struct

+ Result int

+ type BasicHTTPClient struct

+ BaseURL string

+ Cookies []*http.Cookie

+ Header http.Header

+ HttpClient *http.Client

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

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

+ type BlockhashStoreJobSpec struct

+ BlockhashStoreAddress string

+ CoordinatorV2Address string

+ EVMChainID string

+ LookbackBlocks int

+ Name string

+ PollPeriod string

+ RunTimeout string

+ WaitBlocks int

+ func (b *BlockhashStoreJobSpec) String() (string, error)

+ func (b *BlockhashStoreJobSpec) Type() string

+ type BridgeType struct

+ Data BridgeTypeData

+ type BridgeTypeAttributes struct

+ Name string

+ RequestData string

+ URL string

+ type BridgeTypeData struct

+ Attributes BridgeTypeAttributes

+ 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 interface

+ CreateBridge func(bta *BridgeTypeAttributes) error

+ CreateCSAKey func() (*CSAKey, error)

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

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

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

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

+ CreateOCRKey func() (*OCRKey, error)

+ CreateP2PKey func() (*P2PKey, error)

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

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

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

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

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

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

+ CreateVRFKey func() (*VRFKey, error)

+ DeleteBridge func(name string) error

+ DeleteEI func(name string) error

+ DeleteJob func(id string) error

+ DeleteOCR2Key func(id string) error

+ DeleteOCRKey func(id string) error

+ DeleteP2PKey func(id int) error

+ DeleteSpec func(id string) error

+ DeleteTxKey func(chain, id string) error

+ PrimaryEthAddress func() (string, error)

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

+ ReadCSAKeys func() (*CSAKeys, error)

+ ReadEIs func() (*EIKeys, error)

+ ReadETHKeys func() (*ETHKeys, error)

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

+ ReadJobs func() (*ResponseSlice, error)

+ ReadOCR2Keys func() (*OCR2Keys, error)

+ ReadOCRKeys func() (*OCRKeys, error)

+ ReadP2PKeys func() (*P2PKeys, error)

+ ReadPrimaryETHKey func() (*ETHKeyData, error)

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

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

+ ReadTransactionAttempts func() (*TransactionsData, error)

+ ReadTransactions func() (*TransactionsData, error)

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

+ ReadVRFKeys func() (*VRFKeys, error)

+ RemoteIP func() string

+ SendNativeToken func(amount *big.Int, fromAddress, toAddress string) (TransactionData, error)

+ SetClient func(client *http.Client)

+ SetPageSize func(size int)

+ SetSessionCookie func() error

+ URL func() string

+ UpdateEthKeyMaxGasPriceGWei func(keyId string, gwei int) (*ETHKey, error)

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

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

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

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

+ type ChainlinkConfig struct

+ Email string

+ Password string

+ RemoteIP string

+ URL string

+ type ContractInfoJSON struct

+ ContractAddress string

+ ContractVersion int

+ Path string

+ Status string

+ type CronJobSpec struct

+ ObservationSource string

+ Schedule string

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

+ func (c *CronJobSpec) Type() string

+ type DecodeLogTaskRun struct

+ Fee int

+ JobID []int

+ KeyHash []int

+ RequestID []byte

+ Sender 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 EIServiceConfig struct

+ URL string

+ type ETHKey struct

+ Data ETHKeyData

+ type ETHKeyAttributes struct

+ Address string

+ ChainID string

+ ETHBalance string

+ type ETHKeyData struct

+ Attributes ETHKeyAttributes

+ type ETHKeys struct

+ Data []ETHKeyData

+ type ExplorerClient struct

+ Config *ExplorerConfig

+ func NewExplorerClient(cfg *ExplorerConfig) *ExplorerClient

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

+ type ExplorerConfig struct

+ AdminPassword string

+ AdminUsername string

+ URL string

+ 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 HttpInitializer struct

+ Id string

+ Request HttpRequest

+ Response HttpResponse

+ type HttpRequest struct

+ Path string

+ type HttpResponse struct

+ Body interface{}

+ 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 KafkaRestClient struct

+ Config *KafkaRestConfig

+ func NewKafkaRestClient(cfg *KafkaRestConfig) *KafkaRestClient

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

+ type KafkaRestConfig struct

+ URL string

+ type KeeperJobSpec struct

+ ContractAddress string

+ FromAddress string

+ MinIncomingConfirmations int

+ Name string

+ ObservationSource string

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

+ func (k *KeeperJobSpec) Type() string

+ type MockserverClient struct

+ Config *MockserverConfig

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

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

+ func NewMockserverClient(cfg *MockserverConfig) *MockserverClient

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

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

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

+ type MockserverConfig struct

+ ClusterURL string

+ LocalURL string

+ type Name struct

+ Name string

+ type NodeAccessKeys struct

+ AccessKey string

+ ID string

+ Secret string

+ type NodeInfoJSON struct

+ ID string

+ NodeAddress []string

+ type OCR2Key struct

+ Data OCR2KeyData

+ type OCR2KeyAttributes struct

+ ChainType string

+ ConfigPublicKey string

+ OffChainPublicKey string

+ OnChainPublicKey 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

+ JobType string

+ JuelsPerFeeCoinSource string

+ MonitoringEndpoint string

+ Name string

+ OCRKeyBundleID string

+ ObservationSource string

+ P2PBootstrapPeers []P2PData

+ P2PPeerID string

+ PluginType string

+ Relay string

+ RelayConfig map[string]string

+ TrackerPollInterval time.Duration

+ TrackerSubscribeInterval time.Duration

+ TransmitterID string

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

+ func (o *OCR2TaskJobSpec) Type() string

+ type OCRBootstrapJobSpec struct

+ BlockChainTimeout time.Duration

+ ContractAddress string

+ ContractConfirmations int

+ IsBootstrapPeer bool

+ Name 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

+ RemotePort 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 PathSelector struct

+ Path string

+ type PipelineSpec struct

+ BridgeTypeAttributes BridgeTypeAttributes

+ DataPath string

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

+ func (d *PipelineSpec) Type() string

+ type PostgresConfig struct

+ DBName string

+ Host string

+ Password string

+ Port string

+ User string

+ type PostgresConnector struct

+ Cfg *PostgresConfig

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

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

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

+ type Prometheus struct

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

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

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

+ func (p *Prometheus) GetQuery(query string) (model.Value, 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{}

+ TaskRuns []TaskRun

+ type RunsMetaResponse struct

+ Count int

+ type RunsResponseData struct

+ Attributes RunsAttributesResponse

+ ID string

+ Type string

+ type SendEtherRequest struct

+ AllowHigherAmounts bool

+ Amount string

+ DestinationAddress string

+ EVMChainID int

+ FromAddress string

+ type Session struct

+ Email string

+ Password string

+ type SingleTransactionDataWrapper struct

+ Data TransactionData

+ 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 Spec struct

+ Data SpecData

+ type SpecData struct

+ ID string

+ type SpecForm struct

+ TOML string

+ type TaskRun struct

+ CreatedAt time.Time

+ DotID string

+ Error interface{}

+ FinishedAt time.Time

+ Output string

+ Type string

+ type TerraChain struct

+ Attributes TerraChainAttributes

+ type TerraChainAttributes struct

+ ChainID string

+ Config TerraChainConfig

+ FCDURL string

+ 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

+ type TerraNode struct

+ Attributes TerraNodeAttributes

+ type TerraNodeAttributes struct

+ Name string

+ TendermintURL string

+ TerraChainID string

+ type TerraNodeCreate struct

+ Data TerraNode

+ 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

+ type TxKey struct

+ Data TxKeyData

+ type TxKeyAttributes struct

+ PublicKey string

+ type TxKeyData struct

+ Attributes TxKeyAttributes

+ ID string

+ Type string

+ type TxKeys struct

+ Data []TxKeyData

+ type VRFJobSpec struct

+ CoordinatorAddress string

+ ExternalJobID string

+ MinIncomingConfirmations int

+ Name string

+ ObservationSource string

+ PublicKey string

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

+ func (v *VRFJobSpec) Type() string

+ type VRFKey struct

+ Data VRFKeyData

+ type VRFKeyAttributes struct

+ Compressed string

+ CreatedAt time.Time

+ DeletedAt interface{}

+ Hash string

+ Uncompressed string

+ UpdatedAt time.Time

+ type VRFKeyData struct

+ Attributes VRFKeyAttributes

+ ID string

+ Type string

+ type VRFKeys struct

+ Data []VRFKey

+ type VRFTxPipelineSpec struct

+ Address string

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

+ func (d *VRFTxPipelineSpec) Type() string

+ type VRFV2JobSpec struct

+ BackOffInitialDelay time.Duration

+ BackOffMaxDelay time.Duration

+ BatchFulfillmentEnabled bool

+ CoordinatorAddress string

+ EVMChainID string

+ ExternalJobID string

+ FromAddress string

+ MinIncomingConfirmations int

+ Name string

+ ObservationSource string

+ PublicKey string

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

+ func (v *VRFV2JobSpec) Type() string

+ type VRFV2TxPipelineSpec struct

+ Address string

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

+ func (d *VRFV2TxPipelineSpec) Type() string

+ type WebhookJobSpec struct

+ Initiator string

+ InitiatorSpec string

+ Name string

+ ObservationSource string

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

+ func (w *WebhookJobSpec) Type() string