clusterops

Documentation

Index

• Constants
• func IsValidImageName(image string) bool
• type Controller
  • func (c *Controller) BackUpDataRef(clusterOps *clusteroperationv1alpha1.ClusterOperation, ...) (bool, error)
  • func (c *Controller) CalSalt(clusterOps *clusteroperationv1alpha1.ClusterOperation) string
  • func (c *Controller) CheckClusterDataRef(cluster *clusterv1alpha1.Cluster, ...) error
  • func (c *Controller) CheckConfigMapExist(namespace, name string) bool
  • func (c *Controller) CheckSecretExist(namespace, name string) bool
  • func (c *Controller) CopyConfigMap(clusterOps *clusteroperationv1alpha1.ClusterOperation, ...) (*corev1.ConfigMap, error)
  • func (c *Controller) CopySecret(clusterOps *clusteroperationv1alpha1.ClusterOperation, ...) (*corev1.Secret, error)
  • func (c *Controller) CreateEntryPointShellConfigMap(clusterOps *clusteroperationv1alpha1.ClusterOperation) (bool, error)
  • func (c *Controller) CreateKubeSprayJob(clusterOps *clusteroperationv1alpha1.ClusterOperation) (bool, error)
  • func (c *Controller) CurrentJobNeedBlock(clusterOps *clusteroperationv1alpha1.ClusterOperation, ...) (bool, error)
  • func (c *Controller) FetchJobStatus(clusterOps *clusteroperationv1alpha1.ClusterOperation) (clusteroperationv1alpha1.OpsStatus, error)
  • func (c *Controller) GenerateJobName(clusterOps *clusteroperationv1alpha1.ClusterOperation) string
  • func (c *Controller) GetKuBeanCluster(clusterOps *clusteroperationv1alpha1.ClusterOperation) (*clusterv1alpha1.Cluster, error)
  • func (c *Controller) ListClusterOps(clusterName string) ([]clusteroperationv1alpha1.ClusterOperation, error)
  • func (c *Controller) NewKubesprayJob(clusterOps *clusteroperationv1alpha1.ClusterOperation) *batchv1.Job
  • func (c *Controller) Reconcile(ctx context.Context, req controllerruntime.Request) (controllerruntime.Result, error)
  • func (c *Controller) Retry(f func() bool) bool
  • 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 *clusteroperationv1alpha1.ClusterOperation) (bool, error)
  • func (c *Controller) UpdateStatusHasModified(clusterOps *clusteroperationv1alpha1.ClusterOperation) (bool, error)
  • func (c *Controller) UpdateStatusLoop(clusterOps *clusteroperationv1alpha1.ClusterOperation, ...) (bool, error)

Constants

const (
	RequeueAfter     = time.Millisecond * 500
	LoopForJobStatus = time.Second * 3
	RetryInterval    = time.Millisecond * 300
	RetryCount       = 5
)

const BaseSlat = "kubean"

Functions

func IsValidImageName

func IsValidImageName(image string) bool

Types

type Controller

type Controller struct {
	client.Client
	ClientSet           kubernetes.Interface
	KubeanClusterSet    clusterClientSet.Interface
	KubeanClusterOpsSet clusterOperationClientSet.Interface
}

func (*Controller) BackUpDataRef

func (c *Controller) BackUpDataRef(clusterOps *clusteroperationv1alpha1.ClusterOperation, cluster *clusterv1alpha1.Cluster) (bool, error)

BackUpDataRef perform the backup of configRef and secretRef and return (needRequeue,error).

func (*Controller) CalSalt

func (c *Controller) CalSalt(clusterOps *clusteroperationv1alpha1.ClusterOperation) string

func (*Controller) CheckClusterDataRef

func (c *Controller) CheckClusterDataRef(cluster *clusterv1alpha1.Cluster, clusterOPS *clusteroperationv1alpha1.ClusterOperation) error

func (*Controller) CheckConfigMapExist

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

func (*Controller) CheckSecretExist

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

func (*Controller) CopyConfigMap

func (c *Controller) CopyConfigMap(clusterOps *clusteroperationv1alpha1.ClusterOperation, oldConfigMapRef *apis.ConfigMapRef, newName string) (*corev1.ConfigMap, error)

func (*Controller) CopySecret

func (c *Controller) CopySecret(clusterOps *clusteroperationv1alpha1.ClusterOperation, oldSecretRef *apis.SecretRef, newName string) (*corev1.Secret, error)

func (*Controller) CreateEntryPointShellConfigMap

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

CreateEntryPointShellConfigMap create configMap to store entrypoint.sh.

func (*Controller) CreateKubeSprayJob

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

func (*Controller) CurrentJobNeedBlock

func (c *Controller) CurrentJobNeedBlock(clusterOps *clusteroperationv1alpha1.ClusterOperation, listClusterOps func(clusterName string) ([]clusteroperationv1alpha1.ClusterOperation, error)) (bool, error)

func (*Controller) FetchJobStatus

func (c *Controller) FetchJobStatus(clusterOps *clusteroperationv1alpha1.ClusterOperation) (clusteroperationv1alpha1.OpsStatus, error)

func (*Controller) GenerateJobName

func (c *Controller) GenerateJobName(clusterOps *clusteroperationv1alpha1.ClusterOperation) string

func (*Controller) GetKuBeanCluster

func (c *Controller) GetKuBeanCluster(clusterOps *clusteroperationv1alpha1.ClusterOperation) (*clusterv1alpha1.Cluster, error)

GetKuBeanCluster fetch the cluster which clusterOps belongs to.

func (*Controller) ListClusterOps

func (c *Controller) ListClusterOps(clusterName string) ([]clusteroperationv1alpha1.ClusterOperation, error)

func (*Controller) NewKubesprayJob

func (c *Controller) NewKubesprayJob(clusterOps *clusteroperationv1alpha1.ClusterOperation) *batchv1.Job

func (*Controller) Reconcile

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

func (*Controller) Retry

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

func (*Controller) SetOwnerReferences

func (c *Controller) SetOwnerReferences(objectMetaData *metav1.ObjectMeta, clusterOps *clusteroperationv1alpha1.ClusterOperation)

func (*Controller) SetupWithManager

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

func (*Controller) Start

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

func (*Controller) UpdateClusterOpsStatusDigest

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

func (*Controller) UpdateStatusHasModified

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

func (*Controller) UpdateStatusLoop

func (c *Controller) UpdateStatusLoop(clusterOps *clusteroperationv1alpha1.ClusterOperation, fetchJobStatus func(*clusteroperationv1alpha1.ClusterOperation) (clusteroperationv1alpha1.OpsStatus, error)) (bool, error)