rmproxy

Documentation

Index

• type ConfigurationReloader
  • func (cr ConfigurationReloader) DoReloadConfiguration() error
• type RMProxy
  • func NewRMProxy() *RMProxy
  • func (m *RMProxy) GetRMEventHandler() commonevents.EventHandler
  • func (m *RMProxy) GetResourceManagerCallback(rmID string) api.ResourceManagerCallback
  • func (m *RMProxy) HandleEvent(ev interface{})
  • func (m *RMProxy) RegisterResourceManager(request *si.RegisterResourceManagerRequest, ...) (*si.RegisterResourceManagerResponse, error)
  • func (m *RMProxy) ReloadConfiguration(rmID string) error
  • func (m *RMProxy) StartService(handlers handler.EventHandlers)
  • func (m *RMProxy) Update(request *si.UpdateRequest) error

Types

type ConfigurationReloader

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

actual configuration reloader

func (ConfigurationReloader) DoReloadConfiguration

func (cr ConfigurationReloader) DoReloadConfiguration() error

type RMProxy

type RMProxy struct {
	EventHandlers handler.EventHandlers
	// 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 (m *RMProxy) GetRMEventHandler() commonevents.EventHandler

func (*RMProxy) GetResourceManagerCallback

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

func (*RMProxy) HandleEvent

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

func (*RMProxy) RegisterResourceManager

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

func (*RMProxy) ReloadConfiguration

func (m *RMProxy) ReloadConfiguration(rmID string) error

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

func (*RMProxy) StartService

func (m *RMProxy) StartService(handlers handler.EventHandlers)

func (*RMProxy) Update

func (m *RMProxy) Update(request *si.UpdateRequest) error