Versions in this module Expand all Collapse all v1 v1.4.0 Nov 9, 2024 Changes in this version + const CPUManagerControllerName + const CPUManagerFailedStatus + const CPUManagerJobPrefix + const CPUManagerJobTTLInSec + const CPUManagerJobTimeoutInSec + const CPUManagerNonePolicy + const CPUManagerRequestedStatus + const CPUManagerRootMountPath + const CPUManagerRunningStatus + const CPUManagerScriptMountPath + const CPUManagerScriptPath + const CPUManagerStaticPolicy + const CPUManagerSuccessStatus + const CPUManagerWaitLabelTimeoutInSec + func CPUManagerRegister(ctx context.Context, management *config.Management, options config.Options) error + func GetCPUManagerRunningJobsOnNodes(jobCache ctlbatchv1.JobCache, nodeNames []string) ([]*batchv1.Job, error) + func IsManagementRole(node *corev1.Node) bool + func IsWitnessNode(node *corev1.Node, isManagement bool) bool + type CPUManagerPolicy string + type CPUManagerStatus string + type CPUManagerUpdateStatus struct + JobName string + Policy CPUManagerPolicy + Status CPUManagerStatus + func GetCPUManagerUpdateStatus(jsonString string) (*CPUManagerUpdateStatus, error) v1.3.0 Nov 10, 2024 Changes in this version + const CloudweavLabelAnnotationPrefix + const CloudweavManagedNodeLabelKey + const CloudweavMgmtNodeLabelKey + const CloudweavNodeRoleLabelPrefix + const CloudweavPromoteNodeLabelKey + const CloudweavPromoteStatusAnnotationKey + const CloudweavWitnessNodeLabelKey + const CloudweavWorkerNodeLabelKey + const KubeControlPlaneNodeLabelKey + const KubeEtcdNodeLabelKey + const KubeMasterNodeLabelKey + const KubeNodeRoleLabelPrefix + const MaintainStatusAnnotationKey + const MaintainStatusComplete + const MaintainStatusRunning + const PromoteStatusComplete + const PromoteStatusFailed + const PromoteStatusRunning + const PromoteStatusUnknown + var ConditionJobComplete = condition.Cond(batchv1.JobComplete) + var ConditionJobFailed = condition.Cond(batchv1.JobFailed) + func DownRegister(ctx context.Context, management *config.Management, _ config.Options) error + func MaintainRegister(ctx context.Context, management *config.Management, _ config.Options) error + func PromoteRegister(ctx context.Context, management *config.Management, options config.Options) error + func RemoveRegister(ctx context.Context, management *config.Management, _ config.Options) error + func VolumeDetachRegister(ctx context.Context, management *config.Management, _ config.Options) error + type PromoteHandler struct + func (h *PromoteHandler) OnJobChanged(_ string, job *batchv1.Job) (*batchv1.Job, error) + func (h *PromoteHandler) OnJobRemove(_ string, job *batchv1.Job) (*batchv1.Job, error) + func (h *PromoteHandler) OnNodeChanged(_ string, node *corev1.Node) (*corev1.Node, error)
Go to main page