Documentation
¶
Index ¶
- Variables
- func GetChainByID(ctx context.Context, id string) (*commontypes.ChainStatus, error)
- func GetEthTxAttemptsByEthTxID(ctx context.Context, id string) ([]txmgr.TxAttempt, error)
- func GetJobByExternalJobID(ctx context.Context, id string) (*job.Job, error)
- func GetJobByPipelineSpecID(ctx context.Context, id string) (*job.Job, error)
- func GetJobRunsByIDs(ctx context.Context, ids []int64) ([]pipeline.Run, error)
- func GetJobSpecErrorsByJobID(ctx context.Context, jobID int32) ([]job.SpecError, error)
- func GetNodesByChainID(ctx context.Context, id string) ([]types.Node, error)
- func InjectDataloader(ctx context.Context, app erinaceus.Application) context.Context
- func Middleware(app erinaceus.Application) gin.HandlerFunc
- type Dataloader
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalidType = errors.New("invalid type")
ErrInvalidType indicates that results loaded is not the type expected
Functions ¶
func GetChainByID ¶
func GetChainByID(ctx context.Context, id string) (*commontypes.ChainStatus, error)
GetChainByID fetches the chain by it's id.
func GetEthTxAttemptsByEthTxID ¶
GetEthTxAttemptsByEthTxID fetches the attempts for an eth transaction.
func GetJobByExternalJobID ¶
GetJobByExternalJobID fetches the job proposals by external job ID
func GetJobByPipelineSpecID ¶
GetJobByPipelineSpecID fetches the job by pipeline spec ID.
func GetJobRunsByIDs ¶
GetJobRunsByIDs fetches the job runs by their ID.
func GetJobSpecErrorsByJobID ¶
GetJobSpecErrorsByJobID fetches the Spec Errors for a Job.
func GetNodesByChainID ¶
GetNodesByChainID fetches the nodes for a chain.
func InjectDataloader ¶
InjectDataloader injects the dataloader into the context.
func Middleware ¶
func Middleware(app erinaceus.Application) gin.HandlerFunc
Middleware injects the dataloader into a gin context.
Types ¶
type Dataloader ¶
type Dataloader struct {
ChainsByIDLoader *dataloader.Loader
EthTxAttemptsByEthTxIDLoader *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 erinaceus.Application) *Dataloader
Source Files
Click to show internal directories.
Click to hide internal directories.