resolver

package
v2.5.0 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2023 License: MIT Imports: 62 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"
	// OCR2ChainTypeCosmos defines OCR2 Cosmos Chain Type
	OCR2ChainTypeCosmos = "COSMOS"
	// OCR2ChainTypeSolana defines OCR2 Solana Chain Type
	OCR2ChainTypeSolana = "SOLANA"
	// OCR2ChainTypeStarkNet defines OCR2 StarkNet Chain Type
	OCR2ChainTypeStarkNet = "STARKNET"
)

These constants map to the enum type OCR2ChainType in ocr2_keys.graphql

Variables

This section is empty.

Functions

func FromLogLevel 

func FromLogLevel(logLvl LogLevel) string

func FromOCR2ChainType 

func FromOCR2ChainType(ct OCR2ChainType) string

FromOCR2ChainType returns the string (lowercased) value from a OCR2ChainType

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 

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

ApproveJobProposalSpecPayloadResolver resolves the spec payload.

func NewApproveJobProposalSpecPayload 

func NewApproveJobProposalSpecPayload(spec *feeds.JobProposalSpec, err error) *ApproveJobProposalSpecPayloadResolver

NewApproveJobProposalSpecPayload generates the spec payload resolver.

func (*ApproveJobProposalSpecPayloadResolver) ToApproveJobProposalSpecSuccess 

func (r *ApproveJobProposalSpecPayloadResolver) ToApproveJobProposalSpecSuccess() (*ApproveJobProposalSpecSuccessResolver, bool)

ToApproveJobProposalSpecSuccess resolves to the approval job proposal success resolver.

func (*ApproveJobProposalSpecPayloadResolver) ToJobAlreadyExistsError 

func (r *ApproveJobProposalSpecPayloadResolver) ToJobAlreadyExistsError() (*JobAlreadyExistsErrorResolver, bool)

ToJobAlreadyExistsError -

type ApproveJobProposalSpecSuccessResolver 

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

ApproveJobProposalSpecSuccessResolver resolves the approval success response.

func NewApproveJobProposalSpecSuccess 

func NewApproveJobProposalSpecSuccess(spec *feeds.JobProposalSpec) *ApproveJobProposalSpecSuccessResolver

NewApproveJobProposalSpecSuccess generates the resolver.

func (*ApproveJobProposalSpecSuccessResolver) Spec 

func (r *ApproveJobProposalSpecSuccessResolver) Spec() *JobProposalSpecResolver

Spec returns the job proposal spec.

type BlockHeaderFeederSpecResolver 

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

BlockHeaderFeederSpecResolver exposes the job parameters for a BlockHeaderFeederSpec.

func (*BlockHeaderFeederSpecResolver) BatchBlockhashStoreAddress 

func (b *BlockHeaderFeederSpecResolver) BatchBlockhashStoreAddress() string

BatchBlockhashStoreAddress returns the job's BatchBlockhashStoreAddress param.

func (*BlockHeaderFeederSpecResolver) BlockhashStoreAddress 

func (b *BlockHeaderFeederSpecResolver) BlockhashStoreAddress() string

BlockhashStoreAddress returns the job's BlockhashStoreAddress param.

func (*BlockHeaderFeederSpecResolver) CoordinatorV1Address 

func (b *BlockHeaderFeederSpecResolver) CoordinatorV1Address() *string

CoordinatorV1Address returns the address of the V1 Coordinator, if any.

func (*BlockHeaderFeederSpecResolver) CoordinatorV2Address 

func (b *BlockHeaderFeederSpecResolver) CoordinatorV2Address() *string

CoordinatorV2Address returns the address of the V2 Coordinator, if any.

func (*BlockHeaderFeederSpecResolver) CoordinatorV2PlusAddress added in v2.4.0 

func (b *BlockHeaderFeederSpecResolver) CoordinatorV2PlusAddress() *string

CoordinatorV2PlusAddress returns the address of the V2 Coordinator Plus, if any.

func (*BlockHeaderFeederSpecResolver) CreatedAt 

func (b *BlockHeaderFeederSpecResolver) CreatedAt() graphql.Time

CreatedAt resolves the spec's created at timestamp.

func (*BlockHeaderFeederSpecResolver) EVMChainID 

func (b *BlockHeaderFeederSpecResolver) EVMChainID() *string

EVMChainID returns the job's EVMChainID param.

func (*BlockHeaderFeederSpecResolver) FromAddresses 

func (b *BlockHeaderFeederSpecResolver) FromAddresses() *[]string

FromAddress returns the job's FromAddress param, if any.

func (*BlockHeaderFeederSpecResolver) GetBlockhashesBatchSize 

func (b *BlockHeaderFeederSpecResolver) GetBlockhashesBatchSize() int32

GetBlockhashesBatchSize returns the job's GetBlockhashesBatchSize param.

func (*BlockHeaderFeederSpecResolver) LookbackBlocks 

func (b *BlockHeaderFeederSpecResolver) LookbackBlocks() int32

LookbackBlocks returns the job's LookbackBlocks param.

func (*BlockHeaderFeederSpecResolver) PollPeriod 

func (b *BlockHeaderFeederSpecResolver) PollPeriod() string

PollPeriod return's the job's PollPeriod param.

func (*BlockHeaderFeederSpecResolver) RunTimeout 

func (b *BlockHeaderFeederSpecResolver) RunTimeout() string

RunTimeout return's the job's RunTimeout param.

func (*BlockHeaderFeederSpecResolver) StoreBlockhashesBatchSize 

func (b *BlockHeaderFeederSpecResolver) StoreBlockhashesBatchSize() int32

StoreBlockhashesBatchSize returns the job's StoreBlockhashesBatchSize param.

func (*BlockHeaderFeederSpecResolver) WaitBlocks 

func (b *BlockHeaderFeederSpecResolver) WaitBlocks() int32

WaitBlocks returns the job's WaitBlocks param.

type BlockhashStoreSpecResolver 

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

BlockhashStoreSpecResolver exposes the job parameters for a BlockhashStoreSpec.

func (*BlockhashStoreSpecResolver) BlockhashStoreAddress 

func (b *BlockhashStoreSpecResolver) BlockhashStoreAddress() string

BlockhashStoreAddress returns the job's BlockhashStoreAddress param.

func (*BlockhashStoreSpecResolver) CoordinatorV1Address 

func (b *BlockhashStoreSpecResolver) CoordinatorV1Address() *string

CoordinatorV1Address returns the address of the V1 Coordinator, if any.

func (*BlockhashStoreSpecResolver) CoordinatorV2Address 

func (b *BlockhashStoreSpecResolver) CoordinatorV2Address() *string

CoordinatorV2Address returns the address of the V2 Coordinator, if any.

func (*BlockhashStoreSpecResolver) CoordinatorV2PlusAddress added in v2.4.0 

func (b *BlockhashStoreSpecResolver) CoordinatorV2PlusAddress() *string

CoordinatorV2PlusAddress returns the address of the V2Plus Coordinator, if any.

func (*BlockhashStoreSpecResolver) CreatedAt 

func (b *BlockhashStoreSpecResolver) CreatedAt() graphql.Time

CreatedAt resolves the spec's created at timestamp.

func (*BlockhashStoreSpecResolver) EVMChainID 

func (b *BlockhashStoreSpecResolver) EVMChainID() *string

EVMChainID returns the job's EVMChainID param.

func (*BlockhashStoreSpecResolver) FromAddresses 

func (b *BlockhashStoreSpecResolver) FromAddresses() *[]string

FromAddress returns the job's FromAddress param, if any.

func (*BlockhashStoreSpecResolver) LookbackBlocks 

func (b *BlockhashStoreSpecResolver) LookbackBlocks() int32

LookbackBlocks returns the job's LookbackBlocks param.

func (*BlockhashStoreSpecResolver) PollPeriod 

func (b *BlockhashStoreSpecResolver) PollPeriod() string

PollPeriod return's the job's PollPeriod param.

func (*BlockhashStoreSpecResolver) RunTimeout 

func (b *BlockhashStoreSpecResolver) RunTimeout() string

RunTimeout return's the job's RunTimeout param.

func (*BlockhashStoreSpecResolver) TrustedBlockhashStoreAddress added in v2.5.0 

func (b *BlockhashStoreSpecResolver) TrustedBlockhashStoreAddress() *string

TrustedBlockhashStoreAddress returns the address of the job's TrustedBlockhashStoreAddress, if any.

func (*BlockhashStoreSpecResolver) TrustedBlockhashStoreBatchSize added in v2.5.0 

func (b *BlockhashStoreSpecResolver) TrustedBlockhashStoreBatchSize() int32

BatchBlockhashStoreAddress returns the job's BatchBlockhashStoreAddress param.

func (*BlockhashStoreSpecResolver) WaitBlocks 

func (b *BlockhashStoreSpecResolver) WaitBlocks() int32

WaitBlocks returns the job's WaitBlocks param.

type BootstrapSpecResolver 

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

BootstrapSpecResolver defines the Bootstrap Spec Resolver

func (*BootstrapSpecResolver) BlockchainTimeout 

func (r *BootstrapSpecResolver) BlockchainTimeout() *string

BlockchainTimeout resolves the spec's blockchain timeout

func (*BootstrapSpecResolver) ContractConfigConfirmations 

func (r *BootstrapSpecResolver) ContractConfigConfirmations() *int32

ContractConfigConfirmations resolves the spec's confirmations config.

func (*BootstrapSpecResolver) ContractConfigTrackerPollInterval 

func (r *BootstrapSpecResolver) ContractConfigTrackerPollInterval() *string

ContractConfigTrackerPollInterval resolves the spec's contract tracker poll interval config.

func (*BootstrapSpecResolver) ContractID 

func (r *BootstrapSpecResolver) ContractID() string

ContractID resolves the spec's contract address

func (*BootstrapSpecResolver) CreatedAt 

func (r *BootstrapSpecResolver) CreatedAt() graphql.Time

CreatedAt resolves the spec's created at timestamp.

func (*BootstrapSpecResolver) ID 

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

ID resolves the Bootstrap spec ID

func (*BootstrapSpecResolver) MonitoringEndpoint 

func (r *BootstrapSpecResolver) MonitoringEndpoint() *string

MonitoringEndpoint resolves the spec's monitoring endpoint

func (*BootstrapSpecResolver) Relay 

func (r *BootstrapSpecResolver) Relay() string

Relay resolves the spec's relay

func (*BootstrapSpecResolver) RelayConfig 

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 

func (r *BridgesPayloadResolver) Metadata() *PaginationMetadataResolver

Metadata returns the pagination metadata.

func (*BridgesPayloadResolver) Results 

func (r *BridgesPayloadResolver) Results() []*BridgeResolver

Results returns the bridges.

type CSAKeyExistsErrorResolver 

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

func NewCSAKeyExistsError 

func NewCSAKeyExistsError(message string) *CSAKeyExistsErrorResolver

func (*CSAKeyExistsErrorResolver) Code 

func (r *CSAKeyExistsErrorResolver) Code() ErrorCode

func (*CSAKeyExistsErrorResolver) Message 

func (r *CSAKeyExistsErrorResolver) Message() string

type CSAKeyResolver 

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

