Documentation
¶
Index ¶
- Variables
- func GetChainByID(ctx context.Context, id string) (*types.DBChain, error)
- func GetEthTxAttemptsByEthTxID(ctx context.Context, id string) ([]txmgr.EthTxAttempt, error)
- func GetFeedsManagerByID(ctx context.Context, id string) (*feeds.FeedsManager, error)
- func GetFeedsManagerChainConfigsByManagerID(ctx context.Context, mgrID int64) ([]feeds.ChainConfig, error)
- func GetJobByExternalJobID(ctx context.Context, id string) (*job.Job, error)
- func GetJobByPipelineSpecID(ctx context.Context, id string) (*job.Job, error)
- func GetJobProposalsByFeedsManagerID(ctx context.Context, id string) ([]feeds.JobProposal, error)
- func GetJobRunsByIDs(ctx context.Context, ids []int64) ([]pipeline.Run, error)
- func GetJobSpecErrorsByJobID(ctx context.Context, jobID int32) ([]job.SpecError, error)
- func GetLatestSpecByJobProposalID(ctx context.Context, jpID string) (*feeds.JobProposalSpec, error)
- func GetNodesByChainID(ctx context.Context, id string) ([]types.Node, error)
- func GetSpecsByJobProposalID(ctx context.Context, jpID string) ([]feeds.JobProposalSpec, error)
- func InjectDataloader(ctx context.Context, app chainlink.Application) context.Context
- func Middleware(app chainlink.Application) gin.HandlerFunc
- type Dataloader
Constants ¶
This section is empty.
Variables ¶
var ErrInvalidType = errors.New("invalid type")
ErrInvalidType indicates that results loaded is not the type expected
Functions ¶
func GetChainByID ¶
GetChainByID fetches the chain by it's id.
func GetEthTxAttemptsByEthTxID ¶
GetEthTxAttemptsByEthTxID fetches the attempts for an eth transaction.
func GetFeedsManagerByID ¶
GetFeedsManagerByID fetches the feed manager by ID.
func GetJobByExternalJobID ¶
GetJobByExternalJobID fetches the job proposals by external job ID
func GetJobByPipelineSpecID ¶
GetJobByPipelineSpecID fetches the job by pipeline spec ID.
func GetJobProposalsByFeedsManagerID ¶
GetJobProposalsByFeedsManagerID fetches the job proposals by feeds manager ID.
func GetJobRunsByIDs ¶
GetJobRunsByIDs fetches the job runs by their ID.
func GetJobSpecErrorsByJobID ¶
GetJobSpecErrorsByJobID fetches the Spec Errors for a Job.
func GetLatestSpecByJobProposalID ¶
GetLatestSpecByJobProposalID fetches the latest spec for a job proposal id.
func GetNodesByChainID ¶
GetNodesByChainID fetches the nodes for a chain.
func GetSpecsByJobProposalID ¶
GetSpecsByJobProposalID fetches the spec for a job proposal id.
func InjectDataloader ¶
InjectDataloader injects the dataloader into the context.
func Middleware ¶
func Middleware(app chainlink.Application) gin.HandlerFunc
Middleware injects the dataloader into a gin context.
Types ¶
type Dataloader ¶
type Dataloader struct {
ChainsByIDLoader *dataloader.Loader
EthTxAttemptsByEthTxIDLoader *dataloader.Loader
FeedsManagersByIDLoader *dataloader.Loader
FeedsManagerChainConfigsByManagerIDLoader *dataloader.Loader
JobProposalsByManagerIDLoader *dataloader.Loader
JobProposalSpecsByJobProposalID *dataloader.Loader
JobRunsByIDLoader *dataloader.Loader
JobsByExternalJobIDs *dataloader.Loader
JobsByPipelineSpecIDLoader *dataloader.Loader
NodesByChainIDLoader *dataloader.Loader
SpecErrorsByJobIDLoader *dataloader.Loader
// contains filtered or unexported fields
}
func New ¶
func New(app chainlink.Application) *Dataloader
Source Files