appmgmt

Documentation

Index

• type AppManagementService
  • func NewAMService(amProtocol interfaces.ApplicationManagementProtocol, ...) *AppManagementService
  • 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() 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) 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() error

WaitForRecovery initiates and waits for the app management service to finish recovery. If recovery is canceled (used by testing code) or an error occurs, an error will be returned. In production, this method will block until recovery completes.