CSAKeyResolver resolves the single CSA Key object

func NewCSAKey 

func NewCSAKey(key csakey.KeyV2) *CSAKeyResolver

func NewCSAKeys 

func NewCSAKeys(keys []csakey.KeyV2) []*CSAKeyResolver

func (*CSAKeyResolver) ID 

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

ID resolves the CSA Key public key as the id.

func (*CSAKeyResolver) PublicKey 

func (r *CSAKeyResolver) PublicKey() string

PubKey resolves the CSA Key public key string.

func (*CSAKeyResolver) Version 

func (r *CSAKeyResolver) Version() int32

Version resolves the CSA Key version number.

type CSAKeysPayloadResolver 

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

func NewCSAKeysResolver 

func NewCSAKeysResolver(keys []csakey.KeyV2) *CSAKeysPayloadResolver

func (*CSAKeysPayloadResolver) Results 

func (r *CSAKeysPayloadResolver) Results() []*CSAKeyResolver

type CancelJobProposalSpecPayloadResolver 

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

CancelJobProposalSpecPayloadResolver resolves the cancel payload response.

func NewCancelJobProposalSpecPayload 

func NewCancelJobProposalSpecPayload(spec *feeds.JobProposalSpec, err error) *CancelJobProposalSpecPayloadResolver

NewCancelJobProposalSpecPayload generates the resolver.

func (*CancelJobProposalSpecPayloadResolver) ToCancelJobProposalSpecSuccess 

func (r *CancelJobProposalSpecPayloadResolver) ToCancelJobProposalSpecSuccess() (*CancelJobProposalSpecSuccessResolver, bool)

ToCancelJobProposalSpecSuccess resolves to the cancel job proposal spec success resolver.

type CancelJobProposalSpecSuccessResolver 

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

CancelJobProposalSpecSuccessResolver resolves the cancellation success response.

func NewCancelJobProposalSpecSuccess 

func NewCancelJobProposalSpecSuccess(spec *feeds.JobProposalSpec) *CancelJobProposalSpecSuccessResolver

NewCancelJobProposalSpecSuccess generates the resolver.

func (*CancelJobProposalSpecSuccessResolver) Spec 

func (r *CancelJobProposalSpecSuccessResolver) Spec() *JobProposalSpecResolver

Spec returns the job proposal spec.

type ChainPayloadResolver 

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

func NewChainPayload 

func NewChainPayload(chain types.ChainStatus, 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.ChainStatus) *ChainResolver

func NewChains 

func NewChains(chains []types.ChainStatus) []*ChainResolver

func (*ChainResolver) Config 

func (r *ChainResolver) Config() string

Config resolves the chain's configuration 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.

type ChainsPayloadResolver 

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

func NewChainsPayload 

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

func (*ChainsPayloadResolver) Metadata 

func (r *ChainsPayloadResolver) Metadata() *PaginationMetadataResolver

func (*ChainsPayloadResolver) Results 

func (r *ChainsPayloadResolver) Results() []*ChainResolver

type ConfigV2PayloadResolver 

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

func NewConfigV2Payload 

func NewConfigV2Payload(user, effective string) *ConfigV2PayloadResolver

func (*ConfigV2PayloadResolver) Effective 

func (r *ConfigV2PayloadResolver) Effective() string

func (*ConfigV2PayloadResolver) User 

func (r *ConfigV2PayloadResolver) User() string

type CreateAPITokenPayloadResolver 

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

func NewCreateAPITokenPayload 

func NewCreateAPITokenPayload(token *auth.Token, inputErrs map[string]string) *CreateAPITokenPayloadResolver

func (*CreateAPITokenPayloadResolver) ToCreateAPITokenSuccess 

func (r *CreateAPITokenPayloadResolver) ToCreateAPITokenSuccess() (*CreateAPITokenSuccessResolver, bool)

func (*CreateAPITokenPayloadResolver) ToInputErrors 

func (r *CreateAPITokenPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)

type CreateAPITokenSuccessResolver 

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

func NewCreateAPITokenSuccess 

func NewCreateAPITokenSuccess(token *auth.Token) *CreateAPITokenSuccessResolver

func (*CreateAPITokenSuccessResolver) Token 

func (r *CreateAPITokenSuccessResolver) Token() *APITokenResolver

type CreateBridgePayloadResolver 

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

CreateBridgePayloadResolver

func NewCreateBridgePayload 

func NewCreateBridgePayload(bridge bridges.BridgeType, incomingToken string) *CreateBridgePayloadResolver

func (*CreateBridgePayloadResolver) ToCreateBridgeSuccess 

func (r *CreateBridgePayloadResolver) ToCreateBridgeSuccess() (*CreateBridgeSuccessResolver, bool)

type CreateBridgeSuccessResolver 

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

func NewCreateBridgeSuccessResolver 

func NewCreateBridgeSuccessResolver(bridge bridges.BridgeType, incomingToken string) *CreateBridgeSuccessResolver

func (*CreateBridgeSuccessResolver) Bridge 

func (r *CreateBridgeSuccessResolver) Bridge() *BridgeResolver

Bridge resolves the bridge.

func (*CreateBridgeSuccessResolver) IncomingToken 

func (r *CreateBridgeSuccessResolver) IncomingToken() string

Token resolves the bridge's incoming token.

type CreateCSAKeyPayloadResolver 

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

func NewCreateCSAKeyPayload 

func NewCreateCSAKeyPayload(key *csakey.KeyV2, err error) *CreateCSAKeyPayloadResolver

func (*CreateCSAKeyPayloadResolver) ToCSAKeyExistsError 

func (r *CreateCSAKeyPayloadResolver) ToCSAKeyExistsError() (*CSAKeyExistsErrorResolver, bool)

func (*CreateCSAKeyPayloadResolver) ToCreateCSAKeySuccess 

func (r *CreateCSAKeyPayloadResolver) ToCreateCSAKeySuccess() (*CreateCSAKeySuccessResolver, bool)

type CreateCSAKeySuccessResolver 

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

func NewCreateCSAKeySuccessResolver 

func NewCreateCSAKeySuccessResolver(key *csakey.KeyV2) *CreateCSAKeySuccessResolver

func (*CreateCSAKeySuccessResolver) CSAKey 

func (r *CreateCSAKeySuccessResolver) CSAKey() *CSAKeyResolver

type CreateFeedsManagerChainConfigPayloadResolver 

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

CreateFeedsManagerChainConfigPayloadResolver resolves the response to CreateFeedsManagerChainConfig

func NewCreateFeedsManagerChainConfigPayload 

func NewCreateFeedsManagerChainConfigPayload(cfg *feeds.ChainConfig, err error, inputErrs map[string]string) *CreateFeedsManagerChainConfigPayloadResolver

func (*CreateFeedsManagerChainConfigPayloadResolver) ToCreateFeedsManagerChainConfigSuccess 

func (r *CreateFeedsManagerChainConfigPayloadResolver) ToCreateFeedsManagerChainConfigSuccess() (*CreateFeedsManagerChainConfigSuccessResolver, bool)

func (*CreateFeedsManagerChainConfigPayloadResolver) ToInputErrors 

func (r *CreateFeedsManagerChainConfigPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)

type CreateFeedsManagerChainConfigSuccessResolver 

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

func NewCreateFeedsManagerChainConfigSuccessResolver 

func NewCreateFeedsManagerChainConfigSuccessResolver(cfg *feeds.ChainConfig) *CreateFeedsManagerChainConfigSuccessResolver

func (*CreateFeedsManagerChainConfigSuccessResolver) ChainConfig 

func (r *CreateFeedsManagerChainConfigSuccessResolver) ChainConfig() *FeedsManagerChainConfigResolver

type CreateFeedsManagerPayloadResolver 

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

CreateFeedsManagerPayloadResolver -

func NewCreateFeedsManagerPayload 

func NewCreateFeedsManagerPayload(mgr *feeds.FeedsManager, err error, inputErrs map[string]string) *CreateFeedsManagerPayloadResolver

func (*CreateFeedsManagerPayloadResolver) ToCreateFeedsManagerSuccess 

func (r *CreateFeedsManagerPayloadResolver) ToCreateFeedsManagerSuccess() (*CreateFeedsManagerSuccessResolver, bool)

func (*CreateFeedsManagerPayloadResolver) ToInputErrors 

func (r *CreateFeedsManagerPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)

func (*CreateFeedsManagerPayloadResolver) ToSingleFeedsManagerError 

func (r *CreateFeedsManagerPayloadResolver) ToSingleFeedsManagerError() (*SingleFeedsManagerErrorResolver, bool)

type CreateFeedsManagerSuccessResolver 

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

func NewCreateFeedsManagerSuccessResolver 

func NewCreateFeedsManagerSuccessResolver(mgr feeds.FeedsManager) *CreateFeedsManagerSuccessResolver

func (*CreateFeedsManagerSuccessResolver) FeedsManager 

func (r *CreateFeedsManagerSuccessResolver) FeedsManager() *FeedsManagerResolver

type CreateJobPayloadResolver 

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

func NewCreateJobPayload 

func NewCreateJobPayload(app chainlink.Application, job *job.Job, inputErrs map[string]string) *CreateJobPayloadResolver

func (*CreateJobPayloadResolver) ToCreateJobSuccess 

func (r *CreateJobPayloadResolver) ToCreateJobSuccess() (*CreateJobSuccessResolver, bool)

func (*CreateJobPayloadResolver) ToInputErrors 

func (r *CreateJobPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)

type CreateJobSuccessResolver 

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

func NewCreateJobSuccess 

func NewCreateJobSuccess(app chainlink.Application, job *job.Job) *CreateJobSuccessResolver

func (*CreateJobSuccessResolver) Job 

func (r *CreateJobSuccessResolver) Job() *JobResolver

type CreateOCR2KeyBundlePayloadResolver 

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

CreateOCR2KeyBundlePayloadResolver defines the create OCR2 Key bundle mutation resolver

func NewCreateOCR2KeyBundlePayload 

func NewCreateOCR2KeyBundlePayload(key *ocr2key.KeyBundle) *CreateOCR2KeyBundlePayloadResolver

NewCreateOCR2KeyBundlePayload returns the create OCR2 key bundle resolver

func (*CreateOCR2KeyBundlePayloadResolver) ToCreateOCR2KeyBundleSuccess 

func (r *CreateOCR2KeyBundlePayloadResolver) ToCreateOCR2KeyBundleSuccess() (*CreateOCR2KeyBundleSuccessResolver, bool)

ToCreateOCR2KeyBundleSuccess resolves the create OCR2 key bundle success

type CreateOCR2KeyBundleSuccessResolver 

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

CreateOCR2KeyBundleSuccessResolver defines the create OCR2 key bundle success resolver

func NewCreateOCR2KeyBundleSuccess 

func NewCreateOCR2KeyBundleSuccess(key *ocr2key.KeyBundle) *CreateOCR2KeyBundleSuccessResolver

NewCreateOCR2KeyBundleSuccess returns the create OCR2 key bundle success resolver

func (*CreateOCR2KeyBundleSuccessResolver) Bundle 

func (r *CreateOCR2KeyBundleSuccessResolver) Bundle() *OCR2KeyBundleResolver

Bundle resolves the creates OCR2 key bundle

