Documentation ¶
Index ¶
- Constants
- func FromChainType(ct ChainType) string
- func FromGasEstimatorMode(gsm GasEstimatorMode) string
- func FromLogLevel(logLvl LogLevel) string
- func FromOCR2ChainType(ct OCR2ChainType) string
- func ToChainConfig(input ChainConfigInput) (*types.ChainCfg, map[string]string)
- func ValidateBridgeType(bt *bridges.BridgeTypeRequest) error
- func ValidateBridgeTypeUniqueness(bt *bridges.BridgeTypeRequest, orm bridges.ORM) error
- type APITokenResolver
- type ApproveJobProposalSpecPayloadResolver
- type ApproveJobProposalSpecSuccessResolver
- type BlockhashStoreSpecResolver
- func (b *BlockhashStoreSpecResolver) BlockhashStoreAddress() string
- func (b *BlockhashStoreSpecResolver) CoordinatorV1Address() *string
- func (b *BlockhashStoreSpecResolver) CoordinatorV2Address() *string
- func (b *BlockhashStoreSpecResolver) CreatedAt() graphql.Time
- func (b *BlockhashStoreSpecResolver) EVMChainID() *string
- func (b *BlockhashStoreSpecResolver) FromAddress() *string
- func (b *BlockhashStoreSpecResolver) LookbackBlocks() int32
- func (b *BlockhashStoreSpecResolver) PollPeriod() string
- func (b *BlockhashStoreSpecResolver) RunTimeout() string
- func (b *BlockhashStoreSpecResolver) WaitBlocks() int32
- type BootstrapSpecResolver
- func (r *BootstrapSpecResolver) BlockchainTimeout() *string
- func (r *BootstrapSpecResolver) ContractConfigConfirmations() *int32
- func (r *BootstrapSpecResolver) ContractConfigTrackerPollInterval() *string
- func (r *BootstrapSpecResolver) ContractID() string
- func (r *BootstrapSpecResolver) CreatedAt() graphql.Time
- func (r *BootstrapSpecResolver) ID() graphql.ID
- func (r *BootstrapSpecResolver) MonitoringEndpoint() *string
- func (r *BootstrapSpecResolver) Relay() string
- func (r *BootstrapSpecResolver) RelayConfig() gqlscalar.Map
- type BridgePayloadResolver
- type BridgeResolver
- func (r *BridgeResolver) Confirmations() int32
- func (r *BridgeResolver) CreatedAt() graphql.Time
- func (r *BridgeResolver) ID() graphql.ID
- func (r *BridgeResolver) MinimumContractPayment() string
- func (r *BridgeResolver) Name() string
- func (r *BridgeResolver) OutgoingToken() string
- func (r *BridgeResolver) URL() string
- type BridgesPayloadResolver
- type CSAKeyExistsErrorResolver
- type CSAKeyResolver
- type CSAKeysPayloadResolver
- type CancelJobProposalSpecPayloadResolver
- type CancelJobProposalSpecSuccessResolver
- type ChainConfigInput
- type ChainConfigResolver
- func (r *ChainConfigResolver) BlockHistoryEstimatorBlockDelay() *int32
- func (r *ChainConfigResolver) BlockHistoryEstimatorBlockHistorySize() *int32
- func (r *ChainConfigResolver) ChainType() *ChainType
- func (r *ChainConfigResolver) EthTxReaperThreshold() *string
- func (r *ChainConfigResolver) EthTxResendAfterThreshold() *string
- func (r *ChainConfigResolver) EvmEIP1559DynamicFees() *bool
- func (r *ChainConfigResolver) EvmFinalityDepth() *int32
- func (r *ChainConfigResolver) EvmGasBumpPercent() *int32
- func (r *ChainConfigResolver) EvmGasBumpTxDepth() *int32
- func (r *ChainConfigResolver) EvmGasBumpWei() *string
- func (r *ChainConfigResolver) EvmGasLimitDRJobType() *int32
- func (r *ChainConfigResolver) EvmGasLimitDefault() *int32
- func (r *ChainConfigResolver) EvmGasLimitFMJobType() *int32
- func (r *ChainConfigResolver) EvmGasLimitKeeperJobType() *int32
- func (r *ChainConfigResolver) EvmGasLimitMax() *int32
- func (r *ChainConfigResolver) EvmGasLimitMultiplier() *float64
- func (r *ChainConfigResolver) EvmGasLimitOCRJobType() *int32
- func (r *ChainConfigResolver) EvmGasLimitVRFJobType() *int32
- func (r *ChainConfigResolver) EvmGasPriceDefault() *string
- func (r *ChainConfigResolver) EvmGasTipCapDefault() *string
- func (r *ChainConfigResolver) EvmGasTipCapMinimum() *string
- func (r *ChainConfigResolver) EvmHeadTrackerHistoryDepth() *int32
- func (r *ChainConfigResolver) EvmHeadTrackerMaxBufferSize() *int32
- func (r *ChainConfigResolver) EvmHeadTrackerSamplingInterval() *string
- func (r *ChainConfigResolver) EvmLogBackfillBatchSize() *int32
- func (r *ChainConfigResolver) EvmMaxGasPriceWei() *string
- func (r *ChainConfigResolver) EvmNonceAutoSync() *bool
- func (r *ChainConfigResolver) EvmRPCDefaultBatchSize() *int32
- func (r *ChainConfigResolver) FlagsContractAddress() *string
- func (r *ChainConfigResolver) GasEstimatorMode() *GasEstimatorMode
- func (r *ChainConfigResolver) KeySpecificConfigs() []*KeySpecificChainConfigResolver
- func (r *ChainConfigResolver) LinkContractAddress() *string
- func (r *ChainConfigResolver) MinIncomingConfirmations() *int32
- func (r *ChainConfigResolver) MinimumContractPayment() *string
- func (r *ChainConfigResolver) OCRObservationTimeout() *string
- type ChainPayloadResolver
- type ChainResolver
- func (r *ChainResolver) Config() *ChainConfigResolver
- func (r *ChainResolver) CreatedAt() graphql.Time
- func (r *ChainResolver) Enabled() bool
- func (r *ChainResolver) ID() graphql.ID
- func (r *ChainResolver) Nodes(ctx context.Context) ([]*NodeResolver, error)
- func (r *ChainResolver) UpdatedAt() graphql.Time
- type ChainType
- type ChainsPayloadResolver
- type ConfigItemResolver
- type ConfigItemValue
- type ConfigPayloadResolver
- type ConfigResolver
- type ConfigV2PayloadResolver
- type CreateAPITokenPayloadResolver
- type CreateAPITokenSuccessResolver
- type CreateBridgePayloadResolver
- type CreateBridgeSuccessResolver
- type CreateCSAKeyPayloadResolver
- type CreateCSAKeySuccessResolver
- type CreateChainPayloadResolver
- type CreateChainSuccessResolver
- type CreateFeedsManagerChainConfigPayloadResolver
- type CreateFeedsManagerChainConfigSuccessResolver
- type CreateFeedsManagerPayloadResolver
- func (r *CreateFeedsManagerPayloadResolver) ToCreateFeedsManagerSuccess() (*CreateFeedsManagerSuccessResolver, bool)
- func (r *CreateFeedsManagerPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)
- func (r *CreateFeedsManagerPayloadResolver) ToSingleFeedsManagerError() (*SingleFeedsManagerErrorResolver, bool)
- type CreateFeedsManagerSuccessResolver
- type CreateJobPayloadResolver
- type CreateJobSuccessResolver
- type CreateNodePayloadResolver
- type CreateNodeSuccessResolve
- type CreateOCR2KeyBundlePayloadResolver
- type CreateOCR2KeyBundleSuccessResolver
- type CreateOCRKeyBundlePayloadResolver
- type CreateOCRKeyBundleSuccessResolver
- type CreateP2PKeyPayloadResolver
- type CreateP2PKeySuccessResolver
- type CreateVRFKeyPayloadResolver
- type CronSpecResolver
- type DeleteAPITokenPayloadResolver
- type DeleteAPITokenSuccessResolver
- type DeleteBridgeConflictErrorResolver
- type DeleteBridgeInvalidNameErrorResolver
- type DeleteBridgePayloadResolver
- func (r *DeleteBridgePayloadResolver) ToDeleteBridgeConflictError() (*DeleteBridgeConflictErrorResolver, bool)
- func (r *DeleteBridgePayloadResolver) ToDeleteBridgeInvalidNameError() (*DeleteBridgeInvalidNameErrorResolver, bool)
- func (r *DeleteBridgePayloadResolver) ToDeleteBridgeSuccess() (*DeleteBridgeSuccessResolver, bool)
- type DeleteBridgeSuccessResolver
- type DeleteCSAKeyPayloadResolver
- type DeleteCSAKeySuccessResolver
- type DeleteChainPayloadResolver
- type DeleteChainSuccessResolver
- type DeleteFeedsManagerChainConfigPayloadResolver
- type DeleteFeedsManagerChainConfigSuccessResolver
- type DeleteJobPayloadResolver
- type DeleteJobSuccessResolver
- type DeleteNodePayloadResolver
- type DeleteNodeSuccessResolver
- type DeleteOCR2KeyBundlePayloadResolver
- type DeleteOCR2KeyBundleSuccessResolver
- type DeleteOCRKeyBundlePayloadResolver
- type DeleteOCRKeyBundleSuccessResolver
- type DeleteP2PKeyPayloadResolver
- type DeleteP2PKeySuccessResolver
- type DeleteVRFKeyPayloadResolver
- type DeleteVRFKeySuccessResolver
- type DirectRequestSpecResolver
- func (r *DirectRequestSpecResolver) ContractAddress() string
- func (r *DirectRequestSpecResolver) CreatedAt() graphql.Time
- func (r *DirectRequestSpecResolver) EVMChainID() *string
- func (r *DirectRequestSpecResolver) MinContractPaymentLinkJuels() string
- func (r *DirectRequestSpecResolver) MinIncomingConfirmations() int32
- func (r *DirectRequestSpecResolver) MinIncomingConfirmationsEnv() bool
- func (r *DirectRequestSpecResolver) Requesters() *[]string
- type DismissJobErrorPayloadResolver
- type DismissJobErrorSuccessResolver
- type ETHKey
- type ETHKeyResolver
- func (r *ETHKeyResolver) Address() string
- func (r *ETHKeyResolver) Chain(ctx context.Context) (*ChainResolver, error)
- func (r *ETHKeyResolver) CreatedAt() graphql.Time
- func (r *ETHKeyResolver) ETHBalance(ctx context.Context) *string
- func (r *ETHKeyResolver) IsDisabled() bool
- func (r *ETHKeyResolver) LINKBalance(ctx context.Context) *string
- func (r *ETHKeyResolver) MaxGasPriceWei() *string
- func (r *ETHKeyResolver) UpdatedAt() graphql.Time
- type ETHKeysPayloadResolver
- type ErrorCode
- type EthTransactionAttemptResolver
- type EthTransactionPayloadResolver
- type EthTransactionResolver
- func (r *EthTransactionResolver) Attempts(ctx context.Context) ([]*EthTransactionAttemptResolver, error)
- func (r *EthTransactionResolver) Chain(ctx context.Context) (*ChainResolver, error)
- func (r *EthTransactionResolver) Data() hexutil.Bytes
- func (r *EthTransactionResolver) EVMChainID() graphql.ID
- func (r *EthTransactionResolver) From() string
- func (r *EthTransactionResolver) GasLimit() string
- func (r *EthTransactionResolver) GasPrice(ctx context.Context) string
- func (r *EthTransactionResolver) Hash(ctx context.Context) string
- func (r *EthTransactionResolver) Hex(ctx context.Context) string
- func (r *EthTransactionResolver) Nonce() *string
- func (r *EthTransactionResolver) SentAt(ctx context.Context) *string
- func (r *EthTransactionResolver) State() string
- func (r *EthTransactionResolver) To() string
- func (r *EthTransactionResolver) Value() string
- type EthTransactionsAttemptsPayloadResolver
- type EthTransactionsPayloadResolver
- type FeaturesPayloadResolver
- type FeaturesResolver
- type FeedsManagerChainConfigResolver
- func (r *FeedsManagerChainConfigResolver) AccountAddr() string
- func (r *FeedsManagerChainConfigResolver) AdminAddr() string
- func (r *FeedsManagerChainConfigResolver) ChainID() string
- func (r *FeedsManagerChainConfigResolver) ChainType() string
- func (r *FeedsManagerChainConfigResolver) FluxMonitorJobConfig() *FluxMonitorJobConfigResolver
- func (r *FeedsManagerChainConfigResolver) ID() graphql.ID
- func (r *FeedsManagerChainConfigResolver) OCR1JobConfig() *OCR1JobConfigResolver
- func (r *FeedsManagerChainConfigResolver) OCR2JobConfig() *OCR2JobConfigResolver
- type FeedsManagerPayloadResolver
- type FeedsManagerResolver
- func (r *FeedsManagerResolver) ChainConfigs(ctx context.Context) ([]*FeedsManagerChainConfigResolver, error)
- func (r *FeedsManagerResolver) CreatedAt() graphql.Time
- func (r *FeedsManagerResolver) ID() graphql.ID
- func (r *FeedsManagerResolver) IsConnectionActive() bool
- func (r *FeedsManagerResolver) JobProposals(ctx context.Context) ([]*JobProposalResolver, error)
- func (r *FeedsManagerResolver) Name() string
- func (r *FeedsManagerResolver) PublicKey() string
- func (r *FeedsManagerResolver) URI() string
- type FeedsManagersPayloadResolver
- type FluxMonitorJobConfigResolver
- type FluxMonitorSpecResolver
- func (r *FluxMonitorSpecResolver) AbsoluteThreshold() float64
- func (r *FluxMonitorSpecResolver) ContractAddress() string
- func (r *FluxMonitorSpecResolver) CreatedAt() graphql.Time
- func (r *FluxMonitorSpecResolver) DrumbeatEnabled() bool
- func (r *FluxMonitorSpecResolver) DrumbeatRandomDelay() *string
- func (r *FluxMonitorSpecResolver) DrumbeatSchedule() *string
- func (r *FluxMonitorSpecResolver) EVMChainID() *string
- func (r *FluxMonitorSpecResolver) IdleTimerDisabled() bool
- func (r *FluxMonitorSpecResolver) IdleTimerPeriod() string
- func (r *FluxMonitorSpecResolver) MinPayment() *string
- func (r *FluxMonitorSpecResolver) PollTimerDisabled() bool
- func (r *FluxMonitorSpecResolver) PollTimerPeriod() string
- func (r *FluxMonitorSpecResolver) Threshold() float64
- type GasEstimatorMode
- type GetSQLLoggingPayloadResolver
- type GlobalLogLevelPayloadResolver
- type GlobalLogLevelResolver
- type InputErrorResolver
- type InputErrorsResolver
- type JobAlreadyExistsErrorResolver
- type JobErrorResolver
- type JobPayloadResolver
- type JobProposalPayloadResolver
- type JobProposalResolver
- func (r *JobProposalResolver) ExternalJobID() *string
- func (r *JobProposalResolver) FeedsManager(ctx context.Context) (*FeedsManagerResolver, error)
- func (r *JobProposalResolver) ID() graphql.ID
- func (r *JobProposalResolver) JobID(ctx context.Context) (*string, error)
- func (r *JobProposalResolver) LatestSpec(ctx context.Context) (*JobProposalSpecResolver, error)
- func (r *JobProposalResolver) MultiAddrs() []string
- func (r *JobProposalResolver) PendingUpdate() bool
- func (r *JobProposalResolver) RemoteUUID(ctx context.Context) string
- func (r *JobProposalResolver) Specs(ctx context.Context) ([]*JobProposalSpecResolver, error)
- func (r *JobProposalResolver) Status() JobProposalStatus
- type JobProposalSpecResolver
- func (r *JobProposalSpecResolver) CreatedAt() graphql.Time
- func (r *JobProposalSpecResolver) Definition() string
- func (r *JobProposalSpecResolver) ID() graphql.ID
- func (r *JobProposalSpecResolver) Status() SpecStatus
- func (r *JobProposalSpecResolver) StatusUpdatedAt() graphql.Time
- func (r *JobProposalSpecResolver) UpdatedAt() graphql.Time
- func (r *JobProposalSpecResolver) Version() int32
- type JobProposalStatus
- type JobResolver
- func (r *JobResolver) CreatedAt() graphql.Time
- func (r *JobResolver) Errors(ctx context.Context) ([]*JobErrorResolver, error)
- func (r *JobResolver) ExternalJobID() string
- func (r *JobResolver) ForwardingAllowed() *bool
- func (r *JobResolver) GasLimit() *int32
- func (r *JobResolver) ID() graphql.ID
- func (r *JobResolver) MaxTaskDuration() string
- func (r *JobResolver) Name() string
- func (r *JobResolver) ObservationSource() string
- func (r *JobResolver) Runs(ctx context.Context, args struct{ ... }) (*JobRunsPayloadResolver, error)
- func (r *JobResolver) SchemaVersion() int32
- func (r *JobResolver) Spec() *SpecResolver
- func (r *JobResolver) Type() string
- type JobRunPayloadResolver
- type JobRunResolver
- func (r *JobRunResolver) AllErrors() []string
- func (r *JobRunResolver) CreatedAt() graphql.Time
- func (r *JobRunResolver) FatalErrors() []string
- func (r *JobRunResolver) FinishedAt() *graphql.Time
- func (r *JobRunResolver) ID() graphql.ID
- func (r *JobRunResolver) Inputs() string
- func (r *JobRunResolver) Job(ctx context.Context) (*JobResolver, error)
- func (r *JobRunResolver) Outputs() []*string
- func (r *JobRunResolver) PipelineSpecID() graphql.ID
- func (r *JobRunResolver) Status() JobRunStatus
- func (r *JobRunResolver) TaskRuns() []*TaskRunResolver
- type JobRunStatus
- type JobRunsPayloadResolver
- type JobsPayloadResolver
- type KeeperSpecResolver
- type KeySpecificChainConfigInput
- type KeySpecificChainConfigResolver
- type LogLevel
- type NodePayloadResolver
- type NodeResolver
- func (r *NodeResolver) Chain(ctx context.Context) (*ChainResolver, error)
- func (r *NodeResolver) CreatedAt() graphql.Time
- func (r *NodeResolver) HTTPURL() string
- func (r *NodeResolver) ID() graphql.ID
- func (r *NodeResolver) Name() string
- func (r *NodeResolver) State() string
- func (r *NodeResolver) UpdatedAt() graphql.Time
- func (r *NodeResolver) WSURL() string
- type NodesPayloadResolver
- type NotFoundErrorResolver
- type NotFoundErrorUnionType
- type OCR1JobConfigResolver
- type OCR2ChainType
- type OCR2JobConfigResolver
- type OCR2KeyBundleResolver
- type OCR2KeyBundlesPayloadResolver
- type OCR2SpecResolver
- func (r *OCR2SpecResolver) BlockchainTimeout() *string
- func (r *OCR2SpecResolver) ContractConfigConfirmations() *int32
- func (r *OCR2SpecResolver) ContractConfigTrackerPollInterval() *string
- func (r *OCR2SpecResolver) ContractID() string
- func (r *OCR2SpecResolver) CreatedAt() graphql.Time
- func (r *OCR2SpecResolver) MonitoringEndpoint() *string
- func (r *OCR2SpecResolver) OcrKeyBundleID() *string
- func (r *OCR2SpecResolver) P2PV2Bootstrappers() *[]string
- func (r *OCR2SpecResolver) PluginConfig() gqlscalar.Map
- func (r *OCR2SpecResolver) PluginType() string
- func (r *OCR2SpecResolver) Relay() string
- func (r *OCR2SpecResolver) RelayConfig() gqlscalar.Map
- func (r *OCR2SpecResolver) TransmitterID() *string
- type OCRKeyBundleResolver
- type OCRKeyBundlesPayloadResolver
- type OCRSpecResolver
- func (r *OCRSpecResolver) BlockchainTimeout() *string
- func (r *OCRSpecResolver) BlockchainTimeoutEnv() bool
- func (r *OCRSpecResolver) ContractAddress() string
- func (r *OCRSpecResolver) ContractConfigConfirmations() *int32
- func (r *OCRSpecResolver) ContractConfigConfirmationsEnv() bool
- func (r *OCRSpecResolver) ContractConfigTrackerPollInterval() *string
- func (r *OCRSpecResolver) ContractConfigTrackerPollIntervalEnv() bool
- func (r *OCRSpecResolver) ContractConfigTrackerSubscribeInterval() *string
- func (r *OCRSpecResolver) ContractConfigTrackerSubscribeIntervalEnv() bool
- func (r *OCRSpecResolver) ContractTransmitterTransmitTimeout() string
- func (r *OCRSpecResolver) ContractTransmitterTransmitTimeoutEnv() bool
- func (r *OCRSpecResolver) CreatedAt() graphql.Time
- func (r *OCRSpecResolver) DatabaseTimeout() string
- func (r *OCRSpecResolver) DatabaseTimeoutEnv() bool
- func (r *OCRSpecResolver) EVMChainID() *string
- func (r *OCRSpecResolver) IsBootstrapPeer() bool
- func (r *OCRSpecResolver) KeyBundleID() *string
- func (r *OCRSpecResolver) ObservationGracePeriod() string
- func (r *OCRSpecResolver) ObservationGracePeriodEnv() bool
- func (r *OCRSpecResolver) ObservationTimeout() *string
- func (r *OCRSpecResolver) ObservationTimeoutEnv() bool
- func (r *OCRSpecResolver) P2PBootstrapPeers() *[]string
- func (r *OCRSpecResolver) P2PV2Bootstrappers() *[]string
- func (r *OCRSpecResolver) TransmitterAddress() *string
- type P2PKeyResolver
- type P2PKeysPayloadResolver
- type PaginationMetadataResolver
- type RejectJobProposalSpecPayloadResolver
- type RejectJobProposalSpecSuccessResolver
- type Resolver
- func (r *Resolver) ApproveJobProposalSpec(ctx context.Context, args struct{ ... }) (*ApproveJobProposalSpecPayloadResolver, error)
- func (r *Resolver) Bridge(ctx context.Context, args struct{ ... }) (*BridgePayloadResolver, error)
- func (r *Resolver) Bridges(ctx context.Context, args struct{ ... }) (*BridgesPayloadResolver, error)
- func (r *Resolver) CSAKeys(ctx context.Context) (*CSAKeysPayloadResolver, error)
- func (r *Resolver) CancelJobProposalSpec(ctx context.Context, args struct{ ... }) (*CancelJobProposalSpecPayloadResolver, error)
- func (r *Resolver) Chain(ctx context.Context, args struct{ ... }) (*ChainPayloadResolver, error)
- func (r *Resolver) Chains(ctx context.Context, args struct{ ... }) (*ChainsPayloadResolver, error)
- func (r *Resolver) Config(ctx context.Context) (*ConfigPayloadResolver, error)
- func (r *Resolver) ConfigV2(ctx context.Context) (*ConfigV2PayloadResolver, error)
- func (r *Resolver) CreateAPIToken(ctx context.Context, args struct{ ... }) (*CreateAPITokenPayloadResolver, error)
- func (r *Resolver) CreateBridge(ctx context.Context, args struct{ ... }) (*CreateBridgePayloadResolver, error)
- func (r *Resolver) CreateCSAKey(ctx context.Context) (*CreateCSAKeyPayloadResolver, error)
- func (r *Resolver) CreateChain(ctx context.Context, args struct{ ... }) (*CreateChainPayloadResolver, error)
- func (r *Resolver) CreateFeedsManager(ctx context.Context, args struct{ ... }) (*CreateFeedsManagerPayloadResolver, error)
- func (r *Resolver) CreateFeedsManagerChainConfig(ctx context.Context, args struct{ ... }) (*CreateFeedsManagerChainConfigPayloadResolver, error)
- func (r *Resolver) CreateJob(ctx context.Context, args struct{ ... }) (*CreateJobPayloadResolver, error)
- func (r *Resolver) CreateNode(ctx context.Context, args struct{ ... }) (*CreateNodePayloadResolver, error)
- func (r *Resolver) CreateOCR2KeyBundle(ctx context.Context, args struct{ ... }) (*CreateOCR2KeyBundlePayloadResolver, error)
- func (r *Resolver) CreateOCRKeyBundle(ctx context.Context) (*CreateOCRKeyBundlePayloadResolver, error)
- func (r *Resolver) CreateP2PKey(ctx context.Context) (*CreateP2PKeyPayloadResolver, error)
- func (r *Resolver) CreateVRFKey(ctx context.Context) (*CreateVRFKeyPayloadResolver, error)
- func (r *Resolver) DeleteAPIToken(ctx context.Context, args struct{ ... }) (*DeleteAPITokenPayloadResolver, error)
- func (r *Resolver) DeleteBridge(ctx context.Context, args struct{ ... }) (*DeleteBridgePayloadResolver, error)
- func (r *Resolver) DeleteCSAKey(ctx context.Context, args struct{ ... }) (*DeleteCSAKeyPayloadResolver, error)
- func (r *Resolver) DeleteChain(ctx context.Context, args struct{ ... }) (*DeleteChainPayloadResolver, error)
- func (r *Resolver) DeleteFeedsManagerChainConfig(ctx context.Context, args struct{ ... }) (*DeleteFeedsManagerChainConfigPayloadResolver, error)
- func (r *Resolver) DeleteJob(ctx context.Context, args struct{ ... }) (*DeleteJobPayloadResolver, error)
- func (r *Resolver) DeleteNode(ctx context.Context, args struct{ ... }) (*DeleteNodePayloadResolver, error)
- func (r *Resolver) DeleteOCR2KeyBundle(ctx context.Context, args struct{ ... }) (*DeleteOCR2KeyBundlePayloadResolver, error)
- func (r *Resolver) DeleteOCRKeyBundle(ctx context.Context, args struct{ ... }) (*DeleteOCRKeyBundlePayloadResolver, error)
- func (r *Resolver) DeleteP2PKey(ctx context.Context, args struct{ ... }) (*DeleteP2PKeyPayloadResolver, error)
- func (r *Resolver) DeleteVRFKey(ctx context.Context, args struct{ ... }) (*DeleteVRFKeyPayloadResolver, error)
- func (r *Resolver) DismissJobError(ctx context.Context, args struct{ ... }) (*DismissJobErrorPayloadResolver, error)
- func (r *Resolver) ETHKeys(ctx context.Context) (*ETHKeysPayloadResolver, error)
- func (r *Resolver) EthTransaction(ctx context.Context, args struct{ ... }) (*EthTransactionPayloadResolver, error)
- func (r *Resolver) EthTransactions(ctx context.Context, args struct{ ... }) (*EthTransactionsPayloadResolver, error)
- func (r *Resolver) EthTransactionsAttempts(ctx context.Context, args struct{ ... }) (*EthTransactionsAttemptsPayloadResolver, error)
- func (r *Resolver) Features(ctx context.Context) (*FeaturesPayloadResolver, error)
- func (r *Resolver) FeedsManager(ctx context.Context, args struct{ ... }) (*FeedsManagerPayloadResolver, error)
- func (r *Resolver) FeedsManagers(ctx context.Context) (*FeedsManagersPayloadResolver, error)
- func (r *Resolver) GlobalLogLevel(ctx context.Context) (*GlobalLogLevelPayloadResolver, error)
- func (r *Resolver) Job(ctx context.Context, args struct{ ... }) (*JobPayloadResolver, error)
- func (r *Resolver) JobProposal(ctx context.Context, args struct{ ... }) (*JobProposalPayloadResolver, error)
- func (r *Resolver) JobRun(ctx context.Context, args struct{ ... }) (*JobRunPayloadResolver, error)
- func (r *Resolver) JobRuns(ctx context.Context, args struct{ ... }) (*JobRunsPayloadResolver, error)
- func (r *Resolver) Jobs(ctx context.Context, args struct{ ... }) (*JobsPayloadResolver, error)
- func (r *Resolver) Node(ctx context.Context, args struct{ ... }) (*NodePayloadResolver, error)
- func (r *Resolver) Nodes(ctx context.Context, args struct{ ... }) (*NodesPayloadResolver, error)
- func (r *Resolver) OCR2KeyBundles(ctx context.Context) (*OCR2KeyBundlesPayloadResolver, error)
- func (r *Resolver) OCRKeyBundles(ctx context.Context) (*OCRKeyBundlesPayloadResolver, error)
- func (r *Resolver) P2PKeys(ctx context.Context) (*P2PKeysPayloadResolver, error)
- func (r *Resolver) RejectJobProposalSpec(ctx context.Context, args struct{ ... }) (*RejectJobProposalSpecPayloadResolver, error)
- func (r *Resolver) RunJob(ctx context.Context, args struct{ ... }) (*RunJobPayloadResolver, error)
- func (r *Resolver) SQLLogging(ctx context.Context) (*GetSQLLoggingPayloadResolver, error)
- func (r *Resolver) SetGlobalLogLevel(ctx context.Context, args struct{ ... }) (*SetGlobalLogLevelPayloadResolver, error)
- func (r *Resolver) SetSQLLogging(ctx context.Context, args struct{ ... }) (*SetSQLLoggingPayloadResolver, error)
- func (r *Resolver) SolanaKeys(ctx context.Context) (*SolanaKeysPayloadResolver, error)
- func (r *Resolver) UpdateBridge(ctx context.Context, args struct{ ... }) (*UpdateBridgePayloadResolver, error)
- func (r *Resolver) UpdateChain(ctx context.Context, args struct{ ... }) (*UpdateChainPayloadResolver, error)
- func (r *Resolver) UpdateFeedsManager(ctx context.Context, args struct{ ... }) (*UpdateFeedsManagerPayloadResolver, error)
- func (r *Resolver) UpdateFeedsManagerChainConfig(ctx context.Context, args struct{ ... }) (*UpdateFeedsManagerChainConfigPayloadResolver, error)
- func (r *Resolver) UpdateJobProposalSpecDefinition(ctx context.Context, args struct{ ... }) (*UpdateJobProposalSpecDefinitionPayloadResolver, error)
- func (r *Resolver) UpdateUserPassword(ctx context.Context, args struct{ ... }) (*UpdatePasswordPayloadResolver, error)
- func (r *Resolver) VRFKey(ctx context.Context, args struct{ ... }) (*VRFKeyPayloadResolver, error)
- func (r *Resolver) VRFKeys(ctx context.Context) (*VRFKeysPayloadResolver, error)
- type RoleNotPermittedErr
- type RunJobCannotRunErrorResolver
- type RunJobPayloadResolver
- type RunJobSuccessResolver
- type SQLLoggingResolver
- type SetGlobalLogLevelPayloadResolver
- type SetGlobalLogLevelSuccessResolver
- type SetSQLLoggingPayloadResolver
- type SetSQLLoggingSuccessResolver
- type SingleFeedsManagerErrorResolver
- type SolanaKeyResolver
- type SolanaKeysPayloadResolver
- type SpecResolver
- func (r *SpecResolver) ToBlockhashStoreSpec() (*BlockhashStoreSpecResolver, bool)
- func (r *SpecResolver) ToBootstrapSpec() (*BootstrapSpecResolver, bool)
- func (r *SpecResolver) ToCronSpec() (*CronSpecResolver, bool)
- func (r *SpecResolver) ToDirectRequestSpec() (*DirectRequestSpecResolver, bool)
- func (r *SpecResolver) ToFluxMonitorSpec() (*FluxMonitorSpecResolver, bool)
- func (r *SpecResolver) ToKeeperSpec() (*KeeperSpecResolver, bool)
- func (r *SpecResolver) ToOCR2Spec() (*OCR2SpecResolver, bool)
- func (r *SpecResolver) ToOCRSpec() (*OCRSpecResolver, bool)
- func (r *SpecResolver) ToVRFSpec() (*VRFSpecResolver, bool)
- func (r *SpecResolver) ToWebhookSpec() (*WebhookSpecResolver, bool)
- type SpecStatus
- type TaskRunResolver
- func (r *TaskRunResolver) CreatedAt() graphql.Time
- func (r *TaskRunResolver) DotID() string
- func (r *TaskRunResolver) Error() *string
- func (r *TaskRunResolver) FinishedAt() *graphql.Time
- func (r *TaskRunResolver) ID() graphql.ID
- func (r *TaskRunResolver) Output() string
- func (r *TaskRunResolver) Type() string
- type UpdateBridgePayloadResolver
- type UpdateBridgeSuccessResolver
- type UpdateChainPayloadResolver
- type UpdateChainSuccessResolver
- type UpdateFeedsManagerChainConfigPayloadResolver
- type UpdateFeedsManagerChainConfigSuccessResolver
- type UpdateFeedsManagerPayloadResolver
- type UpdateFeedsManagerSuccessResolver
- type UpdateJobProposalSpecDefinitionPayloadResolver
- type UpdateJobProposalSpecDefinitionSuccessResolver
- type UpdatePasswordInput
- type UpdatePasswordPayloadResolver
- type UpdatePasswordSuccessResolver
- type UserResolver
- type VRFKeyPayloadResolver
- type VRFKeyResolver
- type VRFKeySuccessResolver
- type VRFKeysPayloadResolver
- type VRFSpecResolver
- func (r *VRFSpecResolver) BackoffInitialDelay() string
- func (r *VRFSpecResolver) BackoffMaxDelay() string
- func (r *VRFSpecResolver) BatchCoordinatorAddress() *string
- func (r *VRFSpecResolver) BatchFulfillmentEnabled() bool
- func (r *VRFSpecResolver) BatchFulfillmentGasMultiplier() float64
- func (r *VRFSpecResolver) ChunkSize() int32
- func (r *VRFSpecResolver) CoordinatorAddress() string
- func (r *VRFSpecResolver) CreatedAt() graphql.Time
- func (r *VRFSpecResolver) EVMChainID() *string
- func (r *VRFSpecResolver) FromAddresses() *[]string
- func (r *VRFSpecResolver) GasLanePrice() *string
- func (r *VRFSpecResolver) MinIncomingConfirmations() int32
- func (r *VRFSpecResolver) MinIncomingConfirmationsEnv() bool
- func (r *VRFSpecResolver) PollPeriod() string
- func (r *VRFSpecResolver) PublicKey() string
- func (r *VRFSpecResolver) RequestTimeout() string
- func (r *VRFSpecResolver) RequestedConfsDelay() int32
- type WebhookSpecResolver
Constants ¶
const ( // PageDefaultOffset defines the default offset to use if none is provided PageDefaultOffset = 0 // PageDefaultLimit defines the default limit to use if none is provided PageDefaultLimit = 50 )
const ( LogLevelDebug = "DEBUG" LogLevelInfo = "INFO" LogLevelWarn = "WARN" LogLevelError = "ERROR" )
const ( // OCR2ChainTypeEVM defines OCR2 EVM Chain Type OCR2ChainTypeEVM = "EVM" // OCR2ChainTypeSolana defines OCR2 Solana Chain Type OCR2ChainTypeSolana = "SOLANA" // OCR2ChainTypeTerra defines OCR2 Terra Chain Type OCR2ChainTypeTerra = "TERRA" )
Variables ¶
This section is empty.
Functions ¶
func FromChainType ¶
func FromGasEstimatorMode ¶
func FromGasEstimatorMode(gsm GasEstimatorMode) string
func FromLogLevel ¶
func FromOCR2ChainType ¶ added in v1.2.0
func FromOCR2ChainType(ct OCR2ChainType) string
FromOCR2ChainType returns the string (lowercased) value from a OCR2ChainType
func ToChainConfig ¶
func ToChainConfig(input ChainConfigInput) (*types.ChainCfg, map[string]string)
func ValidateBridgeType ¶
func ValidateBridgeType(bt *bridges.BridgeTypeRequest) error
ValidateBridgeType checks that the bridge type doesn't have a duplicate or invalid name or invalid url
This validation function should be moved into a bridge service and return multiple errors.
func ValidateBridgeTypeUniqueness ¶
func ValidateBridgeTypeUniqueness(bt *bridges.BridgeTypeRequest, orm bridges.ORM) error
ValidateBridgeTypeUniqueness checks that a bridge has not already been created
/ This validation function should be moved into a bridge service.
Types ¶
type APITokenResolver ¶
type APITokenResolver struct {
// contains filtered or unexported fields
}
func NewAPIToken ¶
func NewAPIToken(token auth.Token) *APITokenResolver
func (*APITokenResolver) AccessKey ¶
func (r *APITokenResolver) AccessKey() string
func (*APITokenResolver) Secret ¶
func (r *APITokenResolver) Secret() string
type ApproveJobProposalSpecPayloadResolver ¶ added in v1.2.0
type ApproveJobProposalSpecPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
ApproveJobProposalSpecPayloadResolver resolves the spec payload.
func NewApproveJobProposalSpecPayload ¶ added in v1.2.0
func NewApproveJobProposalSpecPayload(spec *feeds.JobProposalSpec, err error) *ApproveJobProposalSpecPayloadResolver
NewApproveJobProposalSpecPayload generates the spec payload resolver.
func (*ApproveJobProposalSpecPayloadResolver) ToApproveJobProposalSpecSuccess ¶ added in v1.2.0
func (r *ApproveJobProposalSpecPayloadResolver) ToApproveJobProposalSpecSuccess() (*ApproveJobProposalSpecSuccessResolver, bool)
ToApproveJobProposalSpecSuccess resolves to the approval job proposal success resolver.
func (*ApproveJobProposalSpecPayloadResolver) ToJobAlreadyExistsError ¶ added in v1.2.0
func (r *ApproveJobProposalSpecPayloadResolver) ToJobAlreadyExistsError() (*JobAlreadyExistsErrorResolver, bool)
ToJobAlreadyExistsError -
type ApproveJobProposalSpecSuccessResolver ¶ added in v1.2.0
type ApproveJobProposalSpecSuccessResolver struct {
// contains filtered or unexported fields
}
ApproveJobProposalSpecSuccessResolver resolves the approval success response.
func NewApproveJobProposalSpecSuccess ¶ added in v1.2.0
func NewApproveJobProposalSpecSuccess(spec *feeds.JobProposalSpec) *ApproveJobProposalSpecSuccessResolver
NewApproveJobProposalSpecSuccess generates the resolver.
func (*ApproveJobProposalSpecSuccessResolver) Spec ¶ added in v1.2.0
func (r *ApproveJobProposalSpecSuccessResolver) Spec() *JobProposalSpecResolver
Spec returns the job proposal spec.
type BlockhashStoreSpecResolver ¶ added in v1.2.0
type BlockhashStoreSpecResolver struct {
// contains filtered or unexported fields
}
BlockhashStoreSpecResolver exposes the job parameters for a BlockhashStoreSpec.
func (*BlockhashStoreSpecResolver) BlockhashStoreAddress ¶ added in v1.2.0
func (b *BlockhashStoreSpecResolver) BlockhashStoreAddress() string
BlockhashStoreAddress returns the job's BlockhashStoreAddress param.
func (*BlockhashStoreSpecResolver) CoordinatorV1Address ¶ added in v1.2.0
func (b *BlockhashStoreSpecResolver) CoordinatorV1Address() *string
CoordinatorV1Address returns the address of the V1 Coordinator, if any.
func (*BlockhashStoreSpecResolver) CoordinatorV2Address ¶ added in v1.2.0
func (b *BlockhashStoreSpecResolver) CoordinatorV2Address() *string
CoordinatorV2Address returns the address of the V2 Coordinator, if any.
func (*BlockhashStoreSpecResolver) CreatedAt ¶ added in v1.2.0
func (b *BlockhashStoreSpecResolver) CreatedAt() graphql.Time
CreatedAt resolves the spec's created at timestamp.
func (*BlockhashStoreSpecResolver) EVMChainID ¶ added in v1.2.0
func (b *BlockhashStoreSpecResolver) EVMChainID() *string
EVMChainID returns the job's EVMChainID param.
func (*BlockhashStoreSpecResolver) FromAddress ¶ added in v1.2.0
func (b *BlockhashStoreSpecResolver) FromAddress() *string
FromAddress returns the job's FromAddress param, if any.
func (*BlockhashStoreSpecResolver) LookbackBlocks ¶ added in v1.2.0
func (b *BlockhashStoreSpecResolver) LookbackBlocks() int32
LookbackBlocks returns the job's LookbackBlocks param.
func (*BlockhashStoreSpecResolver) PollPeriod ¶ added in v1.2.0
func (b *BlockhashStoreSpecResolver) PollPeriod() string
PollPeriod return's the job's PollPeriod param.
func (*BlockhashStoreSpecResolver) RunTimeout ¶ added in v1.2.0
func (b *BlockhashStoreSpecResolver) RunTimeout() string
RunTimeout return's the job's RunTimeout param.
func (*BlockhashStoreSpecResolver) WaitBlocks ¶ added in v1.2.0
func (b *BlockhashStoreSpecResolver) WaitBlocks() int32
WaitBlocks returns the job's WaitBlocks param.
type BootstrapSpecResolver ¶ added in v1.2.0
type BootstrapSpecResolver struct {
// contains filtered or unexported fields
}
BootstrapSpecResolver defines the Bootstrap Spec Resolver
func (*BootstrapSpecResolver) BlockchainTimeout ¶ added in v1.2.0
func (r *BootstrapSpecResolver) BlockchainTimeout() *string
BlockchainTimeout resolves the spec's blockchain timeout
func (*BootstrapSpecResolver) ContractConfigConfirmations ¶ added in v1.2.0
func (r *BootstrapSpecResolver) ContractConfigConfirmations() *int32
ContractConfigConfirmations resolves the spec's confirmations config.
func (*BootstrapSpecResolver) ContractConfigTrackerPollInterval ¶ added in v1.2.0
func (r *BootstrapSpecResolver) ContractConfigTrackerPollInterval() *string
ContractConfigTrackerPollInterval resolves the spec's contract tracker poll interval config.
func (*BootstrapSpecResolver) ContractID ¶ added in v1.2.0
func (r *BootstrapSpecResolver) ContractID() string
ContractID resolves the spec's contract address
func (*BootstrapSpecResolver) CreatedAt ¶ added in v1.2.0
func (r *BootstrapSpecResolver) CreatedAt() graphql.Time
CreatedAt resolves the spec's created at timestamp.
func (*BootstrapSpecResolver) ID ¶ added in v1.2.0
func (r *BootstrapSpecResolver) ID() graphql.ID
ID resolves the Bootstrap spec ID
func (*BootstrapSpecResolver) MonitoringEndpoint ¶ added in v1.2.0
func (r *BootstrapSpecResolver) MonitoringEndpoint() *string
MonitoringEndpoint resolves the spec's monitoring endpoint
func (*BootstrapSpecResolver) Relay ¶ added in v1.2.0
func (r *BootstrapSpecResolver) Relay() string
Relay resolves the spec's relay
func (*BootstrapSpecResolver) RelayConfig ¶ added in v1.2.0
func (r *BootstrapSpecResolver) RelayConfig() gqlscalar.Map
RelayConfig resolves the spec's relay config
type BridgePayloadResolver ¶
type BridgePayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
BridgePayloadResolver resolves a single bridge response
func NewBridgePayload ¶
func NewBridgePayload(bridge bridges.BridgeType, err error) *BridgePayloadResolver
func (*BridgePayloadResolver) ToBridge ¶
func (r *BridgePayloadResolver) ToBridge() (*BridgeResolver, bool)
ToBridge implements the Bridge union type of the payload
type BridgeResolver ¶
type BridgeResolver struct {
// contains filtered or unexported fields
}
BridgeResolver resolves the Bridge type.
func NewBridge ¶
func NewBridge(bridge bridges.BridgeType) *BridgeResolver
func NewBridges ¶
func NewBridges(bridges []bridges.BridgeType) []*BridgeResolver
func (*BridgeResolver) Confirmations ¶
func (r *BridgeResolver) Confirmations() int32
Confirmations resolves the bridge's url.
func (*BridgeResolver) CreatedAt ¶
func (r *BridgeResolver) CreatedAt() graphql.Time
CreatedAt resolves the bridge's created at field.
func (*BridgeResolver) ID ¶
func (r *BridgeResolver) ID() graphql.ID
ID resolves the bridge's name as the id (Bridge does not have an id).
func (*BridgeResolver) MinimumContractPayment ¶
func (r *BridgeResolver) MinimumContractPayment() string
MinimumContractPayment resolves the bridge's minimum contract payment.
func (*BridgeResolver) Name ¶
func (r *BridgeResolver) Name() string
Name resolves the bridge's name.
func (*BridgeResolver) OutgoingToken ¶
func (r *BridgeResolver) OutgoingToken() string
OutgoingToken resolves the bridge's outgoing token.
type BridgesPayloadResolver ¶
type BridgesPayloadResolver struct {
// contains filtered or unexported fields
}
BridgesPayloadResolver resolves a page of bridges
func NewBridgesPayload ¶
func NewBridgesPayload(bridges []bridges.BridgeType, total int32) *BridgesPayloadResolver
func (*BridgesPayloadResolver) Metadata ¶
func (r *BridgesPayloadResolver) Metadata() *PaginationMetadataResolver
Metadata returns the pagination metadata.
func (*BridgesPayloadResolver) Results ¶
func (r *BridgesPayloadResolver) Results() []*BridgeResolver
Results returns the bridges.
type CSAKeyExistsErrorResolver ¶
type CSAKeyExistsErrorResolver struct {
// contains filtered or unexported fields
}
func NewCSAKeyExistsError ¶
func NewCSAKeyExistsError(message string) *CSAKeyExistsErrorResolver
func (*CSAKeyExistsErrorResolver) Code ¶
func (r *CSAKeyExistsErrorResolver) Code() ErrorCode
func (*CSAKeyExistsErrorResolver) Message ¶
func (r *CSAKeyExistsErrorResolver) Message() string
type CSAKeyResolver ¶
type CSAKeyResolver struct {
// contains filtered or unexported fields
}
CSAKeyResolver resolves the single CSA Key object
func NewCSAKey ¶
func NewCSAKey(key csakey.KeyV2) *CSAKeyResolver
func NewCSAKeys ¶
func NewCSAKeys(keys []csakey.KeyV2) []*CSAKeyResolver
func (*CSAKeyResolver) ID ¶
func (r *CSAKeyResolver) ID() graphql.ID
ID resolves the CSA Key public key as the id.
func (*CSAKeyResolver) PublicKey ¶
func (r *CSAKeyResolver) PublicKey() string
PubKey resolves the CSA Key public key string.
func (*CSAKeyResolver) Version ¶
func (r *CSAKeyResolver) Version() int32
Version resolves the CSA Key version number.
type CSAKeysPayloadResolver ¶
type CSAKeysPayloadResolver struct {
// contains filtered or unexported fields
}
func NewCSAKeysResolver ¶
func NewCSAKeysResolver(keys []csakey.KeyV2) *CSAKeysPayloadResolver
func (*CSAKeysPayloadResolver) Results ¶
func (r *CSAKeysPayloadResolver) Results() []*CSAKeyResolver
type CancelJobProposalSpecPayloadResolver ¶ added in v1.2.0
type CancelJobProposalSpecPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
CancelJobProposalSpecPayloadResolver resolves the cancel payload response.
func NewCancelJobProposalSpecPayload ¶ added in v1.2.0
func NewCancelJobProposalSpecPayload(spec *feeds.JobProposalSpec, err error) *CancelJobProposalSpecPayloadResolver
NewCancelJobProposalSpecPayload generates the resolver.
func (*CancelJobProposalSpecPayloadResolver) ToCancelJobProposalSpecSuccess ¶ added in v1.2.0
func (r *CancelJobProposalSpecPayloadResolver) ToCancelJobProposalSpecSuccess() (*CancelJobProposalSpecSuccessResolver, bool)
ToCancelJobProposalSpecSuccess resolves to the cancel job proposal spec success resolver.
type CancelJobProposalSpecSuccessResolver ¶ added in v1.2.0
type CancelJobProposalSpecSuccessResolver struct {
// contains filtered or unexported fields
}
CancelJobProposalSpecSuccessResolver resolves the cancellation success response.
func NewCancelJobProposalSpecSuccess ¶ added in v1.2.0
func NewCancelJobProposalSpecSuccess(spec *feeds.JobProposalSpec) *CancelJobProposalSpecSuccessResolver
NewCancelJobProposalSpecSuccess generates the resolver.
func (*CancelJobProposalSpecSuccessResolver) Spec ¶ added in v1.2.0
func (r *CancelJobProposalSpecSuccessResolver) Spec() *JobProposalSpecResolver
Spec returns the job proposal spec.
type ChainConfigInput ¶
type ChainConfigInput struct { BlockHistoryEstimatorBlockDelay *int32 BlockHistoryEstimatorBlockHistorySize *int32 EthTxReaperThreshold *string EthTxResendAfterThreshold *string EvmEIP1559DynamicFees *bool EvmFinalityDepth *int32 EvmGasBumpPercent *int32 EvmGasBumpTxDepth *int32 EvmGasBumpWei *string EvmGasLimitDefault *int32 EvmGasLimitMax *int32 EvmGasLimitMultiplier *float64 EvmGasLimitOCRJobType *int32 EvmGasLimitDRJobType *int32 EvmGasLimitVRFJobType *int32 EvmGasLimitFMJobType *int32 EvmGasLimitKeeperJobType *int32 EvmGasPriceDefault *string EvmGasTipCapDefault *string EvmGasTipCapMinimum *string EvmHeadTrackerHistoryDepth *int32 EvmHeadTrackerMaxBufferSize *int32 EvmHeadTrackerSamplingInterval *string EvmLogBackfillBatchSize *int32 EvmMaxGasPriceWei *string EvmNonceAutoSync *bool EvmRPCDefaultBatchSize *int32 FlagsContractAddress *string GasEstimatorMode *GasEstimatorMode ChainType *ChainType MinIncomingConfirmations *int32 MinimumContractPayment *string OCRObservationTimeout *string LinkContractAddress *string }
type ChainConfigResolver ¶
type ChainConfigResolver struct {
// contains filtered or unexported fields
}
func NewChainConfig ¶
func NewChainConfig(cfg types.ChainCfg) *ChainConfigResolver
func (*ChainConfigResolver) BlockHistoryEstimatorBlockDelay ¶
func (r *ChainConfigResolver) BlockHistoryEstimatorBlockDelay() *int32
func (*ChainConfigResolver) BlockHistoryEstimatorBlockHistorySize ¶
func (r *ChainConfigResolver) BlockHistoryEstimatorBlockHistorySize() *int32
func (*ChainConfigResolver) ChainType ¶
func (r *ChainConfigResolver) ChainType() *ChainType
func (*ChainConfigResolver) EthTxReaperThreshold ¶
func (r *ChainConfigResolver) EthTxReaperThreshold() *string
func (*ChainConfigResolver) EthTxResendAfterThreshold ¶
func (r *ChainConfigResolver) EthTxResendAfterThreshold() *string
func (*ChainConfigResolver) EvmEIP1559DynamicFees ¶
func (r *ChainConfigResolver) EvmEIP1559DynamicFees() *bool
func (*ChainConfigResolver) EvmFinalityDepth ¶
func (r *ChainConfigResolver) EvmFinalityDepth() *int32
func (*ChainConfigResolver) EvmGasBumpPercent ¶
func (r *ChainConfigResolver) EvmGasBumpPercent() *int32
func (*ChainConfigResolver) EvmGasBumpTxDepth ¶
func (r *ChainConfigResolver) EvmGasBumpTxDepth() *int32
func (*ChainConfigResolver) EvmGasBumpWei ¶
func (r *ChainConfigResolver) EvmGasBumpWei() *string
func (*ChainConfigResolver) EvmGasLimitDRJobType ¶ added in v1.7.0
func (r *ChainConfigResolver) EvmGasLimitDRJobType() *int32
func (*ChainConfigResolver) EvmGasLimitDefault ¶
func (r *ChainConfigResolver) EvmGasLimitDefault() *int32
func (*ChainConfigResolver) EvmGasLimitFMJobType ¶ added in v1.7.0
func (r *ChainConfigResolver) EvmGasLimitFMJobType() *int32
func (*ChainConfigResolver) EvmGasLimitKeeperJobType ¶ added in v1.7.0
func (r *ChainConfigResolver) EvmGasLimitKeeperJobType() *int32
func (*ChainConfigResolver) EvmGasLimitMax ¶ added in v1.8.1
func (r *ChainConfigResolver) EvmGasLimitMax() *int32
func (*ChainConfigResolver) EvmGasLimitMultiplier ¶
func (r *ChainConfigResolver) EvmGasLimitMultiplier() *float64
func (*ChainConfigResolver) EvmGasLimitOCRJobType ¶ added in v1.7.0
func (r *ChainConfigResolver) EvmGasLimitOCRJobType() *int32
func (*ChainConfigResolver) EvmGasLimitVRFJobType ¶ added in v1.7.0
func (r *ChainConfigResolver) EvmGasLimitVRFJobType() *int32
func (*ChainConfigResolver) EvmGasPriceDefault ¶
func (r *ChainConfigResolver) EvmGasPriceDefault() *string
func (*ChainConfigResolver) EvmGasTipCapDefault ¶
func (r *ChainConfigResolver) EvmGasTipCapDefault() *string
func (*ChainConfigResolver) EvmGasTipCapMinimum ¶
func (r *ChainConfigResolver) EvmGasTipCapMinimum() *string
func (*ChainConfigResolver) EvmHeadTrackerHistoryDepth ¶
func (r *ChainConfigResolver) EvmHeadTrackerHistoryDepth() *int32
func (*ChainConfigResolver) EvmHeadTrackerMaxBufferSize ¶
func (r *ChainConfigResolver) EvmHeadTrackerMaxBufferSize() *int32
func (*ChainConfigResolver) EvmHeadTrackerSamplingInterval ¶
func (r *ChainConfigResolver) EvmHeadTrackerSamplingInterval() *string
func (*ChainConfigResolver) EvmLogBackfillBatchSize ¶
func (r *ChainConfigResolver) EvmLogBackfillBatchSize() *int32
func (*ChainConfigResolver) EvmMaxGasPriceWei ¶
func (r *ChainConfigResolver) EvmMaxGasPriceWei() *string
func (*ChainConfigResolver) EvmNonceAutoSync ¶
func (r *ChainConfigResolver) EvmNonceAutoSync() *bool
func (*ChainConfigResolver) EvmRPCDefaultBatchSize ¶
func (r *ChainConfigResolver) EvmRPCDefaultBatchSize() *int32
func (*ChainConfigResolver) FlagsContractAddress ¶
func (r *ChainConfigResolver) FlagsContractAddress() *string
func (*ChainConfigResolver) GasEstimatorMode ¶
func (r *ChainConfigResolver) GasEstimatorMode() *GasEstimatorMode
func (*ChainConfigResolver) KeySpecificConfigs ¶
func (r *ChainConfigResolver) KeySpecificConfigs() []*KeySpecificChainConfigResolver
func (*ChainConfigResolver) LinkContractAddress ¶ added in v1.2.0
func (r *ChainConfigResolver) LinkContractAddress() *string
LinkContractAddress resolves the LINK contract address for the chain
func (*ChainConfigResolver) MinIncomingConfirmations ¶
func (r *ChainConfigResolver) MinIncomingConfirmations() *int32
func (*ChainConfigResolver) MinimumContractPayment ¶
func (r *ChainConfigResolver) MinimumContractPayment() *string
func (*ChainConfigResolver) OCRObservationTimeout ¶
func (r *ChainConfigResolver) OCRObservationTimeout() *string
type ChainPayloadResolver ¶
type ChainPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewChainPayload ¶
func NewChainPayload(chain types.DBChain, err error) *ChainPayloadResolver
func (*ChainPayloadResolver) ToChain ¶
func (r *ChainPayloadResolver) ToChain() (*ChainResolver, bool)
type ChainResolver ¶
type ChainResolver struct {
// contains filtered or unexported fields
}
ChainResolver resolves the Chain type.
func NewChain ¶
func NewChain(chain types.DBChain) *ChainResolver
func NewChains ¶
func NewChains(chains []types.DBChain) []*ChainResolver
func (*ChainResolver) Config ¶
func (r *ChainResolver) Config() *ChainConfigResolver
Config resolves the chain's configuration field
func (*ChainResolver) CreatedAt ¶
func (r *ChainResolver) CreatedAt() graphql.Time
CreatedAt resolves the chain's created at field.
func (*ChainResolver) Enabled ¶
func (r *ChainResolver) Enabled() bool
Enabled resolves the chain's enabled field.
func (*ChainResolver) ID ¶
func (r *ChainResolver) ID() graphql.ID
ID resolves the chain's unique identifier.
func (*ChainResolver) Nodes ¶
func (r *ChainResolver) Nodes(ctx context.Context) ([]*NodeResolver, error)
func (*ChainResolver) UpdatedAt ¶
func (r *ChainResolver) UpdatedAt() graphql.Time
UpdatedAt resolves the chain's updated at field.
type ChainsPayloadResolver ¶
type ChainsPayloadResolver struct {
// contains filtered or unexported fields
}
func NewChainsPayload ¶
func NewChainsPayload(chains []types.DBChain, total int32) *ChainsPayloadResolver
func (*ChainsPayloadResolver) Metadata ¶
func (r *ChainsPayloadResolver) Metadata() *PaginationMetadataResolver
func (*ChainsPayloadResolver) Results ¶
func (r *ChainsPayloadResolver) Results() []*ChainResolver
type ConfigItemResolver ¶ added in v1.2.0
type ConfigItemResolver struct {
// contains filtered or unexported fields
}
func NewConfigItem ¶ added in v1.2.0
func NewConfigItem(key string, value ConfigItemValue) *ConfigItemResolver
func (*ConfigItemResolver) Key ¶ added in v1.2.0
func (r *ConfigItemResolver) Key() string
func (*ConfigItemResolver) Value ¶ added in v1.2.0
func (r *ConfigItemResolver) Value() ConfigItemValue
type ConfigItemValue ¶ added in v1.2.0
type ConfigItemValue struct {
Value interface{} `json:"value"`
}
func (ConfigItemValue) ImplementsGraphQLType ¶ added in v1.2.0
func (ConfigItemValue) ImplementsGraphQLType(name string) bool
func (ConfigItemValue) MarshalJSON ¶ added in v1.2.0
func (c ConfigItemValue) MarshalJSON() ([]byte, error)
func (*ConfigItemValue) UnmarshalGraphQL ¶ added in v1.2.0
func (c *ConfigItemValue) UnmarshalGraphQL(input interface{}) error
type ConfigPayloadResolver ¶ added in v1.2.0
type ConfigPayloadResolver struct {
// contains filtered or unexported fields
}
func NewConfigPayload ¶ added in v1.2.0
func NewConfigPayload(cfg config.EnvPrinter) *ConfigPayloadResolver
func (*ConfigPayloadResolver) Items ¶ added in v1.2.0
func (r *ConfigPayloadResolver) Items() []*ConfigItemResolver
type ConfigResolver ¶ added in v1.2.0
type ConfigResolver struct {
// contains filtered or unexported fields
}
func NewConfig ¶ added in v1.2.0
func NewConfig(cfg config.EnvPrinter) *ConfigResolver
func (*ConfigResolver) Items ¶ added in v1.2.0
func (r *ConfigResolver) Items() []*ConfigItemResolver
type ConfigV2PayloadResolver ¶ added in v1.10.0
type ConfigV2PayloadResolver struct {
// contains filtered or unexported fields
}
func NewConfigV2Payload ¶ added in v1.10.0
func NewConfigV2Payload(user, effective string) *ConfigV2PayloadResolver
func (*ConfigV2PayloadResolver) Effective ¶ added in v1.10.0
func (r *ConfigV2PayloadResolver) Effective() string
func (*ConfigV2PayloadResolver) User ¶ added in v1.10.0
func (r *ConfigV2PayloadResolver) User() string
type CreateAPITokenPayloadResolver ¶
type CreateAPITokenPayloadResolver struct {
// contains filtered or unexported fields
}
func NewCreateAPITokenPayload ¶
func NewCreateAPITokenPayload(token *auth.Token, inputErrs map[string]string) *CreateAPITokenPayloadResolver
func (*CreateAPITokenPayloadResolver) ToCreateAPITokenSuccess ¶
func (r *CreateAPITokenPayloadResolver) ToCreateAPITokenSuccess() (*CreateAPITokenSuccessResolver, bool)
func (*CreateAPITokenPayloadResolver) ToInputErrors ¶
func (r *CreateAPITokenPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)
type CreateAPITokenSuccessResolver ¶
type CreateAPITokenSuccessResolver struct {
// contains filtered or unexported fields
}
func NewCreateAPITokenSuccess ¶
func NewCreateAPITokenSuccess(token *auth.Token) *CreateAPITokenSuccessResolver
func (*CreateAPITokenSuccessResolver) Token ¶
func (r *CreateAPITokenSuccessResolver) Token() *APITokenResolver
type CreateBridgePayloadResolver ¶
type CreateBridgePayloadResolver struct {
// contains filtered or unexported fields
}
CreateBridgePayloadResolver
func NewCreateBridgePayload ¶
func NewCreateBridgePayload(bridge bridges.BridgeType, incomingToken string) *CreateBridgePayloadResolver
func (*CreateBridgePayloadResolver) ToCreateBridgeSuccess ¶
func (r *CreateBridgePayloadResolver) ToCreateBridgeSuccess() (*CreateBridgeSuccessResolver, bool)
type CreateBridgeSuccessResolver ¶
type CreateBridgeSuccessResolver struct {
// contains filtered or unexported fields
}
func NewCreateBridgeSuccessResolver ¶
func NewCreateBridgeSuccessResolver(bridge bridges.BridgeType, incomingToken string) *CreateBridgeSuccessResolver
func (*CreateBridgeSuccessResolver) Bridge ¶
func (r *CreateBridgeSuccessResolver) Bridge() *BridgeResolver
Bridge resolves the bridge.
func (*CreateBridgeSuccessResolver) IncomingToken ¶
func (r *CreateBridgeSuccessResolver) IncomingToken() string
Token resolves the bridge's incoming token.
type CreateCSAKeyPayloadResolver ¶
type CreateCSAKeyPayloadResolver struct {
// contains filtered or unexported fields
}
func NewCreateCSAKeyPayload ¶
func NewCreateCSAKeyPayload(key *csakey.KeyV2, err error) *CreateCSAKeyPayloadResolver
func (*CreateCSAKeyPayloadResolver) ToCSAKeyExistsError ¶
func (r *CreateCSAKeyPayloadResolver) ToCSAKeyExistsError() (*CSAKeyExistsErrorResolver, bool)
func (*CreateCSAKeyPayloadResolver) ToCreateCSAKeySuccess ¶
func (r *CreateCSAKeyPayloadResolver) ToCreateCSAKeySuccess() (*CreateCSAKeySuccessResolver, bool)
type CreateCSAKeySuccessResolver ¶
type CreateCSAKeySuccessResolver struct {
// contains filtered or unexported fields
}
func NewCreateCSAKeySuccessResolver ¶
func NewCreateCSAKeySuccessResolver(key *csakey.KeyV2) *CreateCSAKeySuccessResolver
func (*CreateCSAKeySuccessResolver) CSAKey ¶
func (r *CreateCSAKeySuccessResolver) CSAKey() *CSAKeyResolver
type CreateChainPayloadResolver ¶
type CreateChainPayloadResolver struct {
// contains filtered or unexported fields
}
func NewCreateChainPayload ¶
func NewCreateChainPayload(chain *types.DBChain, inputErrs map[string]string) *CreateChainPayloadResolver
func (*CreateChainPayloadResolver) ToCreateChainSuccess ¶
func (r *CreateChainPayloadResolver) ToCreateChainSuccess() (*CreateChainSuccessResolver, bool)
func (*CreateChainPayloadResolver) ToInputErrors ¶
func (r *CreateChainPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)
type CreateChainSuccessResolver ¶
type CreateChainSuccessResolver struct {
// contains filtered or unexported fields
}
func NewCreateChainSuccess ¶
func NewCreateChainSuccess(chain *types.DBChain) *CreateChainSuccessResolver
func (*CreateChainSuccessResolver) Chain ¶
func (r *CreateChainSuccessResolver) Chain() *ChainResolver
type CreateFeedsManagerChainConfigPayloadResolver ¶ added in v1.5.0
type CreateFeedsManagerChainConfigPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
CreateFeedsManagerChainConfigPayloadResolver resolves the response to CreateFeedsManagerChainConfig
func NewCreateFeedsManagerChainConfigPayload ¶ added in v1.5.0
func NewCreateFeedsManagerChainConfigPayload(cfg *feeds.ChainConfig, err error, inputErrs map[string]string) *CreateFeedsManagerChainConfigPayloadResolver
func (*CreateFeedsManagerChainConfigPayloadResolver) ToCreateFeedsManagerChainConfigSuccess ¶ added in v1.5.0
func (r *CreateFeedsManagerChainConfigPayloadResolver) ToCreateFeedsManagerChainConfigSuccess() (*CreateFeedsManagerChainConfigSuccessResolver, bool)
func (*CreateFeedsManagerChainConfigPayloadResolver) ToInputErrors ¶ added in v1.5.0
func (r *CreateFeedsManagerChainConfigPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)
type CreateFeedsManagerChainConfigSuccessResolver ¶ added in v1.5.0
type CreateFeedsManagerChainConfigSuccessResolver struct {
// contains filtered or unexported fields
}
func NewCreateFeedsManagerChainConfigSuccessResolver ¶ added in v1.5.0
func NewCreateFeedsManagerChainConfigSuccessResolver(cfg *feeds.ChainConfig) *CreateFeedsManagerChainConfigSuccessResolver
func (*CreateFeedsManagerChainConfigSuccessResolver) ChainConfig ¶ added in v1.5.0
func (r *CreateFeedsManagerChainConfigSuccessResolver) ChainConfig() *FeedsManagerChainConfigResolver
type CreateFeedsManagerPayloadResolver ¶
type CreateFeedsManagerPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
CreateFeedsManagerPayloadResolver -
func NewCreateFeedsManagerPayload ¶
func NewCreateFeedsManagerPayload(mgr *feeds.FeedsManager, err error, inputErrs map[string]string) *CreateFeedsManagerPayloadResolver
func (*CreateFeedsManagerPayloadResolver) ToCreateFeedsManagerSuccess ¶
func (r *CreateFeedsManagerPayloadResolver) ToCreateFeedsManagerSuccess() (*CreateFeedsManagerSuccessResolver, bool)
func (*CreateFeedsManagerPayloadResolver) ToInputErrors ¶
func (r *CreateFeedsManagerPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)
func (*CreateFeedsManagerPayloadResolver) ToSingleFeedsManagerError ¶
func (r *CreateFeedsManagerPayloadResolver) ToSingleFeedsManagerError() (*SingleFeedsManagerErrorResolver, bool)
type CreateFeedsManagerSuccessResolver ¶
type CreateFeedsManagerSuccessResolver struct {
// contains filtered or unexported fields
}
func NewCreateFeedsManagerSuccessResolver ¶
func NewCreateFeedsManagerSuccessResolver(mgr feeds.FeedsManager) *CreateFeedsManagerSuccessResolver
func (*CreateFeedsManagerSuccessResolver) FeedsManager ¶
func (r *CreateFeedsManagerSuccessResolver) FeedsManager() *FeedsManagerResolver
type CreateJobPayloadResolver ¶ added in v1.2.0
type CreateJobPayloadResolver struct {
// contains filtered or unexported fields
}
func NewCreateJobPayload ¶ added in v1.2.0
func NewCreateJobPayload(app chainlink.Application, job *job.Job, inputErrs map[string]string) *CreateJobPayloadResolver
func (*CreateJobPayloadResolver) ToCreateJobSuccess ¶ added in v1.2.0
func (r *CreateJobPayloadResolver) ToCreateJobSuccess() (*CreateJobSuccessResolver, bool)
func (*CreateJobPayloadResolver) ToInputErrors ¶ added in v1.2.0
func (r *CreateJobPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)
type CreateJobSuccessResolver ¶ added in v1.2.0
type CreateJobSuccessResolver struct {
// contains filtered or unexported fields
}
func NewCreateJobSuccess ¶ added in v1.2.0
func NewCreateJobSuccess(app chainlink.Application, job *job.Job) *CreateJobSuccessResolver
func (*CreateJobSuccessResolver) Job ¶ added in v1.2.0
func (r *CreateJobSuccessResolver) Job() *JobResolver
type CreateNodePayloadResolver ¶
type CreateNodePayloadResolver struct {
// contains filtered or unexported fields
}
func NewCreateNodePayloadResolver ¶
func NewCreateNodePayloadResolver(node *types.Node) *CreateNodePayloadResolver
func (*CreateNodePayloadResolver) ToCreateNodeSuccess ¶
func (r *CreateNodePayloadResolver) ToCreateNodeSuccess() (*CreateNodeSuccessResolve, bool)
type CreateNodeSuccessResolve ¶
type CreateNodeSuccessResolve struct {
// contains filtered or unexported fields
}
func NewCreateNodeSuccessResolve ¶
func NewCreateNodeSuccessResolve(node types.Node) *CreateNodeSuccessResolve
func (*CreateNodeSuccessResolve) Node ¶
func (r *CreateNodeSuccessResolve) Node() *NodeResolver
type CreateOCR2KeyBundlePayloadResolver ¶ added in v1.2.0
type CreateOCR2KeyBundlePayloadResolver struct {
// contains filtered or unexported fields
}
CreateOCR2KeyBundlePayloadResolver defines the create OCR2 Key bundle mutation resolver
func NewCreateOCR2KeyBundlePayload ¶ added in v1.2.0
func NewCreateOCR2KeyBundlePayload(key *ocr2key.KeyBundle) *CreateOCR2KeyBundlePayloadResolver
NewCreateOCR2KeyBundlePayload returns the create OCR2 key bundle resolver
func (*CreateOCR2KeyBundlePayloadResolver) ToCreateOCR2KeyBundleSuccess ¶ added in v1.2.0
func (r *CreateOCR2KeyBundlePayloadResolver) ToCreateOCR2KeyBundleSuccess() (*CreateOCR2KeyBundleSuccessResolver, bool)
ToCreateOCR2KeyBundleSuccess resolves the create OCR2 key bundle success
type CreateOCR2KeyBundleSuccessResolver ¶ added in v1.2.0
type CreateOCR2KeyBundleSuccessResolver struct {
// contains filtered or unexported fields
}
CreateOCR2KeyBundleSuccessResolver defines the create OCR2 key bundle success resolver
func NewCreateOCR2KeyBundleSuccess ¶ added in v1.2.0
func NewCreateOCR2KeyBundleSuccess(key *ocr2key.KeyBundle) *CreateOCR2KeyBundleSuccessResolver
NewCreateOCR2KeyBundleSuccess returns the create OCR2 key bundle success resolver
func (*CreateOCR2KeyBundleSuccessResolver) Bundle ¶ added in v1.2.0
func (r *CreateOCR2KeyBundleSuccessResolver) Bundle() *OCR2KeyBundleResolver
Bundle resolves the creates OCR2 key bundle
type CreateOCRKeyBundlePayloadResolver ¶
type CreateOCRKeyBundlePayloadResolver struct {
// contains filtered or unexported fields
}
func NewCreateOCRKeyBundlePayload ¶ added in v1.2.0
func NewCreateOCRKeyBundlePayload(key *ocrkey.KeyV2) *CreateOCRKeyBundlePayloadResolver
func (*CreateOCRKeyBundlePayloadResolver) ToCreateOCRKeyBundleSuccess ¶ added in v1.2.0
func (r *CreateOCRKeyBundlePayloadResolver) ToCreateOCRKeyBundleSuccess() (*CreateOCRKeyBundleSuccessResolver, bool)
type CreateOCRKeyBundleSuccessResolver ¶ added in v1.2.0
type CreateOCRKeyBundleSuccessResolver struct {
// contains filtered or unexported fields
}
func NewCreateOCRKeyBundleSuccess ¶ added in v1.2.0
func NewCreateOCRKeyBundleSuccess(key *ocrkey.KeyV2) *CreateOCRKeyBundleSuccessResolver
func (*CreateOCRKeyBundleSuccessResolver) Bundle ¶ added in v1.2.0
func (r *CreateOCRKeyBundleSuccessResolver) Bundle() *OCRKeyBundleResolver
type CreateP2PKeyPayloadResolver ¶
type CreateP2PKeyPayloadResolver struct {
// contains filtered or unexported fields
}
func NewCreateP2PKeyPayload ¶ added in v1.2.0
func NewCreateP2PKeyPayload(key p2pkey.KeyV2) *CreateP2PKeyPayloadResolver
func (*CreateP2PKeyPayloadResolver) P2PKey ¶ added in v1.2.0
func (r *CreateP2PKeyPayloadResolver) P2PKey() P2PKeyResolver
func (*CreateP2PKeyPayloadResolver) ToCreateP2PKeySuccess ¶ added in v1.2.0
func (r *CreateP2PKeyPayloadResolver) ToCreateP2PKeySuccess() (*CreateP2PKeySuccessResolver, bool)
type CreateP2PKeySuccessResolver ¶ added in v1.2.0
type CreateP2PKeySuccessResolver struct {
// contains filtered or unexported fields
}
func NewCreateP2PKeySuccess ¶ added in v1.2.0
func NewCreateP2PKeySuccess(key p2pkey.KeyV2) *CreateP2PKeySuccessResolver
func (*CreateP2PKeySuccessResolver) P2PKey ¶ added in v1.2.0
func (r *CreateP2PKeySuccessResolver) P2PKey() P2PKeyResolver
type CreateVRFKeyPayloadResolver ¶
type CreateVRFKeyPayloadResolver struct {
// contains filtered or unexported fields
}
func NewCreateVRFKeyPayloadResolver ¶
func NewCreateVRFKeyPayloadResolver(key vrfkey.KeyV2) *CreateVRFKeyPayloadResolver
func (*CreateVRFKeyPayloadResolver) Key ¶
func (r *CreateVRFKeyPayloadResolver) Key() VRFKeyResolver
type CronSpecResolver ¶
type CronSpecResolver struct {
// contains filtered or unexported fields
}
func (*CronSpecResolver) CreatedAt ¶
func (r *CronSpecResolver) CreatedAt() graphql.Time
CreatedAt resolves the spec's created at timestamp.
func (*CronSpecResolver) Schedule ¶
func (r *CronSpecResolver) Schedule() string
type DeleteAPITokenPayloadResolver ¶
type DeleteAPITokenPayloadResolver struct {
// contains filtered or unexported fields
}
func NewDeleteAPITokenPayload ¶
func NewDeleteAPITokenPayload(token *auth.Token, inputErrs map[string]string) *DeleteAPITokenPayloadResolver
func (*DeleteAPITokenPayloadResolver) ToDeleteAPITokenSuccess ¶
func (r *DeleteAPITokenPayloadResolver) ToDeleteAPITokenSuccess() (*DeleteAPITokenSuccessResolver, bool)
func (*DeleteAPITokenPayloadResolver) ToInputErrors ¶
func (r *DeleteAPITokenPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)
type DeleteAPITokenSuccessResolver ¶
type DeleteAPITokenSuccessResolver struct {
// contains filtered or unexported fields
}
func NewDeleteAPITokenSuccess ¶
func NewDeleteAPITokenSuccess(token *auth.Token) *DeleteAPITokenSuccessResolver
func (*DeleteAPITokenSuccessResolver) Token ¶
func (r *DeleteAPITokenSuccessResolver) Token() *APITokenResolver
type DeleteBridgeConflictErrorResolver ¶
type DeleteBridgeConflictErrorResolver struct {
// contains filtered or unexported fields
}
func NewDeleteBridgeConflictError ¶
func NewDeleteBridgeConflictError(message string) *DeleteBridgeConflictErrorResolver
func (*DeleteBridgeConflictErrorResolver) Code ¶
func (r *DeleteBridgeConflictErrorResolver) Code() ErrorCode
func (*DeleteBridgeConflictErrorResolver) Message ¶
func (r *DeleteBridgeConflictErrorResolver) Message() string
type DeleteBridgeInvalidNameErrorResolver ¶
type DeleteBridgeInvalidNameErrorResolver struct {
// contains filtered or unexported fields
}
func NewDeleteBridgeInvalidNameError ¶
func NewDeleteBridgeInvalidNameError(message string) *DeleteBridgeInvalidNameErrorResolver
func (*DeleteBridgeInvalidNameErrorResolver) Code ¶
func (r *DeleteBridgeInvalidNameErrorResolver) Code() ErrorCode
func (*DeleteBridgeInvalidNameErrorResolver) Message ¶
func (r *DeleteBridgeInvalidNameErrorResolver) Message() string
type DeleteBridgePayloadResolver ¶
type DeleteBridgePayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewDeleteBridgePayload ¶
func NewDeleteBridgePayload(bridge *bridges.BridgeType, err error) *DeleteBridgePayloadResolver
func (*DeleteBridgePayloadResolver) ToDeleteBridgeConflictError ¶
func (r *DeleteBridgePayloadResolver) ToDeleteBridgeConflictError() (*DeleteBridgeConflictErrorResolver, bool)
func (*DeleteBridgePayloadResolver) ToDeleteBridgeInvalidNameError ¶
func (r *DeleteBridgePayloadResolver) ToDeleteBridgeInvalidNameError() (*DeleteBridgeInvalidNameErrorResolver, bool)
func (*DeleteBridgePayloadResolver) ToDeleteBridgeSuccess ¶
func (r *DeleteBridgePayloadResolver) ToDeleteBridgeSuccess() (*DeleteBridgeSuccessResolver, bool)
type DeleteBridgeSuccessResolver ¶
type DeleteBridgeSuccessResolver struct {
// contains filtered or unexported fields
}
func NewDeleteBridgeSuccess ¶
func NewDeleteBridgeSuccess(bridge *bridges.BridgeType) *DeleteBridgeSuccessResolver
func (*DeleteBridgeSuccessResolver) Bridge ¶
func (r *DeleteBridgeSuccessResolver) Bridge() *BridgeResolver
type DeleteCSAKeyPayloadResolver ¶
type DeleteCSAKeyPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewDeleteCSAKeyPayload ¶
func NewDeleteCSAKeyPayload(key csakey.KeyV2, err error) *DeleteCSAKeyPayloadResolver
func (*DeleteCSAKeyPayloadResolver) ToDeleteCSAKeySuccess ¶
func (r *DeleteCSAKeyPayloadResolver) ToDeleteCSAKeySuccess() (*DeleteCSAKeySuccessResolver, bool)
type DeleteCSAKeySuccessResolver ¶
type DeleteCSAKeySuccessResolver struct {
// contains filtered or unexported fields
}
func NewDeleteCSAKeySuccess ¶
func NewDeleteCSAKeySuccess(key csakey.KeyV2) *DeleteCSAKeySuccessResolver
func (*DeleteCSAKeySuccessResolver) CSAKey ¶
func (r *DeleteCSAKeySuccessResolver) CSAKey() *CSAKeyResolver
type DeleteChainPayloadResolver ¶
type DeleteChainPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewDeleteChainPayload ¶
func NewDeleteChainPayload(chain *types.DBChain, err error) *DeleteChainPayloadResolver
func (*DeleteChainPayloadResolver) ToDeleteChainSuccess ¶
func (r *DeleteChainPayloadResolver) ToDeleteChainSuccess() (*DeleteChainSuccessResolver, bool)
type DeleteChainSuccessResolver ¶
type DeleteChainSuccessResolver struct {
// contains filtered or unexported fields
}
func NewDeleteChainSuccess ¶
func NewDeleteChainSuccess(chain types.DBChain) *DeleteChainSuccessResolver
func (*DeleteChainSuccessResolver) Chain ¶
func (r *DeleteChainSuccessResolver) Chain() *ChainResolver
type DeleteFeedsManagerChainConfigPayloadResolver ¶ added in v1.5.0
type DeleteFeedsManagerChainConfigPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewDeleteFeedsManagerChainConfigPayload ¶ added in v1.5.0
func NewDeleteFeedsManagerChainConfigPayload(cfg *feeds.ChainConfig, err error) *DeleteFeedsManagerChainConfigPayloadResolver
func (*DeleteFeedsManagerChainConfigPayloadResolver) ToDeleteFeedsManagerChainConfigSuccess ¶ added in v1.5.0
func (r *DeleteFeedsManagerChainConfigPayloadResolver) ToDeleteFeedsManagerChainConfigSuccess() (*DeleteFeedsManagerChainConfigSuccessResolver, bool)
type DeleteFeedsManagerChainConfigSuccessResolver ¶ added in v1.5.0
type DeleteFeedsManagerChainConfigSuccessResolver struct {
// contains filtered or unexported fields
}
func NewDeleteFeedsManagerChainConfigSuccess ¶ added in v1.5.0
func NewDeleteFeedsManagerChainConfigSuccess(cfg feeds.ChainConfig) *DeleteFeedsManagerChainConfigSuccessResolver
func (*DeleteFeedsManagerChainConfigSuccessResolver) ChainConfig ¶ added in v1.5.0
func (r *DeleteFeedsManagerChainConfigSuccessResolver) ChainConfig() *FeedsManagerChainConfigResolver
type DeleteJobPayloadResolver ¶ added in v1.2.0
type DeleteJobPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewDeleteJobPayload ¶ added in v1.2.0
func NewDeleteJobPayload(app chainlink.Application, j *job.Job, err error) *DeleteJobPayloadResolver
func (*DeleteJobPayloadResolver) ToDeleteJobSuccess ¶ added in v1.2.0
func (r *DeleteJobPayloadResolver) ToDeleteJobSuccess() (*DeleteJobSuccessResolver, bool)
type DeleteJobSuccessResolver ¶ added in v1.2.0
type DeleteJobSuccessResolver struct {
// contains filtered or unexported fields
}
func NewDeleteJobSuccess ¶ added in v1.2.0
func NewDeleteJobSuccess(app chainlink.Application, job *job.Job) *DeleteJobSuccessResolver
func (*DeleteJobSuccessResolver) Job ¶ added in v1.2.0
func (r *DeleteJobSuccessResolver) Job() *JobResolver
type DeleteNodePayloadResolver ¶
type DeleteNodePayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewDeleteNodePayloadResolver ¶
func NewDeleteNodePayloadResolver(node *types.Node, err error) *DeleteNodePayloadResolver
func (*DeleteNodePayloadResolver) ToDeleteNodeSuccess ¶
func (r *DeleteNodePayloadResolver) ToDeleteNodeSuccess() (*DeleteNodeSuccessResolver, bool)
type DeleteNodeSuccessResolver ¶
type DeleteNodeSuccessResolver struct {
// contains filtered or unexported fields
}
func NewDeleteNodeSuccessResolver ¶
func NewDeleteNodeSuccessResolver(node *types.Node) *DeleteNodeSuccessResolver
func (*DeleteNodeSuccessResolver) Node ¶
func (r *DeleteNodeSuccessResolver) Node() *NodeResolver
type DeleteOCR2KeyBundlePayloadResolver ¶ added in v1.2.0
type DeleteOCR2KeyBundlePayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
DeleteOCR2KeyBundlePayloadResolver defines the delete OCR2 Key bundle mutation resolver
func NewDeleteOCR2KeyBundlePayloadResolver ¶ added in v1.2.0
func NewDeleteOCR2KeyBundlePayloadResolver(key *ocr2key.KeyBundle, err error) *DeleteOCR2KeyBundlePayloadResolver
NewDeleteOCR2KeyBundlePayloadResolver returns the delete OCR2 key bundle payload resolver
func (*DeleteOCR2KeyBundlePayloadResolver) ToDeleteOCR2KeyBundleSuccess ¶ added in v1.2.0
func (r *DeleteOCR2KeyBundlePayloadResolver) ToDeleteOCR2KeyBundleSuccess() (*DeleteOCR2KeyBundleSuccessResolver, bool)
ToDeleteOCR2KeyBundleSuccess resolves the delete OCR2 key bundle success
type DeleteOCR2KeyBundleSuccessResolver ¶ added in v1.2.0
type DeleteOCR2KeyBundleSuccessResolver struct {
// contains filtered or unexported fields
}
DeleteOCR2KeyBundleSuccessResolver defines the delete OCR2 key bundle success resolver
func NewDeleteOCR2KeyBundleSuccessResolver ¶ added in v1.2.0
func NewDeleteOCR2KeyBundleSuccessResolver(key *ocr2key.KeyBundle) *DeleteOCR2KeyBundleSuccessResolver
NewDeleteOCR2KeyBundleSuccessResolver returns the delete OCR2 key bundle success resolver
func (*DeleteOCR2KeyBundleSuccessResolver) Bundle ¶ added in v1.2.0
func (r *DeleteOCR2KeyBundleSuccessResolver) Bundle() *OCR2KeyBundleResolver
Bundle resolves the creates OCR2 key bundle
type DeleteOCRKeyBundlePayloadResolver ¶
type DeleteOCRKeyBundlePayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewDeleteOCRKeyBundlePayloadResolver ¶
func NewDeleteOCRKeyBundlePayloadResolver(key ocrkey.KeyV2, err error) *DeleteOCRKeyBundlePayloadResolver
func (*DeleteOCRKeyBundlePayloadResolver) ToDeleteOCRKeyBundleSuccess ¶
func (r *DeleteOCRKeyBundlePayloadResolver) ToDeleteOCRKeyBundleSuccess() (*DeleteOCRKeyBundleSuccessResolver, bool)
type DeleteOCRKeyBundleSuccessResolver ¶
type DeleteOCRKeyBundleSuccessResolver struct {
// contains filtered or unexported fields
}
func NewDeleteOCRKeyBundleSuccessResolver ¶
func NewDeleteOCRKeyBundleSuccessResolver(key ocrkey.KeyV2) *DeleteOCRKeyBundleSuccessResolver
func (*DeleteOCRKeyBundleSuccessResolver) Bundle ¶
func (r *DeleteOCRKeyBundleSuccessResolver) Bundle() OCRKeyBundleResolver
type DeleteP2PKeyPayloadResolver ¶
type DeleteP2PKeyPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewDeleteP2PKeyPayload ¶ added in v1.2.0
func NewDeleteP2PKeyPayload(p2pKey p2pkey.KeyV2, err error) *DeleteP2PKeyPayloadResolver
func (*DeleteP2PKeyPayloadResolver) ToDeleteP2PKeySuccess ¶
func (r *DeleteP2PKeyPayloadResolver) ToDeleteP2PKeySuccess() (*DeleteP2PKeySuccessResolver, bool)
type DeleteP2PKeySuccessResolver ¶
type DeleteP2PKeySuccessResolver struct {
// contains filtered or unexported fields
}
func NewDeleteP2PKeySuccess ¶ added in v1.2.0
func NewDeleteP2PKeySuccess(p2pKey p2pkey.KeyV2) *DeleteP2PKeySuccessResolver
func (*DeleteP2PKeySuccessResolver) P2PKey ¶ added in v1.2.0
func (r *DeleteP2PKeySuccessResolver) P2PKey() P2PKeyResolver
type DeleteVRFKeyPayloadResolver ¶
type DeleteVRFKeyPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewDeleteVRFKeyPayloadResolver ¶
func NewDeleteVRFKeyPayloadResolver(key vrfkey.KeyV2, err error) *DeleteVRFKeyPayloadResolver
func (*DeleteVRFKeyPayloadResolver) ToDeleteVRFKeySuccess ¶
func (r *DeleteVRFKeyPayloadResolver) ToDeleteVRFKeySuccess() (*DeleteVRFKeySuccessResolver, bool)
type DeleteVRFKeySuccessResolver ¶
type DeleteVRFKeySuccessResolver struct {
// contains filtered or unexported fields
}
func NewDeleteVRFKeySuccessResolver ¶
func NewDeleteVRFKeySuccessResolver(key vrfkey.KeyV2) *DeleteVRFKeySuccessResolver
func (*DeleteVRFKeySuccessResolver) Key ¶
func (r *DeleteVRFKeySuccessResolver) Key() VRFKeyResolver
type DirectRequestSpecResolver ¶
type DirectRequestSpecResolver struct {
// contains filtered or unexported fields
}
func (*DirectRequestSpecResolver) ContractAddress ¶
func (r *DirectRequestSpecResolver) ContractAddress() string
ContractAddress resolves the spec's contract address.
func (*DirectRequestSpecResolver) CreatedAt ¶
func (r *DirectRequestSpecResolver) CreatedAt() graphql.Time
CreatedAt resolves the spec's created at timestamp.
func (*DirectRequestSpecResolver) EVMChainID ¶
func (r *DirectRequestSpecResolver) EVMChainID() *string
EVMChainID resolves the spec's evm chain id.
func (*DirectRequestSpecResolver) MinContractPaymentLinkJuels ¶ added in v1.4.0
func (r *DirectRequestSpecResolver) MinContractPaymentLinkJuels() string
MinContractPaymentLinkJuels resolves the spec's min contract payment link.
func (*DirectRequestSpecResolver) MinIncomingConfirmations ¶
func (r *DirectRequestSpecResolver) MinIncomingConfirmations() int32
MinIncomingConfirmations resolves the spec's min incoming confirmations.
func (*DirectRequestSpecResolver) MinIncomingConfirmationsEnv ¶
func (r *DirectRequestSpecResolver) MinIncomingConfirmationsEnv() bool
EVMChainID resolves the spec's evm chain id.
func (*DirectRequestSpecResolver) Requesters ¶
func (r *DirectRequestSpecResolver) Requesters() *[]string
Requesters resolves the spec's evm chain id.
type DismissJobErrorPayloadResolver ¶ added in v1.2.0
type DismissJobErrorPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewDismissJobErrorPayload ¶ added in v1.2.0
func NewDismissJobErrorPayload(specError *job.SpecError, err error) *DismissJobErrorPayloadResolver
func (*DismissJobErrorPayloadResolver) ToDismissJobErrorSuccess ¶ added in v1.2.0
func (r *DismissJobErrorPayloadResolver) ToDismissJobErrorSuccess() (*DismissJobErrorSuccessResolver, bool)
type DismissJobErrorSuccessResolver ¶ added in v1.2.0
type DismissJobErrorSuccessResolver struct {
// contains filtered or unexported fields
}
func NewDismissJobErrorSuccess ¶ added in v1.2.0
func NewDismissJobErrorSuccess(specError *job.SpecError) *DismissJobErrorSuccessResolver
func (*DismissJobErrorSuccessResolver) JobError ¶ added in v1.2.0
func (r *DismissJobErrorSuccessResolver) JobError() *JobErrorResolver
type ETHKeyResolver ¶ added in v1.2.0
type ETHKeyResolver struct {
// contains filtered or unexported fields
}
func NewETHKey ¶ added in v1.2.0
func NewETHKey(key ETHKey) *ETHKeyResolver
func NewETHKeys ¶ added in v1.2.0
func NewETHKeys(keys []ETHKey) []*ETHKeyResolver
func (*ETHKeyResolver) Address ¶ added in v1.2.0
func (r *ETHKeyResolver) Address() string
func (*ETHKeyResolver) Chain ¶ added in v1.2.0
func (r *ETHKeyResolver) Chain(ctx context.Context) (*ChainResolver, error)
func (*ETHKeyResolver) CreatedAt ¶ added in v1.2.0
func (r *ETHKeyResolver) CreatedAt() graphql.Time
func (*ETHKeyResolver) ETHBalance ¶ added in v1.2.0
func (r *ETHKeyResolver) ETHBalance(ctx context.Context) *string
ETHBalance returns the ETH balance available
func (*ETHKeyResolver) IsDisabled ¶ added in v1.8.0
func (r *ETHKeyResolver) IsDisabled() bool
func (*ETHKeyResolver) LINKBalance ¶ added in v1.2.0
func (r *ETHKeyResolver) LINKBalance(ctx context.Context) *string
func (*ETHKeyResolver) MaxGasPriceWei ¶ added in v1.2.0
func (r *ETHKeyResolver) MaxGasPriceWei() *string
func (*ETHKeyResolver) UpdatedAt ¶ added in v1.2.0
func (r *ETHKeyResolver) UpdatedAt() graphql.Time
type ETHKeysPayloadResolver ¶ added in v1.2.0
type ETHKeysPayloadResolver struct {
// contains filtered or unexported fields
}
func NewETHKeysPayload ¶ added in v1.2.0
func NewETHKeysPayload(keys []ETHKey) *ETHKeysPayloadResolver
func (*ETHKeysPayloadResolver) Results ¶ added in v1.2.0
func (r *ETHKeysPayloadResolver) Results() []*ETHKeyResolver
type EthTransactionAttemptResolver ¶ added in v1.2.0
type EthTransactionAttemptResolver struct {
// contains filtered or unexported fields
}
func NewEthTransactionAttempt ¶ added in v1.2.0
func NewEthTransactionAttempt(attmpt txmgr.EthTxAttempt) *EthTransactionAttemptResolver
func NewEthTransactionsAttempts ¶ added in v1.2.0
func NewEthTransactionsAttempts(results []txmgr.EthTxAttempt) []*EthTransactionAttemptResolver
func (*EthTransactionAttemptResolver) GasPrice ¶ added in v1.2.0
func (r *EthTransactionAttemptResolver) GasPrice() string
func (*EthTransactionAttemptResolver) Hash ¶ added in v1.2.0
func (r *EthTransactionAttemptResolver) Hash() string
func (*EthTransactionAttemptResolver) Hex ¶ added in v1.2.0
func (r *EthTransactionAttemptResolver) Hex() string
func (*EthTransactionAttemptResolver) SentAt ¶ added in v1.2.0
func (r *EthTransactionAttemptResolver) SentAt() *string
type EthTransactionPayloadResolver ¶ added in v1.2.0
type EthTransactionPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewEthTransactionPayload ¶ added in v1.2.0
func NewEthTransactionPayload(tx *txmgr.EthTx, err error) *EthTransactionPayloadResolver
func (*EthTransactionPayloadResolver) ToEthTransaction ¶ added in v1.2.0
func (r *EthTransactionPayloadResolver) ToEthTransaction() (*EthTransactionResolver, bool)
type EthTransactionResolver ¶ added in v1.2.0
type EthTransactionResolver struct {
// contains filtered or unexported fields
}
func NewEthTransaction ¶ added in v1.2.0
func NewEthTransaction(tx txmgr.EthTx) *EthTransactionResolver
func NewEthTransactions ¶ added in v1.2.0
func NewEthTransactions(results []txmgr.EthTx) []*EthTransactionResolver
func (*EthTransactionResolver) Attempts ¶ added in v1.2.0
func (r *EthTransactionResolver) Attempts(ctx context.Context) ([]*EthTransactionAttemptResolver, error)
func (*EthTransactionResolver) Chain ¶ added in v1.2.0
func (r *EthTransactionResolver) Chain(ctx context.Context) (*ChainResolver, error)
Chain resolves the node's chain object field.
func (*EthTransactionResolver) Data ¶ added in v1.2.0
func (r *EthTransactionResolver) Data() hexutil.Bytes
func (*EthTransactionResolver) EVMChainID ¶ added in v1.2.0
func (r *EthTransactionResolver) EVMChainID() graphql.ID
func (*EthTransactionResolver) From ¶ added in v1.2.0
func (r *EthTransactionResolver) From() string
func (*EthTransactionResolver) GasLimit ¶ added in v1.2.0
func (r *EthTransactionResolver) GasLimit() string
func (*EthTransactionResolver) GasPrice ¶ added in v1.2.0
func (r *EthTransactionResolver) GasPrice(ctx context.Context) string
func (*EthTransactionResolver) Hash ¶ added in v1.2.0
func (r *EthTransactionResolver) Hash(ctx context.Context) string
func (*EthTransactionResolver) Hex ¶ added in v1.2.0
func (r *EthTransactionResolver) Hex(ctx context.Context) string
func (*EthTransactionResolver) Nonce ¶ added in v1.2.0
func (r *EthTransactionResolver) Nonce() *string
func (*EthTransactionResolver) SentAt ¶ added in v1.2.0
func (r *EthTransactionResolver) SentAt(ctx context.Context) *string
func (*EthTransactionResolver) State ¶ added in v1.2.0
func (r *EthTransactionResolver) State() string
func (*EthTransactionResolver) To ¶ added in v1.2.0
func (r *EthTransactionResolver) To() string
func (*EthTransactionResolver) Value ¶ added in v1.2.0
func (r *EthTransactionResolver) Value() string
type EthTransactionsAttemptsPayloadResolver ¶ added in v1.2.0
type EthTransactionsAttemptsPayloadResolver struct {
// contains filtered or unexported fields
}
func NewEthTransactionsAttemptsPayload ¶ added in v1.2.0
func NewEthTransactionsAttemptsPayload(results []txmgr.EthTxAttempt, total int32) *EthTransactionsAttemptsPayloadResolver
func (*EthTransactionsAttemptsPayloadResolver) Metadata ¶ added in v1.2.0
func (r *EthTransactionsAttemptsPayloadResolver) Metadata() *PaginationMetadataResolver
func (*EthTransactionsAttemptsPayloadResolver) Results ¶ added in v1.2.0
func (r *EthTransactionsAttemptsPayloadResolver) Results() []*EthTransactionAttemptResolver
type EthTransactionsPayloadResolver ¶ added in v1.2.0
type EthTransactionsPayloadResolver struct {
// contains filtered or unexported fields
}
func NewEthTransactionsPayload ¶ added in v1.2.0
func NewEthTransactionsPayload(results []txmgr.EthTx, total int32) *EthTransactionsPayloadResolver
func (*EthTransactionsPayloadResolver) Metadata ¶ added in v1.2.0
func (r *EthTransactionsPayloadResolver) Metadata() *PaginationMetadataResolver
func (*EthTransactionsPayloadResolver) Results ¶ added in v1.2.0
func (r *EthTransactionsPayloadResolver) Results() []*EthTransactionResolver
type FeaturesPayloadResolver ¶
type FeaturesPayloadResolver struct {
// contains filtered or unexported fields
}
func NewFeaturesPayloadResolver ¶
func NewFeaturesPayloadResolver(cfg config.FeatureFlags) *FeaturesPayloadResolver
func (*FeaturesPayloadResolver) ToFeatures ¶
func (r *FeaturesPayloadResolver) ToFeatures() (*FeaturesResolver, bool)
type FeaturesResolver ¶
type FeaturesResolver struct {
// contains filtered or unexported fields
}
func NewFeaturesResolver ¶
func NewFeaturesResolver(cfg config.FeatureFlags) *FeaturesResolver
func (*FeaturesResolver) CSA ¶
func (r *FeaturesResolver) CSA() bool
CSA resolves to whether CSA Keys are enabled
func (*FeaturesResolver) FeedsManager ¶
func (r *FeaturesResolver) FeedsManager() bool
FeedsManager resolves to whether the Feeds Manager is enabled for the UI
type FeedsManagerChainConfigResolver ¶ added in v1.5.0
type FeedsManagerChainConfigResolver struct {
// contains filtered or unexported fields
}
func NewFeedsManagerChainConfig ¶ added in v1.5.0
func NewFeedsManagerChainConfig(cfg feeds.ChainConfig) *FeedsManagerChainConfigResolver
func NewFeedsManagerChainConfigs ¶ added in v1.5.0
func NewFeedsManagerChainConfigs(cfgs []feeds.ChainConfig) []*FeedsManagerChainConfigResolver
func (*FeedsManagerChainConfigResolver) AccountAddr ¶ added in v1.5.0
func (r *FeedsManagerChainConfigResolver) AccountAddr() string
AccountAddr resolves the chain configs's account address.
func (*FeedsManagerChainConfigResolver) AdminAddr ¶ added in v1.5.0
func (r *FeedsManagerChainConfigResolver) AdminAddr() string
AdminAddr resolves the chain configs's admin address.
func (*FeedsManagerChainConfigResolver) ChainID ¶ added in v1.5.0
func (r *FeedsManagerChainConfigResolver) ChainID() string
ChainID resolves the chain configs's chain id.
func (*FeedsManagerChainConfigResolver) ChainType ¶ added in v1.5.0
func (r *FeedsManagerChainConfigResolver) ChainType() string
ChainType resolves the chain configs's chain type.
func (*FeedsManagerChainConfigResolver) FluxMonitorJobConfig ¶ added in v1.5.0
func (r *FeedsManagerChainConfigResolver) FluxMonitorJobConfig() *FluxMonitorJobConfigResolver
FluxMonitorJobConfig resolves the chain configs's Flux Monitor Config.
func (*FeedsManagerChainConfigResolver) ID ¶ added in v1.5.0
func (r *FeedsManagerChainConfigResolver) ID() graphql.ID
ID resolves the chain configs's unique identifier.
func (*FeedsManagerChainConfigResolver) OCR1JobConfig ¶ added in v1.5.0
func (r *FeedsManagerChainConfigResolver) OCR1JobConfig() *OCR1JobConfigResolver
OCR1JobConfig resolves the chain configs's OCR1 Config.
func (*FeedsManagerChainConfigResolver) OCR2JobConfig ¶ added in v1.5.0
func (r *FeedsManagerChainConfigResolver) OCR2JobConfig() *OCR2JobConfigResolver
OCR2JobConfig resolves the chain configs's OCR2 Config.
type FeedsManagerPayloadResolver ¶
type FeedsManagerPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewFeedsManagerPayload ¶
func NewFeedsManagerPayload(mgr *feeds.FeedsManager, err error) *FeedsManagerPayloadResolver
func (*FeedsManagerPayloadResolver) ToFeedsManager ¶
func (r *FeedsManagerPayloadResolver) ToFeedsManager() (*FeedsManagerResolver, bool)
ToFeedsManager implements the FeedsManager union type of the payload
type FeedsManagerResolver ¶
type FeedsManagerResolver struct {
// contains filtered or unexported fields
}
FeedsManagerResolver resolves the FeedsManager type.
func NewFeedsManager ¶
func NewFeedsManager(mgr feeds.FeedsManager) *FeedsManagerResolver
func NewFeedsManagers ¶
func NewFeedsManagers(mgrs []feeds.FeedsManager) []*FeedsManagerResolver
func (*FeedsManagerResolver) ChainConfigs ¶ added in v1.5.0
func (r *FeedsManagerResolver) ChainConfigs(ctx context.Context) ([]*FeedsManagerChainConfigResolver, error)
func (*FeedsManagerResolver) CreatedAt ¶
func (r *FeedsManagerResolver) CreatedAt() graphql.Time
CreatedAt resolves the chains's created at field.
func (*FeedsManagerResolver) ID ¶
func (r *FeedsManagerResolver) ID() graphql.ID
ID resolves the feed managers's unique identifier.
func (*FeedsManagerResolver) IsConnectionActive ¶
func (r *FeedsManagerResolver) IsConnectionActive() bool
IsConnectionActive resolves the feed managers's isConnectionActive field.
func (*FeedsManagerResolver) JobProposals ¶
func (r *FeedsManagerResolver) JobProposals(ctx context.Context) ([]*JobProposalResolver, error)
func (*FeedsManagerResolver) Name ¶
func (r *FeedsManagerResolver) Name() string
Name resolves the feed managers's name field.
func (*FeedsManagerResolver) PublicKey ¶
func (r *FeedsManagerResolver) PublicKey() string
PublicKey resolves the feed managers's public key field.
func (*FeedsManagerResolver) URI ¶
func (r *FeedsManagerResolver) URI() string
URI resolves the feed managers's uri field.
type FeedsManagersPayloadResolver ¶
type FeedsManagersPayloadResolver struct {
// contains filtered or unexported fields
}
FeedsManagersPayloadResolver resolves a list of feeds managers
func NewFeedsManagersPayload ¶
func NewFeedsManagersPayload(feedsManagers []feeds.FeedsManager) *FeedsManagersPayloadResolver
func (*FeedsManagersPayloadResolver) Results ¶
func (r *FeedsManagersPayloadResolver) Results() []*FeedsManagerResolver
Results returns the feeds managers.
type FluxMonitorJobConfigResolver ¶ added in v1.5.0
type FluxMonitorJobConfigResolver struct {
// contains filtered or unexported fields
}
func (*FluxMonitorJobConfigResolver) Enabled ¶ added in v1.5.0
func (r *FluxMonitorJobConfigResolver) Enabled() bool
type FluxMonitorSpecResolver ¶
type FluxMonitorSpecResolver struct {
// contains filtered or unexported fields
}
func (*FluxMonitorSpecResolver) AbsoluteThreshold ¶
func (r *FluxMonitorSpecResolver) AbsoluteThreshold() float64
AbsoluteThreshold resolves the spec's absolute deviation threshold.
func (*FluxMonitorSpecResolver) ContractAddress ¶
func (r *FluxMonitorSpecResolver) ContractAddress() string
ContractAddress resolves the spec's contract address.
func (*FluxMonitorSpecResolver) CreatedAt ¶
func (r *FluxMonitorSpecResolver) CreatedAt() graphql.Time
CreatedAt resolves the spec's created at timestamp.
func (*FluxMonitorSpecResolver) DrumbeatEnabled ¶
func (r *FluxMonitorSpecResolver) DrumbeatEnabled() bool
AbsoluteThreshold resolves the spec's absolute threshold.
func (*FluxMonitorSpecResolver) DrumbeatRandomDelay ¶
func (r *FluxMonitorSpecResolver) DrumbeatRandomDelay() *string
DrumbeatRandomDelay resolves the spec's drumbeat random delay.
func (*FluxMonitorSpecResolver) DrumbeatSchedule ¶
func (r *FluxMonitorSpecResolver) DrumbeatSchedule() *string
DrumbeatSchedule resolves the spec's drumbeat schedule.
func (*FluxMonitorSpecResolver) EVMChainID ¶
func (r *FluxMonitorSpecResolver) EVMChainID() *string
EVMChainID resolves the spec's evm chain id.
func (*FluxMonitorSpecResolver) IdleTimerDisabled ¶
func (r *FluxMonitorSpecResolver) IdleTimerDisabled() bool
IdleTimerDisabled resolves the spec's idle timer disabled flag.
func (*FluxMonitorSpecResolver) IdleTimerPeriod ¶
func (r *FluxMonitorSpecResolver) IdleTimerPeriod() string
IdleTimerPeriod resolves the spec's idle timer period.
func (*FluxMonitorSpecResolver) MinPayment ¶
func (r *FluxMonitorSpecResolver) MinPayment() *string
MinPayment resolves the spec's min payment.
func (*FluxMonitorSpecResolver) PollTimerDisabled ¶
func (r *FluxMonitorSpecResolver) PollTimerDisabled() bool
PollTimerDisabled resolves the spec's poll timer disabled flag.
func (*FluxMonitorSpecResolver) PollTimerPeriod ¶
func (r *FluxMonitorSpecResolver) PollTimerPeriod() string
PollTimerPeriod resolves the spec's poll timer period.
func (*FluxMonitorSpecResolver) Threshold ¶
func (r *FluxMonitorSpecResolver) Threshold() float64
Threshold resolves the spec's deviation threshold.
type GasEstimatorMode ¶
type GasEstimatorMode string
const ( GasEstimatorModeBlockHistory GasEstimatorMode = "BLOCK_HISTORY" GasEstimatorModeFixedPrice GasEstimatorMode = "FIXED_PRICE" GasEstimatorModeOptimism2 GasEstimatorMode = "OPTIMISM2" GasEstimatorModeL2Suggested GasEstimatorMode = "L2_SUGGESTED" )
func ToGasEstimatorMode ¶
func ToGasEstimatorMode(s string) (GasEstimatorMode, error)
type GetSQLLoggingPayloadResolver ¶ added in v1.2.0
type GetSQLLoggingPayloadResolver struct {
// contains filtered or unexported fields
}
func NewGetSQLLoggingPayload ¶ added in v1.2.0
func NewGetSQLLoggingPayload(enabled bool) *GetSQLLoggingPayloadResolver
func (*GetSQLLoggingPayloadResolver) ToSQLLogging ¶ added in v1.2.0
func (r *GetSQLLoggingPayloadResolver) ToSQLLogging() (*SQLLoggingResolver, bool)
type GlobalLogLevelPayloadResolver ¶ added in v1.2.0
type GlobalLogLevelPayloadResolver struct {
// contains filtered or unexported fields
}
func NewGlobalLogLevelPayload ¶ added in v1.2.0
func NewGlobalLogLevelPayload(lgLvl string) *GlobalLogLevelPayloadResolver
func (*GlobalLogLevelPayloadResolver) ToGlobalLogLevel ¶ added in v1.2.0
func (r *GlobalLogLevelPayloadResolver) ToGlobalLogLevel() (*GlobalLogLevelResolver, bool)
type GlobalLogLevelResolver ¶ added in v1.2.0
type GlobalLogLevelResolver struct {
// contains filtered or unexported fields
}
func GlobalLogLevel ¶ added in v1.2.0
func GlobalLogLevel(lvl string) *GlobalLogLevelResolver
func (*GlobalLogLevelResolver) Level ¶ added in v1.2.0
func (r *GlobalLogLevelResolver) Level() (LogLevel, error)
type InputErrorResolver ¶
type InputErrorResolver struct {
// contains filtered or unexported fields
}
func NewInputError ¶
func NewInputError(path, message string) *InputErrorResolver
func (*InputErrorResolver) Code ¶
func (r *InputErrorResolver) Code() ErrorCode
func (*InputErrorResolver) Message ¶
func (r *InputErrorResolver) Message() string
func (*InputErrorResolver) Path ¶
func (r *InputErrorResolver) Path() string
type InputErrorsResolver ¶
type InputErrorsResolver struct {
// contains filtered or unexported fields
}
InputErrorsResolver groups a slice of input errors
func NewInputErrors ¶
func NewInputErrors(iers []*InputErrorResolver) *InputErrorsResolver
func (*InputErrorsResolver) Errors ¶
func (r *InputErrorsResolver) Errors() []*InputErrorResolver
type JobAlreadyExistsErrorResolver ¶ added in v1.2.0
type JobAlreadyExistsErrorResolver struct {
// contains filtered or unexported fields
}
JobAlreadyExistsErrorResolver -
func NewJobAlreadyExistsError ¶ added in v1.2.0
func NewJobAlreadyExistsError(message string) *JobAlreadyExistsErrorResolver
NewJobAlreadyExistsError -
func (*JobAlreadyExistsErrorResolver) Code ¶ added in v1.2.0
func (r *JobAlreadyExistsErrorResolver) Code() ErrorCode
Code -
func (*JobAlreadyExistsErrorResolver) Message ¶ added in v1.2.0
func (r *JobAlreadyExistsErrorResolver) Message() string
Message -
type JobErrorResolver ¶
type JobErrorResolver struct {
// contains filtered or unexported fields
}
JobErrorResolver resolves a Job Error
func NewJobError ¶
func NewJobError(specError job.SpecError) *JobErrorResolver
func NewJobErrors ¶
func NewJobErrors(specErrors []job.SpecError) []*JobErrorResolver
func (*JobErrorResolver) CreatedAt ¶
func (r *JobErrorResolver) CreatedAt() graphql.Time
CreatedAt resolves the job error's created at timestamp.
func (*JobErrorResolver) Description ¶
func (r *JobErrorResolver) Description() string
Description resolves the job error's description.
func (*JobErrorResolver) ID ¶
func (r *JobErrorResolver) ID() graphql.ID
ID resolves the job error's id.
func (*JobErrorResolver) Occurrences ¶
func (r *JobErrorResolver) Occurrences() int32
Occurrences resolves the job error's number of occurrences.
func (*JobErrorResolver) UpdatedAt ¶ added in v1.2.0
func (r *JobErrorResolver) UpdatedAt() graphql.Time
UpdatedAt resolves the job error's updated at timestamp.
type JobPayloadResolver ¶
type JobPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewJobPayload ¶
func NewJobPayload(app chainlink.Application, j *job.Job, err error) *JobPayloadResolver
func (*JobPayloadResolver) ToJob ¶
func (r *JobPayloadResolver) ToJob() (*JobResolver, bool)
ToJob implements the JobPayload union type of the payload
type JobProposalPayloadResolver ¶
type JobProposalPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
JobProposalPayloadResolver resolves the job proposal payload type
func NewJobProposalPayload ¶
func NewJobProposalPayload(jp *feeds.JobProposal, err error) *JobProposalPayloadResolver
NewJobProposalPayload creates a new job proposal payload
func (*JobProposalPayloadResolver) ToJobProposal ¶
func (r *JobProposalPayloadResolver) ToJobProposal() (*JobProposalResolver, bool)
ToJobProposal resolves to the job proposal resolver
type JobProposalResolver ¶
type JobProposalResolver struct {
// contains filtered or unexported fields
}
JobProposalResolver resolves the Job Proposal type
func NewJobProposal ¶
func NewJobProposal(jp *feeds.JobProposal) *JobProposalResolver
NewJobProposal creates a new JobProposalResolver
func NewJobProposals ¶
func NewJobProposals(jps []feeds.JobProposal) []*JobProposalResolver
func (*JobProposalResolver) ExternalJobID ¶
func (r *JobProposalResolver) ExternalJobID() *string
ExternalJobID resolves to the job proposal ExternalJobID
func (*JobProposalResolver) FeedsManager ¶
func (r *JobProposalResolver) FeedsManager(ctx context.Context) (*FeedsManagerResolver, error)
FeedsManager resolves the job proposal's feeds manager object field.
func (*JobProposalResolver) ID ¶
func (r *JobProposalResolver) ID() graphql.ID
ID resolves to the job proposal ID
func (*JobProposalResolver) JobID ¶ added in v1.3.0
func (r *JobProposalResolver) JobID(ctx context.Context) (*string, error)
JobID resolves to the job proposal JobID if it has an ExternalJobID
func (*JobProposalResolver) LatestSpec ¶ added in v1.2.0
func (r *JobProposalResolver) LatestSpec(ctx context.Context) (*JobProposalSpecResolver, error)
LatestSpec returns the spec with the highest version number.
func (*JobProposalResolver) MultiAddrs ¶
func (r *JobProposalResolver) MultiAddrs() []string
MultiAddrs resolves to the job proposal MultiAddrs
func (*JobProposalResolver) PendingUpdate ¶ added in v1.2.0
func (r *JobProposalResolver) PendingUpdate() bool
PendingUpdate resolves to whether the job proposal has a pending update.
func (*JobProposalResolver) RemoteUUID ¶ added in v1.2.0
func (r *JobProposalResolver) RemoteUUID(ctx context.Context) string
RemoteUUID returns the remote FMS UUID of the proposal.
func (*JobProposalResolver) Specs ¶ added in v1.2.0
func (r *JobProposalResolver) Specs(ctx context.Context) ([]*JobProposalSpecResolver, error)
Specs returns all spec proposals associated with the proposal.
func (*JobProposalResolver) Status ¶
func (r *JobProposalResolver) Status() JobProposalStatus
Status resolves to the job proposal Status
type JobProposalSpecResolver ¶ added in v1.2.0
type JobProposalSpecResolver struct {
// contains filtered or unexported fields
}
JobProposalSpecResolver resolves the Job Proposal Spec type.
func NewJobProposalSpec ¶ added in v1.2.0
func NewJobProposalSpec(spec *feeds.JobProposalSpec) *JobProposalSpecResolver
NewJobProposalSpec creates a new JobProposalSpecResolver.
func NewJobProposalSpecs ¶ added in v1.2.0
func NewJobProposalSpecs(specs []feeds.JobProposalSpec) []*JobProposalSpecResolver
NewJobProposalSpecs creates a slice of JobProposalSpecResolvers.
func (*JobProposalSpecResolver) CreatedAt ¶ added in v1.2.0
func (r *JobProposalSpecResolver) CreatedAt() graphql.Time
CreatedAt resolves to the job proposal spec's created at timestamp
func (*JobProposalSpecResolver) Definition ¶ added in v1.2.0
func (r *JobProposalSpecResolver) Definition() string
Definition resolves to the job proposal spec definition
func (*JobProposalSpecResolver) ID ¶ added in v1.2.0
func (r *JobProposalSpecResolver) ID() graphql.ID
ID resolves to the job proposal spec ID
func (*JobProposalSpecResolver) Status ¶ added in v1.2.0
func (r *JobProposalSpecResolver) Status() SpecStatus
Status resolves to the job proposal spec's status
func (*JobProposalSpecResolver) StatusUpdatedAt ¶ added in v1.2.0
func (r *JobProposalSpecResolver) StatusUpdatedAt() graphql.Time
StatusUpdatedAt resolves to the the last timestamp that the spec status was updated.
func (*JobProposalSpecResolver) UpdatedAt ¶ added in v1.2.0
func (r *JobProposalSpecResolver) UpdatedAt() graphql.Time
UpdatedAt resolves to the job proposal spec's updated at timestamp
func (*JobProposalSpecResolver) Version ¶ added in v1.2.0
func (r *JobProposalSpecResolver) Version() int32
Version resolves to the job proposal spec version
type JobProposalStatus ¶
type JobProposalStatus string
const ( PENDING JobProposalStatus = "PENDING" APPROVED JobProposalStatus = "APPROVED" REJECTED JobProposalStatus = "REJECTED" CANCELLED JobProposalStatus = "CANCELLED" )
func ToJobProposalStatus ¶
func ToJobProposalStatus(s feeds.JobProposalStatus) (JobProposalStatus, error)
type JobResolver ¶
type JobResolver struct {
// contains filtered or unexported fields
}
JobResolver resolves the Job type.
func NewJob ¶
func NewJob(app chainlink.Application, j job.Job) *JobResolver
func NewJobs ¶
func NewJobs(app chainlink.Application, jobs []job.Job) []*JobResolver
func (*JobResolver) CreatedAt ¶
func (r *JobResolver) CreatedAt() graphql.Time
CreatedAt resolves the job's created at timestamp.
func (*JobResolver) Errors ¶
func (r *JobResolver) Errors(ctx context.Context) ([]*JobErrorResolver, error)
Errors resolves the job's top level errors.
func (*JobResolver) ExternalJobID ¶
func (r *JobResolver) ExternalJobID() string
ExternalJobID resolves the job's external job id.
func (*JobResolver) ForwardingAllowed ¶ added in v1.8.0
func (r *JobResolver) ForwardingAllowed() *bool
ForwardingAllowed sets whether txs submitted by this job should be forwarded when possible.
func (*JobResolver) GasLimit ¶ added in v1.7.0
func (r *JobResolver) GasLimit() *int32
GasLimit resolves the job's gas limit.
func (*JobResolver) MaxTaskDuration ¶
func (r *JobResolver) MaxTaskDuration() string
MaxTaskDuration resolves the job's max task duration.
func (*JobResolver) ObservationSource ¶
func (r *JobResolver) ObservationSource() string
ObservationSource resolves the job's observation source.
This could potentially be moved to a dataloader in the future as we are fetching it from a relationship.
func (*JobResolver) Runs ¶
func (r *JobResolver) Runs(ctx context.Context, args struct { Offset *int32 Limit *int32 }) (*JobRunsPayloadResolver, error)
Runs fetches the runs for a Job.
func (*JobResolver) SchemaVersion ¶
func (r *JobResolver) SchemaVersion() int32
SchemaVersion resolves the job's schema version.
func (*JobResolver) Type ¶ added in v1.2.0
func (r *JobResolver) Type() string
Type resolves the job's type.
type JobRunPayloadResolver ¶ added in v1.2.0
type JobRunPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewJobRunPayload ¶ added in v1.2.0
func NewJobRunPayload(jr *pipeline.Run, app chainlink.Application, err error) *JobRunPayloadResolver
func (*JobRunPayloadResolver) ToJobRun ¶ added in v1.2.0
func (r *JobRunPayloadResolver) ToJobRun() (*JobRunResolver, bool)
type JobRunResolver ¶
type JobRunResolver struct {
// contains filtered or unexported fields
}
func NewJobRun ¶
func NewJobRun(run pipeline.Run, app chainlink.Application) *JobRunResolver
func NewJobRuns ¶
func NewJobRuns(runs []pipeline.Run, app chainlink.Application) []*JobRunResolver
func (*JobRunResolver) AllErrors ¶
func (r *JobRunResolver) AllErrors() []string
func (*JobRunResolver) CreatedAt ¶
func (r *JobRunResolver) CreatedAt() graphql.Time
func (*JobRunResolver) FatalErrors ¶
func (r *JobRunResolver) FatalErrors() []string
func (*JobRunResolver) FinishedAt ¶
func (r *JobRunResolver) FinishedAt() *graphql.Time
func (*JobRunResolver) ID ¶
func (r *JobRunResolver) ID() graphql.ID
func (*JobRunResolver) Inputs ¶
func (r *JobRunResolver) Inputs() string
func (*JobRunResolver) Job ¶ added in v1.2.0
func (r *JobRunResolver) Job(ctx context.Context) (*JobResolver, error)
func (*JobRunResolver) Outputs ¶
func (r *JobRunResolver) Outputs() []*string
func (*JobRunResolver) PipelineSpecID ¶
func (r *JobRunResolver) PipelineSpecID() graphql.ID
func (*JobRunResolver) Status ¶ added in v1.2.0
func (r *JobRunResolver) Status() JobRunStatus
func (*JobRunResolver) TaskRuns ¶
func (r *JobRunResolver) TaskRuns() []*TaskRunResolver
TaskRuns resolves the job run's task runs
This could be moved to a data loader later, which means also modifying to ORM to not get everything at once
type JobRunStatus ¶ added in v1.2.0
type JobRunStatus string
const ( JobRunStatusUnknown JobRunStatus = "UNKNOWN" JobRunStatusRunning JobRunStatus = "RUNNING" JobRunStatusSuspended JobRunStatus = "SUSPENDED" JobRunStatusErrored JobRunStatus = "ERRORED" JobRunStatusCompleted JobRunStatus = "COMPLETED" )
func NewJobRunStatus ¶ added in v1.2.0
func NewJobRunStatus(status pipeline.RunStatus) JobRunStatus
type JobRunsPayloadResolver ¶ added in v1.2.0
type JobRunsPayloadResolver struct {
// contains filtered or unexported fields
}
JobRunsPayloadResolver resolves a page of job runs
func NewJobRunsPayload ¶ added in v1.2.0
func NewJobRunsPayload(runs []pipeline.Run, total int32, app chainlink.Application) *JobRunsPayloadResolver
func (*JobRunsPayloadResolver) Metadata ¶ added in v1.2.0
func (r *JobRunsPayloadResolver) Metadata() *PaginationMetadataResolver
Metadata returns the pagination metadata.
func (*JobRunsPayloadResolver) Results ¶ added in v1.2.0
func (r *JobRunsPayloadResolver) Results() []*JobRunResolver
Results returns the job runs.
type JobsPayloadResolver ¶
type JobsPayloadResolver struct {
// contains filtered or unexported fields
}
JobsPayloadResolver resolves a page of jobs
func NewJobsPayload ¶
func NewJobsPayload(app chainlink.Application, jobs []job.Job, total int32) *JobsPayloadResolver
func (*JobsPayloadResolver) Metadata ¶
func (r *JobsPayloadResolver) Metadata() *PaginationMetadataResolver
Metadata returns the pagination metadata.
func (*JobsPayloadResolver) Results ¶
func (r *JobsPayloadResolver) Results() []*JobResolver
Results returns the jobs.
type KeeperSpecResolver ¶
type KeeperSpecResolver struct {
// contains filtered or unexported fields
}
func (*KeeperSpecResolver) ContractAddress ¶
func (r *KeeperSpecResolver) ContractAddress() string
ContractAddress resolves the spec's contract address.
func (*KeeperSpecResolver) CreatedAt ¶
func (r *KeeperSpecResolver) CreatedAt() graphql.Time
CreatedAt resolves the spec's created at timestamp.
func (*KeeperSpecResolver) EVMChainID ¶
func (r *KeeperSpecResolver) EVMChainID() *string
EVMChainID resolves the spec's evm chain id.
func (*KeeperSpecResolver) FromAddress ¶
func (r *KeeperSpecResolver) FromAddress() *string
FromAddress resolves the spec's from contract address.
Because VRF has an non required field of the same name, we have to be consistent in our return value of using a *string instead of a string even though this is a required field for the KeeperSpec.
type KeySpecificChainConfigInput ¶
type KeySpecificChainConfigInput struct { Address string Config ChainConfigInput }
type KeySpecificChainConfigResolver ¶
type KeySpecificChainConfigResolver struct {
// contains filtered or unexported fields
}
func NewKeySpecificChainConfig ¶
func NewKeySpecificChainConfig(address string, cfg types.ChainCfg) *KeySpecificChainConfigResolver
func (*KeySpecificChainConfigResolver) Address ¶
func (r *KeySpecificChainConfigResolver) Address() string
func (*KeySpecificChainConfigResolver) Config ¶
func (r *KeySpecificChainConfigResolver) Config() *ChainConfigResolver
type NodePayloadResolver ¶
type NodePayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewNodePayloadResolver ¶
func NewNodePayloadResolver(node *types.Node, err error) *NodePayloadResolver
func (*NodePayloadResolver) ToNode ¶
func (r *NodePayloadResolver) ToNode() (*NodeResolver, bool)
ToNode resolves the Node object to be returned if it is found
type NodeResolver ¶
type NodeResolver struct {
// contains filtered or unexported fields
}
NodeResolver resolves the Node type.
func NewNode ¶
func NewNode(node types.Node) *NodeResolver
func NewNodes ¶
func NewNodes(nodes []types.Node) []*NodeResolver
func (*NodeResolver) Chain ¶
func (r *NodeResolver) Chain(ctx context.Context) (*ChainResolver, error)
Chain resolves the node's chain object field.
func (*NodeResolver) CreatedAt ¶
func (r *NodeResolver) CreatedAt() graphql.Time
CreatedAt resolves the node's created at field.
func (*NodeResolver) HTTPURL ¶
func (r *NodeResolver) HTTPURL() string
HTTPURL resolves the node's http url field.
func (*NodeResolver) ID ¶
func (r *NodeResolver) ID() graphql.ID
ID resolves the node's unique identifier.
func (*NodeResolver) Name ¶
func (r *NodeResolver) Name() string
Name resolves the node's name field.
func (*NodeResolver) State ¶ added in v1.3.0
func (r *NodeResolver) State() string
State resolves the node state
func (*NodeResolver) UpdatedAt ¶
func (r *NodeResolver) UpdatedAt() graphql.Time
UpdatedAt resolves the node's updated at field.
func (*NodeResolver) WSURL ¶
func (r *NodeResolver) WSURL() string
WSURL resolves the node's websocket url field.
type NodesPayloadResolver ¶
type NodesPayloadResolver struct {
// contains filtered or unexported fields
}
func NewNodesPayload ¶
func NewNodesPayload(nodes []types.Node, total int32) *NodesPayloadResolver
func (*NodesPayloadResolver) Metadata ¶
func (r *NodesPayloadResolver) Metadata() *PaginationMetadataResolver
func (*NodesPayloadResolver) Results ¶
func (r *NodesPayloadResolver) Results() []*NodeResolver
type NotFoundErrorResolver ¶
type NotFoundErrorResolver struct {
// contains filtered or unexported fields
}
func NewNotFoundError ¶
func NewNotFoundError(message string) *NotFoundErrorResolver
func (*NotFoundErrorResolver) Code ¶
func (r *NotFoundErrorResolver) Code() ErrorCode
func (*NotFoundErrorResolver) Message ¶
func (r *NotFoundErrorResolver) Message() string
type NotFoundErrorUnionType ¶
type NotFoundErrorUnionType struct {
// contains filtered or unexported fields
}
func (*NotFoundErrorUnionType) ToNotFoundError ¶
func (e *NotFoundErrorUnionType) ToNotFoundError() (*NotFoundErrorResolver, bool)
ToNotFoundError resolves to the not found error resolver
type OCR1JobConfigResolver ¶ added in v1.5.0
type OCR1JobConfigResolver struct {
// contains filtered or unexported fields
}
func (*OCR1JobConfigResolver) Enabled ¶ added in v1.5.0
func (r *OCR1JobConfigResolver) Enabled() bool
func (*OCR1JobConfigResolver) IsBootstrap ¶ added in v1.5.0
func (r *OCR1JobConfigResolver) IsBootstrap() bool
func (*OCR1JobConfigResolver) KeyBundleID ¶ added in v1.5.0
func (r *OCR1JobConfigResolver) KeyBundleID() *string
func (*OCR1JobConfigResolver) Multiaddr ¶ added in v1.5.0
func (r *OCR1JobConfigResolver) Multiaddr() *string
func (*OCR1JobConfigResolver) P2PPeerID ¶ added in v1.5.0
func (r *OCR1JobConfigResolver) P2PPeerID() *string
type OCR2ChainType ¶ added in v1.2.0
type OCR2ChainType string
OCR2ChainType defines OCR2 Chain Types accepted on this resolver
func ToOCR2ChainType ¶ added in v1.2.0
func ToOCR2ChainType(s string) (OCR2ChainType, error)
ToOCR2ChainType turns a valid string into a OCR2ChainType
type OCR2JobConfigResolver ¶ added in v1.5.0
type OCR2JobConfigResolver struct {
// contains filtered or unexported fields
}
func (*OCR2JobConfigResolver) Enabled ¶ added in v1.5.0
func (r *OCR2JobConfigResolver) Enabled() bool
func (*OCR2JobConfigResolver) IsBootstrap ¶ added in v1.5.0
func (r *OCR2JobConfigResolver) IsBootstrap() bool
func (*OCR2JobConfigResolver) KeyBundleID ¶ added in v1.5.0
func (r *OCR2JobConfigResolver) KeyBundleID() *string
func (*OCR2JobConfigResolver) Multiaddr ¶ added in v1.5.0
func (r *OCR2JobConfigResolver) Multiaddr() *string
func (*OCR2JobConfigResolver) P2PPeerID ¶ added in v1.5.0
func (r *OCR2JobConfigResolver) P2PPeerID() *string
type OCR2KeyBundleResolver ¶ added in v1.2.0
type OCR2KeyBundleResolver struct {
// contains filtered or unexported fields
}
OCR2KeyBundleResolver defines the OCR2 Key bundle on GQL
func NewOCR2KeyBundle ¶ added in v1.2.0
func NewOCR2KeyBundle(key ocr2key.KeyBundle) *OCR2KeyBundleResolver
NewOCR2KeyBundle creates a new GQL OCR2 key bundle resolver
func (OCR2KeyBundleResolver) ChainType ¶ added in v1.2.0
func (r OCR2KeyBundleResolver) ChainType() *OCR2ChainType
ChainType returns the OCR2 Key bundle chain type
func (OCR2KeyBundleResolver) ConfigPublicKey ¶ added in v1.2.0
func (r OCR2KeyBundleResolver) ConfigPublicKey() string
ConfigPublicKey returns the OCR2 Key bundle config public key
func (OCR2KeyBundleResolver) ID ¶ added in v1.2.0
func (r OCR2KeyBundleResolver) ID() graphql.ID
ID returns the OCR2 Key bundle ID
func (OCR2KeyBundleResolver) OffChainPublicKey ¶ added in v1.2.0
func (r OCR2KeyBundleResolver) OffChainPublicKey() string
OffChainPublicKey returns the OCR2 Key bundle off-chain public key
func (OCR2KeyBundleResolver) OnChainPublicKey ¶ added in v1.2.0
func (r OCR2KeyBundleResolver) OnChainPublicKey() string
OnChainPublicKey returns the OCR2 Key bundle on-chain public key
type OCR2KeyBundlesPayloadResolver ¶ added in v1.2.0
type OCR2KeyBundlesPayloadResolver struct {
// contains filtered or unexported fields
}
OCR2KeyBundlesPayloadResolver defines the OCR2 Key bundles query resolver
func NewOCR2KeyBundlesPayload ¶ added in v1.2.0
func NewOCR2KeyBundlesPayload(keys []ocr2key.KeyBundle) *OCR2KeyBundlesPayloadResolver
NewOCR2KeyBundlesPayload returns the OCR2 key bundles resolver
func (*OCR2KeyBundlesPayloadResolver) Results ¶ added in v1.2.0
func (r *OCR2KeyBundlesPayloadResolver) Results() []OCR2KeyBundleResolver
Results resolves the list of OCR2 key bundles
type OCR2SpecResolver ¶ added in v1.2.0
type OCR2SpecResolver struct {
// contains filtered or unexported fields
}
func (*OCR2SpecResolver) BlockchainTimeout ¶ added in v1.2.0
func (r *OCR2SpecResolver) BlockchainTimeout() *string
BlockchainTimeout resolves the spec's blockchain timeout.
func (*OCR2SpecResolver) ContractConfigConfirmations ¶ added in v1.2.0
func (r *OCR2SpecResolver) ContractConfigConfirmations() *int32
ContractConfigConfirmations resolves the spec's confirmations config.
func (*OCR2SpecResolver) ContractConfigTrackerPollInterval ¶ added in v1.2.0
func (r *OCR2SpecResolver) ContractConfigTrackerPollInterval() *string
ContractConfigTrackerPollInterval resolves the spec's contract tracker poll interval config.
func (*OCR2SpecResolver) ContractID ¶ added in v1.2.0
func (r *OCR2SpecResolver) ContractID() string
ContractID resolves the spec's contract address.
func (*OCR2SpecResolver) CreatedAt ¶ added in v1.2.0
func (r *OCR2SpecResolver) CreatedAt() graphql.Time
CreatedAt resolves the spec's created at timestamp.
func (*OCR2SpecResolver) MonitoringEndpoint ¶ added in v1.2.0
func (r *OCR2SpecResolver) MonitoringEndpoint() *string
MonitoringEndpoint resolves the spec's monitoring endpoint
func (*OCR2SpecResolver) OcrKeyBundleID ¶ added in v1.2.0
func (r *OCR2SpecResolver) OcrKeyBundleID() *string
KeyBundleID resolves the spec's key bundle id.
func (*OCR2SpecResolver) P2PV2Bootstrappers ¶ added in v1.5.0
func (r *OCR2SpecResolver) P2PV2Bootstrappers() *[]string
P2PV2Bootstrappers resolves the OCR2 spec's p2pv2 bootstrappers
func (*OCR2SpecResolver) PluginConfig ¶ added in v1.3.0
func (r *OCR2SpecResolver) PluginConfig() gqlscalar.Map
PluginConfig resolves the spec's plugin config
func (*OCR2SpecResolver) PluginType ¶ added in v1.3.0
func (r *OCR2SpecResolver) PluginType() string
PluginType resolves the spec's plugin type
func (*OCR2SpecResolver) Relay ¶ added in v1.2.0
func (r *OCR2SpecResolver) Relay() string
Relay resolves the spec's relay
func (*OCR2SpecResolver) RelayConfig ¶ added in v1.2.0
func (r *OCR2SpecResolver) RelayConfig() gqlscalar.Map
RelayConfig resolves the spec's relay config
func (*OCR2SpecResolver) TransmitterID ¶ added in v1.2.0
func (r *OCR2SpecResolver) TransmitterID() *string
TransmitterID resolves the spec's transmitter id
type OCRKeyBundleResolver ¶
type OCRKeyBundleResolver struct {
// contains filtered or unexported fields
}
func NewOCRKeyBundleResolver ¶
func NewOCRKeyBundleResolver(key ocrkey.KeyV2) OCRKeyBundleResolver
func (OCRKeyBundleResolver) ConfigPublicKey ¶
func (k OCRKeyBundleResolver) ConfigPublicKey() string
func (OCRKeyBundleResolver) ID ¶
func (k OCRKeyBundleResolver) ID() graphql.ID
func (OCRKeyBundleResolver) OffChainPublicKey ¶
func (k OCRKeyBundleResolver) OffChainPublicKey() string
func (OCRKeyBundleResolver) OnChainSigningAddress ¶
func (k OCRKeyBundleResolver) OnChainSigningAddress() string
type OCRKeyBundlesPayloadResolver ¶
type OCRKeyBundlesPayloadResolver struct {
// contains filtered or unexported fields
}
func NewOCRKeyBundlesPayloadResolver ¶
func NewOCRKeyBundlesPayloadResolver(keys []ocrkey.KeyV2) *OCRKeyBundlesPayloadResolver
func (*OCRKeyBundlesPayloadResolver) Results ¶
func (r *OCRKeyBundlesPayloadResolver) Results() []OCRKeyBundleResolver
type OCRSpecResolver ¶
type OCRSpecResolver struct {
// contains filtered or unexported fields
}
func (*OCRSpecResolver) BlockchainTimeout ¶
func (r *OCRSpecResolver) BlockchainTimeout() *string
BlockchainTimeout resolves the spec's blockchain timeout.
func (*OCRSpecResolver) BlockchainTimeoutEnv ¶
func (r *OCRSpecResolver) BlockchainTimeoutEnv() bool
BlockchainTimeoutEnv resolves whether the spec's blockchain timeout comes from an env var.
func (*OCRSpecResolver) ContractAddress ¶
func (r *OCRSpecResolver) ContractAddress() string
ContractAddress resolves the spec's contract address.
func (*OCRSpecResolver) ContractConfigConfirmations ¶
func (r *OCRSpecResolver) ContractConfigConfirmations() *int32
ContractConfigConfirmations resolves the spec's confirmations config.
func (*OCRSpecResolver) ContractConfigConfirmationsEnv ¶
func (r *OCRSpecResolver) ContractConfigConfirmationsEnv() bool
ContractConfigConfirmationsEnv resolves whether spec's confirmations config comes from an env var.
func (*OCRSpecResolver) ContractConfigTrackerPollInterval ¶
func (r *OCRSpecResolver) ContractConfigTrackerPollInterval() *string
ContractConfigTrackerPollInterval resolves the spec's contract tracker poll interval config.
func (*OCRSpecResolver) ContractConfigTrackerPollIntervalEnv ¶
func (r *OCRSpecResolver) ContractConfigTrackerPollIntervalEnv() bool
ContractConfigTrackerPollIntervalEnv resolves the whether spec's tracker poll config comes from an env var.
func (*OCRSpecResolver) ContractConfigTrackerSubscribeInterval ¶
func (r *OCRSpecResolver) ContractConfigTrackerSubscribeInterval() *string
ContractConfigTrackerSubscribeInterval resolves the spec's tracker subscribe interval config.
func (*OCRSpecResolver) ContractConfigTrackerSubscribeIntervalEnv ¶
func (r *OCRSpecResolver) ContractConfigTrackerSubscribeIntervalEnv() bool
ContractConfigTrackerSubscribeIntervalEnv resolves whether spec's tracker subscribe interval config comes from an env var.
func (*OCRSpecResolver) ContractTransmitterTransmitTimeout ¶ added in v1.2.0
func (r *OCRSpecResolver) ContractTransmitterTransmitTimeout() string
ContractTransmitterTransmitTimeout resolves the spec's contract transmitter transmit timeout.
func (*OCRSpecResolver) ContractTransmitterTransmitTimeoutEnv ¶ added in v1.2.0
func (r *OCRSpecResolver) ContractTransmitterTransmitTimeoutEnv() bool
ContractTransmitterTransmitTimeoutEnv resolves the whether spec's contract transmitter transmit timeout config comes from an env var.
func (*OCRSpecResolver) CreatedAt ¶
func (r *OCRSpecResolver) CreatedAt() graphql.Time
CreatedAt resolves the spec's created at timestamp.
func (*OCRSpecResolver) DatabaseTimeout ¶ added in v1.2.0
func (r *OCRSpecResolver) DatabaseTimeout() string
DatabaseTimeout resolves the spec's database timeout.
func (*OCRSpecResolver) DatabaseTimeoutEnv ¶ added in v1.2.0
func (r *OCRSpecResolver) DatabaseTimeoutEnv() bool
DatabaseTimeoutEnv resolves the whether spec's database timeout config comes from an env var.
func (*OCRSpecResolver) EVMChainID ¶
func (r *OCRSpecResolver) EVMChainID() *string
EVMChainID resolves the spec's evm chain id.
func (*OCRSpecResolver) IsBootstrapPeer ¶
func (r *OCRSpecResolver) IsBootstrapPeer() bool
IsBootstrapPeer resolves whether spec is a bootstrap peer.
func (*OCRSpecResolver) KeyBundleID ¶
func (r *OCRSpecResolver) KeyBundleID() *string
KeyBundleID resolves the spec's key bundle id.
func (*OCRSpecResolver) ObservationGracePeriod ¶ added in v1.2.0
func (r *OCRSpecResolver) ObservationGracePeriod() string
ObservationGracePeriod resolves the spec's observation grace period.
func (*OCRSpecResolver) ObservationGracePeriodEnv ¶ added in v1.2.0
func (r *OCRSpecResolver) ObservationGracePeriodEnv() bool
ObservationGracePeriodEnv resolves the whether spec's observation grace period config comes from an env var.
func (*OCRSpecResolver) ObservationTimeout ¶
func (r *OCRSpecResolver) ObservationTimeout() *string
ObservationTimeout resolves the spec's observation timeout
func (*OCRSpecResolver) ObservationTimeoutEnv ¶
func (r *OCRSpecResolver) ObservationTimeoutEnv() bool
ObservationTimeoutEnv resolves whether spec's observation timeout comes from an env var.
func (*OCRSpecResolver) P2PBootstrapPeers ¶
func (r *OCRSpecResolver) P2PBootstrapPeers() *[]string
P2PBootstrapPeers resolves the spec's p2p bootstrap peers
func (*OCRSpecResolver) P2PV2Bootstrappers ¶ added in v1.6.0
func (r *OCRSpecResolver) P2PV2Bootstrappers() *[]string
P2PV2Bootstrappers resolves the OCR1 spec's p2pv2 bootstrappers
func (*OCRSpecResolver) TransmitterAddress ¶
func (r *OCRSpecResolver) TransmitterAddress() *string
TransmitterAddress resolves the spec's transmitter address
type P2PKeyResolver ¶
type P2PKeyResolver struct {
// contains filtered or unexported fields
}
func NewP2PKey ¶ added in v1.2.0
func NewP2PKey(key p2pkey.KeyV2) P2PKeyResolver
func (P2PKeyResolver) ID ¶
func (k P2PKeyResolver) ID() graphql.ID
func (P2PKeyResolver) PeerID ¶
func (k P2PKeyResolver) PeerID() string
func (P2PKeyResolver) PublicKey ¶
func (k P2PKeyResolver) PublicKey() string
type P2PKeysPayloadResolver ¶
type P2PKeysPayloadResolver struct {
// contains filtered or unexported fields
}
func NewP2PKeysPayload ¶ added in v1.2.0
func NewP2PKeysPayload(keys []p2pkey.KeyV2) *P2PKeysPayloadResolver
func (*P2PKeysPayloadResolver) Results ¶
func (r *P2PKeysPayloadResolver) Results() []P2PKeyResolver
type PaginationMetadataResolver ¶
type PaginationMetadataResolver struct {
// contains filtered or unexported fields
}
func NewPaginationMetadata ¶
func NewPaginationMetadata(total int32) *PaginationMetadataResolver
func (*PaginationMetadataResolver) Total ¶
func (r *PaginationMetadataResolver) Total() int32
type RejectJobProposalSpecPayloadResolver ¶ added in v1.2.0
type RejectJobProposalSpecPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
RejectJobProposalSpecPayloadResolver resolves the reject payload response.
func NewRejectJobProposalSpecPayload ¶ added in v1.2.0
func NewRejectJobProposalSpecPayload(spec *feeds.JobProposalSpec, err error) *RejectJobProposalSpecPayloadResolver
NewRejectJobProposalSpecPayload constructs a RejectJobProposalSpecPayloadResolver.
func (*RejectJobProposalSpecPayloadResolver) ToRejectJobProposalSpecSuccess ¶ added in v1.2.0
func (r *RejectJobProposalSpecPayloadResolver) ToRejectJobProposalSpecSuccess() (*RejectJobProposalSpecSuccessResolver, bool)
ToRejectJobProposalSpecSuccess resolves to the reject job proposal spec success resolver.
type RejectJobProposalSpecSuccessResolver ¶ added in v1.2.0
type RejectJobProposalSpecSuccessResolver struct {
// contains filtered or unexported fields
}
RejectJobProposalSpecSuccessResolver resolves the rejection success response.
func NewRejectJobProposalSpecSuccess ¶ added in v1.2.0
func NewRejectJobProposalSpecSuccess(spec *feeds.JobProposalSpec) *RejectJobProposalSpecSuccessResolver
NewRejectJobProposalSpecSuccess generates the resolver.
func (*RejectJobProposalSpecSuccessResolver) Spec ¶ added in v1.2.0
func (r *RejectJobProposalSpecSuccessResolver) Spec() *JobProposalSpecResolver
Spec returns the job proposal spec.
type Resolver ¶
type Resolver struct {
App chainlink.Application
}
func (*Resolver) ApproveJobProposalSpec ¶ added in v1.2.0
func (r *Resolver) ApproveJobProposalSpec(ctx context.Context, args struct { ID graphql.ID Force *bool }) (*ApproveJobProposalSpecPayloadResolver, error)
ApproveJobProposalSpec approves the job proposal spec.
func (*Resolver) Bridge ¶
func (r *Resolver) Bridge(ctx context.Context, args struct{ ID graphql.ID }) (*BridgePayloadResolver, error)
Bridge retrieves a bridges by name.
func (*Resolver) Bridges ¶
func (r *Resolver) Bridges(ctx context.Context, args struct { Offset *int32 Limit *int32 }) (*BridgesPayloadResolver, error)
Bridges retrieves a paginated list of bridges.
func (*Resolver) CSAKeys ¶
func (r *Resolver) CSAKeys(ctx context.Context) (*CSAKeysPayloadResolver, error)
func (*Resolver) CancelJobProposalSpec ¶ added in v1.2.0
func (r *Resolver) CancelJobProposalSpec(ctx context.Context, args struct { ID graphql.ID }) (*CancelJobProposalSpecPayloadResolver, error)
CancelJobProposalSpec cancels the job proposal spec.
func (*Resolver) Chain ¶
func (r *Resolver) Chain(ctx context.Context, args struct{ ID graphql.ID }) (*ChainPayloadResolver, error)
Chain retrieves a chain by id.
func (*Resolver) Chains ¶
func (r *Resolver) Chains(ctx context.Context, args struct { Offset *int32 Limit *int32 }) (*ChainsPayloadResolver, error)
Chains retrieves a paginated list of chains.
func (*Resolver) Config ¶ added in v1.2.0
func (r *Resolver) Config(ctx context.Context) (*ConfigPayloadResolver, error)
Config retrieves the Chainlink node's configuration
func (*Resolver) ConfigV2 ¶ added in v1.10.0
func (r *Resolver) ConfigV2(ctx context.Context) (*ConfigV2PayloadResolver, error)
ConfigV2 retrieves the Chainlink node's configuration (V2 mode)
func (*Resolver) CreateAPIToken ¶
func (*Resolver) CreateBridge ¶
func (r *Resolver) CreateBridge(ctx context.Context, args struct{ Input createBridgeInput }) (*CreateBridgePayloadResolver, error)
CreateBridge creates a new bridge.
func (*Resolver) CreateCSAKey ¶
func (r *Resolver) CreateCSAKey(ctx context.Context) (*CreateCSAKeyPayloadResolver, error)
func (*Resolver) CreateChain ¶
func (r *Resolver) CreateChain(ctx context.Context, args struct { Input struct { ID graphql.ID Config ChainConfigInput KeySpecificConfigs []*KeySpecificChainConfigInput } }) (*CreateChainPayloadResolver, error)
func (*Resolver) CreateFeedsManager ¶
func (r *Resolver) CreateFeedsManager(ctx context.Context, args struct { Input *createFeedsManagerInput }) (*CreateFeedsManagerPayloadResolver, error)
func (*Resolver) CreateFeedsManagerChainConfig ¶ added in v1.5.0
func (r *Resolver) CreateFeedsManagerChainConfig(ctx context.Context, args struct { Input *createFeedsManagerChainConfigInput }) (*CreateFeedsManagerChainConfigPayloadResolver, error)
func (*Resolver) CreateNode ¶
func (*Resolver) CreateOCR2KeyBundle ¶ added in v1.2.0
func (r *Resolver) CreateOCR2KeyBundle(ctx context.Context, args struct { ChainType OCR2ChainType }) (*CreateOCR2KeyBundlePayloadResolver, error)
CreateOCR2KeyBundle resolves a create OCR2 Key bundle mutation
func (*Resolver) CreateOCRKeyBundle ¶
func (r *Resolver) CreateOCRKeyBundle(ctx context.Context) (*CreateOCRKeyBundlePayloadResolver, error)
func (*Resolver) CreateP2PKey ¶
func (r *Resolver) CreateP2PKey(ctx context.Context) (*CreateP2PKeyPayloadResolver, error)
func (*Resolver) CreateVRFKey ¶
func (r *Resolver) CreateVRFKey(ctx context.Context) (*CreateVRFKeyPayloadResolver, error)
func (*Resolver) DeleteAPIToken ¶
func (*Resolver) DeleteBridge ¶
func (r *Resolver) DeleteBridge(ctx context.Context, args struct { ID graphql.ID }) (*DeleteBridgePayloadResolver, error)
func (*Resolver) DeleteCSAKey ¶
func (r *Resolver) DeleteCSAKey(ctx context.Context, args struct { ID graphql.ID }) (*DeleteCSAKeyPayloadResolver, error)
func (*Resolver) DeleteChain ¶
func (r *Resolver) DeleteChain(ctx context.Context, args struct { ID graphql.ID }) (*DeleteChainPayloadResolver, error)
func (*Resolver) DeleteFeedsManagerChainConfig ¶ added in v1.5.0
func (*Resolver) DeleteJob ¶ added in v1.2.0
func (r *Resolver) DeleteJob(ctx context.Context, args struct { ID graphql.ID }) (*DeleteJobPayloadResolver, error)
func (*Resolver) DeleteNode ¶
func (r *Resolver) DeleteNode(ctx context.Context, args struct { ID graphql.ID }) (*DeleteNodePayloadResolver, error)
func (*Resolver) DeleteOCR2KeyBundle ¶ added in v1.2.0
func (r *Resolver) DeleteOCR2KeyBundle(ctx context.Context, args struct { ID graphql.ID }) (*DeleteOCR2KeyBundlePayloadResolver, error)
DeleteOCR2KeyBundle resolves a create OCR2 Key bundle mutation
func (*Resolver) DeleteOCRKeyBundle ¶
func (*Resolver) DeleteP2PKey ¶
func (r *Resolver) DeleteP2PKey(ctx context.Context, args struct { ID graphql.ID }) (*DeleteP2PKeyPayloadResolver, error)
func (*Resolver) DeleteVRFKey ¶
func (r *Resolver) DeleteVRFKey(ctx context.Context, args struct { ID graphql.ID }) (*DeleteVRFKeyPayloadResolver, error)
func (*Resolver) DismissJobError ¶ added in v1.2.0
func (r *Resolver) DismissJobError(ctx context.Context, args struct { ID graphql.ID }) (*DismissJobErrorPayloadResolver, error)
func (*Resolver) ETHKeys ¶ added in v1.2.0
func (r *Resolver) ETHKeys(ctx context.Context) (*ETHKeysPayloadResolver, error)
func (*Resolver) EthTransaction ¶ added in v1.2.0
func (r *Resolver) EthTransaction(ctx context.Context, args struct { Hash graphql.ID }) (*EthTransactionPayloadResolver, error)
func (*Resolver) EthTransactions ¶ added in v1.2.0
func (*Resolver) EthTransactionsAttempts ¶ added in v1.2.0
func (*Resolver) Features ¶
func (r *Resolver) Features(ctx context.Context) (*FeaturesPayloadResolver, error)
Features retrieves each featured enabled by boolean mapping
func (*Resolver) FeedsManager ¶
func (r *Resolver) FeedsManager(ctx context.Context, args struct{ ID graphql.ID }) (*FeedsManagerPayloadResolver, error)
FeedsManager retrieves a feeds manager by id.
func (*Resolver) FeedsManagers ¶
func (r *Resolver) FeedsManagers(ctx context.Context) (*FeedsManagersPayloadResolver, error)
func (*Resolver) GlobalLogLevel ¶ added in v1.2.0
func (r *Resolver) GlobalLogLevel(ctx context.Context) (*GlobalLogLevelPayloadResolver, error)
func (*Resolver) Job ¶
func (r *Resolver) Job(ctx context.Context, args struct{ ID graphql.ID }) (*JobPayloadResolver, error)
Job retrieves a job by id.
func (*Resolver) JobProposal ¶
func (r *Resolver) JobProposal(ctx context.Context, args struct { ID graphql.ID }) (*JobProposalPayloadResolver, error)
JobProposal retrieves a job proposal by ID
func (*Resolver) JobRun ¶ added in v1.2.0
func (r *Resolver) JobRun(ctx context.Context, args struct { ID graphql.ID }) (*JobRunPayloadResolver, error)
func (*Resolver) Jobs ¶
func (r *Resolver) Jobs(ctx context.Context, args struct { Offset *int32 Limit *int32 }) (*JobsPayloadResolver, error)
Jobs fetches a paginated list of jobs
func (*Resolver) Node ¶
func (r *Resolver) Node(ctx context.Context, args struct{ ID graphql.ID }) (*NodePayloadResolver, error)
Node retrieves a node by ID (Name)
func (*Resolver) Nodes ¶
func (r *Resolver) Nodes(ctx context.Context, args struct { Offset *int32 Limit *int32 }) (*NodesPayloadResolver, error)
Nodes retrieves a paginated list of nodes.
func (*Resolver) OCR2KeyBundles ¶ added in v1.2.0
func (r *Resolver) OCR2KeyBundles(ctx context.Context) (*OCR2KeyBundlesPayloadResolver, error)
OCR2KeyBundles resolves the list of OCR2 key bundles
func (*Resolver) OCRKeyBundles ¶
func (r *Resolver) OCRKeyBundles(ctx context.Context) (*OCRKeyBundlesPayloadResolver, error)
func (*Resolver) P2PKeys ¶
func (r *Resolver) P2PKeys(ctx context.Context) (*P2PKeysPayloadResolver, error)
func (*Resolver) RejectJobProposalSpec ¶ added in v1.2.0
func (r *Resolver) RejectJobProposalSpec(ctx context.Context, args struct { ID graphql.ID }) (*RejectJobProposalSpecPayloadResolver, error)
RejectJobProposalSpec rejects the job proposal spec.
func (*Resolver) RunJob ¶ added in v1.2.0
func (r *Resolver) RunJob(ctx context.Context, args struct { ID graphql.ID }) (*RunJobPayloadResolver, error)
func (*Resolver) SQLLogging ¶ added in v1.2.0
func (r *Resolver) SQLLogging(ctx context.Context) (*GetSQLLoggingPayloadResolver, error)
func (*Resolver) SetGlobalLogLevel ¶ added in v1.2.0
func (*Resolver) SetSQLLogging ¶
func (*Resolver) SolanaKeys ¶ added in v1.2.0
func (r *Resolver) SolanaKeys(ctx context.Context) (*SolanaKeysPayloadResolver, error)
func (*Resolver) UpdateBridge ¶
func (r *Resolver) UpdateBridge(ctx context.Context, args struct { ID graphql.ID Input updateBridgeInput }) (*UpdateBridgePayloadResolver, error)
func (*Resolver) UpdateChain ¶
func (r *Resolver) UpdateChain(ctx context.Context, args struct { ID graphql.ID Input struct { Enabled bool Config ChainConfigInput KeySpecificConfigs []*KeySpecificChainConfigInput } }) (*UpdateChainPayloadResolver, error)
func (*Resolver) UpdateFeedsManager ¶
func (r *Resolver) UpdateFeedsManager(ctx context.Context, args struct { ID graphql.ID Input *updateFeedsManagerInput }) (*UpdateFeedsManagerPayloadResolver, error)
func (*Resolver) UpdateFeedsManagerChainConfig ¶ added in v1.5.0
func (*Resolver) UpdateJobProposalSpecDefinition ¶ added in v1.2.0
func (r *Resolver) UpdateJobProposalSpecDefinition(ctx context.Context, args struct { ID graphql.ID Input *struct{ Definition string } }) (*UpdateJobProposalSpecDefinitionPayloadResolver, error)
UpdateJobProposalSpecDefinition updates the spec definition.
func (*Resolver) UpdateUserPassword ¶
func (r *Resolver) UpdateUserPassword(ctx context.Context, args struct { Input UpdatePasswordInput }) (*UpdatePasswordPayloadResolver, error)
type RoleNotPermittedErr ¶ added in v1.7.0
func (RoleNotPermittedErr) Error ¶ added in v1.7.0
func (e RoleNotPermittedErr) Error() string
type RunJobCannotRunErrorResolver ¶ added in v1.2.0
type RunJobCannotRunErrorResolver struct {
// contains filtered or unexported fields
}
func NewRunJobCannotRunError ¶ added in v1.2.0
func NewRunJobCannotRunError(err error) *RunJobCannotRunErrorResolver
func (*RunJobCannotRunErrorResolver) Code ¶ added in v1.2.0
func (r *RunJobCannotRunErrorResolver) Code() ErrorCode
func (*RunJobCannotRunErrorResolver) Message ¶ added in v1.2.0
func (r *RunJobCannotRunErrorResolver) Message() string
type RunJobPayloadResolver ¶ added in v1.2.0
type RunJobPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewRunJobPayload ¶ added in v1.2.0
func NewRunJobPayload(run *pipeline.Run, app chainlink.Application, err error) *RunJobPayloadResolver
func (*RunJobPayloadResolver) ToRunJobCannotRunError ¶ added in v1.2.0
func (r *RunJobPayloadResolver) ToRunJobCannotRunError() (*RunJobCannotRunErrorResolver, bool)
func (*RunJobPayloadResolver) ToRunJobSuccess ¶ added in v1.2.0
func (r *RunJobPayloadResolver) ToRunJobSuccess() (*RunJobSuccessResolver, bool)
type RunJobSuccessResolver ¶ added in v1.2.0
type RunJobSuccessResolver struct {
// contains filtered or unexported fields
}
func NewRunJobSuccess ¶ added in v1.2.0
func NewRunJobSuccess(run pipeline.Run, app chainlink.Application) *RunJobSuccessResolver
func (*RunJobSuccessResolver) JobRun ¶ added in v1.2.0
func (r *RunJobSuccessResolver) JobRun() *JobRunResolver
type SQLLoggingResolver ¶
type SQLLoggingResolver struct {
// contains filtered or unexported fields
}
func NewSQLLogging ¶
func NewSQLLogging(enabled bool) *SQLLoggingResolver
func (*SQLLoggingResolver) Enabled ¶
func (r *SQLLoggingResolver) Enabled() bool
type SetGlobalLogLevelPayloadResolver ¶ added in v1.2.0
type SetGlobalLogLevelPayloadResolver struct {
// contains filtered or unexported fields
}
func NewSetGlobalLogLevelPayload ¶ added in v1.2.0
func NewSetGlobalLogLevelPayload(lvl LogLevel, inputErrs map[string]string) *SetGlobalLogLevelPayloadResolver
func (*SetGlobalLogLevelPayloadResolver) ToInputErrors ¶ added in v1.2.0
func (r *SetGlobalLogLevelPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)
func (*SetGlobalLogLevelPayloadResolver) ToSetGlobalLogLevelSuccess ¶ added in v1.2.0
func (r *SetGlobalLogLevelPayloadResolver) ToSetGlobalLogLevelSuccess() (*SetGlobalLogLevelSuccessResolver, bool)
type SetGlobalLogLevelSuccessResolver ¶ added in v1.2.0
type SetGlobalLogLevelSuccessResolver struct {
// contains filtered or unexported fields
}
func NewSetGlobalLogLevelSuccess ¶ added in v1.2.0
func NewSetGlobalLogLevelSuccess(lvl LogLevel) *SetGlobalLogLevelSuccessResolver
func (*SetGlobalLogLevelSuccessResolver) GlobalLogLevel ¶ added in v1.2.0
func (r *SetGlobalLogLevelSuccessResolver) GlobalLogLevel() *GlobalLogLevelResolver
type SetSQLLoggingPayloadResolver ¶
type SetSQLLoggingPayloadResolver struct {
// contains filtered or unexported fields
}
func NewSetSQLLoggingPayload ¶
func NewSetSQLLoggingPayload(enabled bool) *SetSQLLoggingPayloadResolver
func (*SetSQLLoggingPayloadResolver) ToSetSQLLoggingSuccess ¶
func (r *SetSQLLoggingPayloadResolver) ToSetSQLLoggingSuccess() (*SetSQLLoggingSuccessResolver, bool)
type SetSQLLoggingSuccessResolver ¶
type SetSQLLoggingSuccessResolver struct {
// contains filtered or unexported fields
}
func NewSetSQLLoggingSuccess ¶
func NewSetSQLLoggingSuccess(enabled bool) *SetSQLLoggingSuccessResolver
func (*SetSQLLoggingSuccessResolver) SQLLogging ¶
func (r *SetSQLLoggingSuccessResolver) SQLLogging() *SQLLoggingResolver
type SingleFeedsManagerErrorResolver ¶
type SingleFeedsManagerErrorResolver struct {
// contains filtered or unexported fields
}
SingleFeedsManagerErrorResolver -
func NewSingleFeedsManagerError ¶
func NewSingleFeedsManagerError(message string) *SingleFeedsManagerErrorResolver
func (*SingleFeedsManagerErrorResolver) Code ¶
func (r *SingleFeedsManagerErrorResolver) Code() ErrorCode
func (*SingleFeedsManagerErrorResolver) Message ¶
func (r *SingleFeedsManagerErrorResolver) Message() string
type SolanaKeyResolver ¶ added in v1.2.0
type SolanaKeyResolver struct {
// contains filtered or unexported fields
}
func NewSolanaKey ¶ added in v1.2.0
func NewSolanaKey(key solkey.Key) *SolanaKeyResolver
func NewSolanaKeys ¶ added in v1.2.0
func NewSolanaKeys(keys []solkey.Key) []*SolanaKeyResolver
func (*SolanaKeyResolver) ID ¶ added in v1.2.0
func (r *SolanaKeyResolver) ID() graphql.ID
type SolanaKeysPayloadResolver ¶ added in v1.2.0
type SolanaKeysPayloadResolver struct {
// contains filtered or unexported fields
}
func NewSolanaKeysPayload ¶ added in v1.2.0
func NewSolanaKeysPayload(keys []solkey.Key) *SolanaKeysPayloadResolver
func (*SolanaKeysPayloadResolver) Results ¶ added in v1.2.0
func (r *SolanaKeysPayloadResolver) Results() []*SolanaKeyResolver
type SpecResolver ¶
type SpecResolver struct {
// contains filtered or unexported fields
}
func NewSpec ¶
func NewSpec(j job.Job) *SpecResolver
func (*SpecResolver) ToBlockhashStoreSpec ¶ added in v1.2.0
func (r *SpecResolver) ToBlockhashStoreSpec() (*BlockhashStoreSpecResolver, bool)
ToBlockhashStoreSpec returns the BlockhashStoreSpec from the SpecResolver if the job is a BlockhashStore job.
func (*SpecResolver) ToBootstrapSpec ¶ added in v1.2.0
func (r *SpecResolver) ToBootstrapSpec() (*BootstrapSpecResolver, bool)
ToBootstrapSpec resolves to the Booststrap Spec Resolver
func (*SpecResolver) ToCronSpec ¶
func (r *SpecResolver) ToCronSpec() (*CronSpecResolver, bool)
func (*SpecResolver) ToDirectRequestSpec ¶
func (r *SpecResolver) ToDirectRequestSpec() (*DirectRequestSpecResolver, bool)
func (*SpecResolver) ToFluxMonitorSpec ¶
func (r *SpecResolver) ToFluxMonitorSpec() (*FluxMonitorSpecResolver, bool)
func (*SpecResolver) ToKeeperSpec ¶
func (r *SpecResolver) ToKeeperSpec() (*KeeperSpecResolver, bool)
func (*SpecResolver) ToOCR2Spec ¶ added in v1.2.0
func (r *SpecResolver) ToOCR2Spec() (*OCR2SpecResolver, bool)
func (*SpecResolver) ToOCRSpec ¶
func (r *SpecResolver) ToOCRSpec() (*OCRSpecResolver, bool)
func (*SpecResolver) ToVRFSpec ¶
func (r *SpecResolver) ToVRFSpec() (*VRFSpecResolver, bool)
func (*SpecResolver) ToWebhookSpec ¶
func (r *SpecResolver) ToWebhookSpec() (*WebhookSpecResolver, bool)
type SpecStatus ¶ added in v1.2.0
type SpecStatus string
SpecStatus defines the enum values for GQL
const ( // revive:disable SpecStatusUnknown SpecStatus = "UNKNOWN" SpecStatusPending SpecStatus = "PENDING" SpecStatusApproved SpecStatus = "APPROVED" SpecStatusRejected SpecStatus = "REJECTED" SpecStatusCancelled SpecStatus = "CANCELLED" )
func ToSpecStatus ¶ added in v1.2.0
func ToSpecStatus(s feeds.SpecStatus) SpecStatus
ToSpecStatus converts the feeds status into the enum value.
type TaskRunResolver ¶
type TaskRunResolver struct {
// contains filtered or unexported fields
}
func NewTaskRun ¶
func NewTaskRun(tr pipeline.TaskRun) *TaskRunResolver
func NewTaskRuns ¶
func NewTaskRuns(runs []pipeline.TaskRun) []*TaskRunResolver
func (*TaskRunResolver) CreatedAt ¶
func (r *TaskRunResolver) CreatedAt() graphql.Time
func (*TaskRunResolver) DotID ¶
func (r *TaskRunResolver) DotID() string
func (*TaskRunResolver) Error ¶
func (r *TaskRunResolver) Error() *string
func (*TaskRunResolver) FinishedAt ¶
func (r *TaskRunResolver) FinishedAt() *graphql.Time
func (*TaskRunResolver) ID ¶
func (r *TaskRunResolver) ID() graphql.ID
func (*TaskRunResolver) Output ¶
func (r *TaskRunResolver) Output() string
func (*TaskRunResolver) Type ¶
func (r *TaskRunResolver) Type() string
type UpdateBridgePayloadResolver ¶
type UpdateBridgePayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewUpdateBridgePayload ¶
func NewUpdateBridgePayload(bridge *bridges.BridgeType, err error) *UpdateBridgePayloadResolver
func (*UpdateBridgePayloadResolver) ToUpdateBridgeSuccess ¶
func (r *UpdateBridgePayloadResolver) ToUpdateBridgeSuccess() (*UpdateBridgeSuccessResolver, bool)
type UpdateBridgeSuccessResolver ¶
type UpdateBridgeSuccessResolver struct {
// contains filtered or unexported fields
}
UpdateBridgePayloadResolver resolves
func NewUpdateBridgeSuccess ¶
func NewUpdateBridgeSuccess(bridge bridges.BridgeType) *UpdateBridgeSuccessResolver
func (*UpdateBridgeSuccessResolver) Bridge ¶
func (r *UpdateBridgeSuccessResolver) Bridge() *BridgeResolver
Bridge resolves the success payload's bridge.
type UpdateChainPayloadResolver ¶
type UpdateChainPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewUpdateChainPayload ¶
func (*UpdateChainPayloadResolver) ToInputErrors ¶
func (r *UpdateChainPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)
func (*UpdateChainPayloadResolver) ToUpdateChainSuccess ¶
func (r *UpdateChainPayloadResolver) ToUpdateChainSuccess() (*UpdateChainSuccessResolver, bool)
type UpdateChainSuccessResolver ¶
type UpdateChainSuccessResolver struct {
// contains filtered or unexported fields
}
func NewUpdateChainSuccess ¶
func NewUpdateChainSuccess(chain types.DBChain) *UpdateChainSuccessResolver
func (*UpdateChainSuccessResolver) Chain ¶
func (r *UpdateChainSuccessResolver) Chain() *ChainResolver
type UpdateFeedsManagerChainConfigPayloadResolver ¶ added in v1.5.0
type UpdateFeedsManagerChainConfigPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
UpdateFeedsManagerChainConfigPayloadResolver resolves the response to UpdateFeedsManagerChainConfig
func NewUpdateFeedsManagerChainConfigPayload ¶ added in v1.5.0
func NewUpdateFeedsManagerChainConfigPayload(cfg *feeds.ChainConfig, err error, inputErrs map[string]string) *UpdateFeedsManagerChainConfigPayloadResolver
func (*UpdateFeedsManagerChainConfigPayloadResolver) ToInputErrors ¶ added in v1.5.0
func (r *UpdateFeedsManagerChainConfigPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)
func (*UpdateFeedsManagerChainConfigPayloadResolver) ToUpdateFeedsManagerChainConfigSuccess ¶ added in v1.5.0
func (r *UpdateFeedsManagerChainConfigPayloadResolver) ToUpdateFeedsManagerChainConfigSuccess() (*UpdateFeedsManagerChainConfigSuccessResolver, bool)
type UpdateFeedsManagerChainConfigSuccessResolver ¶ added in v1.5.0
type UpdateFeedsManagerChainConfigSuccessResolver struct {
// contains filtered or unexported fields
}
func NewUpdateFeedsManagerChainConfigSuccessResolver ¶ added in v1.5.0
func NewUpdateFeedsManagerChainConfigSuccessResolver(cfg *feeds.ChainConfig) *UpdateFeedsManagerChainConfigSuccessResolver
func (*UpdateFeedsManagerChainConfigSuccessResolver) ChainConfig ¶ added in v1.5.0
func (r *UpdateFeedsManagerChainConfigSuccessResolver) ChainConfig() *FeedsManagerChainConfigResolver
type UpdateFeedsManagerPayloadResolver ¶
type UpdateFeedsManagerPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
UpdateFeedsManagerPayloadResolver -
func NewUpdateFeedsManagerPayload ¶
func NewUpdateFeedsManagerPayload(mgr *feeds.FeedsManager, err error, inputErrs map[string]string) *UpdateFeedsManagerPayloadResolver
func (*UpdateFeedsManagerPayloadResolver) ToInputErrors ¶
func (r *UpdateFeedsManagerPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)
func (*UpdateFeedsManagerPayloadResolver) ToUpdateFeedsManagerSuccess ¶
func (r *UpdateFeedsManagerPayloadResolver) ToUpdateFeedsManagerSuccess() (*UpdateFeedsManagerSuccessResolver, bool)
type UpdateFeedsManagerSuccessResolver ¶
type UpdateFeedsManagerSuccessResolver struct {
// contains filtered or unexported fields
}
func NewUpdateFeedsManagerSuccessResolver ¶
func NewUpdateFeedsManagerSuccessResolver(mgr feeds.FeedsManager) *UpdateFeedsManagerSuccessResolver
func (*UpdateFeedsManagerSuccessResolver) FeedsManager ¶
func (r *UpdateFeedsManagerSuccessResolver) FeedsManager() *FeedsManagerResolver
type UpdateJobProposalSpecDefinitionPayloadResolver ¶ added in v1.2.0
type UpdateJobProposalSpecDefinitionPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
UpdateJobProposalSpecDefinitionPayloadResolver generates the update spec definition payload.
func NewUpdateJobProposalSpecDefinitionPayload ¶ added in v1.2.0
func NewUpdateJobProposalSpecDefinitionPayload(spec *feeds.JobProposalSpec, err error) *UpdateJobProposalSpecDefinitionPayloadResolver
NewUpdateJobProposalSpecDefinitionPayload constructs UpdateJobProposalSpecDefinitionPayloadResolver.
func (*UpdateJobProposalSpecDefinitionPayloadResolver) ToUpdateJobProposalSpecDefinitionSuccess ¶ added in v1.2.0
func (r *UpdateJobProposalSpecDefinitionPayloadResolver) ToUpdateJobProposalSpecDefinitionSuccess() (*UpdateJobProposalSpecDefinitionSuccessResolver, bool)
ToUpdateJobProposalSpecDefinitionSuccess resolves to the update job proposal definition success resolver.
type UpdateJobProposalSpecDefinitionSuccessResolver ¶ added in v1.2.0
type UpdateJobProposalSpecDefinitionSuccessResolver struct {
// contains filtered or unexported fields
}
UpdateJobProposalSpecDefinitionSuccessResolver resolves the update success response.
func NewUpdateJobProposalSpecDefinitionSuccess ¶ added in v1.2.0
func NewUpdateJobProposalSpecDefinitionSuccess(spec *feeds.JobProposalSpec) *UpdateJobProposalSpecDefinitionSuccessResolver
NewUpdateJobProposalSpecDefinitionSuccess constructs UpdateJobProposalSpecDefinitionSuccessResolver.
func (*UpdateJobProposalSpecDefinitionSuccessResolver) Spec ¶ added in v1.2.0
func (r *UpdateJobProposalSpecDefinitionSuccessResolver) Spec() *JobProposalSpecResolver
Spec returns the job proposal spec.
type UpdatePasswordInput ¶
type UpdatePasswordPayloadResolver ¶
type UpdatePasswordPayloadResolver struct {
// contains filtered or unexported fields
}
UpdatePasswordPayloadResolver resolves the payload type
func NewUpdatePasswordPayload ¶
func NewUpdatePasswordPayload(user *sessions.User, inputErrs map[string]string) *UpdatePasswordPayloadResolver
func (*UpdatePasswordPayloadResolver) ToInputErrors ¶
func (r *UpdatePasswordPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)
func (*UpdatePasswordPayloadResolver) ToUpdatePasswordSuccess ¶
func (r *UpdatePasswordPayloadResolver) ToUpdatePasswordSuccess() (*UpdatePasswordSuccessResolver, bool)
type UpdatePasswordSuccessResolver ¶
type UpdatePasswordSuccessResolver struct {
// contains filtered or unexported fields
}
func NewUpdatePasswordSuccess ¶
func NewUpdatePasswordSuccess(user *sessions.User) *UpdatePasswordSuccessResolver
func (*UpdatePasswordSuccessResolver) User ¶
func (r *UpdatePasswordSuccessResolver) User() *UserResolver
type UserResolver ¶
type UserResolver struct {
// contains filtered or unexported fields
}
UserResolver resolves the User type
func NewUser ¶
func NewUser(user *sessions.User) *UserResolver
func (*UserResolver) CreatedAt ¶
func (r *UserResolver) CreatedAt() graphql.Time
CreatedAt resolves the user's creation date
type VRFKeyPayloadResolver ¶
type VRFKeyPayloadResolver struct { NotFoundErrorUnionType // contains filtered or unexported fields }
func NewVRFKeyPayloadResolver ¶
func NewVRFKeyPayloadResolver(key vrfkey.KeyV2, err error) *VRFKeyPayloadResolver
func (*VRFKeyPayloadResolver) ToVRFKeySuccess ¶
func (r *VRFKeyPayloadResolver) ToVRFKeySuccess() (*VRFKeySuccessResolver, bool)
type VRFKeyResolver ¶
type VRFKeyResolver struct {
// contains filtered or unexported fields
}
func NewVRFKeyResolver ¶
func NewVRFKeyResolver(key vrfkey.KeyV2) VRFKeyResolver
func (VRFKeyResolver) Compressed ¶
func (k VRFKeyResolver) Compressed() string
Compressed returns the compressed version of the public key.
func (VRFKeyResolver) Hash ¶
func (k VRFKeyResolver) Hash() string
Hash returns the hash of the VRF public key.
func (VRFKeyResolver) ID ¶
func (k VRFKeyResolver) ID() graphql.ID
ID returns the ID of the VRF key, which is the public key.
func (VRFKeyResolver) Uncompressed ¶
func (k VRFKeyResolver) Uncompressed() string
type VRFKeySuccessResolver ¶
type VRFKeySuccessResolver struct {
// contains filtered or unexported fields
}
func NewVRFKeySuccessResolver ¶
func NewVRFKeySuccessResolver(key vrfkey.KeyV2) *VRFKeySuccessResolver
func (*VRFKeySuccessResolver) Key ¶
func (r *VRFKeySuccessResolver) Key() VRFKeyResolver
type VRFKeysPayloadResolver ¶
type VRFKeysPayloadResolver struct {
// contains filtered or unexported fields
}
func NewVRFKeysPayloadResolver ¶
func NewVRFKeysPayloadResolver(keys []vrfkey.KeyV2) *VRFKeysPayloadResolver
func (*VRFKeysPayloadResolver) Results ¶
func (r *VRFKeysPayloadResolver) Results() []VRFKeyResolver
type VRFSpecResolver ¶
type VRFSpecResolver struct {
// contains filtered or unexported fields
}
func (*VRFSpecResolver) BackoffInitialDelay ¶ added in v1.4.0
func (r *VRFSpecResolver) BackoffInitialDelay() string
BackoffInitialDelay resolves the spec's backoff initial delay.
func (*VRFSpecResolver) BackoffMaxDelay ¶ added in v1.4.0
func (r *VRFSpecResolver) BackoffMaxDelay() string
BackoffMaxDelay resolves the spec's backoff max delay.
func (*VRFSpecResolver) BatchCoordinatorAddress ¶ added in v1.4.0
func (r *VRFSpecResolver) BatchCoordinatorAddress() *string
BatchCoordinatorAddress resolves the spec's batch coordinator address.
func (*VRFSpecResolver) BatchFulfillmentEnabled ¶ added in v1.4.0
func (r *VRFSpecResolver) BatchFulfillmentEnabled() bool
BatchFulfillmentEnabled resolves the spec's batch fulfillment enabled flag.
func (*VRFSpecResolver) BatchFulfillmentGasMultiplier ¶ added in v1.4.0
func (r *VRFSpecResolver) BatchFulfillmentGasMultiplier() float64
BatchFulfillmentGasMultiplier resolves the spec's batch fulfillment gas multiplier.
func (*VRFSpecResolver) ChunkSize ¶ added in v1.4.0
func (r *VRFSpecResolver) ChunkSize() int32
ChunkSize resolves the spec's chunk size.
func (*VRFSpecResolver) CoordinatorAddress ¶
func (r *VRFSpecResolver) CoordinatorAddress() string
CoordinatorAddress resolves the spec's coordinator address.
func (*VRFSpecResolver) CreatedAt ¶
func (r *VRFSpecResolver) CreatedAt() graphql.Time
CreatedAt resolves the spec's created at timestamp.
func (*VRFSpecResolver) EVMChainID ¶
func (r *VRFSpecResolver) EVMChainID() *string
EVMChainID resolves the spec's evm chain id.
func (*VRFSpecResolver) FromAddresses ¶ added in v1.3.0
func (r *VRFSpecResolver) FromAddresses() *[]string
FromAddresses resolves the spec's from addresses.
func (*VRFSpecResolver) GasLanePrice ¶ added in v1.11.0
func (r *VRFSpecResolver) GasLanePrice() *string
GasLanePrice resolves the spec's gas lane price.
func (*VRFSpecResolver) MinIncomingConfirmations ¶
func (r *VRFSpecResolver) MinIncomingConfirmations() int32
MinIncomingConfirmations resolves the spec's min incoming confirmations.
func (*VRFSpecResolver) MinIncomingConfirmationsEnv ¶ added in v1.2.0
func (r *VRFSpecResolver) MinIncomingConfirmationsEnv() bool
MinIncomingConfirmations resolves the spec's min incoming confirmations.
func (*VRFSpecResolver) PollPeriod ¶
func (r *VRFSpecResolver) PollPeriod() string
PollPeriod resolves the spec's poll period.
func (*VRFSpecResolver) PublicKey ¶
func (r *VRFSpecResolver) PublicKey() string
PublicKey resolves the spec's public key.
func (*VRFSpecResolver) RequestTimeout ¶ added in v1.2.0
func (r *VRFSpecResolver) RequestTimeout() string
RequestTimeout resolves the spec's request timeout.
func (*VRFSpecResolver) RequestedConfsDelay ¶
func (r *VRFSpecResolver) RequestedConfsDelay() int32
RequestedConfsDelay resolves the spec's requested conf delay.
type WebhookSpecResolver ¶
type WebhookSpecResolver struct {
// contains filtered or unexported fields
}
func (*WebhookSpecResolver) CreatedAt ¶
func (r *WebhookSpecResolver) CreatedAt() graphql.Time
CreatedAt resolves the spec's created at timestamp.
Source Files ¶
- api_token.go
- auth.go
- bridge.go
- config.go
- config_v2.go
- csa_keys.go
- errors.go
- eth_key.go
- eth_transaction.go
- eth_transaction_attempt.go
- evm_chain.go
- evm_chain_config.go
- features.go
- feeds_manager.go
- feeds_manager_chain_config.go
- helpers.go
- job.go
- job_error.go
- job_proposal.go
- job_proposal_spec.go
- job_run.go
- log.go
- mutation.go
- node.go
- ocr.go
- orc2_keys.go
- p2p.go
- pagination.go
- query.go
- solana_key.go
- spec.go
- task_run.go
- user.go
- vrf.go