mocks

Documentation

Index

• type MockLeaseService
  • func NewMockLeaseService() *MockLeaseService
  • func (ls *MockLeaseService) AssertReportDoneCalledOnceWith(t *testing.T, expected []string)
  • func (ls *MockLeaseService) RenewJobLeases(jobs []*job.RunningJob) ([]*job.RunningJob, error)
  • func (ls *MockLeaseService) ReportDone(jobIds []string) error
  • func (ls *MockLeaseService) RequestJobLeases(availableResource *armadaresource.ComputeResources, nodes []api.NodeInfo, ...) ([]*api.Job, error)
  • func (ls *MockLeaseService) ReturnLease(pod *v1.Pod, reason string, jobRunAttempted bool) error

Types

type MockLeaseService

type MockLeaseService struct {
	NonrenewableJobIds    []string
	ReturnLeaseCalls      int
	RequestJobLeasesCalls int
	ReportDoneCalls       int

	ReturnLeaseArg *v1.Pod
	ReportDoneArg  []string
}

func NewMockLeaseService

func NewMockLeaseService() *MockLeaseService

func (*MockLeaseService) AssertReportDoneCalledOnceWith

func (ls *MockLeaseService) AssertReportDoneCalledOnceWith(t *testing.T, expected []string)

func (*MockLeaseService) RenewJobLeases

func (ls *MockLeaseService) RenewJobLeases(jobs []*job.RunningJob) ([]*job.RunningJob, error)

func (*MockLeaseService) ReportDone

func (ls *MockLeaseService) ReportDone(jobIds []string) error

func (*MockLeaseService) RequestJobLeases

func (ls *MockLeaseService) RequestJobLeases(
	availableResource *armadaresource.ComputeResources,
	nodes []api.NodeInfo,
	leasedResourceByQueue map[string]armadaresource.ComputeResources,
	leasedResourceByQueueAndPriority map[string]map[int32]armadaresource.ComputeResources,
) ([]*api.Job, error)

func (*MockLeaseService) ReturnLease

func (ls *MockLeaseService) ReturnLease(pod *v1.Pod, reason string, jobRunAttempted bool) error