general

Documentation

Index

• Constants
• type EventSource
• type EventType
• type Manager
  • func NewManager(apiProvider client.APIProvider, podEventHandler *PodEventHandler) *Manager
  • func (os *Manager) AddPod(obj interface{})
  • func (os *Manager) GetExistingAllocation(pod *v1.Pod) *si.Allocation
  • func (os *Manager) ListPods() ([]*v1.Pod, error)
  • func (os *Manager) Name() string
  • func (os *Manager) ServiceInit() error
  • func (os *Manager) Start() error
  • func (os *Manager) Stop()
• type PodEventHandler
  • func NewPodEventHandler(amProtocol interfaces.ApplicationManagementProtocol, recoveryRunning bool) *PodEventHandler
  • func (p *PodEventHandler) HandleEvent(eventType EventType, source EventSource, pod *v1.Pod) interfaces.ManagedApp
  • func (p *PodEventHandler) RecoveryDone(terminatedPods map[string]bool)

Constants

const (
	AddPod = iota
	UpdatePod
	DeletePod
)

const (
	Recovery = iota
	Informers
)

Types

type EventSource

type EventSource int

type EventType

type EventType int

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(apiProvider client.APIProvider, podEventHandler *PodEventHandler) *Manager

func (*Manager) AddPod

func (os *Manager) AddPod(obj interface{})

AddPod Add application and task using pod metadata Visibility: Public only for testing

func (*Manager) GetExistingAllocation

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

func (*Manager) ListPods

func (os *Manager) ListPods() ([]*v1.Pod, 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

type PodEventHandler

type PodEventHandler struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewPodEventHandler

func NewPodEventHandler(amProtocol interfaces.ApplicationManagementProtocol, recoveryRunning bool) *PodEventHandler

func (*PodEventHandler) HandleEvent

func (p *PodEventHandler) HandleEvent(eventType EventType, source EventSource, pod *v1.Pod) interfaces.ManagedApp

func (*PodEventHandler) RecoveryDone

func (p *PodEventHandler) RecoveryDone(terminatedPods map[string]bool)