type CreateOCRKeyBundlePayloadResolver 

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

func NewCreateOCRKeyBundlePayload 

func NewCreateOCRKeyBundlePayload(key *ocrkey.KeyV2) *CreateOCRKeyBundlePayloadResolver

func (*CreateOCRKeyBundlePayloadResolver) ToCreateOCRKeyBundleSuccess 

func (r *CreateOCRKeyBundlePayloadResolver) ToCreateOCRKeyBundleSuccess() (*CreateOCRKeyBundleSuccessResolver, bool)

type CreateOCRKeyBundleSuccessResolver 

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

func NewCreateOCRKeyBundleSuccess 

func NewCreateOCRKeyBundleSuccess(key *ocrkey.KeyV2) *CreateOCRKeyBundleSuccessResolver

func (*CreateOCRKeyBundleSuccessResolver) Bundle 

func (r *CreateOCRKeyBundleSuccessResolver) Bundle() *OCRKeyBundleResolver

type CreateP2PKeyPayloadResolver 

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

func NewCreateP2PKeyPayload 

func NewCreateP2PKeyPayload(key p2pkey.KeyV2) *CreateP2PKeyPayloadResolver

func (*CreateP2PKeyPayloadResolver) P2PKey 

func (r *CreateP2PKeyPayloadResolver) P2PKey() P2PKeyResolver

func (*CreateP2PKeyPayloadResolver) ToCreateP2PKeySuccess 

func (r *CreateP2PKeyPayloadResolver) ToCreateP2PKeySuccess() (*CreateP2PKeySuccessResolver, bool)

type CreateP2PKeySuccessResolver 

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

func NewCreateP2PKeySuccess 

func NewCreateP2PKeySuccess(key p2pkey.KeyV2) *CreateP2PKeySuccessResolver

func (*CreateP2PKeySuccessResolver) P2PKey 

func (r *CreateP2PKeySuccessResolver) P2PKey() P2PKeyResolver

type CreateVRFKeyPayloadResolver 

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

func NewCreateVRFKeyPayloadResolver 

func NewCreateVRFKeyPayloadResolver(key vrfkey.KeyV2) *CreateVRFKeyPayloadResolver

func (*CreateVRFKeyPayloadResolver) Key 

func (r *CreateVRFKeyPayloadResolver) Key() VRFKeyResolver

type CronSpecResolver 

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

func (*CronSpecResolver) CreatedAt 

func (r *CronSpecResolver) CreatedAt() graphql.Time

CreatedAt resolves the spec's created at timestamp.

func (*CronSpecResolver) Schedule 

func (r *CronSpecResolver) Schedule() string

type DeleteAPITokenPayloadResolver 

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

func NewDeleteAPITokenPayload 

func NewDeleteAPITokenPayload(token *auth.Token, inputErrs map[string]string) *DeleteAPITokenPayloadResolver

func (*DeleteAPITokenPayloadResolver) ToDeleteAPITokenSuccess 

func (r *DeleteAPITokenPayloadResolver) ToDeleteAPITokenSuccess() (*DeleteAPITokenSuccessResolver, bool)

func (*DeleteAPITokenPayloadResolver) ToInputErrors 

func (r *DeleteAPITokenPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)

type DeleteAPITokenSuccessResolver 

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

func NewDeleteAPITokenSuccess 

func NewDeleteAPITokenSuccess(token *auth.Token) *DeleteAPITokenSuccessResolver

func (*DeleteAPITokenSuccessResolver) Token 

func (r *DeleteAPITokenSuccessResolver) Token() *APITokenResolver

type DeleteBridgeConflictErrorResolver 

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

func NewDeleteBridgeConflictError 

func NewDeleteBridgeConflictError(message string) *DeleteBridgeConflictErrorResolver

func (*DeleteBridgeConflictErrorResolver) Code 

func (r *DeleteBridgeConflictErrorResolver) Code() ErrorCode

func (*DeleteBridgeConflictErrorResolver) Message 

func (r *DeleteBridgeConflictErrorResolver) Message() string

type DeleteBridgeInvalidNameErrorResolver 

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

func NewDeleteBridgeInvalidNameError 

func NewDeleteBridgeInvalidNameError(message string) *DeleteBridgeInvalidNameErrorResolver

func (*DeleteBridgeInvalidNameErrorResolver) Code 

func (r *DeleteBridgeInvalidNameErrorResolver) Code() ErrorCode

func (*DeleteBridgeInvalidNameErrorResolver) Message 

func (r *DeleteBridgeInvalidNameErrorResolver) Message() string

type DeleteBridgePayloadResolver 

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

func NewDeleteBridgePayload 

func NewDeleteBridgePayload(bridge *bridges.BridgeType, err error) *DeleteBridgePayloadResolver

func (*DeleteBridgePayloadResolver) ToDeleteBridgeConflictError 

func (r *DeleteBridgePayloadResolver) ToDeleteBridgeConflictError() (*DeleteBridgeConflictErrorResolver, bool)

func (*DeleteBridgePayloadResolver) ToDeleteBridgeInvalidNameError 

func (r *DeleteBridgePayloadResolver) ToDeleteBridgeInvalidNameError() (*DeleteBridgeInvalidNameErrorResolver, bool)

func (*DeleteBridgePayloadResolver) ToDeleteBridgeSuccess 

func (r *DeleteBridgePayloadResolver) ToDeleteBridgeSuccess() (*DeleteBridgeSuccessResolver, bool)

type DeleteBridgeSuccessResolver 

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

func NewDeleteBridgeSuccess 

func NewDeleteBridgeSuccess(bridge *bridges.BridgeType) *DeleteBridgeSuccessResolver

func (*DeleteBridgeSuccessResolver) Bridge 

func (r *DeleteBridgeSuccessResolver) Bridge() *BridgeResolver

type DeleteCSAKeyPayloadResolver 

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

func NewDeleteCSAKeyPayload 

func NewDeleteCSAKeyPayload(key csakey.KeyV2, err error) *DeleteCSAKeyPayloadResolver

func (*DeleteCSAKeyPayloadResolver) ToDeleteCSAKeySuccess 

func (r *DeleteCSAKeyPayloadResolver) ToDeleteCSAKeySuccess() (*DeleteCSAKeySuccessResolver, bool)

type DeleteCSAKeySuccessResolver 

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

func NewDeleteCSAKeySuccess 

func NewDeleteCSAKeySuccess(key csakey.KeyV2) *DeleteCSAKeySuccessResolver

func (*DeleteCSAKeySuccessResolver) CSAKey 

func (r *DeleteCSAKeySuccessResolver) CSAKey() *CSAKeyResolver

type DeleteFeedsManagerChainConfigPayloadResolver 

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

func NewDeleteFeedsManagerChainConfigPayload 

func NewDeleteFeedsManagerChainConfigPayload(cfg *feeds.ChainConfig, err error) *DeleteFeedsManagerChainConfigPayloadResolver

func (*DeleteFeedsManagerChainConfigPayloadResolver) ToDeleteFeedsManagerChainConfigSuccess 

func (r *DeleteFeedsManagerChainConfigPayloadResolver) ToDeleteFeedsManagerChainConfigSuccess() (*DeleteFeedsManagerChainConfigSuccessResolver, bool)

type DeleteFeedsManagerChainConfigSuccessResolver 

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

func NewDeleteFeedsManagerChainConfigSuccess 

func NewDeleteFeedsManagerChainConfigSuccess(cfg feeds.ChainConfig) *DeleteFeedsManagerChainConfigSuccessResolver

func (*DeleteFeedsManagerChainConfigSuccessResolver) ChainConfig 

func (r *DeleteFeedsManagerChainConfigSuccessResolver) ChainConfig() *FeedsManagerChainConfigResolver

type DeleteJobPayloadResolver 

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

func NewDeleteJobPayload 

func NewDeleteJobPayload(app chainlink.Application, j *job.Job, err error) *DeleteJobPayloadResolver

func (*DeleteJobPayloadResolver) ToDeleteJobSuccess 

func (r *DeleteJobPayloadResolver) ToDeleteJobSuccess() (*DeleteJobSuccessResolver, bool)

type DeleteJobSuccessResolver 

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

func NewDeleteJobSuccess 

func NewDeleteJobSuccess(app chainlink.Application, job *job.Job) *DeleteJobSuccessResolver

func (*DeleteJobSuccessResolver) Job 

func (r *DeleteJobSuccessResolver) Job() *JobResolver

type DeleteOCR2KeyBundlePayloadResolver 

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

DeleteOCR2KeyBundlePayloadResolver defines the delete OCR2 Key bundle mutation resolver

func NewDeleteOCR2KeyBundlePayloadResolver 

func NewDeleteOCR2KeyBundlePayloadResolver(key *ocr2key.KeyBundle, err error) *DeleteOCR2KeyBundlePayloadResolver

NewDeleteOCR2KeyBundlePayloadResolver returns the delete OCR2 key bundle payload resolver

func (*DeleteOCR2KeyBundlePayloadResolver) ToDeleteOCR2KeyBundleSuccess 

func (r *DeleteOCR2KeyBundlePayloadResolver) ToDeleteOCR2KeyBundleSuccess() (*DeleteOCR2KeyBundleSuccessResolver, bool)

ToDeleteOCR2KeyBundleSuccess resolves the delete OCR2 key bundle success

type DeleteOCR2KeyBundleSuccessResolver 

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

DeleteOCR2KeyBundleSuccessResolver defines the delete OCR2 key bundle success resolver

func NewDeleteOCR2KeyBundleSuccessResolver 

func NewDeleteOCR2KeyBundleSuccessResolver(key *ocr2key.KeyBundle) *DeleteOCR2KeyBundleSuccessResolver

NewDeleteOCR2KeyBundleSuccessResolver returns the delete OCR2 key bundle success resolver

func (*DeleteOCR2KeyBundleSuccessResolver) Bundle 

func (r *DeleteOCR2KeyBundleSuccessResolver) Bundle() *OCR2KeyBundleResolver

Bundle resolves the creates OCR2 key bundle

type DeleteOCRKeyBundlePayloadResolver 

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

func NewDeleteOCRKeyBundlePayloadResolver 

func NewDeleteOCRKeyBundlePayloadResolver(key ocrkey.KeyV2, err error) *DeleteOCRKeyBundlePayloadResolver

func (*DeleteOCRKeyBundlePayloadResolver) ToDeleteOCRKeyBundleSuccess 

func (r *DeleteOCRKeyBundlePayloadResolver) ToDeleteOCRKeyBundleSuccess() (*DeleteOCRKeyBundleSuccessResolver, bool)

type DeleteOCRKeyBundleSuccessResolver 

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

func NewDeleteOCRKeyBundleSuccessResolver 

func NewDeleteOCRKeyBundleSuccessResolver(key ocrkey.KeyV2) *DeleteOCRKeyBundleSuccessResolver

func (*DeleteOCRKeyBundleSuccessResolver) Bundle 

func (r *DeleteOCRKeyBundleSuccessResolver) Bundle() OCRKeyBundleResolver

type DeleteP2PKeyPayloadResolver 

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

func NewDeleteP2PKeyPayload 

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 

func NewDeleteP2PKeySuccess(p2pKey p2pkey.KeyV2) *DeleteP2PKeySuccessResolver

func (*DeleteP2PKeySuccessResolver) P2PKey 

func (r *DeleteP2PKeySuccessResolver) P2PKey() P2PKeyResolver

type DeleteVRFKeyPayloadResolver 

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

func NewDeleteVRFKeyPayloadResolver 

func NewDeleteVRFKeyPayloadResolver(key vrfkey.KeyV2, err error) *DeleteVRFKeyPayloadResolver

func (*DeleteVRFKeyPayloadResolver) ToDeleteVRFKeySuccess 

func (r *DeleteVRFKeyPayloadResolver) ToDeleteVRFKeySuccess() (*DeleteVRFKeySuccessResolver, bool)

type DeleteVRFKeySuccessResolver 

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

func NewDeleteVRFKeySuccessResolver 

func NewDeleteVRFKeySuccessResolver(key vrfkey.KeyV2) *DeleteVRFKeySuccessResolver

func (*DeleteVRFKeySuccessResolver) Key 

func (r *DeleteVRFKeySuccessResolver) Key() VRFKeyResolver

type DirectRequestSpecResolver 

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

func (*DirectRequestSpecResolver) ContractAddress 

func (r *DirectRequestSpecResolver) ContractAddress() string

ContractAddress resolves the spec's contract address.

func (*DirectRequestSpecResolver) CreatedAt 

func (r *DirectRequestSpecResolver) CreatedAt() graphql.Time

CreatedAt resolves the spec's created at timestamp.

func (*DirectRequestSpecResolver) EVMChainID 

func (r *DirectRequestSpecResolver) EVMChainID() *string

EVMChainID resolves the spec's evm chain id.

func (*DirectRequestSpecResolver) MinContractPaymentLinkJuels 

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 

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

func NewDismissJobErrorPayload 

func NewDismissJobErrorPayload(specError *job.SpecError, err error) *DismissJobErrorPayloadResolver

func (*DismissJobErrorPayloadResolver) ToDismissJobErrorSuccess 

func (r *DismissJobErrorPayloadResolver) ToDismissJobErrorSuccess() (*DismissJobErrorSuccessResolver, bool)

type DismissJobErrorSuccessResolver 

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

func NewDismissJobErrorSuccess 

func NewDismissJobErrorSuccess(specError *job.SpecError) *DismissJobErrorSuccessResolver

func (*DismissJobErrorSuccessResolver) JobError 

func (r *DismissJobErrorSuccessResolver) JobError() *JobErrorResolver

type ETHKey 

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

type ETHKeyResolver 

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

func NewETHKey 

func NewETHKey(key ETHKey) *ETHKeyResolver

func NewETHKeys 

func NewETHKeys(keys []ETHKey) []*ETHKeyResolver

func (*ETHKeyResolver) Address 

func (r *ETHKeyResolver) Address() string

func (*ETHKeyResolver) Chain 

func (r *ETHKeyResolver) Chain(ctx context.Context) (*ChainResolver, error)

func (*ETHKeyResolver) CreatedAt 

func (r *ETHKeyResolver) CreatedAt() graphql.Time

func (*ETHKeyResolver) ETHBalance 

func (r *ETHKeyResolver) ETHBalance(ctx context.Context) *string

ETHBalance returns the ETH balance available

func (*ETHKeyResolver) IsDisabled 

func (r *ETHKeyResolver) IsDisabled() bool

func (*ETHKeyResolver) LINKBalance 

func (r *ETHKeyResolver) LINKBalance(ctx context.Context) *string

func (*ETHKeyResolver) MaxGasPriceWei 

func (r *ETHKeyResolver) MaxGasPriceWei() *string

func (*ETHKeyResolver) UpdatedAt 

func (r *ETHKeyResolver) UpdatedAt() graphql.Time

type ETHKeysPayloadResolver 

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

func NewETHKeysPayload 

func NewETHKeysPayload(keys []ETHKey) *ETHKeysPayloadResolver

func (*ETHKeysPayloadResolver) Results 

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 

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

func NewEthTransactionAttempt 

func NewEthTransactionAttempt(attmpt txmgr.TxAttempt) *EthTransactionAttemptResolver

func NewEthTransactionsAttempts 

func NewEthTransactionsAttempts(results []txmgr.TxAttempt) []*EthTransactionAttemptResolver

func (*EthTransactionAttemptResolver) GasPrice 

func (r *EthTransactionAttemptResolver) GasPrice() string

func (*EthTransactionAttemptResolver) Hash 

func (r *EthTransactionAttemptResolver) Hash() string

func (*EthTransactionAttemptResolver) Hex 

func (r *EthTransactionAttemptResolver) Hex() string

func (*EthTransactionAttemptResolver) SentAt 

func (r *EthTransactionAttemptResolver) SentAt() *string

type EthTransactionPayloadResolver 

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

func NewEthTransactionPayload 

func NewEthTransactionPayload(tx *txmgr.Tx, err error) *EthTransactionPayloadResolver

func (*EthTransactionPayloadResolver) ToEthTransaction 

func (r *EthTransactionPayloadResolver) ToEthTransaction() (*EthTransactionResolver, bool)

type EthTransactionResolver 

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

func NewEthTransaction 

func NewEthTransaction(tx txmgr.Tx) *EthTransactionResolver

func NewEthTransactions 

func NewEthTransactions(results []txmgr.Tx) []*EthTransactionResolver

func (*EthTransactionResolver) Attempts 

func (r *EthTransactionResolver) Attempts(ctx context.Context) ([]*EthTransactionAttemptResolver, error)

func (*EthTransactionResolver) Chain 

func (r *EthTransactionResolver) Chain(ctx context.Context) (*ChainResolver, error)

Chain resolves the node's chain object field.

func (*EthTransactionResolver) Data 

func (r *EthTransactionResolver) Data() hexutil.Bytes

func (*EthTransactionResolver) EVMChainID 

func (r *EthTransactionResolver) EVMChainID() graphql.ID

func (*EthTransactionResolver) From 

func (r *EthTransactionResolver) From() string

func (*EthTransactionResolver) GasLimit 

func (r *EthTransactionResolver) GasLimit() string

func (*EthTransactionResolver) GasPrice 

func (r *EthTransactionResolver) GasPrice(ctx context.Context) string

func (*EthTransactionResolver) Hash 

func (r *EthTransactionResolver) Hash(ctx context.Context) string

func (*EthTransactionResolver) Hex 

func (r *EthTransactionResolver) Hex(ctx context.Context) string

func (*EthTransactionResolver) Nonce 

func (r *EthTransactionResolver) Nonce() *string

func (*EthTransactionResolver) SentAt 

func (r *EthTransactionResolver) SentAt(ctx context.Context) *string

func (*EthTransactionResolver) State 

func (r *EthTransactionResolver) State() string

func (*EthTransactionResolver) To 

func (r *EthTransactionResolver) To() string

func (*EthTransactionResolver) Value 

func (r *EthTransactionResolver) Value() string

type EthTransactionsAttemptsPayloadResolver 

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

func NewEthTransactionsAttemptsPayload 

func NewEthTransactionsAttemptsPayload(results []txmgr.TxAttempt, total int32) *EthTransactionsAttemptsPayloadResolver

func (*EthTransactionsAttemptsPayloadResolver) Metadata 

func (r *EthTransactionsAttemptsPayloadResolver) Metadata() *PaginationMetadataResolver

func (*EthTransactionsAttemptsPayloadResolver) Results 

func (r *EthTransactionsAttemptsPayloadResolver) Results() []*EthTransactionAttemptResolver

type EthTransactionsPayloadResolver 

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

func NewEthTransactionsPayload 

func NewEthTransactionsPayload(results []txmgr.Tx, total int32) *EthTransactionsPayloadResolver

func (*EthTransactionsPayloadResolver) Metadata 

func (r *EthTransactionsPayloadResolver) Metadata() *PaginationMetadataResolver

func (*EthTransactionsPayloadResolver) Results 

func (r *EthTransactionsPayloadResolver) Results() []*EthTransactionResolver

type FeaturesPayloadResolver 

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

func NewFeaturesPayloadResolver 

func NewFeaturesPayloadResolver(cfg config.Feature) *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.Feature) *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 

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

func NewFeedsManagerChainConfig 

func NewFeedsManagerChainConfig(cfg feeds.ChainConfig) *FeedsManagerChainConfigResolver

func NewFeedsManagerChainConfigs 

func NewFeedsManagerChainConfigs(cfgs []feeds.ChainConfig) []*FeedsManagerChainConfigResolver

func (*FeedsManagerChainConfigResolver) AccountAddr 

func (r *FeedsManagerChainConfigResolver) AccountAddr() string

AccountAddr resolves the chain configs's account address.

func (*FeedsManagerChainConfigResolver) AdminAddr 

func (r *FeedsManagerChainConfigResolver) AdminAddr() string

AdminAddr resolves the chain configs's admin address.

func (*FeedsManagerChainConfigResolver) ChainID 

func (r *FeedsManagerChainConfigResolver) ChainID() string

ChainID resolves the chain configs's chain id.

func (*FeedsManagerChainConfigResolver) ChainType 

func (r *FeedsManagerChainConfigResolver) ChainType() string

ChainType resolves the chain configs's chain type.

func (*FeedsManagerChainConfigResolver) FluxMonitorJobConfig 

func (r *FeedsManagerChainConfigResolver) FluxMonitorJobConfig() *FluxMonitorJobConfigResolver

FluxMonitorJobConfig resolves the chain configs's Flux Monitor Config.

func (*FeedsManagerChainConfigResolver) ID 

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

ID resolves the chain configs's unique identifier.

func (*FeedsManagerChainConfigResolver) OCR1JobConfig 

func (r *FeedsManagerChainConfigResolver) OCR1JobConfig() *OCR1JobConfigResolver

OCR1JobConfig resolves the chain configs's OCR1 Config.

func (*FeedsManagerChainConfigResolver) OCR2JobConfig 

func (r *FeedsManagerChainConfigResolver) OCR2JobConfig() *OCR2JobConfigResolver

OCR2JobConfig resolves the chain configs's OCR2 Config.

type FeedsManagerPayloadResolver 

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

func NewFeedsManagerPayload 

func NewFeedsManagerPayload(mgr *feeds.FeedsManager, err error) *FeedsManagerPayloadResolver

func (*FeedsManagerPayloadResolver) ToFeedsManager 

func (r *FeedsManagerPayloadResolver) ToFeedsManager() (*FeedsManagerResolver, bool)

ToFeedsManager implements the FeedsManager union type of the payload

type FeedsManagerResolver 

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

FeedsManagerResolver resolves the FeedsManager type.

func NewFeedsManager 

func NewFeedsManager(mgr feeds.FeedsManager) *FeedsManagerResolver

func NewFeedsManagers 

func NewFeedsManagers(mgrs []feeds.FeedsManager) []*FeedsManagerResolver

func (*FeedsManagerResolver) ChainConfigs 

func (r *FeedsManagerResolver) ChainConfigs(ctx context.Context) ([]*FeedsManagerChainConfigResolver, error)

func (*FeedsManagerResolver) CreatedAt 

func (r *FeedsManagerResolver) CreatedAt() graphql.Time

