workloadspread

Documentation

Index

• Constants
• Variables
• func GenerateEmptyWorkloadObject(gvk schema.GroupVersionKind, key types.NamespacedName) (object client.Object)
• func GetPodVersion(pod *corev1.Pod) string
• func GetReplicasFromCustomWorkload(reader client.Reader, object *unstructured.Unstructured) int32
• func GetReplicasFromObject(object *unstructured.Unstructured, replicasPath string) (int32, error)
• func GetReplicasFromWorkloadWithTargetFilter(object client.Object, targetFilter *appsv1alpha1.TargetFilter) (int32, error)
• func GetWorkloadVersion(reader client.Reader, object client.Object) (string, error)
• func IsPodSelected(filter *appsv1alpha1.TargetFilter, podLabels map[string]string) (bool, error)
• func NestedField[T any](obj any, paths ...string) (T, bool, error)
• func VerifyGroupKind(ref interface{}, expectedKind string, expectedGroups []string) (bool, error)
• type Handler
  • func NewWorkloadSpreadHandler(c client.Client) *Handler
  • func (h *Handler) HandlePodCreation(pod *corev1.Pod) (skip bool, err error)
  • func (h *Handler) HandlePodDeletion(pod *corev1.Pod, operation Operation) error
• type InjectWorkloadSpread
• type Operation

Constants

const (
	// MatchedWorkloadSpreadSubsetAnnotations matched pod workloadSpread
	MatchedWorkloadSpreadSubsetAnnotations = "apps.kruise.io/matched-workloadspread"

	PodDeletionCostAnnotation = "controller.kubernetes.io/pod-deletion-cost"

	PodDeletionCostPositive = 100
	PodDeletionCostNegative = -100

	// VersionIgnored means all Pods should be regard as a universal version,
	// i.e., ignore the Pod/Workload version.
	VersionIgnored = "versionIgnored"
)

Variables

var (
	EnabledWorkloadSetForVersionedStatus sets.String

	GenerateNotFoundError = func(object client.Object, msg string) error {
		objectGroupKind := object.GetObjectKind().GroupVersionKind().GroupKind()
		return errors.NewNotFound(schema.GroupResource{Group: objectGroupKind.Group, Resource: objectGroupKind.Kind}, msg)
	}
)

Functions

func GenerateEmptyWorkloadObject

func GenerateEmptyWorkloadObject(gvk schema.GroupVersionKind, key types.NamespacedName) (object client.Object)

func GetPodVersion

func GetPodVersion(pod *corev1.Pod) string

func GetReplicasFromCustomWorkload

func GetReplicasFromCustomWorkload(reader client.Reader, object *unstructured.Unstructured) int32

func GetReplicasFromObject

func GetReplicasFromObject(object *unstructured.Unstructured, replicasPath string) (int32, error)

func GetReplicasFromWorkloadWithTargetFilter

func GetReplicasFromWorkloadWithTargetFilter(object client.Object, targetFilter *appsv1alpha1.TargetFilter) (int32, error)

func GetWorkloadVersion

func GetWorkloadVersion(reader client.Reader, object client.Object) (string, error)

func IsPodSelected

func IsPodSelected(filter *appsv1alpha1.TargetFilter, podLabels map[string]string) (bool, error)

func NestedField

func NestedField[T any](obj any, paths ...string) (T, bool, error)

func VerifyGroupKind

func VerifyGroupKind(ref interface{}, expectedKind string, expectedGroups []string) (bool, error)

Types

type Handler

type Handler struct {
	client.Client
}

func NewWorkloadSpreadHandler

func NewWorkloadSpreadHandler(c client.Client) *Handler

func (*Handler) HandlePodCreation

func (h *Handler) HandlePodCreation(pod *corev1.Pod) (skip bool, err error)

func (*Handler) HandlePodDeletion

func (h *Handler) HandlePodDeletion(pod *corev1.Pod, operation Operation) error

type InjectWorkloadSpread

type InjectWorkloadSpread struct {
	// matched WorkloadSpread.Name
	Name string `json:"name"`
	// Subset.Name
	Subset string `json:"subset"`
	// generate id if the Pod's name is nil.
	UID string `json:"uid,omitempty"`
}

type Operation

type Operation string

const (
	CreateOperation   Operation = "Create"
	DeleteOperation   Operation = "Delete"
	EvictionOperation Operation = "Eviction"
)