tests

Documentation

Index

• Variables
• type MockRMCallbackHandler
  • func NewMockRMCallbackHandler(t testing.TB) *MockRMCallbackHandler
  • func (m *MockRMCallbackHandler) EvalPredicates(name string, node string) error
  • func (m *MockRMCallbackHandler) RecvUpdateResponse(response *si.UpdateResponse) error
• type MockScheduler
  • func (m *MockScheduler) AddApp(appID string, queue string, partition string)
  • func (m *MockScheduler) AddNode(nodeID string, resource *si.Resource)
  • func (m *MockScheduler) GetSchedulingQueue(queue string) *scheduler.SchedulingQueue
  • func (m *MockScheduler) Init(t *testing.T, config string)
  • func (m *MockScheduler) Stop()

Variables

var TwoEqualQueueConfigEnabledPreemption = `` /* 533-byte string literal not displayed */

Types

type MockRMCallbackHandler

type MockRMCallbackHandler struct {
	Allocations map[string]*si.Allocation
	// contains filtered or unexported fields
}

func NewMockRMCallbackHandler

func NewMockRMCallbackHandler(t testing.TB) *MockRMCallbackHandler

func (*MockRMCallbackHandler) EvalPredicates

func (m *MockRMCallbackHandler) EvalPredicates(name string, node string) error

func (*MockRMCallbackHandler) RecvUpdateResponse

func (m *MockRMCallbackHandler) RecvUpdateResponse(response *si.UpdateResponse) error

type MockScheduler

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

func (*MockScheduler) AddApp

func (m *MockScheduler) AddApp(appID string, queue string, partition string)

func (*MockScheduler) AddNode

func (m *MockScheduler) AddNode(nodeID string, resource *si.Resource)

func (*MockScheduler) GetSchedulingQueue

func (m *MockScheduler) GetSchedulingQueue(queue string) *scheduler.SchedulingQueue

func (*MockScheduler) Init

func (m *MockScheduler) Init(t *testing.T, config string)

func (*MockScheduler) Stop

func (m *MockScheduler) Stop()