mockprovider

Documentation

Index

• func NewMockJobBackendProvider(logger *zap.Logger, conf *config.Config) (jobbackendprovider.IJobBackendProvider, error)
• type MockJobBackendProvider
  • func (p *MockJobBackendProvider) Healthcheck() bool
  • func (p *MockJobBackendProvider) Init(notifChan chan jobbackendprovider.Event) error
  • func (p *MockJobBackendProvider) JobExists(jobUUID job.JobUUID) (bool, error)
  • func (p *MockJobBackendProvider) LoadJobs() (job.JobMap, error)
  • func (p *MockJobBackendProvider) NotifyChange(event jobbackendprovider.Event)
  • func (p *MockJobBackendProvider) OnAllResourcesUnlocked() error
  • func (p *MockJobBackendProvider) OnJobCanceled(j *job.Job) error
  • func (p *MockJobBackendProvider) OnJobCreated(j *job.Job) error
  • func (p *MockJobBackendProvider) OnJobDeleted(jobUUID job.JobUUID) error
  • func (p *MockJobBackendProvider) OnJobEnqueued(j *job.Job) error
  • func (p *MockJobBackendProvider) OnJobStarted(j *job.Job) error
  • func (p *MockJobBackendProvider) OnJobSucceeded(j *job.Job) error
  • func (p *MockJobBackendProvider) OnJobTimeout(j *job.Job) error
  • func (p *MockJobBackendProvider) OnJobsDeleted() error
  • func (p *MockJobBackendProvider) OnResourceUnlocked(j *job.Job, resource string) error
  • func (p *MockJobBackendProvider) Run() error
  • func (p *MockJobBackendProvider) Stop() error

Functions

func NewMockJobBackendProvider

func NewMockJobBackendProvider(logger *zap.Logger, conf *config.Config) (jobbackendprovider.IJobBackendProvider, error)

Types

type MockJobBackendProvider

type MockJobBackendProvider struct {
	// contains filtered or unexported fields
}

func (*MockJobBackendProvider) Healthcheck

func (p *MockJobBackendProvider) Healthcheck() bool

func (*MockJobBackendProvider) Init

func (p *MockJobBackendProvider) Init(notifChan chan jobbackendprovider.Event) error

func (*MockJobBackendProvider) JobExists

func (p *MockJobBackendProvider) JobExists(jobUUID job.JobUUID) (bool, error)

func (*MockJobBackendProvider) LoadJobs

func (p *MockJobBackendProvider) LoadJobs() (job.JobMap, error)

func (*MockJobBackendProvider) NotifyChange

func (p *MockJobBackendProvider) NotifyChange(event jobbackendprovider.Event)

func (*MockJobBackendProvider) OnAllResourcesUnlocked

func (p *MockJobBackendProvider) OnAllResourcesUnlocked() error

func (*MockJobBackendProvider) OnJobCanceled

func (p *MockJobBackendProvider) OnJobCanceled(j *job.Job) error

func (*MockJobBackendProvider) OnJobCreated

func (p *MockJobBackendProvider) OnJobCreated(j *job.Job) error

func (*MockJobBackendProvider) OnJobDeleted

func (p *MockJobBackendProvider) OnJobDeleted(jobUUID job.JobUUID) error

func (*MockJobBackendProvider) OnJobEnqueued

func (p *MockJobBackendProvider) OnJobEnqueued(j *job.Job) error

func (*MockJobBackendProvider) OnJobStarted

func (p *MockJobBackendProvider) OnJobStarted(j *job.Job) error

func (*MockJobBackendProvider) OnJobSucceeded

func (p *MockJobBackendProvider) OnJobSucceeded(j *job.Job) error

func (*MockJobBackendProvider) OnJobTimeout

func (p *MockJobBackendProvider) OnJobTimeout(j *job.Job) error

func (*MockJobBackendProvider) OnJobsDeleted

func (p *MockJobBackendProvider) OnJobsDeleted() error

func (*MockJobBackendProvider) OnResourceUnlocked

func (p *MockJobBackendProvider) OnResourceUnlocked(j *job.Job, resource string) error

func (*MockJobBackendProvider) Run

func (p *MockJobBackendProvider) Run() error

func (*MockJobBackendProvider) Stop

func (p *MockJobBackendProvider) Stop() error