resolver

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Jan 25, 2022 License: MIT Imports: 35 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"
)

Variables

This section is empty.

Functions

func FromChainType 

func FromChainType(ct ChainType) string

func FromGasEstimatorMode 

func FromGasEstimatorMode(gsm GasEstimatorMode) string

func FromJobTypeInput 

func FromJobTypeInput(jt JobType) string

FromJobType converts a JoyType into a string which is used to create/update a feeds manager.

FluxMonitor is a special case because the FeedsManager expects a 'fluxmonitor' string rather than just the lowercased value.

Note: We should change the flux monitor service methods to accept an enum for the job type to add more consistency.

func FromLogLevel 

func FromLogLevel(logLvl LogLevel) string

func ToChainConfig 

func ToChainConfig(input ChainConfigInput) (*types.ChainCfg, map[string]string)

func ValidateBridgeType 

func ValidateBridgeType(bt *bridges.BridgeTypeRequest) error

ValidateBridgeType checks that the bridge type doesn't have a duplicate or invalid name or invalid url

This validation function should be moved into a bridge service and return multiple errors.

func ValidateBridgeTypeUniqueness 

func ValidateBridgeTypeUniqueness(bt *bridges.BridgeTypeRequest, orm bridges.ORM) error

ValidateBridgeTypeUniqueness checks that a bridge has not already been created

/ This validation function should be moved into a bridge service.

Types

type APITokenResolver 

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

func NewAPIToken 

func NewAPIToken(token auth.Token) *APITokenResolver

func (*APITokenResolver) AccessKey 

func (r *APITokenResolver) AccessKey() string

func (*APITokenResolver) Secret 

func (r *APITokenResolver) Secret() string

type ApproveJobProposalPayloadResolver 

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

func NewApproveJobProposalPayload 

func NewApproveJobProposalPayload(jp *feeds.JobProposal, err error) *ApproveJobProposalPayloadResolver

func (*ApproveJobProposalPayloadResolver) ToApproveJobProposalSuccess 

func (r *ApproveJobProposalPayloadResolver) ToApproveJobProposalSuccess() (*ApproveJobProposalSuccessResolver, bool)

ToApproveJobProposalSuccess resolves to the approval job proposal success resolver

type ApproveJobProposalSuccessResolver 

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

func NewApproveJobProposalSuccess 

func NewApproveJobProposalSuccess(jp *feeds.JobProposal) *ApproveJobProposalSuccessResolver

func (*ApproveJobProposalSuccessResolver) JobProposal 

func (r *ApproveJobProposalSuccessResolver) JobProposal() *JobProposalResolver

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 CancelJobProposalPayloadResolver 

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

func NewCancelJobProposalPayload 

func NewCancelJobProposalPayload(jp *feeds.JobProposal, err error) *CancelJobProposalPayloadResolver

func (*CancelJobProposalPayloadResolver) ToCancelJobProposalSuccess 

func (r *CancelJobProposalPayloadResolver) ToCancelJobProposalSuccess() (*CancelJobProposalSuccessResolver, bool)

ToCancelJobProposalSuccess resolves to the approval job proposal success resolver

type CancelJobProposalSuccessResolver 

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

func NewCancelJobProposalSuccess 

func NewCancelJobProposalSuccess(jp *feeds.JobProposal) *CancelJobProposalSuccessResolver

func (*CancelJobProposalSuccessResolver) JobProposal 

func (r *CancelJobProposalSuccessResolver) JobProposal() *JobProposalResolver

type ChainConfigInput 

type ChainConfigInput struct {
	BlockHistoryEstimatorBlockDelay       *int32
	BlockHistoryEstimatorBlockHistorySize *int32
	EthTxReaperThreshold                  *string
	EthTxResendAfterThreshold             *string
	EvmEIP1559DynamicFees                 *bool
	EvmFinalityDepth                      *int32
	EvmGasBumpPercent                     *int32
	EvmGasBumpTxDepth                     *int32
	EvmGasBumpWei                         *string
	EvmGasLimitDefault                    *int32
	EvmGasLimitMultiplier                 *float64
	EvmGasPriceDefault                    *string
	EvmGasTipCapDefault                   *string
	EvmGasTipCapMinimum                   *string
	EvmHeadTrackerHistoryDepth            *int32
	EvmHeadTrackerMaxBufferSize           *int32
	EvmHeadTrackerSamplingInterval        *string
	EvmLogBackfillBatchSize               *int32
	EvmMaxGasPriceWei                     *string
	EvmNonceAutoSync                      *bool
	EvmRPCDefaultBatchSize                *int32
	FlagsContractAddress                  *string
	GasEstimatorMode                      *GasEstimatorMode
	ChainType                             *ChainType
	MinIncomingConfirmations              *int32
	MinRequiredOutgoingConfirmations      *int32
	MinimumContractPayment                *string
	OCRObservationTimeout                 *string
}

type ChainConfigResolver 

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

func NewChainConfig 

func NewChainConfig(cfg types.ChainCfg) *ChainConfigResolver

func (*ChainConfigResolver) BlockHistoryEstimatorBlockDelay 

func (r *ChainConfigResolver) BlockHistoryEstimatorBlockDelay() *int32