CreatedAt resolves the chains's created at field.

func (*FeedsManagerResolver) ID 

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

ID resolves the feed managers's unique identifier.

func (*FeedsManagerResolver) IsConnectionActive 

func (r *FeedsManagerResolver) IsConnectionActive() bool

IsConnectionActive resolves the feed managers's isConnectionActive field.

func (*FeedsManagerResolver) JobProposals 

func (r *FeedsManagerResolver) JobProposals(ctx context.Context) ([]*JobProposalResolver, error)

func (*FeedsManagerResolver) Name 

func (r *FeedsManagerResolver) Name() string

Name resolves the feed managers's name field.

func (*FeedsManagerResolver) PublicKey 

func (r *FeedsManagerResolver) PublicKey() string

PublicKey resolves the feed managers's public key field.

func (*FeedsManagerResolver) URI 

func (r *FeedsManagerResolver) URI() string

URI resolves the feed managers's uri field.

type FeedsManagersPayloadResolver 

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

FeedsManagersPayloadResolver resolves a list of feeds managers

func NewFeedsManagersPayload 

func NewFeedsManagersPayload(feedsManagers []feeds.FeedsManager) *FeedsManagersPayloadResolver

func (*FeedsManagersPayloadResolver) Results 

func (r *FeedsManagersPayloadResolver) Results() []*FeedsManagerResolver

Results returns the feeds managers.

type FluxMonitorJobConfigResolver 

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

func (*FluxMonitorJobConfigResolver) Enabled 

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 GatewaySpecResolver added in v2.3.0 

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

func (*GatewaySpecResolver) CreatedAt added in v2.3.0 

func (r *GatewaySpecResolver) CreatedAt() graphql.Time

func (*GatewaySpecResolver) GatewayConfig added in v2.3.0 

func (r *GatewaySpecResolver) GatewayConfig() gqlscalar.Map

func (*GatewaySpecResolver) ID added in v2.3.0 

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

type GetSQLLoggingPayloadResolver 

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

func NewGetSQLLoggingPayload 

func NewGetSQLLoggingPayload(enabled bool) *GetSQLLoggingPayloadResolver

func (*GetSQLLoggingPayloadResolver) ToSQLLogging 

func (r *GetSQLLoggingPayloadResolver) ToSQLLogging() (*SQLLoggingResolver, bool)

type GlobalLogLevelPayloadResolver 

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

func NewGlobalLogLevelPayload 

func NewGlobalLogLevelPayload(lgLvl string) *GlobalLogLevelPayloadResolver

func (*GlobalLogLevelPayloadResolver) ToGlobalLogLevel 

func (r *GlobalLogLevelPayloadResolver) ToGlobalLogLevel() (*GlobalLogLevelResolver, bool)

type GlobalLogLevelResolver 

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

func GlobalLogLevel 

func GlobalLogLevel(lvl string) *GlobalLogLevelResolver

func (*GlobalLogLevelResolver) Level 

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 

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

JobAlreadyExistsErrorResolver -

func NewJobAlreadyExistsError 

func NewJobAlreadyExistsError(message string) *JobAlreadyExistsErrorResolver

NewJobAlreadyExistsError -

func (*JobAlreadyExistsErrorResolver) Code 

func (r *JobAlreadyExistsErrorResolver) Code() ErrorCode

Code -

func (*JobAlreadyExistsErrorResolver) Message 

func (r *JobAlreadyExistsErrorResolver) Message() string

Message -

type JobErrorResolver 

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

JobErrorResolver resolves a Job Error

func NewJobError 

func NewJobError(specError job.SpecError) *JobErrorResolver

func NewJobErrors 

func NewJobErrors(specErrors []job.SpecError) []*JobErrorResolver

func (*JobErrorResolver) CreatedAt 

func (r *JobErrorResolver) CreatedAt() graphql.Time

CreatedAt resolves the job error's created at timestamp.

func (*JobErrorResolver) Description 

func (r *JobErrorResolver) Description() string

Description resolves the job error's description.

func (*JobErrorResolver) ID 

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

ID resolves the job error's id.

func (*JobErrorResolver) Occurrences 

func (r *JobErrorResolver) Occurrences() int32

Occurrences resolves the job error's number of occurrences.

func (*JobErrorResolver) UpdatedAt 

func (r *JobErrorResolver) UpdatedAt() graphql.Time

UpdatedAt resolves the job error's updated at timestamp.

type JobPayloadResolver 

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

func NewJobPayload 

func NewJobPayload(app chainlink.Application, j *job.Job, err error) *JobPayloadResolver

func (*JobPayloadResolver) ToJob 

func (r *JobPayloadResolver) ToJob() (*JobResolver, bool)

ToJob implements the JobPayload union type of the payload

type JobProposalPayloadResolver 

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

JobProposalPayloadResolver resolves the job proposal payload type

func NewJobProposalPayload 

func NewJobProposalPayload(jp *feeds.JobProposal, err error) *JobProposalPayloadResolver

NewJobProposalPayload creates a new job proposal payload

func (*JobProposalPayloadResolver) ToJobProposal 

func (r *JobProposalPayloadResolver) ToJobProposal() (*JobProposalResolver, bool)

ToJobProposal resolves to the job proposal resolver

type JobProposalResolver 

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

JobProposalResolver resolves the Job Proposal type

func NewJobProposal 

func NewJobProposal(jp *feeds.JobProposal) *JobProposalResolver

NewJobProposal creates a new JobProposalResolver

func NewJobProposals 

func NewJobProposals(jps []feeds.JobProposal) []*JobProposalResolver

func (*JobProposalResolver) ExternalJobID 

func (r *JobProposalResolver) ExternalJobID() *string

ExternalJobID resolves to the job proposal ExternalJobID

func (*JobProposalResolver) FeedsManager 

func (r *JobProposalResolver) FeedsManager(ctx context.Context) (*FeedsManagerResolver, error)

FeedsManager resolves the job proposal's feeds manager object field.

func (*JobProposalResolver) ID 

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

ID resolves to the job proposal ID

func (*JobProposalResolver) JobID 

func (r *JobProposalResolver) JobID(ctx context.Context) (*string, error)

JobID resolves to the job proposal JobID if it has an ExternalJobID

func (*JobProposalResolver) LatestSpec 

func (r *JobProposalResolver) LatestSpec(ctx context.Context) (*JobProposalSpecResolver, error)

LatestSpec returns the spec with the highest version number.

func (*JobProposalResolver) MultiAddrs 

func (r *JobProposalResolver) MultiAddrs() []string

MultiAddrs resolves to the job proposal MultiAddrs

func (*JobProposalResolver) Name 

func (r *JobProposalResolver) Name() *string

Name resolves to the job proposal name

func (*JobProposalResolver) PendingUpdate 

func (r *JobProposalResolver) PendingUpdate() bool

PendingUpdate resolves to whether the job proposal has a pending update.

func (*JobProposalResolver) RemoteUUID 

func (r *JobProposalResolver) RemoteUUID(ctx context.Context) string

RemoteUUID returns the remote FMS UUID of the proposal.

func (*JobProposalResolver) Specs 

func (r *JobProposalResolver) Specs(ctx context.Context) ([]*JobProposalSpecResolver, error)

Specs returns all spec proposals associated with the proposal.

func (*JobProposalResolver) Status 

func (r *JobProposalResolver) Status() JobProposalStatus

Status resolves to the job proposal Status

type JobProposalSpecResolver 

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

JobProposalSpecResolver resolves the Job Proposal Spec type.

func NewJobProposalSpec 

func NewJobProposalSpec(spec *feeds.JobProposalSpec) *JobProposalSpecResolver

NewJobProposalSpec creates a new JobProposalSpecResolver.

func NewJobProposalSpecs 

func NewJobProposalSpecs(specs []feeds.JobProposalSpec) []*JobProposalSpecResolver

NewJobProposalSpecs creates a slice of JobProposalSpecResolvers.

func (*JobProposalSpecResolver) CreatedAt 

func (r *JobProposalSpecResolver) CreatedAt() graphql.Time

CreatedAt resolves to the job proposal spec's created at timestamp

func (*JobProposalSpecResolver) Definition 

func (r *JobProposalSpecResolver) Definition() string

Definition resolves to the job proposal spec definition

func (*JobProposalSpecResolver) ID 

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

ID resolves to the job proposal spec ID

func (*JobProposalSpecResolver) Status 

func (r *JobProposalSpecResolver) Status() SpecStatus

Status resolves to the job proposal spec's status

func (*JobProposalSpecResolver) StatusUpdatedAt 

func (r *JobProposalSpecResolver) StatusUpdatedAt() graphql.Time

StatusUpdatedAt resolves to the the last timestamp that the spec status was updated.

func (*JobProposalSpecResolver) UpdatedAt 

func (r *JobProposalSpecResolver) UpdatedAt() graphql.Time

UpdatedAt resolves to the job proposal spec's updated at timestamp

func (*JobProposalSpecResolver) Version 

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"
	DELETED   JobProposalStatus = "DELETED"
	REVOKED   JobProposalStatus = "REVOKED"
)

func ToJobProposalStatus 

func ToJobProposalStatus(s feeds.JobProposalStatus) (JobProposalStatus, error)

type JobResolver 

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

JobResolver resolves the Job type.

func NewJob 

func NewJob(app chainlink.Application, j job.Job) *JobResolver

func NewJobs 

func NewJobs(app chainlink.Application, jobs []job.Job) []*JobResolver

func (*JobResolver) CreatedAt 

func (r *JobResolver) CreatedAt() graphql.Time

CreatedAt resolves the job's created at timestamp.

func (*JobResolver) Errors 

func (r *JobResolver) Errors(ctx context.Context) ([]*JobErrorResolver, error)

Errors resolves the job's top level errors.

func (*JobResolver) ExternalJobID 

func (r *JobResolver) ExternalJobID() string

ExternalJobID resolves the job's external job id.

func (*JobResolver) ForwardingAllowed 

func (r *JobResolver) ForwardingAllowed() *bool

ForwardingAllowed sets whether txs submitted by this job should be forwarded when possible.

func (*JobResolver) GasLimit 

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 

func (r *JobResolver) Type() string

Type resolves the job's type.

type JobRunPayloadResolver 

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

func NewJobRunPayload 

func NewJobRunPayload(jr *pipeline.Run, app chainlink.Application, err error) *JobRunPayloadResolver

func (*JobRunPayloadResolver) ToJobRun 

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 

func (r *JobRunResolver) Job(ctx context.Context) (*JobResolver, error)

func (*JobRunResolver) Outputs 

func (r *JobRunResolver) Outputs() []*string

func (*JobRunResolver) PipelineSpecID 

func (r *JobRunResolver) PipelineSpecID() graphql.ID

func (*JobRunResolver) Status 

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 

type JobRunStatus string
const (
	JobRunStatusUnknown   JobRunStatus = "UNKNOWN"
	JobRunStatusRunning   JobRunStatus = "RUNNING"
	JobRunStatusSuspended JobRunStatus = "SUSPENDED"
	JobRunStatusErrored   JobRunStatus = "ERRORED"
	JobRunStatusCompleted JobRunStatus = "COMPLETED"
)

