Documentation ¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
Click to show internal directories.
Click to hide internal directories.