mocks

Documentation

Index

• type Delegate
  • func (_m *Delegate) AfterJobCreated(spec job.Job)
  • func (_m *Delegate) BeforeJobDeleted(spec job.Job)
  • func (_m *Delegate) JobType() job.Type
  • func (_m *Delegate) ServicesForSpec(spec job.Job) ([]job.Service, error)
• type ORM
  • func (_m *ORM) Close() error
  • func (_m *ORM) CreateJob(ctx context.Context, jobSpec *job.Job, _a2 pipeline.Pipeline) (job.Job, error)
  • func (_m *ORM) DeleteJob(ctx context.Context, id int32) 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(ctx context.Context, _a1 uuid.UUID) (job.Job, error)
  • func (_m *ORM) FindJobIDsWithBridge(name string) ([]int32, error)
  • func (_m *ORM) FindJobTx(id int32) (job.Job, error)
  • func (_m *ORM) JobsV2(offset int, limit int) ([]job.Job, int, error)
  • func (_m *ORM) PipelineRuns(offset int, size int) ([]pipeline.Run, int, error)
  • func (_m *ORM) PipelineRunsByJobID(jobID int32, offset int, size int) ([]pipeline.Run, int, error)
  • func (_m *ORM) RecordError(ctx context.Context, jobID int32, description string)
• type Service
  • func (_m *Service) Close() error
  • func (_m *Service) Start() error
• type Spawner
  • func (_m *Spawner) ActiveJobs() map[int32]job.Job
  • func (_m *Spawner) Close() error
  • func (_m *Spawner) CreateJob(ctx context.Context, spec job.Job, name null.String) (job.Job, error)
  • func (_m *Spawner) DeleteJob(ctx context.Context, jobID int32) error
  • func (_m *Spawner) Healthy() error
  • func (_m *Spawner) Ready() error
  • func (_m *Spawner) Start() error
  • func (_m *Spawner) StartService(spec job.Job) error

Types

type Delegate

type Delegate struct {
	mock.Mock
}

Delegate is an autogenerated mock type for the Delegate type

func (*Delegate) AfterJobCreated

func (_m *Delegate) AfterJobCreated(spec job.Job)

AfterJobCreated provides a mock function with given fields: spec

func (*Delegate) BeforeJobDeleted

func (_m *Delegate) BeforeJobDeleted(spec job.Job)

BeforeJobDeleted provides a mock function with given fields: spec

func (*Delegate) JobType

func (_m *Delegate) JobType() job.Type

JobType provides a mock function with given fields:

func (*Delegate) ServicesForSpec

func (_m *Delegate) ServicesForSpec(spec job.Job) ([]job.Service, error)

ServicesForSpec provides a mock function with given fields: spec

type ORM

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func (*ORM) Close

func (_m *ORM) Close() error

Close provides a mock function with given fields:

func (*ORM) CreateJob

func (_m *ORM) CreateJob(ctx context.Context, jobSpec *job.Job, _a2 pipeline.Pipeline) (job.Job, error)

CreateJob provides a mock function with given fields: ctx, jobSpec, _a2

func (*ORM) DeleteJob

func (_m *ORM) DeleteJob(ctx context.Context, id int32) error

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

func (*ORM) DismissError

func (_m *ORM) DismissError(ctx context.Context, errorID int32) 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(ctx context.Context, _a1 uuid.UUID) (job.Job, error)

FindJobByExternalJobID provides a mock function with given fields: ctx, _a1

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) JobsV2

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

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

func (*ORM) PipelineRuns

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

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

func (*ORM) PipelineRunsByJobID

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

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

func (*ORM) RecordError

func (_m *ORM) RecordError(ctx context.Context, jobID int32, description string)

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

type Service

type Service struct {
	mock.Mock
}

Service is an autogenerated mock type for the Service type

func (*Service) Close

func (_m *Service) Close() error

Close provides a mock function with given fields:

func (*Service) Start

func (_m *Service) Start() error

Start provides a mock function with given fields:

type Spawner

type Spawner struct {
	mock.Mock
}

Spawner is an autogenerated mock type for the Spawner type

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(ctx context.Context, spec job.Job, name null.String) (job.Job, error)

CreateJob provides a mock function with given fields: ctx, spec, name

func (*Spawner) DeleteJob

func (_m *Spawner) DeleteJob(ctx context.Context, jobID int32) error

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

func (*Spawner) Healthy

func (_m *Spawner) Healthy() error

Healthy 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() error

Start provides a mock function with given fields:

func (*Spawner) StartService

func (_m *Spawner) StartService(spec job.Job) error

StartService provides a mock function with given fields: spec