cluster

Documentation

Index

• Constants
• func CompareClusterCondition(conditionA, conditionB clusterv1alpha1.ClusterCondition) bool
• func CompareClusterConditions(condAList, condBList []clusterv1alpha1.ClusterCondition) bool
• type ConfigProperty
  • func (config *ConfigProperty) GetClusterOperationsBackEndLimit() int
• type Controller
  • func (c *Controller) CleanExcessClusterOps(cluster *clusterv1alpha1.Cluster, OpsBackupNum int) (bool, error)
  • func (c *Controller) FetchKubeanConfigProperty() *ConfigProperty
  • func (c *Controller) GetEliminateScoreValue(operation clusteroperationv1alpha1.ClusterOperation) int
  • 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) UpdateOwnReferenceToCluster(cluster *clusterv1alpha1.Cluster) error
  • func (c *Controller) UpdateStatus(cluster *clusterv1alpha1.Cluster) error

Constants

const (
	RequeueAfter                         = time.Second * 15
	KubeanConfigMapName                  = "kubean-config"
	DefaultClusterOperationsBackEndLimit = 30
	MaxClusterOperationsBackEndLimit     = 200
	EliminateScoreAnno                   = "kubean.io/eliminate-score"
)

Functions

func CompareClusterCondition

func CompareClusterCondition(conditionA, conditionB clusterv1alpha1.ClusterCondition) bool

func CompareClusterConditions

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

Types

type ConfigProperty

type ConfigProperty struct {
	ClusterOperationsBackEndLimit string `json:"CLUSTER_OPERATIONS_BACKEND_LIMIT"`
}

func (*ConfigProperty) GetClusterOperationsBackEndLimit

func (config *ConfigProperty) GetClusterOperationsBackEndLimit() int

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, OpsBackupNum int) (bool, error)

CleanExcessClusterOps clean up excess ClusterOperation.

func (*Controller) FetchKubeanConfigProperty

func (c *Controller) FetchKubeanConfigProperty() *ConfigProperty

func (*Controller) GetEliminateScoreValue

func (c *Controller) GetEliminateScoreValue(operation clusteroperationv1alpha1.ClusterOperation) int

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 sort operations order by EliminateScore ascend , createTime desc.

func (*Controller) Start

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

func (*Controller) UpdateOwnReferenceToCluster

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

func (*Controller) UpdateStatus

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