Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager implements interfaces#Recoverable, interfaces#AppManager
func NewManager ¶
func NewManager(amProtocol interfaces.ApplicationManagementProtocol, apiProvider client.APIProvider) *Manager
func (*Manager) ServiceInit ¶
ServiceInit implements AppManagementService interface
It watches for changes to the SparkApplications CRD objects Two event handlers are defined to react accordingly when an SparkApplication is updated or deleted. Note that there's no need for an event handler for AddFunc because when a SparkApplication object is first created, the application ID has not been generated yet. It will only be available after the driver pod starts and then the Spark K8s backend will assign a string that starts with "spark-" as the app ID
Click to show internal directories.
Click to hide internal directories.