util

Documentation

Index

• Constants
• func CheckBrokerResources(kubeClient kubernetes.Interface, brokerNamespace string, expPresent bool) bool
• func CheckManifestWorks(workClient workclientset.Interface, managedClusterName string, expPresent bool, ...) (bool, []*workv1.ManifestWork)
• func GetCurrentNamespace(kubeClient kubernetes.Interface, defaultNamespace string) (string, error)
• func NewIntegrationTestEventRecorder(comp string) events.Recorder
• func NewManagedCluster(name string, labels map[string]string) *clusterv1.ManagedCluster
• func NewManagedClusterAddOn(namespace string) *addonv1alpha1.ManagedClusterAddOn
• func NewManagedClusterSet(name string) *clusterv1beta2.ManagedClusterSet
• func NewNamespace(namespace string) *corev1.Namespace
• func NewSubmariner(name string) *unstructured.Unstructured
• func SetSubmarinerDeployedStatus(submariner *unstructured.Unstructured)
• func SetupServiceAccount(kubeClient kubernetes.Interface, namespace, name string) error
• func UpdateManagedClusterLabels(clusterClient clusterclientset.Interface, managedClusterName string, ...) error
• type IntegrationTestEventRecorder
  • func (r *IntegrationTestEventRecorder) ComponentName() string
  • func (r *IntegrationTestEventRecorder) Event(reason, message string)
  • func (r *IntegrationTestEventRecorder) Eventf(reason, messageFmt string, args ...interface{})
  • func (r *IntegrationTestEventRecorder) ForComponent(c string) events.Recorder
  • func (r *IntegrationTestEventRecorder) Shutdown()
  • func (r *IntegrationTestEventRecorder) Warning(reason, message string)
  • func (r *IntegrationTestEventRecorder) Warningf(reason, messageFmt string, args ...interface{})
  • func (r *IntegrationTestEventRecorder) WithComponentSuffix(suffix string) events.Recorder
  • func (r *IntegrationTestEventRecorder) WithContext(_ context.Context) events.Recorder

Constants

const (
	InstallationNamespace = "submariner-operator"
)

Functions

func CheckBrokerResources

func CheckBrokerResources(kubeClient kubernetes.Interface, brokerNamespace string, expPresent bool) bool

func CheckManifestWorks

func CheckManifestWorks(workClient workclientset.Interface, managedClusterName string, expPresent bool, works ...string,
) (bool, []*workv1.ManifestWork)

func GetCurrentNamespace

func GetCurrentNamespace(kubeClient kubernetes.Interface, defaultNamespace string) (string, error)

on prow env, the /var/run/secrets/kubernetes.io/serviceaccount/namespace can be found.

func NewIntegrationTestEventRecorder

func NewIntegrationTestEventRecorder(comp string) events.Recorder

func NewManagedCluster

func NewManagedCluster(name string, labels map[string]string) *clusterv1.ManagedCluster

func NewManagedClusterAddOn

func NewManagedClusterAddOn(namespace string) *addonv1alpha1.ManagedClusterAddOn

func NewManagedClusterSet

func NewManagedClusterSet(name string) *clusterv1beta2.ManagedClusterSet

func NewNamespace

func NewNamespace(namespace string) *corev1.Namespace

func NewSubmariner

func NewSubmariner(name string) *unstructured.Unstructured

func SetSubmarinerDeployedStatus

func SetSubmarinerDeployedStatus(submariner *unstructured.Unstructured)

func SetupServiceAccount

func SetupServiceAccount(kubeClient kubernetes.Interface, namespace, name string) error

func UpdateManagedClusterLabels

func UpdateManagedClusterLabels(clusterClient clusterclientset.Interface, managedClusterName string, labels map[string]string) error

Types

type IntegrationTestEventRecorder

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

func (*IntegrationTestEventRecorder) ComponentName

func (r *IntegrationTestEventRecorder) ComponentName() string

func (*IntegrationTestEventRecorder) Event

func (r *IntegrationTestEventRecorder) Event(reason, message string)

func (*IntegrationTestEventRecorder) Eventf

func (r *IntegrationTestEventRecorder) Eventf(reason, messageFmt string, args ...interface{})

func (*IntegrationTestEventRecorder) ForComponent

func (r *IntegrationTestEventRecorder) ForComponent(c string) events.Recorder

func (*IntegrationTestEventRecorder) Shutdown

func (r *IntegrationTestEventRecorder) Shutdown()

func (*IntegrationTestEventRecorder) Warning

func (r *IntegrationTestEventRecorder) Warning(reason, message string)

func (*IntegrationTestEventRecorder) Warningf

func (r *IntegrationTestEventRecorder) Warningf(reason, messageFmt string, args ...interface{})

func (*IntegrationTestEventRecorder) WithComponentSuffix

func (r *IntegrationTestEventRecorder) WithComponentSuffix(suffix string) events.Recorder

func (*IntegrationTestEventRecorder) WithContext

func (r *IntegrationTestEventRecorder) WithContext(_ context.Context) events.Recorder