controller

package
v0.0.0-...-d4ceb64 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SparkHistoryHTTPPortName   string = "http"
	SparkHistoryHTTPPortNumber int32  = 18080
)
View Source 
const DefaultLog4jProperties = `` /* 2565-byte string literal not displayed */
View Source 
const Log4jCfgName = "log4j2.properties"

Variables

This section is empty.

Functions

func CreateRoleGroupLoggingConfigMapName 

func CreateRoleGroupLoggingConfigMapName(instanceName string, groupName string) string

CreateRoleGroupLoggingConfigMapName create role group logging config-map name

func PropertiesValue 

func PropertiesValue(_ Logger, loggingConfig *stackv1alpha1.LoggingConfigSpec) string

func RegisterRole 

func RegisterRole(role common.Role, roleReconciler common.RoleReconciler)

Types

type ClusterReconciler 

type ClusterReconciler struct {
	Log logr.Logger
	// contains filtered or unexported fields
}

func NewClusterReconciler 

func NewClusterReconciler(
	client client.Client,
	scheme *runtime.Scheme,
	cr *sparkv1alpha1.SparkHistoryServer) *ClusterReconciler

func (*ClusterReconciler) ReconcileCluster 

func (c *ClusterReconciler) ReconcileCluster(ctx context.Context) (ctrl.Result, error)

type ConfigMapReconciler 

type ConfigMapReconciler struct {
	common.ConfigurationStyleReconciler[*sparkv1alpha1.SparkHistoryServer, *sparkv1alpha1.RoleGroupSpec]
}

func NewConfigMap 

func NewConfigMap(
	scheme *runtime.Scheme,
	instance *sparkv1alpha1.SparkHistoryServer,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *sparkv1alpha1.RoleGroupSpec,
) *ConfigMapReconciler

NewConfigMap new a ConfigMapReconcile

func (*ConfigMapReconciler) Build 

func (c *ConfigMapReconciler) Build(ctx context.Context) (client.Object, error)

Build implements the ResourceBuilder interface

func (*ConfigMapReconciler) ConfigurationOverride 

func (c *ConfigMapReconciler) ConfigurationOverride(resource client.Object)

ConfigurationOverride implement the ConfigurationOverride interface

type DeploymentReconciler 

type DeploymentReconciler struct {
	common.DeploymentStyleReconciler[*sparkv1alpha1.SparkHistoryServer, *sparkv1alpha1.RoleGroupSpec]
}

func NewDeployment 

func NewDeployment(
	scheme *runtime.Scheme,
	instance *sparkv1alpha1.SparkHistoryServer,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *sparkv1alpha1.RoleGroupSpec,
	replicates int32,
) *DeploymentReconciler

NewDeployment new a DeploymentReconcile

func (*DeploymentReconciler) Build 

func (d *DeploymentReconciler) Build(ctx context.Context) (client.Object, error)

Build implements the ResourceBuilder interface

func (*DeploymentReconciler) CommandOverride 

func (d *DeploymentReconciler) CommandOverride(resource client.Object)

CommandOverride implement the WorkloadOverride interface

func (*DeploymentReconciler) EnvOverride 

func (d *DeploymentReconciler) EnvOverride(resource client.Object)

EnvOverride implement the WorkloadOverride interface

func (*DeploymentReconciler) GetConditions 

func (d *DeploymentReconciler) GetConditions() *[]metav1.Condition

GetConditions implement the ConditionGetter interface

func (*DeploymentReconciler) LogOverride 

func (d *DeploymentReconciler) LogOverride(resource client.Object)

LogOverride implement the WorkloadOverride interface

type IngressReconciler 

type IngressReconciler struct {
	common.GeneralResourceStyleReconciler[*sparkv1alpha1.SparkHistoryServer, *sparkv1alpha1.RoleGroupSpec]
}

func NewIngress 

func NewIngress(
	scheme *runtime.Scheme,
	instance *sparkv1alpha1.SparkHistoryServer,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *sparkv1alpha1.RoleGroupSpec,
) *IngressReconciler

func (*IngressReconciler) Build 

func (i *IngressReconciler) Build(_ context.Context) (client.Object, error)

Build implements the ResourceBuilder interface

type Logger 

type Logger string

type LoggingRecociler 

type LoggingRecociler struct {
	common.GeneralResourceStyleReconciler[*stackv1alpha1.SparkHistoryServer, any]
	RoleLoggingDataBuilder RoleLoggingDataBuilder
}

func NewLogging 

func NewLogging(
	scheme *runtime.Scheme,
	instance *stackv1alpha1.SparkHistoryServer,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg any,
	logDataBuilder RoleLoggingDataBuilder,
) *LoggingRecociler

NewLogging new logging reconcile

func (*LoggingRecociler) Build 

func (l *LoggingRecociler) Build(_ context.Context) (client.Object, error)

Build log4j config map

type PvcReconciler 

type PvcReconciler struct {
	common.GeneralResourceStyleReconciler[*sparkv1alpha1.SparkHistoryServer, *sparkv1alpha1.RoleGroupSpec]
}

func NewPvc 

func NewPvc(
	scheme *runtime.Scheme,
	instance *sparkv1alpha1.SparkHistoryServer,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *sparkv1alpha1.RoleGroupSpec,
) *PvcReconciler

NewPvc new a PvcReconcile

