util

Documentation

Index

• func ExcludeNamesFilter(names ...string) factory.EventFilterFunc
• func HandleManagementState(ctx context.Context, c consoleOperatorController, ...) error
• func IncludeNamesFilter(names ...string) factory.EventFilterFunc
• func IsExternalControlPlaneWithIngressDisabled(infrastructureConfig *configv1.Infrastructure, ...) bool
• func LabelFilter(labels map[string]string) factory.EventFilterFunc
• type InformerWithSwitch
  • func NewSwitchedInformer(ctx context.Context, oauthClient authclient.Interface, resync time.Duration, ...) *InformerWithSwitch
  • func (s *InformerWithSwitch) Informer() cache.SharedIndexInformer
  • func (s *InformerWithSwitch) Lister() oauthlistersv1.OAuthClientLister
  • func (s *InformerWithSwitch) Start(stopCh <-chan struct{})

Functions

func ExcludeNamesFilter

func ExcludeNamesFilter(names ...string) factory.EventFilterFunc

Inverse of IncludeNamesFilter

func HandleManagementState

func HandleManagementState(ctx context.Context, c consoleOperatorController, operatorClient v1helpers.OperatorClient) error

func IncludeNamesFilter

func IncludeNamesFilter(names ...string) factory.EventFilterFunc

Return func which returns true if obj name is in names

func IsExternalControlPlaneWithIngressDisabled

func IsExternalControlPlaneWithIngressDisabled(infrastructureConfig *configv1.Infrastructure, clusterVersionConfig *configv1.ClusterVersion) bool

IsExternalControlPlaneWithIngressDisabled returns true if the cluster is in external control plane topology (hypershift) and the ingress cluster capability is disabled.

func LabelFilter

func LabelFilter(labels map[string]string) factory.EventFilterFunc

Return a func which returns true if obj matches on every label in labels (i.e for each key in labels map, obj.metadata.labels[key] is equal to labels[key])

Types

type InformerWithSwitch

type InformerWithSwitch struct {
	// contains filtered or unexported fields
}

func NewSwitchedInformer

func NewSwitchedInformer(
	ctx context.Context,
	oauthClient authclient.Interface,
	resync time.Duration,
	authnInformer configv1informers.AuthenticationInformer,
	recorder events.Recorder,
) *InformerWithSwitch

func (*InformerWithSwitch) Informer

func (s *InformerWithSwitch) Informer() cache.SharedIndexInformer

func (*InformerWithSwitch) Lister

func (s *InformerWithSwitch) Lister() oauthlistersv1.OAuthClientLister

func (*InformerWithSwitch) Start

func (s *InformerWithSwitch) Start(stopCh <-chan struct{})