helpers

Documentation

Index

• func CreateSelfSubjectAccessReviews(ctx context.Context, kubeClient kubernetes.Interface, ...) (bool, *authorizationv1.SelfSubjectAccessReview, error)
• func FilterClusterAnnotations(annotations map[string]string) map[string]string
• func GetBootstrapSSARs() []authorizationv1.SelfSubjectAccessReview
• func GetClusterChanges(client clusterlister.PlacementDecisionLister, ...) (sets.Set[string], sets.Set[string], error)
• func GetHubConfigSSARs(clusterName string) []authorizationv1.SelfSubjectAccessReview
• func NewEventRecorder(ctx context.Context, scheme *runtime.Scheme, kubeClient kubernetes.Interface, ...) (kevents.EventRecorder, error)
• type PlacementDecisionGetter
  • func (pdl PlacementDecisionGetter) List(selector labels.Selector, namespace string) ([]*clusterv1beta1.PlacementDecision, error)
• type RequeueError
  • func NewRequeueError(msg string, requeueTime time.Duration) RequeueError
  • func (r RequeueError) Error() string

Functions

func CreateSelfSubjectAccessReviews

func CreateSelfSubjectAccessReviews(
	ctx context.Context,
	kubeClient kubernetes.Interface,
	selfSubjectAccessReviews []authorizationv1.SelfSubjectAccessReview) (bool, *authorizationv1.SelfSubjectAccessReview, error)

func FilterClusterAnnotations

func FilterClusterAnnotations(annotations map[string]string) map[string]string

func GetBootstrapSSARs

func GetBootstrapSSARs() []authorizationv1.SelfSubjectAccessReview

func GetClusterChanges

func GetClusterChanges(client clusterlister.PlacementDecisionLister, placement *clusterv1beta1.Placement,
	existingClusters sets.Set[string]) (sets.Set[string], sets.Set[string], error)

Get added and deleted clusters names

func GetHubConfigSSARs

func GetHubConfigSSARs(clusterName string) []authorizationv1.SelfSubjectAccessReview

func NewEventRecorder

func NewEventRecorder(ctx context.Context, scheme *runtime.Scheme,
	kubeClient kubernetes.Interface, controllerName string) (kevents.EventRecorder, error)

NewEventRecorder creates a new event recorder for the given controller, it will also log the events

Types

type PlacementDecisionGetter

type PlacementDecisionGetter struct {
	Client clusterlister.PlacementDecisionLister
}

func (PlacementDecisionGetter) List

func (pdl PlacementDecisionGetter) List(selector labels.Selector, namespace string) ([]*clusterv1beta1.PlacementDecision, error)

type RequeueError

type RequeueError struct {
	RequeueTime time.Duration
	Message     string
}

func NewRequeueError

func NewRequeueError(msg string, requeueTime time.Duration) RequeueError

func (RequeueError) Error

func (r RequeueError) Error() string