func (*ChainConfigResolver) BlockHistoryEstimatorBlockHistorySize 

func (r *ChainConfigResolver) BlockHistoryEstimatorBlockHistorySize() *int32

func (*ChainConfigResolver) ChainType 

func (r *ChainConfigResolver) ChainType() *ChainType

func (*ChainConfigResolver) EthTxReaperThreshold 

func (r *ChainConfigResolver) EthTxReaperThreshold() *string

func (*ChainConfigResolver) EthTxResendAfterThreshold 

func (r *ChainConfigResolver) EthTxResendAfterThreshold() *string

func (*ChainConfigResolver) EvmEIP1559DynamicFees 

func (r *ChainConfigResolver) EvmEIP1559DynamicFees() *bool

func (*ChainConfigResolver) EvmFinalityDepth 

func (r *ChainConfigResolver) EvmFinalityDepth() *int32

func (*ChainConfigResolver) EvmGasBumpPercent 

func (r *ChainConfigResolver) EvmGasBumpPercent() *int32

func (*ChainConfigResolver) EvmGasBumpTxDepth 

func (r *ChainConfigResolver) EvmGasBumpTxDepth() *int32

func (*ChainConfigResolver) EvmGasBumpWei 

func (r *ChainConfigResolver) EvmGasBumpWei() *string

func (*ChainConfigResolver) EvmGasLimitDefault 

func (r *ChainConfigResolver) EvmGasLimitDefault() *int32

func (*ChainConfigResolver) EvmGasLimitMultiplier 

func (r *ChainConfigResolver) EvmGasLimitMultiplier() *float64

func (*ChainConfigResolver) EvmGasPriceDefault 

func (r *ChainConfigResolver) EvmGasPriceDefault() *string

func (*ChainConfigResolver) EvmGasTipCapDefault 

func (r *ChainConfigResolver) EvmGasTipCapDefault() *string

func (*ChainConfigResolver) EvmGasTipCapMinimum 

func (r *ChainConfigResolver) EvmGasTipCapMinimum() *string

func (*ChainConfigResolver) EvmHeadTrackerHistoryDepth 

func (r *ChainConfigResolver) EvmHeadTrackerHistoryDepth() *int32

func (*ChainConfigResolver) EvmHeadTrackerMaxBufferSize 

func (r *ChainConfigResolver) EvmHeadTrackerMaxBufferSize() *int32

func (*ChainConfigResolver) EvmHeadTrackerSamplingInterval 

func (r *ChainConfigResolver) EvmHeadTrackerSamplingInterval() *string

func (*ChainConfigResolver) EvmLogBackfillBatchSize 

func (r *ChainConfigResolver) EvmLogBackfillBatchSize() *int32

func (*ChainConfigResolver) EvmMaxGasPriceWei 

func (r *ChainConfigResolver) EvmMaxGasPriceWei() *string

func (*ChainConfigResolver) EvmNonceAutoSync 

func (r *ChainConfigResolver) EvmNonceAutoSync() *bool

func (*ChainConfigResolver) EvmRPCDefaultBatchSize 

func (r *ChainConfigResolver) EvmRPCDefaultBatchSize() *int32

func (*ChainConfigResolver) FlagsContractAddress 

func (r *ChainConfigResolver) FlagsContractAddress() *string

func (*ChainConfigResolver) GasEstimatorMode 

func (r *ChainConfigResolver) GasEstimatorMode() *GasEstimatorMode

func (*ChainConfigResolver) KeySpecificConfigs 

func (r *ChainConfigResolver) KeySpecificConfigs() []*KeySpecificChainConfigResolver

func (*ChainConfigResolver) MinIncomingConfirmations 

func (r *ChainConfigResolver) MinIncomingConfirmations() *int32

func (*ChainConfigResolver) MinRequiredOutgoingConfirmations 

func (r *ChainConfigResolver) MinRequiredOutgoingConfirmations() *int32

func (*ChainConfigResolver) MinimumContractPayment 

func (r *ChainConfigResolver) MinimumContractPayment() *string

func (*ChainConfigResolver) OCRObservationTimeout 

func (r *ChainConfigResolver) OCRObservationTimeout() *string

type ChainPayloadResolver 

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

func NewChainPayload 

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

func NewChains 

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

func (*ChainResolver) Config 

func (r *ChainResolver) Config() *ChainConfigResolver

Config resolves the chain's configuration field

func (*ChainResolver) CreatedAt 

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

CreatedAt resolves the chains's created at field.

func (*ChainResolver) Enabled 

func (r *ChainResolver) Enabled() bool

Enabled resolves the chains's enabled field.

func (*ChainResolver) ID 

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

ID resolves the chains's unique identifier.

func (*ChainResolver) Nodes 

func (r *ChainResolver) Nodes(ctx context.Context) ([]*NodeResolver, error)

func (*ChainResolver) UpdatedAt 

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

UpdatedAt resolves the chains's updated at field.

type ChainType 

type ChainType string
const (
	ChainTypeArbitrum ChainType = "ARBITRUM"
	ChainTypeExChain  ChainType = "EXCHAIN"
	ChainTypeOptimism ChainType = "OPTIMISM"
	ChainTypeXDAI     ChainType = "XDAI"
)

