cluster

Documentation

Index

• Constants
• func CompareClusterCondition(conditionA, conditionB clusterv1alpha1.ClusterCondition) bool
• func CompareClusterConditions(condAList, condBList []clusterv1alpha1.ClusterCondition) bool
• type Controller
  • func (c *Controller) CleanExcessClusterOps(cluster *clusterv1alpha1.Cluster) (bool, error)
  • func (c *Controller) Reconcile(ctx context.Context, req controllerruntime.Request) (controllerruntime.Result, error)
  • func (c *Controller) SetupWithManager(mgr controllerruntime.Manager) error
  • func (c *Controller) SortClusterOperationsByCreation(operations []clusteroperationv1alpha1.ClusterOperation)
  • func (c *Controller) Start(ctx context.Context) error
  • func (c *Controller) UpdateStatus(cluster *clusterv1alpha1.Cluster) error

Constants

const (
	RequeueAfter = time.Second * 5
	OpsBackupNum = 5
)

Functions

func CompareClusterCondition

func CompareClusterCondition(conditionA, conditionB clusterv1alpha1.ClusterCondition) bool

func CompareClusterConditions

func CompareClusterConditions(condAList, condBList []clusterv1alpha1.ClusterCondition) bool

Types

type Controller

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

func (*Controller) CleanExcessClusterOps

func (c *Controller) CleanExcessClusterOps(cluster *clusterv1alpha1.Cluster) (bool, error)

CleanExcessClusterOps clean up excess ClusterOperation.

func (*Controller) Reconcile

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

func (*Controller) SetupWithManager

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

func (*Controller) SortClusterOperationsByCreation

func (c *Controller) SortClusterOperationsByCreation(operations []clusteroperationv1alpha1.ClusterOperation)

SortClusterOperationsByCreation operations from large to small by creation timestamp.

func (*Controller) Start

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

func (*Controller) UpdateStatus

func (c *Controller) UpdateStatus(cluster *clusterv1alpha1.Cluster) error