appmgmt

Documentation

Index

• type AppManagementService
  • func NewAMService(amProtocol interfaces.ApplicationManagementProtocol, ...) *AppManagementService
  • func (svc *AppManagementService) ApplicationStateUpdateEventHandler() func(obj interface{})
  • func (svc *AppManagementService) GetAllManagers() []interfaces.AppManager
  • func (svc *AppManagementService) GetManagerByName(name string) interfaces.AppManager
  • func (svc *AppManagementService) Start() error
  • func (svc *AppManagementService) Stop()
  • func (svc *AppManagementService) WaitForRecovery(maxTimeout time.Duration) error

Types

type AppManagementService

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

AppManagementService is a central service that interacts with one or more K8s operators for app scheduling.

func NewAMService

func NewAMService(amProtocol interfaces.ApplicationManagementProtocol,
	apiProvider client.APIProvider) *AppManagementService

func (*AppManagementService) ApplicationStateUpdateEventHandler

func (svc *AppManagementService) ApplicationStateUpdateEventHandler() func(obj interface{})

func (*AppManagementService) GetAllManagers

func (svc *AppManagementService) GetAllManagers() []interfaces.AppManager

func (*AppManagementService) GetManagerByName

func (svc *AppManagementService) GetManagerByName(name string) interfaces.AppManager

func (*AppManagementService) Start

func (svc *AppManagementService) Start() error

func (*AppManagementService) Stop

func (svc *AppManagementService) Stop()

func (*AppManagementService) WaitForRecovery

func (svc *AppManagementService) WaitForRecovery(maxTimeout time.Duration) error