resolver

package
v1.11.0-rc5 Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2022 License: MIT Imports: 59 Imported by: 0

Documentation

Index

Constants

View Source
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
)
View Source
const (
	LogLevelDebug = "DEBUG"
	LogLevelInfo  = "INFO"
	LogLevelWarn  = "WARN"
	LogLevelError = "ERROR"
)
View Source
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 FromChainType(ct ChainType) string

func FromGasEstimatorMode

func FromGasEstimatorMode(gsm GasEstimatorMode) string

func FromLogLevel

func FromLogLevel(logLvl LogLevel) string

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

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

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.

func (*BridgeResolver) URL

func (r *BridgeResolver) URL() string

URL resolves the bridge's url.

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

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

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 ChainType

type ChainType string
const (
	ChainTypeArbitrum ChainType = "ARBITRUM"
	ChainTypeMetis    ChainType = "METIS"
	ChainTypeOptimism ChainType = "OPTIMISM"
	ChainTypeXDAI     ChainType = "XDAI"
)

func ToChainType

func ToChainType(s string) (ChainType, error)

type ChainsPayloadResolver

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

func NewChainsPayload

func NewChainsPayload(chains []types.DBChain, total int32) *ChainsPayloadResolver

func (*ChainsPayloadResolver) Metadata

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

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

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

type CreateAPITokenSuccessResolver

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

func NewCreateAPITokenSuccess

func NewCreateAPITokenSuccess(token *auth.Token) *CreateAPITokenSuccessResolver

func (*CreateAPITokenSuccessResolver) Token

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

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

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

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 (*CreateFeedsManagerChainConfigPayloadResolver) ToInputErrors added in v1.5.0

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

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

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

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

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

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

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

type CreateVRFKeyPayloadResolver

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

func NewCreateVRFKeyPayloadResolver

func NewCreateVRFKeyPayloadResolver(key vrfkey.KeyV2) *CreateVRFKeyPayloadResolver

func (*CreateVRFKeyPayloadResolver) Key

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

type DeleteAPITokenSuccessResolver

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

func NewDeleteAPITokenSuccess

func NewDeleteAPITokenSuccess(token *auth.Token) *DeleteAPITokenSuccessResolver

func (*DeleteAPITokenSuccessResolver) Token

type DeleteBridgeConflictErrorResolver

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

func NewDeleteBridgeConflictError

func NewDeleteBridgeConflictError(message string) *DeleteBridgeConflictErrorResolver

func (*DeleteBridgeConflictErrorResolver) Code

func (*DeleteBridgeConflictErrorResolver) Message

type DeleteBridgeInvalidNameErrorResolver

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

func NewDeleteBridgeInvalidNameError

func NewDeleteBridgeInvalidNameError(message string) *DeleteBridgeInvalidNameErrorResolver

func (*DeleteBridgeInvalidNameErrorResolver) Code

func (*DeleteBridgeInvalidNameErrorResolver) Message

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

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

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

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

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

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

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

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

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

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

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

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

type ETHKey added in v1.2.0

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

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 ErrorCode

type ErrorCode string
const (
	ErrorCodeNotFound       ErrorCode = "NOT_FOUND"
	ErrorCodeInvalidInput   ErrorCode = "INVALID_INPUT"
	ErrorCodeUnprocessable  ErrorCode = "UNPROCESSABLE"
	ErrorCodeStatusConflict ErrorCode = "STATUS_CONFLICT"
)

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 (*EthTransactionAttemptResolver) Hex added in v1.2.0

func (*EthTransactionAttemptResolver) SentAt added in v1.2.0

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 (*EthTransactionResolver) Chain added in v1.2.0

Chain resolves the node's chain object field.

func (*EthTransactionResolver) Data added in v1.2.0

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 (*EthTransactionResolver) Hex added in v1.2.0

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 (*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 (*EthTransactionsAttemptsPayloadResolver) Results added in v1.2.0

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 (*EthTransactionsPayloadResolver) Results added in v1.2.0

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

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

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

OCR1JobConfig resolves the chain configs's OCR1 Config.

func (*FeedsManagerChainConfigResolver) OCR2JobConfig added in v1.5.0

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

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

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

Code -

func (*JobAlreadyExistsErrorResolver) Message added in v1.2.0

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

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

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

Specs returns all spec proposals associated with the proposal.

func (*JobProposalResolver) Status

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"
)

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) ID

func (r *JobResolver) ID() graphql.ID

ID resolves the job's id.

func (*JobResolver) MaxTaskDuration

func (r *JobResolver) MaxTaskDuration() string

MaxTaskDuration resolves the job's max task duration.

func (*JobResolver) Name

func (r *JobResolver) Name() string

Name resolves the job's name.

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) Spec

func (r *JobResolver) Spec() *SpecResolver

Spec resolves the job's spec.

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

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

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.

http://spec.graphql.org/draft/#sec-Field-Selection-Merging

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 (*KeySpecificChainConfigResolver) Config

type LogLevel

type LogLevel string

func ToLogLevel added in v1.2.0

func ToLogLevel(str string) (LogLevel, error)

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

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

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

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 (r *Resolver) CreateAPIToken(ctx context.Context, args struct {
	Input struct{ Password string }
}) (*CreateAPITokenPayloadResolver, error)

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) CreateJob added in v1.2.0

func (r *Resolver) CreateJob(ctx context.Context, args struct {
	Input struct {
		TOML string
	}
}) (*CreateJobPayloadResolver, error)

func (*Resolver) CreateNode

func (r *Resolver) CreateNode(ctx context.Context, args struct {
	Input *types.NewNode
}) (*CreateNodePayloadResolver, error)

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 (r *Resolver) DeleteAPIToken(ctx context.Context, args struct {
	Input struct{ Password string }
}) (*DeleteAPITokenPayloadResolver, error)

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 (r *Resolver) DeleteFeedsManagerChainConfig(ctx context.Context, args struct {
	ID string
}) (*DeleteFeedsManagerChainConfigPayloadResolver, error)

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 (r *Resolver) DeleteOCRKeyBundle(ctx context.Context, args struct {
	ID string
}) (*DeleteOCRKeyBundlePayloadResolver, error)

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 (r *Resolver) EthTransactions(ctx context.Context, args struct {
	Offset *int32
	Limit  *int32
}) (*EthTransactionsPayloadResolver, error)

func (*Resolver) EthTransactionsAttempts added in v1.2.0

func (r *Resolver) EthTransactionsAttempts(ctx context.Context, args struct {
	Offset *int32
	Limit  *int32
}) (*EthTransactionsAttemptsPayloadResolver, error)

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) JobRuns added in v1.2.0

func (r *Resolver) JobRuns(ctx context.Context, args struct {
	Offset *int32
	Limit  *int32
}) (*JobRunsPayloadResolver, 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 (*Resolver) SetGlobalLogLevel added in v1.2.0

func (r *Resolver) SetGlobalLogLevel(ctx context.Context, args struct {
	Level LogLevel
}) (*SetGlobalLogLevelPayloadResolver, error)

func (*Resolver) SetSQLLogging

func (r *Resolver) SetSQLLogging(ctx context.Context, args struct {
	Input struct{ Enabled bool }
}) (*SetSQLLoggingPayloadResolver, error)

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 (r *Resolver) UpdateFeedsManagerChainConfig(ctx context.Context, args struct {
	ID    string
	Input *updateFeedsManagerChainConfigInput
}) (*UpdateFeedsManagerChainConfigPayloadResolver, error)

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)

func (*Resolver) VRFKey

func (r *Resolver) VRFKey(ctx context.Context, args struct {
	ID graphql.ID
}) (*VRFKeyPayloadResolver, error)

VRFKey fetches the VRF key with the given ID.

func (*Resolver) VRFKeys

func (r *Resolver) VRFKeys(ctx context.Context) (*VRFKeysPayloadResolver, error)

VRFKeys fetches all VRF keys.

type RoleNotPermittedErr added in v1.7.0

type RoleNotPermittedErr struct {
	Role sessions.UserRole
}

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

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

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

type SingleFeedsManagerErrorResolver

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

SingleFeedsManagerErrorResolver -

func NewSingleFeedsManagerError

func NewSingleFeedsManagerError(message string) *SingleFeedsManagerErrorResolver

func (*SingleFeedsManagerErrorResolver) Code

func (*SingleFeedsManagerErrorResolver) Message

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

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

Bridge resolves the success payload's bridge.

type UpdateChainPayloadResolver

type UpdateChainPayloadResolver struct {
	NotFoundErrorUnionType
	// contains filtered or unexported fields
}

func NewUpdateChainPayload

func NewUpdateChainPayload(chain *types.DBChain, inputErrs map[string]string, err error) *UpdateChainPayloadResolver

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

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 (*UpdateFeedsManagerChainConfigPayloadResolver) ToUpdateFeedsManagerChainConfigSuccess added in v1.5.0

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

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

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

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

Spec returns the job proposal spec.

type UpdatePasswordInput

type UpdatePasswordInput struct {
	OldPassword string
	NewPassword string
}

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

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

func (*UserResolver) Email

func (r *UserResolver) Email() string

Email resolves the user's email

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

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.

Jump to

Keyboard shortcuts

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