func NewJobRunStatus 

func NewJobRunStatus(status pipeline.RunStatus) JobRunStatus

type JobRunsPayloadResolver 

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

JobRunsPayloadResolver resolves a page of job runs

func NewJobRunsPayload 

func NewJobRunsPayload(runs []pipeline.Run, total int32, app chainlink.Application) *JobRunsPayloadResolver

func (*JobRunsPayloadResolver) Metadata 

func (r *JobRunsPayloadResolver) Metadata() *PaginationMetadataResolver

Metadata returns the pagination metadata.

func (*JobRunsPayloadResolver) Results 

func (r *JobRunsPayloadResolver) Results() []*JobRunResolver

Results returns the job runs.

type JobsPayloadResolver 

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

JobsPayloadResolver resolves a page of jobs

func NewJobsPayload 

func NewJobsPayload(app chainlink.Application, jobs []job.Job, total int32) *JobsPayloadResolver

func (*JobsPayloadResolver) Metadata 

func (r *JobsPayloadResolver) Metadata() *PaginationMetadataResolver

Metadata returns the pagination metadata.

func (*JobsPayloadResolver) Results 

func (r *JobsPayloadResolver) Results() []*JobResolver

Results returns the jobs.

type KeeperSpecResolver 

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

func (*KeeperSpecResolver) ContractAddress 

func (r *KeeperSpecResolver) ContractAddress() string

ContractAddress resolves the spec's contract address.

func (*KeeperSpecResolver) CreatedAt 

func (r *KeeperSpecResolver) CreatedAt() graphql.Time

CreatedAt resolves the spec's created at timestamp.

func (*KeeperSpecResolver) EVMChainID 

func (r *KeeperSpecResolver) EVMChainID() *string

EVMChainID resolves the spec's evm chain id.

func (*KeeperSpecResolver) FromAddress 

func (r *KeeperSpecResolver) FromAddress() *string

FromAddress resolves the spec's from contract address.

Because VRF has an non required field of the same name, we have to be consistent in our return value of using a *string instead of a string even though this is a required field for the KeeperSpec.

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

type LogLevel 

type LogLevel string

func ToLogLevel 

func ToLogLevel(str string) (LogLevel, error)

type NodePayloadResolver 

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

func NewNodePayloadResolver 

func NewNodePayloadResolver(node *types.NodeStatus, err error) (npr *NodePayloadResolver, warn error)

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(status types.NodeStatus) (nr *NodeResolver, warn error)

func NewNodes 

func NewNodes(nodes []types.NodeStatus) (resolvers []*NodeResolver, warns error)

func (*NodeResolver) Chain 

func (r *NodeResolver) Chain(ctx context.Context) (*ChainResolver, error)

Chain resolves the node's chain object 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) Order added in v2.3.0 

func (r *NodeResolver) Order() *int32

Order resolves the node's order field

func (*NodeResolver) SendOnly 

func (r *NodeResolver) SendOnly() bool

SendOnly resolves the node's sendOnly bool

func (*NodeResolver) State 

func (r *NodeResolver) State() string

State resolves the node state

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.NodeStatus, total int32) (npr *NodesPayloadResolver, warn error)

func (*NodesPayloadResolver) Metadata 

func (r *NodesPayloadResolver) Metadata() *PaginationMetadataResolver

func (*NodesPayloadResolver) Results 

func (r *NodesPayloadResolver) Results() []*NodeResolver

type NotFoundErrorResolver 

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

func NewNotFoundError 

func NewNotFoundError(message string) *NotFoundErrorResolver

func (*NotFoundErrorResolver) Code 

func (r *NotFoundErrorResolver) Code() ErrorCode

func (*NotFoundErrorResolver) Message 

func (r *NotFoundErrorResolver) Message() string

type NotFoundErrorUnionType 

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

func (*NotFoundErrorUnionType) ToNotFoundError 

func (e *NotFoundErrorUnionType) ToNotFoundError() (*NotFoundErrorResolver, bool)

ToNotFoundError resolves to the not found error resolver

type OCR1JobConfigResolver 

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

func (*OCR1JobConfigResolver) Enabled 

func (r *OCR1JobConfigResolver) Enabled() bool

func (*OCR1JobConfigResolver) IsBootstrap 

func (r *OCR1JobConfigResolver) IsBootstrap() bool

func (*OCR1JobConfigResolver) KeyBundleID 

func (r *OCR1JobConfigResolver) KeyBundleID() *string

func (*OCR1JobConfigResolver) Multiaddr 

func (r *OCR1JobConfigResolver) Multiaddr() *string

func (*OCR1JobConfigResolver) P2PPeerID 

func (r *OCR1JobConfigResolver) P2PPeerID() *string

type OCR2ChainType 

type OCR2ChainType string

OCR2ChainType defines OCR2 Chain Types accepted on this resolver

func ToOCR2ChainType 

func ToOCR2ChainType(s string) (OCR2ChainType, error)

ToOCR2ChainType turns a valid string into a OCR2ChainType

type OCR2JobConfigResolver 

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

func (*OCR2JobConfigResolver) Enabled 

func (r *OCR2JobConfigResolver) Enabled() bool

func (*OCR2JobConfigResolver) IsBootstrap 

func (r *OCR2JobConfigResolver) IsBootstrap() bool

func (*OCR2JobConfigResolver) KeyBundleID 

func (r *OCR2JobConfigResolver) KeyBundleID() *string

func (*OCR2JobConfigResolver) Multiaddr 

func (r *OCR2JobConfigResolver) Multiaddr() *string

func (*OCR2JobConfigResolver) P2PPeerID 

func (r *OCR2JobConfigResolver) P2PPeerID() *string

func (*OCR2JobConfigResolver) Plugins 

func (r *OCR2JobConfigResolver) Plugins() *PluginsResolver

type OCR2KeyBundleResolver 

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

OCR2KeyBundleResolver defines the OCR2 Key bundle on GQL

func NewOCR2KeyBundle 

func NewOCR2KeyBundle(key ocr2key.KeyBundle) *OCR2KeyBundleResolver

NewOCR2KeyBundle creates a new GQL OCR2 key bundle resolver

func (OCR2KeyBundleResolver) ChainType 

func (r OCR2KeyBundleResolver) ChainType() *OCR2ChainType

ChainType returns the OCR2 Key bundle chain type

func (OCR2KeyBundleResolver) ConfigPublicKey 

func (r OCR2KeyBundleResolver) ConfigPublicKey() string

ConfigPublicKey returns the OCR2 Key bundle config public key

func (OCR2KeyBundleResolver) ID 

func (r OCR2KeyBundleResolver) ID() graphql.ID

ID returns the OCR2 Key bundle ID

func (OCR2KeyBundleResolver) OffChainPublicKey 

func (r OCR2KeyBundleResolver) OffChainPublicKey() string

OffChainPublicKey returns the OCR2 Key bundle off-chain public key

func (OCR2KeyBundleResolver) OnChainPublicKey 

func (r OCR2KeyBundleResolver) OnChainPublicKey() string

OnChainPublicKey returns the OCR2 Key bundle on-chain public key

type OCR2KeyBundlesPayloadResolver 

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

OCR2KeyBundlesPayloadResolver defines the OCR2 Key bundles query resolver

func NewOCR2KeyBundlesPayload 

func NewOCR2KeyBundlesPayload(keys []ocr2key.KeyBundle) *OCR2KeyBundlesPayloadResolver

NewOCR2KeyBundlesPayload returns the OCR2 key bundles resolver

func (*OCR2KeyBundlesPayloadResolver) Results 

func (r *OCR2KeyBundlesPayloadResolver) Results() []OCR2KeyBundleResolver

Results resolves the list of OCR2 key bundles

type OCR2SpecResolver 

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

func (*OCR2SpecResolver) BlockchainTimeout 

func (r *OCR2SpecResolver) BlockchainTimeout() *string

BlockchainTimeout resolves the spec's blockchain timeout.

func (*OCR2SpecResolver) ContractConfigConfirmations 

func (r *OCR2SpecResolver) ContractConfigConfirmations() *int32

ContractConfigConfirmations resolves the spec's confirmations config.

func (*OCR2SpecResolver) ContractConfigTrackerPollInterval 

func (r *OCR2SpecResolver) ContractConfigTrackerPollInterval() *string

ContractConfigTrackerPollInterval resolves the spec's contract tracker poll interval config.

func (*OCR2SpecResolver) ContractID 

func (r *OCR2SpecResolver) ContractID() string

ContractID resolves the spec's contract address.

func (*OCR2SpecResolver) CreatedAt 

func (r *OCR2SpecResolver) CreatedAt() graphql.Time

CreatedAt resolves the spec's created at timestamp.

func (*OCR2SpecResolver) FeedID 

func (r *OCR2SpecResolver) FeedID() *string

FeedID resolves the spec's feed ID

func (*OCR2SpecResolver) MonitoringEndpoint 

func (r *OCR2SpecResolver) MonitoringEndpoint() *string

MonitoringEndpoint resolves the spec's monitoring endpoint

func (*OCR2SpecResolver) OcrKeyBundleID 

func (r *OCR2SpecResolver) OcrKeyBundleID() *string

OcrKeyBundleID resolves the spec's key bundle id.

func (*OCR2SpecResolver) P2PV2Bootstrappers 

func (r *OCR2SpecResolver) P2PV2Bootstrappers() *[]string

P2PV2Bootstrappers resolves the OCR2 spec's p2pv2 bootstrappers

func (*OCR2SpecResolver) PluginConfig 

func (r *OCR2SpecResolver) PluginConfig() gqlscalar.Map

PluginConfig resolves the spec's plugin config

func (*OCR2SpecResolver) PluginType 

func (r *OCR2SpecResolver) PluginType() string

PluginType resolves the spec's plugin type

func (*OCR2SpecResolver) Relay 

func (r *OCR2SpecResolver) Relay() string

Relay resolves the spec's relay

func (*OCR2SpecResolver) RelayConfig 

func (r *OCR2SpecResolver) RelayConfig() gqlscalar.Map

RelayConfig resolves the spec's relay config

func (*OCR2SpecResolver) TransmitterID 

func (r *OCR2SpecResolver) TransmitterID() *string

TransmitterID resolves the spec's transmitter id

type OCRKeyBundleResolver 

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

func NewOCRKeyBundleResolver 

func NewOCRKeyBundleResolver(key ocrkey.KeyV2) OCRKeyBundleResolver

func (OCRKeyBundleResolver) ConfigPublicKey 

func (k OCRKeyBundleResolver) ConfigPublicKey() string

func (OCRKeyBundleResolver) ID 

func (k OCRKeyBundleResolver) ID() graphql.ID

func (OCRKeyBundleResolver) OffChainPublicKey 

func (k OCRKeyBundleResolver) OffChainPublicKey() string

func (OCRKeyBundleResolver) OnChainSigningAddress 

func (k OCRKeyBundleResolver) OnChainSigningAddress() string

type OCRKeyBundlesPayloadResolver 

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

func NewOCRKeyBundlesPayloadResolver 

func NewOCRKeyBundlesPayloadResolver(keys []ocrkey.KeyV2) *OCRKeyBundlesPayloadResolver

func (*OCRKeyBundlesPayloadResolver) Results 

func (r *OCRKeyBundlesPayloadResolver) Results() []OCRKeyBundleResolver

type OCRSpecResolver 

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

func (*OCRSpecResolver) BlockchainTimeout 

func (r *OCRSpecResolver) BlockchainTimeout() *string

BlockchainTimeout resolves the spec's blockchain timeout.

func (*OCRSpecResolver) BlockchainTimeoutEnv 

func (r *OCRSpecResolver) BlockchainTimeoutEnv() bool

BlockchainTimeoutEnv resolves whether the spec's blockchain timeout comes from an env var.

func (*OCRSpecResolver) ContractAddress 

func (r *OCRSpecResolver) ContractAddress() string

ContractAddress resolves the spec's contract address.

func (*OCRSpecResolver) ContractConfigConfirmations 

func (r *OCRSpecResolver) ContractConfigConfirmations() *int32

ContractConfigConfirmations resolves the spec's confirmations config.

func (*OCRSpecResolver) ContractConfigConfirmationsEnv 

func (r *OCRSpecResolver) ContractConfigConfirmationsEnv() bool

ContractConfigConfirmationsEnv resolves whether spec's confirmations config comes from an env var.

func (*OCRSpecResolver) ContractConfigTrackerPollInterval 

func (r *OCRSpecResolver) ContractConfigTrackerPollInterval() *string

ContractConfigTrackerPollInterval resolves the spec's contract tracker poll interval config.

func (*OCRSpecResolver) ContractConfigTrackerPollIntervalEnv 

func (r *OCRSpecResolver) ContractConfigTrackerPollIntervalEnv() bool

ContractConfigTrackerPollIntervalEnv resolves the whether spec's tracker poll config comes from an env var.

func (*OCRSpecResolver) ContractConfigTrackerSubscribeInterval 

func (r *OCRSpecResolver) ContractConfigTrackerSubscribeInterval() *string

ContractConfigTrackerSubscribeInterval resolves the spec's tracker subscribe interval config.

func (*OCRSpecResolver) ContractConfigTrackerSubscribeIntervalEnv 

func (r *OCRSpecResolver) ContractConfigTrackerSubscribeIntervalEnv() bool

ContractConfigTrackerSubscribeIntervalEnv resolves whether spec's tracker subscribe interval config comes from an env var.

func (*OCRSpecResolver) ContractTransmitterTransmitTimeout 

func (r *OCRSpecResolver) ContractTransmitterTransmitTimeout() string

ContractTransmitterTransmitTimeout resolves the spec's contract transmitter transmit timeout.

func (*OCRSpecResolver) ContractTransmitterTransmitTimeoutEnv 

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 

func (r *OCRSpecResolver) DatabaseTimeout() string

DatabaseTimeout resolves the spec's database timeout.

func (*OCRSpecResolver) DatabaseTimeoutEnv 

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 

func (r *OCRSpecResolver) ObservationGracePeriod() string

ObservationGracePeriod resolves the spec's observation grace period.

func (*OCRSpecResolver) ObservationGracePeriodEnv 

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 

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 

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 

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 PluginsResolver 

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

func (PluginsResolver) Commit 

func (r PluginsResolver) Commit() bool

Commit returns the the status of the commit plugin.

func (PluginsResolver) Execute 

func (r PluginsResolver) Execute() bool

Execute returns the the status of the execute plugin.

func (PluginsResolver) Median 

func (r PluginsResolver) Median() bool

Median returns the the status of the median plugin.

func (PluginsResolver) Mercury 

func (r PluginsResolver) Mercury() bool

Mercury returns the the status of the mercury plugin.

type RejectJobProposalSpecPayloadResolver 

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

RejectJobProposalSpecPayloadResolver resolves the reject payload response.

func NewRejectJobProposalSpecPayload 

func NewRejectJobProposalSpecPayload(spec *feeds.JobProposalSpec, err error) *RejectJobProposalSpecPayloadResolver

NewRejectJobProposalSpecPayload constructs a RejectJobProposalSpecPayloadResolver.

func (*RejectJobProposalSpecPayloadResolver) ToRejectJobProposalSpecSuccess 

func (r *RejectJobProposalSpecPayloadResolver) ToRejectJobProposalSpecSuccess() (*RejectJobProposalSpecSuccessResolver, bool)

ToRejectJobProposalSpecSuccess resolves to the reject job proposal spec success resolver.

type RejectJobProposalSpecSuccessResolver 

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

RejectJobProposalSpecSuccessResolver resolves the rejection success response.

func NewRejectJobProposalSpecSuccess 

func NewRejectJobProposalSpecSuccess(spec *feeds.JobProposalSpec) *RejectJobProposalSpecSuccessResolver

NewRejectJobProposalSpecSuccess generates the resolver.

func (*RejectJobProposalSpecSuccessResolver) Spec 

func (r *RejectJobProposalSpecSuccessResolver) Spec() *JobProposalSpecResolver

Spec returns the job proposal spec.

type Resolver 

type Resolver struct {
	App chainlink.Application
}

func (*Resolver) ApproveJobProposalSpec 

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 

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

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

func (r *Resolver) CreateFeedsManager(ctx context.Context, args struct {
	Input *createFeedsManagerInput
}) (*CreateFeedsManagerPayloadResolver, error)

func (*Resolver) CreateFeedsManagerChainConfig 

func (r *Resolver) CreateFeedsManagerChainConfig(ctx context.Context, args struct {
	Input *createFeedsManagerChainConfigInput
}) (*CreateFeedsManagerChainConfigPayloadResolver, error)

func (*Resolver) CreateJob 

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

func (*Resolver) CreateOCR2KeyBundle 

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

func (r *Resolver) DeleteFeedsManagerChainConfig(ctx context.Context, args struct {
	ID string
}) (*DeleteFeedsManagerChainConfigPayloadResolver, error)

func (*Resolver) DeleteJob 

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

func (*Resolver) DeleteOCR2KeyBundle 

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 

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

func (*Resolver) ETHKeys 

func (r *Resolver) ETHKeys(ctx context.Context) (*ETHKeysPayloadResolver, error)

func (*Resolver) EthTransaction 

func (r *Resolver) EthTransaction(ctx context.Context, args struct {
	Hash graphql.ID
}) (*EthTransactionPayloadResolver, error)

func (*Resolver) EthTransactions 

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

func (*Resolver) EthTransactionsAttempts 

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 

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 

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

func (*Resolver) JobRuns 

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 

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 

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

RejectJobProposalSpec rejects the job proposal spec.

func (*Resolver) RunJob 

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

func (*Resolver) SQLLogging 

func (r *Resolver) SQLLogging(ctx context.Context) (*GetSQLLoggingPayloadResolver, error)

func (*Resolver) SetGlobalLogLevel 

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 

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

func (r *Resolver) UpdateFeedsManager(ctx context.Context, args struct {
	ID    graphql.ID
	Input *updateFeedsManagerInput
}) (*UpdateFeedsManagerPayloadResolver, error)

func (*Resolver) UpdateFeedsManagerChainConfig 

func (r *Resolver) UpdateFeedsManagerChainConfig(ctx context.Context, args struct {
	ID    string
	Input *updateFeedsManagerChainConfigInput
}) (*UpdateFeedsManagerChainConfigPayloadResolver, error)

func (*Resolver) UpdateJobProposalSpecDefinition 

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 

type RoleNotPermittedErr struct {
	Role sessions.UserRole
}

func (RoleNotPermittedErr) Error 

func (e RoleNotPermittedErr) Error() string

type RunJobCannotRunErrorResolver 

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

func NewRunJobCannotRunError 

func NewRunJobCannotRunError(err error) *RunJobCannotRunErrorResolver

func (*RunJobCannotRunErrorResolver) Code 

func (r *RunJobCannotRunErrorResolver) Code() ErrorCode

func (*RunJobCannotRunErrorResolver) Message 

func (r *RunJobCannotRunErrorResolver) Message() string

type RunJobPayloadResolver 

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

func NewRunJobPayload 

func NewRunJobPayload(run *pipeline.Run, app chainlink.Application, err error) *RunJobPayloadResolver

func (*RunJobPayloadResolver) ToRunJobCannotRunError 

func (r *RunJobPayloadResolver) ToRunJobCannotRunError() (*RunJobCannotRunErrorResolver, bool)

func (*RunJobPayloadResolver) ToRunJobSuccess 

func (r *RunJobPayloadResolver) ToRunJobSuccess() (*RunJobSuccessResolver, bool)

type RunJobSuccessResolver 

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

func NewRunJobSuccess 

func NewRunJobSuccess(run pipeline.Run, app chainlink.Application) *RunJobSuccessResolver

func (*RunJobSuccessResolver) JobRun 

func (r *RunJobSuccessResolver) JobRun() *JobRunResolver

type SQLLoggingResolver 

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

func NewSQLLogging 

func NewSQLLogging(enabled bool) *SQLLoggingResolver

func (*SQLLoggingResolver) Enabled 

func (r *SQLLoggingResolver) Enabled() bool

type SetGlobalLogLevelPayloadResolver 

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

func NewSetGlobalLogLevelPayload 

func NewSetGlobalLogLevelPayload(lvl LogLevel, inputErrs map[string]string) *SetGlobalLogLevelPayloadResolver

func (*SetGlobalLogLevelPayloadResolver) ToInputErrors 

func (r *SetGlobalLogLevelPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)

func (*SetGlobalLogLevelPayloadResolver) ToSetGlobalLogLevelSuccess 

func (r *SetGlobalLogLevelPayloadResolver) ToSetGlobalLogLevelSuccess() (*SetGlobalLogLevelSuccessResolver, bool)

type SetGlobalLogLevelSuccessResolver 

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

func NewSetGlobalLogLevelSuccess 

func NewSetGlobalLogLevelSuccess(lvl LogLevel) *SetGlobalLogLevelSuccessResolver

func (*SetGlobalLogLevelSuccessResolver) GlobalLogLevel 

func (r *SetGlobalLogLevelSuccessResolver) GlobalLogLevel() *GlobalLogLevelResolver

type SetSQLLoggingPayloadResolver 

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

func NewSetSQLLoggingPayload 

func NewSetSQLLoggingPayload(enabled bool) *SetSQLLoggingPayloadResolver

func (*SetSQLLoggingPayloadResolver) ToSetSQLLoggingSuccess 

func (r *SetSQLLoggingPayloadResolver) ToSetSQLLoggingSuccess() (*SetSQLLoggingSuccessResolver, bool)

type SetSQLLoggingSuccessResolver 

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

func NewSetSQLLoggingSuccess 

func NewSetSQLLoggingSuccess(enabled bool) *SetSQLLoggingSuccessResolver

func (*SetSQLLoggingSuccessResolver) SQLLogging 

func (r *SetSQLLoggingSuccessResolver) SQLLogging() *SQLLoggingResolver

type SingleFeedsManagerErrorResolver 

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

SingleFeedsManagerErrorResolver -

func NewSingleFeedsManagerError 

func NewSingleFeedsManagerError(message string) *SingleFeedsManagerErrorResolver

func (*SingleFeedsManagerErrorResolver) Code 

func (r *SingleFeedsManagerErrorResolver) Code() ErrorCode

