mocks

Documentation

Index

• type Delegate
  • func (_m *Delegate) JobType() job.Type
  • func (_m *Delegate) OnJobCreated(spec job.Job)
  • func (_m *Delegate) OnJobDeleted(spec job.Job)
  • func (_m *Delegate) ServicesForSpec(spec job.Job) ([]job.Service, error)
• type ORM
  • func (_m *ORM) CheckForDeletedJobs(ctx context.Context) ([]int32, error)
  • func (_m *ORM) ClaimUnclaimedJobs(ctx context.Context) ([]job.Job, error)
  • func (_m *ORM) Close() error
  • func (_m *ORM) CreateJob(ctx context.Context, jobSpec *job.Job, _a2 pipeline.Pipeline) error
  • func (_m *ORM) DeleteJob(ctx context.Context, id int32) error
  • func (_m *ORM) FindJob(id int32) (job.Job, error)
  • func (_m *ORM) FindJobIDsWithBridge(name string) ([]int32, error)
  • func (_m *ORM) JobsV2() ([]job.Job, error)
  • func (_m *ORM) ListenForDeletedJobs() (postgres.Subscription, error)
  • func (_m *ORM) ListenForNewJobs() (postgres.Subscription, 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)
  • func (_m *ORM) UnclaimJob(ctx context.Context, id int32) error
• 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) (int32, 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

Types

type Delegate

type Delegate struct {
	mock.Mock
}

Delegate is an autogenerated mock type for the Delegate type

func (*Delegate) JobType

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

JobType provides a mock function with given fields:

func (*Delegate) OnJobCreated

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

OnJobCreated provides a mock function with given fields: spec

func (*Delegate) OnJobDeleted

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

OnJobDeleted provides a mock function with given fields: spec

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

func (_m *ORM) CheckForDeletedJobs(ctx context.Context) ([]int32, error)

CheckForDeletedJobs provides a mock function with given fields: ctx

func (*ORM) ClaimUnclaimedJobs

func (_m *ORM) ClaimUnclaimedJobs(ctx context.Context) ([]job.Job, error)

ClaimUnclaimedJobs provides a mock function with given fields: ctx

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

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

FindJob provides a mock function with given fields: id

func (*ORM) FindJobIDsWithBridge

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

FindJobIDsWithBridge provides a mock function with given fields: name

func (*ORM) JobsV2

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

JobsV2 provides a mock function with given fields:

func (*ORM) ListenForDeletedJobs

func (_m *ORM) ListenForDeletedJobs() (postgres.Subscription, error)

ListenForDeletedJobs provides a mock function with given fields:

func (*ORM) ListenForNewJobs

func (_m *ORM) ListenForNewJobs() (postgres.Subscription, error)

ListenForNewJobs provides a mock function with given fields:

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

func (*ORM) UnclaimJob

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

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

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) (int32, 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: