mocks

Documentation

Index

• type ORM
  • func NewORM(t mockConstructorTestingTNewORM) *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 ServiceCtx
  • func NewServiceCtx(t mockConstructorTestingTNewServiceCtx) *ServiceCtx
  • func (_m *ServiceCtx) Close() error
  • func (_m *ServiceCtx) Start(_a0 context.Context) error
• type Spawner
  • func NewSpawner(t mockConstructorTestingTNewSpawner) *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) 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

Types

type ORM

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func NewORM

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

func (_m *ORM) AssertBridgesExist(p pipeline.Pipeline) error

AssertBridgesExist provides a mock function with given fields: p

func (*ORM) Close

func (_m *ORM) Close() error

Close provides a mock function with given fields:

func (*ORM) CountPipelineRunsByJobID

func (_m *ORM) CountPipelineRunsByJobID(jobID int32) (int32, error)

CountPipelineRunsByJobID provides a mock function with given fields: jobID

func (*ORM) CreateJob

func (_m *ORM) CreateJob(jb *job.Job, qopts ...pg.QOpt) error

CreateJob provides a mock function with given fields: jb, qopts

func (*ORM) DeleteJob

func (_m *ORM) DeleteJob(id int32, qopts ...pg.QOpt) error

DeleteJob provides a mock function with given fields: id, qopts

func (*ORM) DismissError

func (_m *ORM) DismissError(ctx context.Context, errorID int64) error

DismissError provides a mock function with given fields: ctx, errorID

func (*ORM) FindJob

func (_m *ORM) FindJob(ctx context.Context, id int32) (job.Job, error)

FindJob provides a mock function with given fields: ctx, id

func (*ORM) FindJobByExternalJobID

func (_m *ORM) FindJobByExternalJobID(_a0 uuid.UUID, qopts ...pg.QOpt) (job.Job, error)

FindJobByExternalJobID provides a mock function with given fields: _a0, qopts

func (*ORM) FindJobIDByAddress

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

func (_m *ORM) FindJobIDsWithBridge(name string) ([]int32, error)

FindJobIDsWithBridge provides a mock function with given fields: name

func (*ORM) FindJobTx

func (_m *ORM) FindJobTx(id int32) (job.Job, error)

FindJobTx provides a mock function with given fields: id

func (*ORM) FindJobWithoutSpecErrors

func (_m *ORM) FindJobWithoutSpecErrors(id int32) (job.Job, error)

FindJobWithoutSpecErrors provides a mock function with given fields: id

func (*ORM) FindJobs

func (_m *ORM) FindJobs(offset int, limit int) ([]job.Job, int, error)

FindJobs provides a mock function with given fields: offset, limit

func (*ORM) FindJobsByPipelineSpecIDs

func (_m *ORM) FindJobsByPipelineSpecIDs(ids []int32) ([]job.Job, error)

FindJobsByPipelineSpecIDs provides a mock function with given fields: ids

func (*ORM) FindPipelineRunByID

func (_m *ORM) FindPipelineRunByID(id int64) (pipeline.Run, error)

FindPipelineRunByID provides a mock function with given fields: id

func (*ORM) FindPipelineRunIDsByJobID

func (_m *ORM) FindPipelineRunIDsByJobID(jobID int32, offset int, limit int) ([]int64, error)

FindPipelineRunIDsByJobID provides a mock function with given fields: jobID, offset, limit

func (*ORM) FindPipelineRunsByIDs

func (_m *ORM) FindPipelineRunsByIDs(ids []int64) ([]pipeline.Run, error)

FindPipelineRunsByIDs provides a mock function with given fields: ids

func (*ORM) FindSpecError

func (_m *ORM) FindSpecError(id int64, qopts ...pg.QOpt) (job.SpecError, error)

FindSpecError provides a mock function with given fields: id, qopts

func (*ORM) FindSpecErrorsByJobIDs

func (_m *ORM) FindSpecErrorsByJobIDs(ids []int32, qopts ...pg.QOpt) ([]job.SpecError, error)

FindSpecErrorsByJobIDs provides a mock function with given fields: ids, qopts

func (*ORM) FindTaskResultByRunIDAndTaskName

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

func (_m *ORM) InsertJob(_a0 *job.Job, qopts ...pg.QOpt) error

InsertJob provides a mock function with given fields: _a0, qopts

func (*ORM) InsertWebhookSpec

func (_m *ORM) InsertWebhookSpec(webhookSpec *job.WebhookSpec, qopts ...pg.QOpt) error

InsertWebhookSpec provides a mock function with given fields: webhookSpec, qopts

func (*ORM) PipelineRuns

func (_m *ORM) PipelineRuns(jobID *int32, offset int, size int) ([]pipeline.Run, int, error)

PipelineRuns provides a mock function with given fields: jobID, offset, size

func (*ORM) RecordError

func (_m *ORM) RecordError(jobID int32, description string, qopts ...pg.QOpt) error

RecordError provides a mock function with given fields: jobID, description, qopts

func (*ORM) TryRecordError

func (_m *ORM) TryRecordError(jobID int32, description string, qopts ...pg.QOpt)

TryRecordError provides a mock function with given fields: jobID, description, qopts

type ServiceCtx

type ServiceCtx struct {
	mock.Mock
}

ServiceCtx is an autogenerated mock type for the ServiceCtx type

func NewServiceCtx

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

func (_m *ServiceCtx) Close() error

Close provides a mock function with given fields:

func (*ServiceCtx) Start

func (_m *ServiceCtx) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

type Spawner

type Spawner struct {
	mock.Mock
}

Spawner is an autogenerated mock type for the Spawner type

func NewSpawner

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

func (_m *Spawner) ActiveJobs() map[int32]job.Job

ActiveJobs provides a mock function with given fields:

func (*Spawner) Close

func (_m *Spawner) Close() error

Close provides a mock function with given fields:

func (*Spawner) CreateJob

func (_m *Spawner) CreateJob(jb *job.Job, qopts ...pg.QOpt) error

CreateJob provides a mock function with given fields: jb, qopts

func (*Spawner) DeleteJob

func (_m *Spawner) DeleteJob(jobID int32, qopts ...pg.QOpt) error

DeleteJob provides a mock function with given fields: jobID, qopts

func (*Spawner) HealthReport

func (_m *Spawner) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*Spawner) Name

func (_m *Spawner) Name() string

Name provides a mock function with given fields:

func (*Spawner) Ready

func (_m *Spawner) Ready() error

Ready provides a mock function with given fields:

func (*Spawner) Start

func (_m *Spawner) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

func (*Spawner) StartService

func (_m *Spawner) StartService(ctx context.Context, spec job.Job) error

StartService provides a mock function with given fields: ctx, spec