func (*SingleFeedsManagerErrorResolver) Message 

func (r *SingleFeedsManagerErrorResolver) Message() string

type SolanaKeyResolver 

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

func NewSolanaKey 

func NewSolanaKey(key solkey.Key) *SolanaKeyResolver

func NewSolanaKeys 

func NewSolanaKeys(keys []solkey.Key) []*SolanaKeyResolver

func (*SolanaKeyResolver) ID 

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

type SolanaKeysPayloadResolver 

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

func NewSolanaKeysPayload 

func NewSolanaKeysPayload(keys []solkey.Key) *SolanaKeysPayloadResolver

func (*SolanaKeysPayloadResolver) Results 

func (r *SolanaKeysPayloadResolver) Results() []*SolanaKeyResolver

type SpecResolver 

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

func NewSpec 

func NewSpec(j job.Job) *SpecResolver

func (*SpecResolver) ToBlockHeaderFeederSpec 

func (r *SpecResolver) ToBlockHeaderFeederSpec() (*BlockHeaderFeederSpecResolver, bool)

ToBlockHeaderFeederSpec returns the BlockHeaderFeederSpec from the SpecResolver if the job is a BlockHeaderFeeder job.

func (*SpecResolver) ToBlockhashStoreSpec 

func (r *SpecResolver) ToBlockhashStoreSpec() (*BlockhashStoreSpecResolver, bool)

ToBlockhashStoreSpec returns the BlockhashStoreSpec from the SpecResolver if the job is a BlockhashStore job.

func (*SpecResolver) ToBootstrapSpec 

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) ToGatewaySpec added in v2.3.0 

func (r *SpecResolver) ToGatewaySpec() (*GatewaySpecResolver, bool)

func (*SpecResolver) ToKeeperSpec 

func (r *SpecResolver) ToKeeperSpec() (*KeeperSpecResolver, bool)

func (*SpecResolver) ToOCR2Spec 

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 

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"
	SpecStatusRevoked   SpecStatus = "REVOKED"
)

func ToSpecStatus 

func ToSpecStatus(s feeds.SpecStatus) SpecStatus

ToSpecStatus converts the feeds status into the enum value.

type TaskRunResolver 

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

func NewTaskRun 

func NewTaskRun(tr pipeline.TaskRun) *TaskRunResolver

func NewTaskRuns 

func NewTaskRuns(runs []pipeline.TaskRun) []*TaskRunResolver

func (*TaskRunResolver) CreatedAt 

func (r *TaskRunResolver) CreatedAt() graphql.Time

func (*TaskRunResolver) DotID 

func (r *TaskRunResolver) DotID() string

func (*TaskRunResolver) Error 

func (r *TaskRunResolver) Error() *string

func (*TaskRunResolver) FinishedAt 

func (r *TaskRunResolver) FinishedAt() *graphql.Time

func (*TaskRunResolver) ID 

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

func (*TaskRunResolver) Output 

func (r *TaskRunResolver) Output() string

func (*TaskRunResolver) Type 

func (r *TaskRunResolver) Type() string

type UpdateBridgePayloadResolver 

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

func NewUpdateBridgePayload 

func NewUpdateBridgePayload(bridge *bridges.BridgeType, err error) *UpdateBridgePayloadResolver

func (*UpdateBridgePayloadResolver) ToUpdateBridgeSuccess 

func (r *UpdateBridgePayloadResolver) ToUpdateBridgeSuccess() (*UpdateBridgeSuccessResolver, bool)

type UpdateBridgeSuccessResolver 

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

UpdateBridgePayloadResolver resolves

func NewUpdateBridgeSuccess 

func NewUpdateBridgeSuccess(bridge bridges.BridgeType) *UpdateBridgeSuccessResolver

func (*UpdateBridgeSuccessResolver) Bridge 

func (r *UpdateBridgeSuccessResolver) Bridge() *BridgeResolver

Bridge resolves the success payload's bridge.

type UpdateFeedsManagerChainConfigPayloadResolver 

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

UpdateFeedsManagerChainConfigPayloadResolver resolves the response to UpdateFeedsManagerChainConfig

func NewUpdateFeedsManagerChainConfigPayload 

func NewUpdateFeedsManagerChainConfigPayload(cfg *feeds.ChainConfig, err error, inputErrs map[string]string) *UpdateFeedsManagerChainConfigPayloadResolver

func (*UpdateFeedsManagerChainConfigPayloadResolver) ToInputErrors 

func (r *UpdateFeedsManagerChainConfigPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)

func (*UpdateFeedsManagerChainConfigPayloadResolver) ToUpdateFeedsManagerChainConfigSuccess 

func (r *UpdateFeedsManagerChainConfigPayloadResolver) ToUpdateFeedsManagerChainConfigSuccess() (*UpdateFeedsManagerChainConfigSuccessResolver, bool)

type UpdateFeedsManagerChainConfigSuccessResolver 

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

func NewUpdateFeedsManagerChainConfigSuccessResolver 

func NewUpdateFeedsManagerChainConfigSuccessResolver(cfg *feeds.ChainConfig) *UpdateFeedsManagerChainConfigSuccessResolver

func (*UpdateFeedsManagerChainConfigSuccessResolver) ChainConfig 

func (r *UpdateFeedsManagerChainConfigSuccessResolver) ChainConfig() *FeedsManagerChainConfigResolver

type UpdateFeedsManagerPayloadResolver 

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

UpdateFeedsManagerPayloadResolver -

func NewUpdateFeedsManagerPayload 

func NewUpdateFeedsManagerPayload(mgr *feeds.FeedsManager, err error, inputErrs map[string]string) *UpdateFeedsManagerPayloadResolver

func (*UpdateFeedsManagerPayloadResolver) ToInputErrors 

func (r *UpdateFeedsManagerPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)

func (*UpdateFeedsManagerPayloadResolver) ToUpdateFeedsManagerSuccess 

func (r *UpdateFeedsManagerPayloadResolver) ToUpdateFeedsManagerSuccess() (*UpdateFeedsManagerSuccessResolver, bool)

type UpdateFeedsManagerSuccessResolver 

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

func NewUpdateFeedsManagerSuccessResolver 

func NewUpdateFeedsManagerSuccessResolver(mgr feeds.FeedsManager) *UpdateFeedsManagerSuccessResolver

func (*UpdateFeedsManagerSuccessResolver) FeedsManager 

func (r *UpdateFeedsManagerSuccessResolver) FeedsManager() *FeedsManagerResolver

type UpdateJobProposalSpecDefinitionPayloadResolver 

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

UpdateJobProposalSpecDefinitionPayloadResolver generates the update spec definition payload.

func NewUpdateJobProposalSpecDefinitionPayload 

func NewUpdateJobProposalSpecDefinitionPayload(spec *feeds.JobProposalSpec, err error) *UpdateJobProposalSpecDefinitionPayloadResolver

NewUpdateJobProposalSpecDefinitionPayload constructs UpdateJobProposalSpecDefinitionPayloadResolver.

func (*UpdateJobProposalSpecDefinitionPayloadResolver) ToUpdateJobProposalSpecDefinitionSuccess 

func (r *UpdateJobProposalSpecDefinitionPayloadResolver) ToUpdateJobProposalSpecDefinitionSuccess() (*UpdateJobProposalSpecDefinitionSuccessResolver, bool)

ToUpdateJobProposalSpecDefinitionSuccess resolves to the update job proposal definition success resolver.

type UpdateJobProposalSpecDefinitionSuccessResolver 

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

UpdateJobProposalSpecDefinitionSuccessResolver resolves the update success response.

func NewUpdateJobProposalSpecDefinitionSuccess 

func NewUpdateJobProposalSpecDefinitionSuccess(spec *feeds.JobProposalSpec) *UpdateJobProposalSpecDefinitionSuccessResolver

NewUpdateJobProposalSpecDefinitionSuccess constructs UpdateJobProposalSpecDefinitionSuccessResolver.

func (*UpdateJobProposalSpecDefinitionSuccessResolver) Spec 

func (r *UpdateJobProposalSpecDefinitionSuccessResolver) Spec() *JobProposalSpecResolver

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 (r *UpdatePasswordPayloadResolver) ToInputErrors() (*InputErrorsResolver, bool)

func (*UpdatePasswordPayloadResolver) ToUpdatePasswordSuccess 

func (r *UpdatePasswordPayloadResolver) ToUpdatePasswordSuccess() (*UpdatePasswordSuccessResolver, bool)

type UpdatePasswordSuccessResolver 

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

func NewUpdatePasswordSuccess 

func NewUpdatePasswordSuccess(user *sessions.User) *UpdatePasswordSuccessResolver

func (*UpdatePasswordSuccessResolver) User 

func (r *UpdatePasswordSuccessResolver) User() *UserResolver

type UserResolver 

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

UserResolver resolves the User type

func NewUser 

func NewUser(user *sessions.User) *UserResolver

func (*UserResolver) CreatedAt 

func (r *UserResolver) CreatedAt() graphql.Time

CreatedAt resolves the user's creation date

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 

func (r *VRFKeySuccessResolver) Key() VRFKeyResolver

type VRFKeysPayloadResolver 

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

func NewVRFKeysPayloadResolver 

func NewVRFKeysPayloadResolver(keys []vrfkey.KeyV2) *VRFKeysPayloadResolver

func (*VRFKeysPayloadResolver) Results 

func (r *VRFKeysPayloadResolver) Results() []VRFKeyResolver

type VRFSpecResolver 

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

func (*VRFSpecResolver) BackoffInitialDelay 

func (r *VRFSpecResolver) BackoffInitialDelay() string

BackoffInitialDelay resolves the spec's backoff initial delay.

func (*VRFSpecResolver) BackoffMaxDelay 

func (r *VRFSpecResolver) BackoffMaxDelay() string

BackoffMaxDelay resolves the spec's backoff max delay.

func (*VRFSpecResolver) BatchCoordinatorAddress 

func (r *VRFSpecResolver) BatchCoordinatorAddress() *string

BatchCoordinatorAddress resolves the spec's batch coordinator address.

func (*VRFSpecResolver) BatchFulfillmentEnabled 

func (r *VRFSpecResolver) BatchFulfillmentEnabled() bool

BatchFulfillmentEnabled resolves the spec's batch fulfillment enabled flag.

func (*VRFSpecResolver) BatchFulfillmentGasMultiplier 

func (r *VRFSpecResolver) BatchFulfillmentGasMultiplier() float64

BatchFulfillmentGasMultiplier resolves the spec's batch fulfillment gas multiplier.

func (*VRFSpecResolver) ChunkSize 

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 

func (r *VRFSpecResolver) FromAddresses() *[]string

FromAddresses resolves the spec's from addresses.

func (*VRFSpecResolver) GasLanePrice 

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 

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 

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.

func (*VRFSpecResolver) VRFOwnerAddress added in v2.3.0 

func (r *VRFSpecResolver) VRFOwnerAddress() *string

VRFOwnerAddress resolves the spec's vrf owner address.

type WebhookSpecResolver 

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

func (*WebhookSpecResolver) CreatedAt 

func (r *WebhookSpecResolver) CreatedAt() graphql.Time

CreatedAt resolves the spec's created at timestamp.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.