Documentation ¶
Index ¶
- type Delegate
- type ORM
- func (_m *ORM) Close() error
- func (_m *ORM) CreateJob(jb *job.Job, qopts ...pg.QOpt) error
- func (_m *ORM) DeleteJob(id int32, qopts ...pg.QOpt) error
- func (_m *ORM) DismissError(ctx context.Context, errorID int32) error
- func (_m *ORM) FindJob(ctx context.Context, id int32) (job.Job, error)
- func (_m *ORM) FindJobByExternalJobID(_a0 uuid.UUID, qopts ...pg.QOpt) (job.Job, error)
- func (_m *ORM) FindJobIDsWithBridge(name string) ([]int32, error)
- func (_m *ORM) FindJobTx(id int32) (job.Job, error)
- func (_m *ORM) FindJobs(offset int, limit int) ([]job.Job, int, error)
- func (_m *ORM) InsertJob(_a0 *job.Job, qopts ...pg.QOpt) error
- func (_m *ORM) InsertWebhookSpec(webhookSpec *job.WebhookSpec, qopts ...pg.QOpt) error
- func (_m *ORM) PipelineRuns(jobID *int32, offset int, size int) ([]pipeline.Run, int, error)
- func (_m *ORM) PipelineRunsByJobsIDs(jobsIDs []int32) ([]pipeline.Run, error)
- func (_m *ORM) RecordError(jobID int32, description string, qopts ...pg.QOpt) error
- func (_m *ORM) TryRecordError(jobID int32, description string, qopts ...pg.QOpt)
- type Service
- type Spawner
- func (_m *Spawner) ActiveJobs() map[int32]job.Job
- func (_m *Spawner) Close() error
- func (_m *Spawner) CreateJob(jb *job.Job, qopts ...pg.QOpt) error
- func (_m *Spawner) DeleteJob(jobID int32, qopts ...pg.QOpt) error
- func (_m *Spawner) Healthy() error
- func (_m *Spawner) Ready() error
- func (_m *Spawner) Start() error
- func (_m *Spawner) StartService(spec job.Job) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Delegate ¶
Delegate is an autogenerated mock type for the Delegate type
func (*Delegate) AfterJobCreated ¶ added in v0.10.11
AfterJobCreated provides a mock function with given fields: spec
func (*Delegate) BeforeJobDeleted ¶ added in v0.10.11
BeforeJobDeleted provides a mock function with given fields: spec
type ORM ¶
ORM is an autogenerated mock type for the ORM type
func (*ORM) DismissError ¶ added in v0.10.11
DismissError provides a mock function with given fields: ctx, errorID
func (*ORM) FindJobByExternalJobID ¶ added in v1.1.0
FindJobByExternalJobID provides a mock function with given fields: _a0, qopts
func (*ORM) FindJobIDsWithBridge ¶ added in v0.10.4
FindJobIDsWithBridge provides a mock function with given fields: name
func (*ORM) FindJobs ¶ added in v1.1.0
FindJobs provides a mock function with given fields: offset, limit
func (*ORM) InsertJob ¶ added in v1.1.0
InsertJob provides a mock function with given fields: _a0, qopts
func (*ORM) InsertWebhookSpec ¶ added in v1.1.0
InsertWebhookSpec provides a mock function with given fields: webhookSpec, qopts
func (*ORM) PipelineRuns ¶ added in v0.10.11
PipelineRuns provides a mock function with given fields: jobID, offset, size
func (*ORM) PipelineRunsByJobsIDs ¶ added in v1.1.0
PipelineRunsByJobsIDs provides a mock function with given fields: jobsIDs
func (*ORM) RecordError ¶ added in v0.9.6
RecordError provides a mock function with given fields: jobID, description, qopts
type Service ¶
Service is an autogenerated mock type for the Service type
type Spawner ¶
Spawner is an autogenerated mock type for the Spawner type
func (*Spawner) ActiveJobs ¶ added in v0.10.8
ActiveJobs provides a mock function with given fields: