common

Feb 29, 2024

Changes in this version

+ func CalculatePerClusterStatus(ctx context.Context, c client.Client, rootPolicy *policiesv1.Policy, ...) ([]*policiesv1.CompliancePerClusterStatus, error)

+ func CalculateRootCompliance(clusters []*policiesv1.CompliancePerClusterStatus) policiesv1.ComplianceState

+ func GetAffectedObjs[T comparable](oldObjs []T, newObjs []T) []T

+ func GetPolicyPlacementDecisions(ctx context.Context, c client.Client, instance *policiesv1.Policy, ...) (clusterDecisions []string, placements []*policiesv1.Placement, err error)

+ func GetRepPoliciesInPlacementBinding(ctx context.Context, c client.Client, pb *policiesv1.PlacementBinding) []reconcile.Request

+ func GetRootPolicyRequests(ctx context.Context, c client.Client, namespace, placementRefName string, ...) ([]reconcile.Request, error)

+ func IsPolicyInPolicySet(ctx context.Context, c client.Client, ...) bool

+ type DecisionSet map[string]bool

+ func GetClusterDecisions(ctx context.Context, c client.Client, rootPolicy *policiesv1.Policy) ([]*policiesv1.Placement, DecisionSet, error)

+ func RootStatusUpdate(ctx context.Context, c client.Client, rootPolicy *policiesv1.Policy) (DecisionSet, error)

+ type EnqueueRequestsFromPolicySet struct

+ func (e *EnqueueRequestsFromPolicySet) Create(_ context.Context, evt event.CreateEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestsFromPolicySet) Delete(_ context.Context, evt event.DeleteEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestsFromPolicySet) Generic(_ context.Context, evt event.GenericEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestsFromPolicySet) Update(_ context.Context, evt event.UpdateEvent, q workqueue.RateLimitingInterface)

+ type GuttedObject struct

+ func (in *GuttedObject) DeepCopy() *GuttedObject

+ func (in *GuttedObject) DeepCopyInto(out *GuttedObject)

+ func (in *GuttedObject) DeepCopyObject() runtime.Object

+ type PlacementRefKinds string

+ const Placement

+ const PlacementRule

Oct 6, 2023

Changes in this version

+ const PolicyAutomationResouceV

+ func GetDecisions(c client.Client, pb *policiesv1.PlacementBinding) ([]appsv1.PlacementDecision, error)

+ func GetPoliciesInPlacementBinding(ctx context.Context, c client.Client, pb *policiesv1.PlacementBinding) []reconcile.Request

+ func HasValidPlacementRef(pb *policiesv1.PlacementBinding) bool

+ func IsForPolicyOrPolicySet(pb *policiesv1.PlacementBinding) bool

+ func IsPbForPolicySet(pb *policiesv1.PlacementBinding) bool

+ func MapToRootPolicy(c client.Client) handler.MapFunc

+ func MatchPAResouceV(policyAutomation *policyv1beta1.PolicyAutomation, ...) (bool, error)

May 16, 2023

Changes in this version

+ const ControllerName

+ const PolicyAutomationGeneration

+ const PolicyAutomationLabel

+ func MatchPAGeneration(policyAutomation *policyv1beta1.PolicyAutomation, ...) (bool, error)

Jan 30, 2023

Changes in this version

+ var ErrInvalidLabelValue = errors.New("unexpected format of label value")

+ func IsReplicatedPolicy(c client.Client, policy client.Object) (bool, error)

+ func ParseRootPolicyLabel(rootPlc string) (name, namespace string, err error)

+ func PolicyMapper(c client.Client) handler.MapFunc

+ func TypeConverter(a, b interface{}) error

Mar 30, 2022

Changes in this version

+ func GetApplicationPlacementDecisions(c client.Client, pb policiesv1.PlacementBinding, instance *policiesv1.Policy, ...) ([]appsv1.PlacementDecision, error)

+ func GetClusterPlacementDecisions(c client.Client, pb policiesv1.PlacementBinding, instance *policiesv1.Policy, ...) ([]appsv1.PlacementDecision, error)

+ func GetNumWorkers(listLength int, concurrencyPerPolicy int) int

+ func GetRetryOptions(logger logr.Logger, retryMsg string, attempts uint) []retry.Option

+ func IsPbForPoicySet(pb *policiesv1.PlacementBinding) bool

Jan 21, 2022

Changes in this version

+ const APIGroup

+ const ClusterNameLabel

+ const ClusterNamespaceLabel

+ const RootPolicyLabel

+ var NeverEnqueue = predicate.NewPredicateFuncs(func(o client.Object) bool { ... })

+ func CompareSpecAndAnnotation(plc1 *policiesv1.Policy, plc2 *policiesv1.Policy) bool

+ func CreateAnsibleJob(policyAutomation *policyv1beta1.PolicyAutomation, ...) error

+ func FindNonCompliantClustersForPolicy(plc *policiesv1.Policy) []string

+ func FullNameForPolicy(plc *policiesv1.Policy) string

+ func IsInClusterNamespace(ns string, allClusters []clusterv1.ManagedCluster) bool

+ func IsPbForPoicy(pb *policiesv1.PlacementBinding) bool

+ func LabelsForRootPolicy(plc *policiesv1.Policy) map[string]string

+ type EnqueueRequestsFromMapFunc struct

+ ToRequests handler.MapFunc

+ func (e *EnqueueRequestsFromMapFunc) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestsFromMapFunc) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestsFromMapFunc) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

+ func (e *EnqueueRequestsFromMapFunc) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)