pubcontrol

Documentation

Index

• Constants
• Variables
• func InitPubControl(cli client.Client, finder *controllerfinder.ControllerFinder, ...)
• func IsReferenceEqual(ref1, ref2 *policyv1alpha1.TargetReference) bool
• func PodUnavailableBudgetValidatePod(pod *corev1.Pod, operation policyv1alpha1.PubOperation, username string, ...) (allowed bool, reason string, err error)

Constants

const (
	// MaxUnavailablePodSize is the max size of PUB.DisruptedPods + PUB.UnavailablePods.
	MaxUnavailablePodSize = 2000
)

const (
	// related-pub annotation in pod
	PodRelatedPubAnnotation = "kruise.io/related-pub"
)

Variables

var ConflictRetry = wait.Backoff{
	Steps:    4,
	Duration: 500 * time.Millisecond,
	Factor:   1.0,
	Jitter:   0.1,
}

var (
	PodUnavailableBudgetMetrics = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: "pod_unavailable_budget",
			Help: "Pod Unavailable Budget Metrics",
		}, []string{"kind_namespace_name", "username"},
	)
)

var PubControl pubControl

Functions

func InitPubControl

func InitPubControl(cli client.Client, finder *controllerfinder.ControllerFinder, rec record.EventRecorder)

func IsReferenceEqual

func IsReferenceEqual(ref1, ref2 *policyv1alpha1.TargetReference) bool

check APIVersion, Kind, Name

func PodUnavailableBudgetValidatePod

func PodUnavailableBudgetValidatePod(pod *corev1.Pod, operation policyv1alpha1.PubOperation, username string, dryRun bool) (allowed bool, reason string, err error)

parameters: 1. allowed(bool) indicates whether to allow this update operation 2. err(error)