func ToChainType 

func ToChainType(s string) (ChainType, error)

type ChainsPayloadResolver 

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

func NewChainsPayload 

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

func (*ChainsPayloadResolver) Metadata 

func (r *ChainsPayloadResolver) Metadata() *PaginationMetadataResolver

func (*ChainsPayloadResolver) Results 

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

type CreateAPITokenPayloadResolver 

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

func NewCreateAPITokenPayload 

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

func (*CreateAPITokenPayloadResolver) ToCreateAPITokenSuccess 

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

func (*CreateAPITokenPayloadResolver) ToInputErrors 

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

type CreateAPITokenSuccessResolver 

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

func NewCreateAPITokenSuccess 

func NewCreateAPITokenSuccess(token *auth.Token) *CreateAPITokenSuccessResolver

func (*CreateAPITokenSuccessResolver) Token 

func (r *CreateAPITokenSuccessResolver) Token() *APITokenResolver

type CreateBridgePayloadResolver 

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

CreateBridgePayloadResolver

func NewCreateBridgePayload 

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

func (*CreateBridgePayloadResolver) ToCreateBridgeSuccess 

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

type CreateBridgeSuccessResolver 

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

func NewCreateBridgeSuccessResolver 

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

func (*CreateBridgeSuccessResolver) Bridge 

func (r *CreateBridgeSuccessResolver) Bridge() *BridgeResolver

Bridge resolves the bridge.

func (*CreateBridgeSuccessResolver) IncomingToken 

func (r *CreateBridgeSuccessResolver) IncomingToken() string

Token resolves the bridge's incoming token.

type CreateCSAKeyPayloadResolver 

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

func NewCreateCSAKeyPayload 

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

func (*CreateCSAKeyPayloadResolver) ToCSAKeyExistsError 

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

func (*CreateCSAKeyPayloadResolver) ToCreateCSAKeySuccess 

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

type CreateCSAKeySuccessResolver 

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

func NewCreateCSAKeySuccessResolver 

func NewCreateCSAKeySuccessResolver(key *csakey.KeyV2) *CreateCSAKeySuccessResolver

func (*CreateCSAKeySuccessResolver) CSAKey 

func (r *CreateCSAKeySuccessResolver) CSAKey() *CSAKeyResolver

type CreateChainPayloadResolver 

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

func NewCreateChainPayload 

func NewCreateChainPayload(chain *types.Chain, inputErrs map[string]string) *CreateChainPayloadResolver

func (*CreateChainPayloadResolver) ToCreateChainSuccess 

func (r *CreateChainPayloadResolver) ToCreateChainSuccess() (*CreateChainSuccessResolver, bool)

func (*CreateChainPayloadResolver) ToInputErrors 

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

type CreateChainSuccessResolver 

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

func NewCreateChainSuccess 

func NewCreateChainSuccess(chain *types.Chain) *CreateChainSuccessResolver

func (*CreateChainSuccessResolver) Chain 

func (r *CreateChainSuccessResolver) Chain() *ChainResolver

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 CreateNodePayloadResolver 

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

func NewCreateNodePayloadResolver 

func NewCreateNodePayloadResolver(node *types.Node) *CreateNodePayloadResolver

func (*CreateNodePayloadResolver) ToCreateNodeSuccess 

func (r *CreateNodePayloadResolver) ToCreateNodeSuccess() (*CreateNodeSuccessResolve, bool)

type CreateNodeSuccessResolve 

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

func NewCreateNodeSuccessResolve 

func NewCreateNodeSuccessResolve(node types.Node) *CreateNodeSuccessResolve

func (*CreateNodeSuccessResolve) Node 

func (r *CreateNodeSuccessResolve) Node() *NodeResolver

type CreateOCRKeyBundlePayloadResolver 

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

func NewCreateOCRKeyBundlePayloadResolver 

func NewCreateOCRKeyBundlePayloadResolver(key ocrkey.KeyV2) *CreateOCRKeyBundlePayloadResolver

func (*CreateOCRKeyBundlePayloadResolver) Bundle 

func (r *CreateOCRKeyBundlePayloadResolver) Bundle() OCRKeyBundleResolver

type CreateP2PKeyPayloadResolver 

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

func NewCreateP2PKeyPayloadResolver 

func NewCreateP2PKeyPayloadResolver(key p2pkey.KeyV2) *CreateP2PKeyPayloadResolver

func (*CreateP2PKeyPayloadResolver) Key 

func (r *CreateP2PKeyPayloadResolver) Key() P2PKeyResolver

type CreateVRFKeyPayloadResolver 

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

func NewCreateVRFKeyPayloadResolver 

func NewCreateVRFKeyPayloadResolver(key vrfkey.KeyV2) *CreateVRFKeyPayloadResolver

func (*CreateVRFKeyPayloadResolver) Key 

func (r *CreateVRFKeyPayloadResolver) Key() VRFKeyResolver

type CronSpecResolver 

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

func (*CronSpecResolver) CreatedAt 

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

CreatedAt resolves the spec's created at timestamp.

func (*CronSpecResolver) Schedule 

