rmproxy

Documentation

Index

• type RMProxy
  • func NewRMProxy() *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(handlers handler.EventHandlers)
  • func (rmp *RMProxy) UpdateAllocation(request *si.AllocationRequest) error
  • func (rmp *RMProxy) UpdateApplication(request *si.ApplicationRequest) error
  • func (rmp *RMProxy) UpdateConfiguration(rmID string) error
  • func (rmp *RMProxy) UpdateNode(request *si.NodeRequest) error

Types

type RMProxy

type RMProxy struct {
	EventHandlers handler.EventHandlers

	sync.RWMutex
	// contains filtered or unexported fields
}

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

func NewRMProxy

func NewRMProxy() *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(handlers handler.EventHandlers)

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(rmID string) 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