factory

Documentation

Index

• Constants
• func BuildBackup(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent, ...) (*dataprotectionv1alpha1.Backup, error)
• func BuildBackupManifestsJob(key types.NamespacedName, backup *dataprotectionv1alpha1.Backup, ...) (*batchv1.Job, error)
• func BuildCfgManagerContainer(sidecarRenderedParam *cfgcm.CfgManagerBuildParams, ...) (*corev1.Container, error)
• func BuildCfgManagerToolsContainer(sidecarRenderedParam *cfgcm.CfgManagerBuildParams, ...) ([]corev1.Container, error)
• func BuildClusterRoleBinding(cluster *appsv1alpha1.Cluster) (*rbacv1.ClusterRoleBinding, error)
• func BuildConfigMapWithTemplate(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent, ...) (*corev1.ConfigMap, error)
• func BuildConnCredential(clusterDefinition *appsv1alpha1.ClusterDefinition, ...) (*corev1.Secret, error)
• func BuildDeploy(reqCtx intctrlutil.RequestCtx, cluster *appsv1alpha1.Cluster, ...) (*appsv1.Deployment, error)
• func BuildEnvConfig(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent) (*corev1.ConfigMap, error)
• func BuildHeadlessSvc(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent) (*corev1.Service, error)
• func BuildPDB(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent) (*policyv1.PodDisruptionBudget, error)
• func BuildPVC(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent, ...) (*corev1.PersistentVolumeClaim, error)
• func BuildPersistentVolumeClaimLabels(component *component.SynthesizedComponent, pvc *corev1.PersistentVolumeClaim, ...)
• func BuildRSM(reqCtx intctrlutil.RequestCtx, cluster *appsv1alpha1.Cluster, ...) (*workloads.ReplicatedStateMachine, error)
• func BuildRestoreJob(cluster *appsv1alpha1.Cluster, ...) (*batchv1.Job, error)
• func BuildRoleBinding(cluster *appsv1alpha1.Cluster) (*rbacv1.RoleBinding, error)
• func BuildServiceAccount(cluster *appsv1alpha1.Cluster) (*corev1.ServiceAccount, error)
• func BuildSts(reqCtx intctrlutil.RequestCtx, cluster *appsv1alpha1.Cluster, ...) (*appsv1.StatefulSet, error)
• func BuildSvcList(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent) ([]*corev1.Service, error)
• func BuildSvcListWithCustomAttributes(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent, ...) ([]*corev1.Service, error)
• func BuildVolumeSnapshotClass(name string, driver string) (*snapshotv1.VolumeSnapshotClass, error)

Constants

const (
	VolumeName = "tls"
	CAName     = "ca.crt"
	CertName   = "tls.crt"
	KeyName    = "tls.key"
	MountPath  = "/etc/pki/tls"
)

Functions

func BuildBackup

func BuildBackup(cluster *appsv1alpha1.Cluster,
	component *component.SynthesizedComponent,
	backupPolicyName string,
	backupKey types.NamespacedName,
	backupType string) (*dataprotectionv1alpha1.Backup, error)

func BuildBackupManifestsJob

func BuildBackupManifestsJob(key types.NamespacedName, backup *dataprotectionv1alpha1.Backup, podSpec *corev1.PodSpec) (*batchv1.Job, error)

func BuildCfgManagerContainer

func BuildCfgManagerContainer(sidecarRenderedParam *cfgcm.CfgManagerBuildParams, component *component.SynthesizedComponent) (*corev1.Container, error)

func BuildCfgManagerToolsContainer

func BuildCfgManagerToolsContainer(sidecarRenderedParam *cfgcm.CfgManagerBuildParams, component *component.SynthesizedComponent, toolsMetas []appsv1alpha1.ToolConfig, toolsMap map[string]cfgcm.ConfigSpecMeta) ([]corev1.Container, error)

func BuildClusterRoleBinding

func BuildClusterRoleBinding(cluster *appsv1alpha1.Cluster) (*rbacv1.ClusterRoleBinding, error)

func BuildConfigMapWithTemplate

func BuildConfigMapWithTemplate(cluster *appsv1alpha1.Cluster,
	component *component.SynthesizedComponent,
	configs map[string]string,
	cmName string,
	configConstraintName string,
	configTemplateSpec appsv1alpha1.ComponentTemplateSpec) (*corev1.ConfigMap, error)

func BuildConnCredential

func BuildConnCredential(clusterDefinition *appsv1alpha1.ClusterDefinition, cluster *appsv1alpha1.Cluster,
	component *component.SynthesizedComponent) (*corev1.Secret, error)

func BuildDeploy

func BuildDeploy(reqCtx intctrlutil.RequestCtx, cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent, envConfigName string) (*appsv1.Deployment, error)

func BuildEnvConfig

func BuildEnvConfig(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent) (*corev1.ConfigMap, error)

BuildEnvConfig builds cluster component context ConfigMap object, which is to be used in workload container's envFrom.configMapRef with name of "$(cluster.metadata.name)-$(component.name)-env" pattern.

func BuildHeadlessSvc

func BuildHeadlessSvc(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent) (*corev1.Service, error)

func BuildPDB

func BuildPDB(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent) (*policyv1.PodDisruptionBudget, error)

func BuildPVC

func BuildPVC(cluster *appsv1alpha1.Cluster,
	component *component.SynthesizedComponent,
	vct *corev1.PersistentVolumeClaimTemplate,
	pvcKey types.NamespacedName,
	snapshotName string) (*corev1.PersistentVolumeClaim, error)

func BuildPersistentVolumeClaimLabels

func BuildPersistentVolumeClaimLabels(component *component.SynthesizedComponent, pvc *corev1.PersistentVolumeClaim,
	pvcTplName string)

BuildPersistentVolumeClaimLabels builds a pvc name label, and synchronize the labels from sts to pvc.

func BuildRSM

func BuildRSM(reqCtx intctrlutil.RequestCtx, cluster *appsv1alpha1.Cluster,
	component *component.SynthesizedComponent, envConfigName string) (*workloads.ReplicatedStateMachine, error)

func BuildRestoreJob

func BuildRestoreJob(cluster *appsv1alpha1.Cluster, synthesizedComponent *component.SynthesizedComponent, name, image string, command []string,
	volumes []corev1.Volume, volumeMounts []corev1.VolumeMount, env []corev1.EnvVar, resources *corev1.ResourceRequirements) (*batchv1.Job, error)

func BuildRoleBinding

func BuildRoleBinding(cluster *appsv1alpha1.Cluster) (*rbacv1.RoleBinding, error)

func BuildServiceAccount

func BuildServiceAccount(cluster *appsv1alpha1.Cluster) (*corev1.ServiceAccount, error)

func BuildSts

func BuildSts(reqCtx intctrlutil.RequestCtx, cluster *appsv1alpha1.Cluster,
	component *component.SynthesizedComponent, envConfigName string) (*appsv1.StatefulSet, error)

func BuildSvcList

func BuildSvcList(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent) ([]*corev1.Service, error)

func BuildSvcListWithCustomAttributes

func BuildSvcListWithCustomAttributes(cluster *appsv1alpha1.Cluster, component *component.SynthesizedComponent,
	customAttributeSetter func(*corev1.Service)) ([]*corev1.Service, error)

func BuildVolumeSnapshotClass

func BuildVolumeSnapshotClass(name string, driver string) (*snapshotv1.VolumeSnapshotClass, error)