func (r *CronSpecResolver) Schedule() string

type DeleteAPITokenPayloadResolver 

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

func NewDeleteAPITokenPayload 

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

func (*DeleteAPITokenPayloadResolver) ToDeleteAPITokenSuccess 

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

func (*DeleteAPITokenPayloadResolver) ToInputErrors 

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

type DeleteAPITokenSuccessResolver 

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

func NewDeleteAPITokenSuccess 

func NewDeleteAPITokenSuccess(token *auth.Token) *DeleteAPITokenSuccessResolver

func (*DeleteAPITokenSuccessResolver) Token 

func (r *DeleteAPITokenSuccessResolver) Token() *APITokenResolver

type DeleteBridgeConflictErrorResolver 

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

func NewDeleteBridgeConflictError 

func NewDeleteBridgeConflictError(message string) *DeleteBridgeConflictErrorResolver

func (*DeleteBridgeConflictErrorResolver) Code 

func (r *DeleteBridgeConflictErrorResolver) Code() ErrorCode

func (*DeleteBridgeConflictErrorResolver) Message 

func (r *DeleteBridgeConflictErrorResolver) Message() string

type DeleteBridgeInvalidNameErrorResolver 

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

func NewDeleteBridgeInvalidNameError 

func NewDeleteBridgeInvalidNameError(message string) *DeleteBridgeInvalidNameErrorResolver

func (*DeleteBridgeInvalidNameErrorResolver) Code 

func (r *DeleteBridgeInvalidNameErrorResolver) Code() ErrorCode

func (*DeleteBridgeInvalidNameErrorResolver) Message 

func (r *DeleteBridgeInvalidNameErrorResolver) Message() string

type DeleteBridgePayloadResolver 

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

func NewDeleteBridgePayload 

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

func (*DeleteBridgePayloadResolver) ToDeleteBridgeConflictError 

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

func (*DeleteBridgePayloadResolver) ToDeleteBridgeInvalidNameError 

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

func (*DeleteBridgePayloadResolver) ToDeleteBridgeSuccess 

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

type DeleteBridgeSuccessResolver 

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

func NewDeleteBridgeSuccess 

func NewDeleteBridgeSuccess(bridge *bridges.BridgeType) *DeleteBridgeSuccessResolver

func (*DeleteBridgeSuccessResolver) Bridge 

func (r *DeleteBridgeSuccessResolver) Bridge() *BridgeResolver

type DeleteCSAKeyPayloadResolver 

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

func NewDeleteCSAKeyPayload 

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

func (*DeleteCSAKeyPayloadResolver) ToDeleteCSAKeySuccess 

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

type DeleteCSAKeySuccessResolver 

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

func NewDeleteCSAKeySuccess 

func NewDeleteCSAKeySuccess(key csakey.KeyV2) *DeleteCSAKeySuccessResolver

func (*DeleteCSAKeySuccessResolver) CSAKey 

func (r *DeleteCSAKeySuccessResolver) CSAKey() *CSAKeyResolver

type DeleteChainPayloadResolver 

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

func NewDeleteChainPayload 

func NewDeleteChainPayload(chain *types.Chain, err error) *DeleteChainPayloadResolver

func (*DeleteChainPayloadResolver) ToDeleteChainSuccess 

func (r *DeleteChainPayloadResolver) ToDeleteChainSuccess() (*DeleteChainSuccessResolver, bool)

type DeleteChainSuccessResolver 

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

func NewDeleteChainSuccess 

func NewDeleteChainSuccess(chain types.Chain) *DeleteChainSuccessResolver

func (*DeleteChainSuccessResolver) Chain 

func (r *DeleteChainSuccessResolver) Chain() *ChainResolver

type DeleteNodePayloadResolver 

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

func NewDeleteNodePayloadResolver 

func NewDeleteNodePayloadResolver(node *types.Node, err error) *DeleteNodePayloadResolver

func (*DeleteNodePayloadResolver) ToDeleteNodeSuccess 

func (r *DeleteNodePayloadResolver) ToDeleteNodeSuccess() (*DeleteNodeSuccessResolver, bool)

type DeleteNodeSuccessResolver 

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

func NewDeleteNodeSuccessResolver 

func NewDeleteNodeSuccessResolver(node *types.Node) *DeleteNodeSuccessResolver

func (*DeleteNodeSuccessResolver) Node 

func (r *DeleteNodeSuccessResolver) Node() *NodeResolver

type 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 NewDeleteP2PKeyPayloadResolver 

func NewDeleteP2PKeyPayloadResolver(key 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 NewDeleteP2PKeySuccessResolver 

func NewDeleteP2PKeySuccessResolver(key p2pkey.KeyV2) *DeleteP2PKeySuccessResolver

func (*DeleteP2PKeySuccessResolver) Key 

func (r *DeleteP2PKeySuccessResolver) Key() 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) MinContractPayment 

func (r *DirectRequestSpecResolver) MinContractPayment() string

MinContractPayment resolves the spec's evm chain id.

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 ErrorCode 

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

type FeaturesPayloadResolver 

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

func NewFeaturesPayloadResolver 

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