func (*PvcReconciler) Build 

func (p *PvcReconciler) Build(_ context.Context) (client.Object, error)

Build implements the ResourceBuilder interface

type RoleLoggingDataBuilder 

type RoleLoggingDataBuilder interface {
	MakeContainerLog4jData() map[string]string
}

type RoleMasterGroup 

type RoleMasterGroup struct {
	Scheme     *runtime.Scheme
	Instance   *sparkv1alpha1.SparkHistoryServer
	Client     client.Client
	GroupName  string
	RoleLabels map[string]string
	Log        logr.Logger
}

RoleMasterGroup master role group reconcile

func NewRoleMasterGroup 

func NewRoleMasterGroup(
	scheme *runtime.Scheme,
	instance *sparkv1alpha1.SparkHistoryServer,
	client client.Client,
	groupName string,
	roleLabels map[string]string,
	log logr.Logger) *RoleMasterGroup

func (*RoleMasterGroup) MergeGroupConfigSpec 

func (r *RoleMasterGroup) MergeGroupConfigSpec() any

func (*RoleMasterGroup) MergeLabels 

func (r *RoleMasterGroup) MergeLabels(mergedCfg any) map[string]string

func (*RoleMasterGroup) ReconcileGroup 

func (r *RoleMasterGroup) ReconcileGroup(ctx context.Context) (ctrl.Result, error)

ReconcileGroup ReconcileRole implements the Role interface

type SecretReconciler 

type SecretReconciler struct {
	common.ConfigurationStyleReconciler[*sparkv1alpha1.SparkHistoryServer, *sparkv1alpha1.RoleGroupSpec]
}

func NewSecret 

func NewSecret(
	scheme *runtime.Scheme,
	instance *sparkv1alpha1.SparkHistoryServer,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *sparkv1alpha1.RoleGroupSpec,

) *SecretReconciler

NewSecret new a SecretReconcile

func (*SecretReconciler) Build 

func (s *SecretReconciler) Build(ctx context.Context) (client.Object, error)

Build implements the ResourceBuilder interface

func (*SecretReconciler) ConfigurationOverride 

func (s *SecretReconciler) ConfigurationOverride(_ client.Object)

ConfigurationOverride implement the ConfigurationOverride interface

type ServiceReconciler 

type ServiceReconciler struct {
	common.GeneralResourceStyleReconciler[*sparkv1alpha1.SparkHistoryServer, *sparkv1alpha1.RoleGroupSpec]
}

func NewService 

func NewService(
	scheme *runtime.Scheme,
	instance *sparkv1alpha1.SparkHistoryServer,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *sparkv1alpha1.RoleGroupSpec,

) *ServiceReconciler

NewService new a ServiceReconcile

func (*ServiceReconciler) Build 

func (s *ServiceReconciler) Build(ctx context.Context) (client.Object, error)

Build implements the ResourceBuilder interface

func (*ServiceReconciler) GetServiceType 

func (s *ServiceReconciler) GetServiceType(ctx context.Context) corev1.ServiceType

type SparkHistoryInstance 

type SparkHistoryInstance struct {
	Instance *sparkv1alpha1.SparkHistoryServer
}

func (*SparkHistoryInstance) GetClusterConfig 

func (i *SparkHistoryInstance) GetClusterConfig() *sparkv1alpha1.ClusterConfigSpec

func (*SparkHistoryInstance) GetClusterOperation 

func (i *SparkHistoryInstance) GetClusterOperation() *sparkv1alpha1.ClusterOperationSpec

type SparkHistoryServer 

type SparkHistoryServer struct {
	common.BaseRoleReconciler[*sparkv1alpha1.SparkHistoryServer, *sparkv1alpha1.RoleSpec]
}

func NewSparkHistoryServer 

func NewSparkHistoryServer(
	scheme *runtime.Scheme,
	instance *sparkv1alpha1.SparkHistoryServer,
	client client.Client,
	log logr.Logger) *SparkHistoryServer

NewSparkHistoryServer new roleMaster

func (*SparkHistoryServer) MergeLabels 

func (r *SparkHistoryServer) MergeLabels() map[string]string

func (*SparkHistoryServer) ReconcileRole 

func (r *SparkHistoryServer) ReconcileRole(ctx context.Context) (ctrl.Result, error)

func (*SparkHistoryServer) RoleName 

func (r *SparkHistoryServer) RoleName() common.Role

type SparkHistoryServerLoggingDataBuilder 

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

func (*SparkHistoryServerLoggingDataBuilder) MakeContainerLog4jData 

func (s *SparkHistoryServerLoggingDataBuilder) MakeContainerLog4jData() map[string]string

MakeContainerLog4jData implement RoleLoggingDataBuilder interface

type SparkHistoryServerReconciler 

type SparkHistoryServerReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

SparkHistoryServerReconciler reconciles a SparkHistoryServer object

func (*SparkHistoryServerReconciler) Reconcile 

func (r *SparkHistoryServerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the SparkHistoryServer object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.1/pkg/reconcile

func (*SparkHistoryServerReconciler) ReconciliationPaused 

func (r *SparkHistoryServerReconciler) ReconciliationPaused(
	ctx context.Context,
	instance *sparkv1alpha1.SparkHistoryServer,
) bool

func (*SparkHistoryServerReconciler) SetupWithManager 

func (r *SparkHistoryServerReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.