mocks

Documentation

Index

• type Delegate
  • func (_m *Delegate) FromDBRow(spec models.JobSpecV2) job.Spec
  • func (_m *Delegate) JobType() job.Type
  • func (_m *Delegate) ServicesForSpec(spec job.Spec) ([]job.Service, error)
  • func (_m *Delegate) ToDBRow(spec job.Spec) models.JobSpecV2
• type ORM
  • func (_m *ORM) CheckForDeletedJobs(ctx context.Context) ([]int32, error)
  • func (_m *ORM) ClaimUnclaimedJobs(ctx context.Context) ([]models.JobSpecV2, error)
  • func (_m *ORM) Close() error
  • func (_m *ORM) CreateJob(ctx context.Context, jobSpec *models.JobSpecV2, taskDAG pipeline.TaskDAG) error
  • func (_m *ORM) DeleteJob(ctx context.Context, id int32) error
  • func (_m *ORM) ListenForDeletedJobs() (postgres.Subscription, error)
  • func (_m *ORM) ListenForNewJobs() (postgres.Subscription, 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) CreateJob(ctx context.Context, spec job.Spec, name null.String) (int32, error)
  • func (_m *Spawner) DeleteJob(ctx context.Context, jobID int32) error
  • func (_m *Spawner) RegisterDelegate(delegate job.Delegate)
  • func (_m *Spawner) Start()
  • func (_m *Spawner) Stop()
• type Spec
  • func (_m *Spec) JobID() int32
  • func (_m *Spec) JobType() job.Type
  • func (_m *Spec) TableName() string
  • func (_m *Spec) TaskDAG() pipeline.TaskDAG

Types

type Delegate

type Delegate struct {
	mock.Mock
}

Delegate is an autogenerated mock type for the Delegate type

func (*Delegate) FromDBRow

func (_m *Delegate) FromDBRow(spec models.JobSpecV2) job.Spec

FromDBRow 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.Spec) ([]job.Service, error)

ServicesForSpec provides a mock function with given fields: spec

func (*Delegate) ToDBRow

func (_m *Delegate) ToDBRow(spec job.Spec) models.JobSpecV2

ToDBRow 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) ([]models.JobSpecV2, 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 *models.JobSpecV2, taskDAG pipeline.TaskDAG) error

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

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

func (_m *Spawner) CreateJob(ctx context.Context, spec job.Spec, 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) RegisterDelegate

func (_m *Spawner) RegisterDelegate(delegate job.Delegate)

RegisterDelegate provides a mock function with given fields: delegate

func (*Spawner) Start

func (_m *Spawner) Start()

Start provides a mock function with given fields:

func (*Spawner) Stop

func (_m *Spawner) Stop()

Stop provides a mock function with given fields:

type Spec

type Spec struct {
	mock.Mock
}

Spec is an autogenerated mock type for the Spec type

func (*Spec) JobID

func (_m *Spec) JobID() int32

JobID provides a mock function with given fields:

func (*Spec) JobType

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

JobType provides a mock function with given fields:

func (*Spec) TableName

func (_m *Spec) TableName() string

TableName provides a mock function with given fields:

func (*Spec) TaskDAG

func (_m *Spec) TaskDAG() pipeline.TaskDAG

TaskDAG provides a mock function with given fields: