general

Documentation

Index

• type Manager
  • func NewManager(amProtocol interfaces.ApplicationManagementProtocol, ...) *Manager
  • func (os *Manager) GetExistingAllocation(pod *v1.Pod) *si.Allocation
  • func (os *Manager) ListApplications() (map[string]interfaces.ApplicationMetadata, error)
  • func (os *Manager) Name() string
  • func (os *Manager) ServiceInit() error
  • func (os *Manager) Start() error
  • func (os *Manager) Stop()

Types

type Manager

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

Manager implements interfaces#Recoverable, interfaces#AppManager generic app management service watches events from all the pods, it recognize apps by reading pod's spec labels, if there are proper info such as applicationID, queue name found, and claim it as an app or a app task, then report them to scheduler cache by calling am protocol

func NewManager

func NewManager(amProtocol interfaces.ApplicationManagementProtocol, apiProvider client.APIProvider) *Manager

func (*Manager) GetExistingAllocation

func (os *Manager) GetExistingAllocation(pod *v1.Pod) *si.Allocation

func (*Manager) ListApplications

func (os *Manager) ListApplications() (map[string]interfaces.ApplicationMetadata, error)

func (*Manager) Name

func (os *Manager) Name() string

this implements AppManagementService interface

func (*Manager) ServiceInit

func (os *Manager) ServiceInit() error

this implements AppManagementService interface

func (*Manager) Start

func (os *Manager) Start() error

this implements AppManagementService interface

func (*Manager) Stop

func (os *Manager) Stop()

this implements AppManagementService interface