func (r *FeedsManagerResolver) BootstrapPeerMultiaddr() *string

BootstrapPeer resolves the feed managers's isConnectionActive field.

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

func (r *FeedsManagerResolver) IsBootstrapPeer() bool

IsBootstrapPeer resolves the feed managers's isBootstrapPeer field.

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

func (r *FeedsManagerResolver) JobTypes() []JobType

JobTypes resolves the feed managers's jobTypes field.

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 FluxMonitorSpecResolver 

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

func (*FluxMonitorSpecResolver) AbsoluteThreshold 

func (r *FluxMonitorSpecResolver) AbsoluteThreshold() float64

AbsoluteThreshold resolves the spec's absolute deviation threshold.

func (*FluxMonitorSpecResolver) ContractAddress 

func (r *FluxMonitorSpecResolver) ContractAddress() string

ContractAddress resolves the spec's contract address.

func (*FluxMonitorSpecResolver) CreatedAt 

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

CreatedAt resolves the spec's created at timestamp.

func (*FluxMonitorSpecResolver) DrumbeatEnabled 

func (r *FluxMonitorSpecResolver) DrumbeatEnabled() bool

AbsoluteThreshold resolves the spec's absolute threshold.

func (*FluxMonitorSpecResolver) DrumbeatRandomDelay 

func (r *FluxMonitorSpecResolver) DrumbeatRandomDelay() *string

DrumbeatRandomDelay resolves the spec's drumbeat random delay.

func (*FluxMonitorSpecResolver) DrumbeatSchedule 

func (r *FluxMonitorSpecResolver) DrumbeatSchedule() *string

DrumbeatSchedule resolves the spec's drumbeat schedule.

func (*FluxMonitorSpecResolver) EVMChainID 

func (r *FluxMonitorSpecResolver) EVMChainID() *string

EVMChainID resolves the spec's evm chain id.

func (*FluxMonitorSpecResolver) IdleTimerDisabled 

func (r *FluxMonitorSpecResolver) IdleTimerDisabled() bool

IdleTimerDisabled resolves the spec's idle timer disabled flag.

func (*FluxMonitorSpecResolver) IdleTimerPeriod 

func (r *FluxMonitorSpecResolver) IdleTimerPeriod() string

IdleTimerPeriod resolves the spec's idle timer period.

func (*FluxMonitorSpecResolver) MinPayment 

func (r *FluxMonitorSpecResolver) MinPayment() *string

MinPayment resolves the spec's min payment.

func (*FluxMonitorSpecResolver) PollTimerDisabled 

func (r *FluxMonitorSpecResolver) PollTimerDisabled() bool

PollTimerDisabled resolves the spec's poll timer disabled flag.

func (*FluxMonitorSpecResolver) PollTimerPeriod 

func (r *FluxMonitorSpecResolver) PollTimerPeriod() string

PollTimerPeriod resolves the spec's poll timer period.

func (*FluxMonitorSpecResolver) Threshold 

func (r *FluxMonitorSpecResolver) Threshold() float64

Threshold resolves the spec's deviation threshold.

type GasEstimatorMode 

type GasEstimatorMode string
const (
	GasEstimatorModeBlockHistory GasEstimatorMode = "BLOCK_HISTORY"
	GasEstimatorModeFixedPrice   GasEstimatorMode = "FIXED_PRICE"
	GasEstimatorModeOptimism     GasEstimatorMode = "OPTIMISM"
	GasEstimatorModeOptimism2    GasEstimatorMode = "OPTIMISM2"
)

func ToGasEstimatorMode 

