Documentation ¶
Index ¶
- type Delegate
- type ORM
- func (_m *ORM) AssertBridgesExist(p pipeline.Pipeline) error
- func (_m *ORM) Close() error
- func (_m *ORM) CountPipelineRunsByJobID(jobID int32) (int32, 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 int64) 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) FindJobIDByAddress(address ethkey.EIP55Address, evmChainID *utils.Big, qopts ...pg.QOpt) (int32, error)
- func (_m *ORM) FindJobIDsWithBridge(name string) ([]int32, error)
- func (_m *ORM) FindJobTx(id int32) (job.Job, error)
- func (_m *ORM) FindJobWithoutSpecErrors(id int32) (job.Job, error)
- func (_m *ORM) FindJobs(offset int, limit int) ([]job.Job, int, error)
- func (_m *ORM) FindJobsByPipelineSpecIDs(ids []int32) ([]job.Job, error)
- func (_m *ORM) FindPipelineRunByID(id int64) (pipeline.Run, error)
- func (_m *ORM) FindPipelineRunIDsByJobID(jobID int32, offset int, limit int) ([]int64, error)
- func (_m *ORM) FindPipelineRunsByIDs(ids []int64) ([]pipeline.Run, error)
- func (_m *ORM) FindSpecError(id int64, qopts ...pg.QOpt) (job.SpecError, error)
- func (_m *ORM) FindSpecErrorsByJobIDs(ids []int32, qopts ...pg.QOpt) ([]job.SpecError, error)
- func (_m *ORM) FindTaskResultByRunIDAndTaskName(runID int64, taskName string, qopts ...pg.QOpt) ([]byte, 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) RecordError(jobID int32, description string, qopts ...pg.QOpt) error
- func (_m *ORM) TryRecordError(jobID int32, description string, qopts ...pg.QOpt)
- type Service
- type ServiceCtx
- 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) HealthReport() map[string]error
- func (_m *Spawner) Healthy() error
- func (_m *Spawner) Name() string
- func (_m *Spawner) Ready() error
- func (_m *Spawner) Start(_a0 context.Context) error
- func (_m *Spawner) StartService(ctx context.Context, 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 NewDelegate ¶ added in v1.6.0
func NewDelegate(t mockConstructorTestingTNewDelegate) *Delegate
NewDelegate creates a new instance of Delegate. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Delegate) AfterJobCreated ¶ added in v0.10.11
AfterJobCreated provides a mock function with given fields: spec
func (*Delegate) BeforeJobCreated ¶ added in v1.10.0
BeforeJobCreated 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
func (*Delegate) ServicesForSpec ¶
ServicesForSpec provides a mock function with given fields: spec
type ORM ¶
ORM is an autogenerated mock type for the ORM type
func NewORM ¶ added in v1.6.0
func NewORM(t mockConstructorTestingTNewORM) *ORM
NewORM creates a new instance of ORM. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ORM) AssertBridgesExist ¶ added in v1.11.0
AssertBridgesExist provides a mock function with given fields: p
func (*ORM) CountPipelineRunsByJobID ¶ added in v1.2.0
CountPipelineRunsByJobID provides a mock function with given fields: jobID
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) FindJobIDByAddress ¶ added in v1.2.0
func (_m *ORM) FindJobIDByAddress(address ethkey.EIP55Address, evmChainID *utils.Big, qopts ...pg.QOpt) (int32, error)
FindJobIDByAddress provides a mock function with given fields: address, evmChainID, qopts
func (*ORM) FindJobIDsWithBridge ¶ added in v0.10.4
FindJobIDsWithBridge provides a mock function with given fields: name
func (*ORM) FindJobWithoutSpecErrors ¶ added in v1.5.0
FindJobWithoutSpecErrors provides a mock function with given fields: id
func (*ORM) FindJobs ¶ added in v1.1.0
FindJobs provides a mock function with given fields: offset, limit
func (*ORM) FindJobsByPipelineSpecIDs ¶ added in v1.2.0
FindJobsByPipelineSpecIDs provides a mock function with given fields: ids
func (*ORM) FindPipelineRunByID ¶ added in v1.2.0
FindPipelineRunByID provides a mock function with given fields: id
func (*ORM) FindPipelineRunIDsByJobID ¶ added in v1.2.0
FindPipelineRunIDsByJobID provides a mock function with given fields: jobID, offset, limit
func (*ORM) FindPipelineRunsByIDs ¶ added in v1.2.0
FindPipelineRunsByIDs provides a mock function with given fields: ids
func (*ORM) FindSpecError ¶ added in v1.2.0
FindSpecError provides a mock function with given fields: id, qopts
func (*ORM) FindSpecErrorsByJobIDs ¶ added in v1.5.0
FindSpecErrorsByJobIDs provides a mock function with given fields: ids, qopts
func (*ORM) FindTaskResultByRunIDAndTaskName ¶ added in v1.10.0
func (_m *ORM) FindTaskResultByRunIDAndTaskName(runID int64, taskName string, qopts ...pg.QOpt) ([]byte, error)
FindTaskResultByRunIDAndTaskName provides a mock function with given fields: runID, taskName, qopts
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) 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
func NewService ¶ added in v1.6.0
func NewService(t mockConstructorTestingTNewService) *Service
NewService creates a new instance of Service. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
type ServiceCtx ¶ added in v1.3.0
ServiceCtx is an autogenerated mock type for the ServiceCtx type
func NewServiceCtx ¶ added in v1.6.0
func NewServiceCtx(t mockConstructorTestingTNewServiceCtx) *ServiceCtx
NewServiceCtx creates a new instance of ServiceCtx. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ServiceCtx) Close ¶ added in v1.3.0
func (_m *ServiceCtx) Close() error
Close provides a mock function with given fields:
type Spawner ¶
Spawner is an autogenerated mock type for the Spawner type
func NewSpawner ¶ added in v1.6.0
func NewSpawner(t mockConstructorTestingTNewSpawner) *Spawner
NewSpawner creates a new instance of Spawner. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Spawner) ActiveJobs ¶ added in v0.10.8
ActiveJobs provides a mock function with given fields:
func (*Spawner) HealthReport ¶ added in v1.13.0
HealthReport provides a mock function with given fields: