rmproxy

Documentation

Index

• type MockedRMProxy
  • func NewMockedRMProxy() *MockedRMProxy
  • func (rmp *MockedRMProxy) GetEvents() []interface{}
  • func (rmp *MockedRMProxy) HandleEvent(ev interface{})
  • func (rmp *MockedRMProxy) IsHandled() bool
• type RMProxy
  • func NewRMProxy(schedulerEventHandler handler.EventHandler) *RMProxy
  • func (rmp *RMProxy) GetRMEventHandler() handler.EventHandler
  • func (rmp *RMProxy) GetResourceManagerCallback(rmID string) api.ResourceManagerCallback
  • func (rmp *RMProxy) HandleEvent(ev interface{})
  • func (rmp *RMProxy) RegisterResourceManager(request *si.RegisterResourceManagerRequest, ...) (*si.RegisterResourceManagerResponse, error)
  • func (rmp *RMProxy) StartService()
  • func (rmp *RMProxy) Stop()
  • func (rmp *RMProxy) UpdateAllocation(request *si.AllocationRequest) error
  • func (rmp *RMProxy) UpdateApplication(request *si.ApplicationRequest) error
  • func (rmp *RMProxy) UpdateConfiguration(request *si.UpdateConfigurationRequest) error
  • func (rmp *RMProxy) UpdateNode(request *si.NodeRequest) error

Types

type MockedRMProxy

type MockedRMProxy struct {
	locking.RWMutex
	// contains filtered or unexported fields
}

MockedRMProxy Implements RMProxy Mock Event Handler for testing

func NewMockedRMProxy

func NewMockedRMProxy() *MockedRMProxy

func (*MockedRMProxy) GetEvents

func (rmp *MockedRMProxy) GetEvents() []interface{}

GetEvents return the list of events processed by the handler and reset

func (*MockedRMProxy) HandleEvent

func (rmp *MockedRMProxy) HandleEvent(ev interface{})

HandleEvent implements event handling for a limited set of events for testing

func (*MockedRMProxy) IsHandled

func (rmp *MockedRMProxy) IsHandled() bool

IsHandled return the last action performed by the handler and reset

type RMProxy

type RMProxy struct {
	locking.RWMutex
	// contains filtered or unexported fields
}

Gateway to talk to ResourceManager (behind grpc/API of scheduler-interface)

func NewRMProxy

func NewRMProxy(schedulerEventHandler handler.EventHandler) *RMProxy

func (*RMProxy) GetRMEventHandler

func (rmp *RMProxy) GetRMEventHandler() handler.EventHandler

func (*RMProxy) GetResourceManagerCallback

func (rmp *RMProxy) GetResourceManagerCallback(rmID string) api.ResourceManagerCallback

func (*RMProxy) HandleEvent

func (rmp *RMProxy) HandleEvent(ev interface{})

func (*RMProxy) RegisterResourceManager

func (rmp *RMProxy) RegisterResourceManager(request *si.RegisterResourceManagerRequest, callback api.ResourceManagerCallback) (*si.RegisterResourceManagerResponse, error)

func (*RMProxy) StartService

func (rmp *RMProxy) StartService()

func (*RMProxy) Stop

func (rmp *RMProxy) Stop()

func (*RMProxy) UpdateAllocation

func (rmp *RMProxy) UpdateAllocation(request *si.AllocationRequest) error

func (*RMProxy) UpdateApplication

func (rmp *RMProxy) UpdateApplication(request *si.ApplicationRequest) error

func (*RMProxy) UpdateConfiguration

func (rmp *RMProxy) UpdateConfiguration(request *si.UpdateConfigurationRequest) error

Triggers scheduler to reload configuration and apply the changes on-the-fly to the scheduler itself.

func (*RMProxy) UpdateNode

func (rmp *RMProxy) UpdateNode(request *si.NodeRequest) error