func ToGasEstimatorMode(s string) (GasEstimatorMode, 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 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 occurances.

type JobPayloadResolver 

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

func NewJobPayload 

func NewJobPayload(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 JobProposalAction 

type JobProposalAction string

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

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

MultiAddrs resolves to the job proposal MultiAddrs

func (*JobProposalResolver) ProposedAt 

func (r *JobProposalResolver) ProposedAt() graphql.Time

ProposedAt resolves to the job proposal ProposedAt date

func (*JobProposalResolver) Spec 

func (r *JobProposalResolver) Spec() string

Spec resolves to the job proposal Spec

func (*JobProposalResolver) Status 

func (r *JobProposalResolver) Status() JobProposalStatus

Status resolves to the job proposal Status

type JobProposalStatus 

type JobProposalStatus string
const (
	PENDING   JobProposalStatus = "PENDING"
	APPROVED  JobProposalStatus = "APPROVED"
	REJECTED  JobProposalStatus = "REJECTED"
	CANCELLED JobProposalStatus = "CANCELLED"
)

func ToJobProposalStatus 

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

type JobResolver 

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

JobResolver resolves the Job type.

func NewJob 

func NewJob(j job.Job) *JobResolver

func NewJobs 

func NewJobs(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() []*JobErrorResolver

Errors resolves the job's top level errors.

This could potentially be moved into a dataloader if only resolver code uses it.

func (*JobResolver) ExternalJobID 

func (r *JobResolver) ExternalJobID() string

ExternalJobID resolves the job's external job id.

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) ([]*JobRunResolver, error)

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.

type JobRunResolver 

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

func NewJobRun 

func NewJobRun(run pipeline.Run) *JobRunResolver

func NewJobRuns 

func NewJobRuns(runs []pipeline.Run) []*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) Outputs 

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

func (*JobRunResolver) PipelineSpecID 

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

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 JobType 

type JobType string
const (
	JobTypeFluxMonitor JobType = "FLUX_MONITOR"
	JobTypeOCR         JobType = "OCR"
)

func ToJobType 

func ToJobType(s string) (JobType, error)

type JobsPayloadResolver 

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

JobsPayloadResolver resolves a page of jobs

func NewJobsPayload 

func NewJobsPayload(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 bridges.

type KeeperSpecResolver 

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

func (*KeeperSpecResolver) ContractAddress 

func (r *KeeperSpecResolver) ContractAddress() string

ContractAddress resolves the spec's contract address.

func (*KeeperSpecResolver) CreatedAt 

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

CreatedAt resolves the spec's created at timestamp.

func (*KeeperSpecResolver) EVMChainID 

func (r *KeeperSpecResolver) EVMChainID() *string

EVMChainID resolves the spec's evm chain id.

func (*KeeperSpecResolver) FromAddress 

func (r *KeeperSpecResolver) FromAddress() *string

FromAddress resolves the spec's from contract address.

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

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

type KeySpecificChainConfigInput 

type KeySpecificChainConfigInput struct {
	Address string
	Config  ChainConfigInput
}

type KeySpecificChainConfigResolver 

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

func NewKeySpecificChainConfig 

func NewKeySpecificChainConfig(address string, cfg types.ChainCfg) *KeySpecificChainConfigResolver

func (*KeySpecificChainConfigResolver) Address 

func (r *KeySpecificChainConfigResolver) Address() string

func (*KeySpecificChainConfigResolver) Config 

func (r *KeySpecificChainConfigResolver) Config() *ChainConfigResolver

type LogLevel 

type LogLevel string

type LogLevelConfig 

type LogLevelConfig struct {
	HeadTracker *LogLevel
	FluxMonitor *LogLevel
	Keeper      *LogLevel
}

type LogLevelConfigResolver 

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

func NewLogLevelConfig 

func NewLogLevelConfig(cfg LogLevelConfig) *LogLevelConfigResolver

func (*LogLevelConfigResolver) FluxMonitor 

func (r *LogLevelConfigResolver) FluxMonitor() *LogLevel

func (*LogLevelConfigResolver) HeadTracker 

func (r *LogLevelConfigResolver) HeadTracker() *LogLevel

func (*LogLevelConfigResolver) Keeper 

func (r *LogLevelConfigResolver) Keeper() *LogLevel

type NodePayloadResolver 

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

func NewNodePayloadResolver 

func NewNodePayloadResolver(node *types.Node, err error) *NodePayloadResolver

func (*NodePayloadResolver) ToNode 

func (r *NodePayloadResolver) ToNode() (*NodeResolver, bool)

ToNode resolves the Node object to be returned if it is found

type NodeResolver 

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

NodeResolver resolves the Node type.

func NewNode 

func NewNode(node types.Node) *NodeResolver

func NewNodes 

func NewNodes(nodes []types.Node) []*NodeResolver

func (*NodeResolver) Chain 

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

Chain resolves the node's chain object field.

func (*NodeResolver) CreatedAt 

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

CreatedAt resolves the node's created at field.

func (*NodeResolver) HTTPURL 

func (r *NodeResolver) HTTPURL() string

HTTPURL resolves the node's http url field.

func (*NodeResolver) ID 

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

ID resolves the node's unique identifier.

func (*NodeResolver) Name 

func (r *NodeResolver) Name() string

Name resolves the node's name field.

func (*NodeResolver) UpdatedAt 

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

UpdatedAt resolves the node's updated at field.

func (*NodeResolver) WSURL 

func (r *NodeResolver) WSURL() string

WSURL resolves the node's websocket url field.

type NodesPayloadResolver 

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

func NewNodesPayload 

func NewNodesPayload(nodes []types.Node, total int32) *NodesPayloadResolver

func (*NodesPayloadResolver) Metadata 

func (r *NodesPayloadResolver) Metadata() *PaginationMetadataResolver

func (*NodesPayloadResolver) Results 

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

type NotFoundErrorResolver 

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

func NewNotFoundError 

func NewNotFoundError(message string) *NotFoundErrorResolver

func (*NotFoundErrorResolver) Code 

func (r *NotFoundErrorResolver) Code() ErrorCode

func (*NotFoundErrorResolver) Message 

func (r *NotFoundErrorResolver) Message() string

type NotFoundErrorUnionType 

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

func (*NotFoundErrorUnionType) ToNotFoundError 

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

ToNotFoundError resolves to the not found error resolver

type 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) CreatedAt 

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

CreatedAt resolves the spec's created at timestamp.

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

func (r *OCRSpecResolver) P2PPeerID() string

P2PPeerID resolves the spec's p2p peer id

func (*OCRSpecResolver) P2PPeerIDEnv 

func (r *OCRSpecResolver) P2PPeerIDEnv() bool

P2PPeerID resolves the whether spec's p2p peer id comes from an env var

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 NewP2PKeyResolver 

func NewP2PKeyResolver(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 NewP2PKeysPayloadResolver 

func NewP2PKeysPayloadResolver(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 RejectJobProposalPayloadResolver 

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

func NewRejectJobProposalPayload 

func NewRejectJobProposalPayload(jp *feeds.JobProposal, err error) *RejectJobProposalPayloadResolver

func (*RejectJobProposalPayloadResolver) ToRejectJobProposalSuccess 

func (r *RejectJobProposalPayloadResolver) ToRejectJobProposalSuccess() (*RejectJobProposalSuccessResolver, bool)

ToRejectJobProposalSuccess resolves to the approval job proposal success resolver

type RejectJobProposalSuccessResolver 

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

func NewRejectJobProposalSuccess 

func NewRejectJobProposalSuccess(jp *feeds.JobProposal) *RejectJobProposalSuccessResolver

func (*RejectJobProposalSuccessResolver) JobProposal 

func (r *RejectJobProposalSuccessResolver) JobProposal() *JobProposalResolver

type Resolver 

type Resolver struct {
	App chainlink.Application
}

func (*Resolver) ApproveJobProposal 

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

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

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

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

func (r *Resolver) CreateAPIToken(ctx context.Context, args struct {
	Input struct{ Password string }
}) (*CreateAPITokenPayloadResolver, error)

func (*Resolver) CreateBridge 

func (r *Resolver) CreateBridge(ctx context.Context, args struct{ Input createBridgeInput }) (*CreateBridgePayloadResolver, error)

CreateBridge creates a new bridge.

func (*Resolver) CreateCSAKey 

func (r *Resolver) CreateCSAKey(ctx context.Context) (*CreateCSAKeyPayloadResolver, error)

func (*Resolver) CreateChain 

func (r *Resolver) CreateChain(ctx context.Context, args struct {
	Input struct {
		ID                 graphql.ID
		Config             ChainConfigInput
		KeySpecificConfigs []*KeySpecificChainConfigInput
	}
}) (*CreateChainPayloadResolver, error)

func (*Resolver) CreateFeedsManager 

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

func (*Resolver) CreateNode 

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

func (*Resolver) CreateOCRKeyBundle 

func (r *Resolver) CreateOCRKeyBundle(ctx context.Context) (*CreateOCRKeyBundlePayloadResolver, error)

func (*Resolver) CreateP2PKey 

func (r *Resolver) CreateP2PKey(ctx context.Context) (*CreateP2PKeyPayloadResolver, error)

func (*Resolver) CreateVRFKey 

func (r *Resolver) CreateVRFKey(ctx context.Context) (*CreateVRFKeyPayloadResolver, error)

func (*Resolver) DeleteAPIToken 

func (r *Resolver) DeleteAPIToken(ctx context.Context, args struct {
	Input struct{ Password string }
}) (*DeleteAPITokenPayloadResolver, error)

func (*Resolver) DeleteBridge 

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

func (*Resolver) DeleteCSAKey 

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

func (*Resolver) DeleteChain 

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

func (*Resolver) DeleteNode 

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

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

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

func (r *Resolver) OCRKeyBundles(ctx context.Context) (*OCRKeyBundlesPayloadResolver, error)

func (*Resolver) P2PKeys 

func (r *Resolver) P2PKeys(ctx context.Context) (*P2PKeysPayloadResolver, error)

func (*Resolver) RejectJobProposal 

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

func (*Resolver) SetSQLLogging 

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

func (*Resolver) SetServicesLogLevels 

func (r *Resolver) SetServicesLogLevels(ctx context.Context, args struct {
	Input struct{ Config LogLevelConfig }
}) (*SetServicesLogLevelsPayloadResolver, error)

func (*Resolver) UpdateBridge 

func (r *Resolver) UpdateBridge(ctx context.Context, args struct {
	ID    graphql.ID
	Input updateBridgeInput
}) (*UpdateBridgePayloadResolver, error)

func (*Resolver) UpdateChain 

func (r *Resolver) UpdateChain(ctx context.Context, args struct {
	ID    graphql.ID
	Input struct {
		Enabled            bool
		Config             ChainConfigInput
		KeySpecificConfigs []*KeySpecificChainConfigInput
	}
}) (*UpdateChainPayloadResolver, error)

func (*Resolver) UpdateFeedsManager 

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

func (*Resolver) UpdateJobProposalSpec 

func (r *Resolver) UpdateJobProposalSpec(ctx context.Context, args struct {
	ID    graphql.ID
	Input *struct{ Spec string }
}) (*UpdateJobProposalSpecPayloadResolver, error)

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 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 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 SetServicesLogLevelsPayloadResolver 

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

func NewSetServicesLogLevelsPayload 

func NewSetServicesLogLevelsPayload(cfg *LogLevelConfig, inputErrs map[string]string) *SetServicesLogLevelsPayloadResolver

func (*SetServicesLogLevelsPayloadResolver) ToInputErrors 

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

func (*SetServicesLogLevelsPayloadResolver) ToSetServicesLogLevelsSuccess 

func (r *SetServicesLogLevelsPayloadResolver) ToSetServicesLogLevelsSuccess() (*SetServicesLogLevelsSuccessResolver, bool)

type SetServicesLogLevelsSuccessResolver 

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

func NewSetServicesLogLevelsSuccess 

func NewSetServicesLogLevelsSuccess(cfg LogLevelConfig) *SetServicesLogLevelsSuccessResolver

func (*SetServicesLogLevelsSuccessResolver) Config 

func (r *SetServicesLogLevelsSuccessResolver) Config() *LogLevelConfigResolver

type SingleFeedsManagerErrorResolver 

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

func NewSingleFeedsManagerError 

func NewSingleFeedsManagerError(message string) *SingleFeedsManagerErrorResolver

func (*SingleFeedsManagerErrorResolver) Code 

func (r *SingleFeedsManagerErrorResolver) Code() ErrorCode

func (*SingleFeedsManagerErrorResolver) Message 

func (r *SingleFeedsManagerErrorResolver) Message() string

type SpecResolver 

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

func NewSpec 

func NewSpec(j job.Job) *SpecResolver

func (*SpecResolver) ToCronSpec 

func (r *SpecResolver) ToCronSpec() (*CronSpecResolver, bool)

func (*SpecResolver) ToDirectRequestSpec 

func (r *SpecResolver) ToDirectRequestSpec() (*DirectRequestSpecResolver, bool)

func (*SpecResolver) ToFluxMonitorSpec 

func (r *SpecResolver) ToFluxMonitorSpec() (*FluxMonitorSpecResolver, bool)

func (*SpecResolver) ToKeeperSpec 

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

func (*SpecResolver) 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 TaskRunResolver 

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

func NewTaskRun 

func NewTaskRun(tr pipeline.TaskRun) *TaskRunResolver

func NewTaskRuns 

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

func (*TaskRunResolver) CreatedAt 

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

func (*TaskRunResolver) DotID 

func (r *TaskRunResolver) DotID() string

func (*TaskRunResolver) Error 

func (r *TaskRunResolver) Error() *string

func (*TaskRunResolver) FinishedAt 

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

func (*TaskRunResolver) ID 

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

func (*TaskRunResolver) Output 

func (r *TaskRunResolver) Output() string

func (*TaskRunResolver) Type 

func (r *TaskRunResolver) Type() string

type UpdateBridgePayloadResolver 

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

func NewUpdateBridgePayload 

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

func (*UpdateBridgePayloadResolver) ToUpdateBridgeSuccess 

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

type UpdateBridgeSuccessResolver 

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

UpdateBridgePayloadResolver resolves

func NewUpdateBridgeSuccess 

func NewUpdateBridgeSuccess(bridge bridges.BridgeType) *UpdateBridgeSuccessResolver

func (*UpdateBridgeSuccessResolver) Bridge 

func (r *UpdateBridgeSuccessResolver) Bridge() *BridgeResolver

Bridge resolves the success payload's bridge.

type UpdateChainPayloadResolver 

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

func NewUpdateChainPayload 

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

func (*UpdateChainPayloadResolver) ToInputErrors 

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

func (*UpdateChainPayloadResolver) ToUpdateChainSuccess 

func (r *UpdateChainPayloadResolver) ToUpdateChainSuccess() (*UpdateChainSuccessResolver, bool)

type UpdateChainSuccessResolver 

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

func NewUpdateChainSuccess 

func NewUpdateChainSuccess(chain types.Chain) *UpdateChainSuccessResolver

func (*UpdateChainSuccessResolver) Chain 

func (r *UpdateChainSuccessResolver) Chain() *ChainResolver

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 UpdateJobProposalSpecPayloadResolver 

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

func NewUpdateJobProposalSpecPayload 

func NewUpdateJobProposalSpecPayload(jp *feeds.JobProposal, err error) *UpdateJobProposalSpecPayloadResolver

func (*UpdateJobProposalSpecPayloadResolver) ToUpdateJobProposalSpecSuccess 

func (r *UpdateJobProposalSpecPayloadResolver) ToUpdateJobProposalSpecSuccess() (*UpdateJobProposalSpecSuccessResolver, bool)

ToUpdateJobProposalSpecSuccess resolves to the approval job proposal success resolver

type UpdateJobProposalSpecSuccessResolver 

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

func NewUpdateJobProposalSpecSuccess 

func NewUpdateJobProposalSpecSuccess(jp *feeds.JobProposal) *UpdateJobProposalSpecSuccessResolver

func (*UpdateJobProposalSpecSuccessResolver) JobProposal 

func (r *UpdateJobProposalSpecSuccessResolver) JobProposal() *JobProposalResolver

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

func (r *VRFSpecResolver) FromAddress() *string

FromAddress resolves the spec's from address.

func (*VRFSpecResolver) MinIncomingConfirmations 

func (r *VRFSpecResolver) MinIncomingConfirmations() int32

CreatedAt 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) RequestedConfsDelay 

func (r *VRFSpecResolver) RequestedConfsDelay() int32

RequestedConfsDelay resolves the spec's requested conf delay.

type WebhookSpecResolver 

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

func (*WebhookSpecResolver) CreatedAt 

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

CreatedAt resolves the spec's created at timestamp.

Source Files

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.