clusterops

Sep 14, 2023

Changes in this version

type Controller

+ func (c *Controller) UpdateStatusForLabel(ops *clusteroperationv1alpha1.ClusterOperation) error

Aug 7, 2023

Changes in this version

+ const JobActorPodAnnoKey

type Controller

+ func (c *Controller) GetRunningPodFromJob(job *batchv1.Job) (*corev1.Pod, error)

+ func (c *Controller) TrySuspendPod(clusterOps *clusteroperationv1alpha1.ClusterOperation) (bool, error)

+ func (c *Controller) UpdateOwnReferenceToClusterOps(clusterOps *clusteroperationv1alpha1.ClusterOperation) error

Jul 20, 2023

Changes in this version

type Controller

+ func (c *Controller) UpdateOperationOwnReferenceForCluster(operation *clusteroperationv1alpha1.ClusterOperation, ...) (bool, error)

Jun 19, 2023

Changes in this version

type Controller

+ func (c *Controller) FetchJobConditionStatusAndCompletionTime(clusterOps *clusteroperationv1alpha1.ClusterOperation) (clusteroperationv1alpha1.OpsStatus, *metav1.Time, error)

May 14, 2023

Changes in this version

type Controller

+ Client client.Client

Mar 22, 2023

Changes in this version

+ const SprayJobPodName

type Controller

+ func (c *Controller) HookCustomAction(clusterOps *clusteroperationv1alpha1.ClusterOperation, job *batchv1.Job) error

Feb 15, 2023

Changes in this version

+ const ServiceAccount

type Controller

+ func (c *Controller) GetServiceAccountName(namespace, labelSelector string) (string, error)

Dec 10, 2022

Changes in this version

type Controller

+ InfoManifestClientSet manifestClientSet.Interface

+ func (c *Controller) FetchGlobalInfoManifest() (*manifestv1alpha1.Manifest, error)

+ func (c *Controller) FetchGlobalManifestImageTag() string

+ func (c *Controller) ProcessKubeanOperationImage(oldImage, globalManifestImageTag string) string

Oct 24, 2022

Changes in this version

+ const RetryCount

+ const RetryInterval

type Controller

+ func (c *Controller) Retry(f func() bool) bool

Oct 14, 2022

Changes in this version

type Controller

+ func (c *Controller) CheckClusterDataRef(cluster *kubeanclusterv1alpha1.KuBeanCluster, ...) error

+ func (c *Controller) CheckConfigMapExist(namespace, name string) bool

+ func (c *Controller) CheckSecretExist(namespace, name string) bool

Sep 7, 2022

Changes in this version

type Controller

+ func (c *Controller) GenerateJobName(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps) string

Aug 25, 2022

Changes in this version

+ func IsValidImageName(image string) bool

Aug 16, 2022

Changes in this version

+ const BaseSlat

+ const KubeanClusterLabelKey

+ const LoopForJobStatus

+ const OpsBackupNum

+ const RequeueAfter

+ type Controller struct

+ ClientSet *kubernetes.Clientset

+ KubeanClusterOpsSet *kubeanClusterOpsClientSet.Clientset

+ KubeanClusterSet *kubeanClusterClientSet.Clientset

+ func (c *Controller) BackUpDataRef(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps, ...) (bool, error)

+ func (c *Controller) CalSalt(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps) string

+ func (c *Controller) CleanExcessClusterOps(cluster *kubeanclusterv1alpha1.KuBeanCluster) (bool, error)

+ func (c *Controller) CopyConfigMap(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps, ...) (*corev1.ConfigMap, error)

+ func (c *Controller) CopySecret(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps, ...) (*corev1.Secret, error)

+ func (c *Controller) CreateEntryPointShellConfigMap(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps) (bool, error)

+ func (c *Controller) CreateKubeSprayJob(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps) (bool, error)

+ func (c *Controller) CurrentJobNeedBlock(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps, ...) (bool, error)

+ func (c *Controller) FetchJobStatus(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps) (kubeanclusteropsv1alpha1.OpsStatus, error)

+ func (c *Controller) GetKuBeanCluster(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps) (*kubeanclusterv1alpha1.KuBeanCluster, error)

+ func (c *Controller) ListClusterOps(clusterName string) ([]kubeanclusteropsv1alpha1.KuBeanClusterOps, error)

+ func (c *Controller) NewKubesprayJob(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps) *batchv1.Job

+ func (c *Controller) Reconcile(ctx context.Context, req controllerruntime.Request) (controllerruntime.Result, error)

+ func (c *Controller) SetOwnerReferences(objectMetaData *metav1.ObjectMeta, ...)

+ func (c *Controller) SetupWithManager(mgr controllerruntime.Manager) error

+ func (c *Controller) Start(ctx context.Context) error

+ func (c *Controller) UpdateClusterOpsStatusDigest(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps) (bool, error)

+ func (c *Controller) UpdateStatusHasModified(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps) (bool, error)

+ func (c *Controller) UpdateStatusLoop(clusterOps *kubeanclusteropsv1alpha1.KuBeanClusterOps, ...) (bool, error)