utils

package
v0.0.0-...-f264b1e Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ServerCACerts = "observability-server-ca-certs"
	ClientCACerts = "observability-client-ca-certs"
	ServerCerts   = "observability-server-certs"
	GrafanaCerts  = "observability-grafana-certs"
)
View Source 
const (
	MCO_CR_NAME                   = "observability"
	MCO_COMPONENT_LABEL           = "observability.open-cluster-management.io/name=" + MCO_CR_NAME
	OBSERVATORIUM_COMPONENT_LABEL = "app.kubernetes.io/part-of=observatorium"
	MCO_NAMESPACE                 = "open-cluster-management-observability"
	MCO_ADDON_NAMESPACE           = "open-cluster-management-addon-observability"
	MCO_PULL_SECRET_NAME          = "multiclusterhub-operator-pull-secret"
	OBJ_SECRET_NAME               = "thanos-object-storage" // #nosec G101 -- Not a hardcoded credential.
	MCO_GROUP                     = "observability.open-cluster-management.io"
	OCM_WORK_GROUP                = "work.open-cluster-management.io"
	OCM_CLUSTER_GROUP             = "cluster.open-cluster-management.io"
	OCM_ADDON_GROUP               = "addon.open-cluster-management.io"
)
View Source 
const (
	ManagedClusterAddOnDisabledMessage = "enableMetrics is set to False"
	OBMAddonEnabledMessage             = "Cluster metrics sent successfully"
	ManagedClusterAddOnEnabledMessage  = "observability-controller add-on is available"
)
View Source 
const (
	RouterCertsSecretName = "router-certs-default"
)

Variables

This section is empty.

Functions

func Apply 

func Apply(url string, kubeconfig string, ctx string, yamlB []byte) error

Apply a multi resources file to the cluster described by the url, kubeconfig and ctx. url of the cluster kubeconfig which contains the ctx ctx, the ctx to use yamlB, a byte array containing the resources file

func CheckAdvRetentionConfig 

func CheckAdvRetentionConfig(opt TestOptions) (bool, error)

func CheckAllOBADisabled 

func CheckAllOBADisabled(opt TestOptions) error

func CheckAllOBAsDeleted 

func CheckAllOBAsDeleted(opt TestOptions) error

func CheckAllOBAsEnabled 

func CheckAllOBAsEnabled(opt TestOptions) error

func CheckAllPodNodeSelector 

func CheckAllPodNodeSelector(opt TestOptions, nodeSelector map[string]interface{}) error

func CheckAllPodsAffinity 

func CheckAllPodsAffinity(opt TestOptions) error

func CheckDeploymentPodReady 

func CheckDeploymentPodReady(opt TestOptions, deployName string) error

func CheckMCOAddon 

func CheckMCOAddon(opt TestOptions) error

func CheckMCOAddonResources 

func CheckMCOAddonResources(opt TestOptions) error

func CheckMCOComponents 

func CheckMCOComponents(opt TestOptions) error

func CheckMCOConversion 

func CheckMCOConversion(opt TestOptions, v1beta1tov1beta2GoldenPath string) error

func CheckManagedClusterAddonsStatus 

func CheckManagedClusterAddonsStatus(opt TestOptions, namespace, status string) error

func CheckOBAComponents 

func CheckOBAComponents(opt TestOptions) error

func CheckOBADeleted 

func CheckOBADeleted(opt TestOptions, namespace string) error

func CheckOBAStatus 

func CheckOBAStatus(opt TestOptions, namespace, status string) error

func CheckStatefulSetPodReady 

func CheckStatefulSetPodReady(opt TestOptions, stsName string) error

func CheckStorageResize 

func CheckStorageResize(opt TestOptions, stsName string, expectedCapacity string) error

func CleanExportResources 

func CleanExportResources(opt TestOptions) error

func ContainDashboard 

func ContainDashboard(opt TestOptions, title string) (error, bool)

func ContainManagedClusterMetric 

func ContainManagedClusterMetric(opt TestOptions, query string, matchedLabels []string) (error, bool)

func CreateCRB 

func CreateCRB(opt TestOptions, isHub bool,
	crb *rbacv1.ClusterRoleBinding) error

func CreateConfigMap 

func CreateConfigMap(opt TestOptions, isHub bool, cm *corev1.ConfigMap) error

func CreateMCONamespace 

func CreateMCONamespace(opt TestOptions) error

func CreateMCOTestingRBAC 

func CreateMCOTestingRBAC(opt TestOptions) error

func CreateObjSecret 

func CreateObjSecret(opt TestOptions) error

func CreatePullSecret 

func CreatePullSecret(opt TestOptions, mcoNs string) error

func CreateSA 

func CreateSA(opt TestOptions, isHub bool, namespace string,
	sa *v1.ServiceAccount) error

func DeleteCRB 

func DeleteCRB(opt TestOptions, isHub bool, name string) error

func DeleteCertSecret 

func DeleteCertSecret(opt TestOptions) error

func DeleteConfigMap 

func DeleteConfigMap(opt TestOptions, isHub bool, name string, namespace string) error

func DeleteDeployment 

func DeleteDeployment(opt TestOptions, isHub bool, name string, namespace string) error

func DeleteMCOInstance 

func DeleteMCOInstance(opt TestOptions, name string) error

func DeleteMCOTestingRBAC 

func DeleteMCOTestingRBAC(opt TestOptions) error

func DeletePod 

func DeletePod(opt TestOptions, isHub bool, namespace, name string) error

func DeleteSA 

func DeleteSA(opt TestOptions, isHub bool, namespace string,
	name string) error

func FetchBearerToken 

func FetchBearerToken(opt TestOptions) (string, error)

func GetAllMCOPods 

func GetAllMCOPods(opt TestOptions) ([]corev1.Pod, error)

func GetAllOBAPods 

func GetAllOBAPods(opt TestOptions) ([]corev1.Pod, error)

func GetCRB 

func GetCRB(opt TestOptions, isHub bool, name string) (error, *rbacv1.ClusterRoleBinding)

func GetConfigMap 

func GetConfigMap(opt TestOptions, isHub bool, name string,
	namespace string) (error, *corev1.ConfigMap)

func GetDefaultMetricList 

func GetDefaultMetricList(opt TestOptions) ([]string, []string)

func GetDeployment 

func GetDeployment(opt TestOptions, isHub bool, name string,
	namespace string) (*appv1.Deployment, error)

func GetDeploymentWithLabel 

func GetDeploymentWithLabel(opt TestOptions, isHub bool, label string,
	namespace string) (*appv1.DeploymentList, error)

func GetGrafanaURL 

func GetGrafanaURL(opt TestOptions) string

func GetIgnoreMetricMap 

func GetIgnoreMetricMap() map[string]bool

func GetKubeClientDynamic 

func GetKubeClientDynamic(opt TestOptions, isHub bool) dynamic.Interface

func GetKubeVersion 

func GetKubeVersion(client *rest.RESTClient) version.Info

func GetMCOAddonSpecMetrics 

func GetMCOAddonSpecMetrics(opt TestOptions) (bool, error)

func GetMCOAddonSpecResources 

func GetMCOAddonSpecResources(opt TestOptions) (map[string]interface{}, error)

func GetManagedClusterName 

func GetManagedClusterName(opt TestOptions) string

func GetNamespace 

func GetNamespace(opt TestOptions, isHub bool, namespace string) (error, *v1.Namespace)

func GetPodList 

func GetPodList(opt TestOptions, isHub bool, namespace string, labelSelector string) (error, *v1.PodList)

func GetPodLogs 

func GetPodLogs(
	opt TestOptions,
	isHub bool,
	namespace, podName, containerName string,
	previous bool,
	tailLines int64,
) (string, error)

func GetPullSecret 

func GetPullSecret(opt TestOptions) (string, error)

GetPullSecret checks the secret from MCH CR and return the secret name

func GetRouterCA 

func GetRouterCA(cli kubernetes.Interface) ([]byte, error)

func GetSAWithLabel 

func GetSAWithLabel(opt TestOptions, isHub bool, label string,
	namespace string) (*v1.ServiceAccountList, error)

func GetStatefulSet 

func GetStatefulSet(opt TestOptions, isHub bool, name string,
	namespace string) (*appv1.StatefulSet, error)

func GetStatefulSetWithLabel 

func GetStatefulSetWithLabel(opt TestOptions, isHub bool, label string,
	namespace string) (*appv1.StatefulSetList, error)

func HaveCRDs 

func HaveCRDs(c Cluster, kubeconfig string, expectedCRDs []string) error

func HaveDeploymentsInNamespace 

func HaveDeploymentsInNamespace(
	c Cluster,
	kubeconfig string,
	namespace string,
	expectedDeploymentNames []string,
) error

func HaveServerResources 

func HaveServerResources(c Cluster, kubeconfig string, expectedAPIGroups []string) error

func IntegrityChecking 

func IntegrityChecking(opt TestOptions) error

IntegrityChecking checks to ensure all required conditions are met when completing the specs

func IsOpenshift 

func IsOpenshift(client *rest.RESTClient) bool

func ListKSManagedClusterNames 

func ListKSManagedClusterNames(opt TestOptions) ([]string, error)

func ListManagedClusters 

func ListManagedClusters(opt TestOptions) ([]string, error)

func ListOCPManagedClusterIDs 

func ListOCPManagedClusterIDs(opt TestOptions, minVersionStr string) ([]string, error)

func LoadConfig 

func LoadConfig(url, kubeconfig, ctx string) (*rest.Config, error)

func LogPodsDebugInfo 

func LogPodsDebugInfo(hubClient kubernetes.Interface, pods []corev1.Pod, force bool)

func ModifyMCOAddonSpecInterval 

func ModifyMCOAddonSpecInterval(opt TestOptions, interval int64) error

func ModifyMCOAddonSpecMetrics 

func ModifyMCOAddonSpecMetrics(opt TestOptions, enable bool) error

func ModifyMCOAvailabilityConfig 

func ModifyMCOAvailabilityConfig(opt TestOptions, availabilityConfig string) error

func ModifyMCOCR 

func ModifyMCOCR(opt TestOptions) error

ModifyMCOCR modifies the MCO CR for reconciling. modify multiple parameter to save running time

func ModifyMCORetentionResolutionRaw 

func ModifyMCORetentionResolutionRaw(opt TestOptions) error

func NewKubeClient 

func NewKubeClient(url, kubeconfig, ctx string) kubernetes.Interface

func NewKubeClientAPIExtension 

func NewKubeClientAPIExtension(url, kubeconfig, ctx string) apiextensionsclientset.Interface

func NewKubeClientDynamic 

func NewKubeClientDynamic(url, kubeconfig, ctx string) dynamic.Interface

func NewMCOAddonGVR 

func NewMCOAddonGVR() schema.GroupVersionResource

func NewMCOClusterManagementAddonsGVR 

func NewMCOClusterManagementAddonsGVR() schema.GroupVersionResource

func NewMCOGVRV1BETA1 

func NewMCOGVRV1BETA1() schema.GroupVersionResource

func NewMCOGVRV1BETA2 

func NewMCOGVRV1BETA2() schema.GroupVersionResource

func NewMCOMObservatoriumGVR 

func NewMCOMObservatoriumGVR() schema.GroupVersionResource

func NewMCOManagedClusterAddonsGVR 

func NewMCOManagedClusterAddonsGVR() schema.GroupVersionResource

func NewOCMManagedClustersGVR 

func NewOCMManagedClustersGVR() schema.GroupVersionResource

func NewOCMManifestworksGVR 

func NewOCMManifestworksGVR() schema.GroupVersionResource

func NewOCMMultiClusterHubGVR 

func NewOCMMultiClusterHubGVR() schema.GroupVersionResource

func NewUnversionedRestClient 

func NewUnversionedRestClient(url, kubeconfig, ctx string) *rest.RESTClient

func PrintAllMCOPodsStatus 

func PrintAllMCOPodsStatus(opt TestOptions)

func PrintAllOBAPodsStatus 

func PrintAllOBAPodsStatus(opt TestOptions)

func PrintMCOObject 

func PrintMCOObject(opt TestOptions)

func PrintManagedClusterOBAObject 

func PrintManagedClusterOBAObject(opt TestOptions)

func ReadImageManifestConfigMap 

func ReadImageManifestConfigMap(c kubernetes.Interface) (map[string]string, error)

ReadImageManifestConfigMap reads configmap with the label ocm-configmap-type=image-manifest.

func RevertMCOCRModification 

func RevertMCOCRModification(opt TestOptions) error

RevertMCOCRModification revert the previous changes

func StatusContainsTypeEqualTo 

func StatusContainsTypeEqualTo(u *unstructured.Unstructured, typeString string) bool

StatusContainsTypeEqualTo check if u contains a condition type with value typeString

func UninstallMCO 

func UninstallMCO(opt TestOptions) error

func UpdateCRB 

func UpdateCRB(opt TestOptions, isHub bool, name string,
	crb *rbacv1.ClusterRoleBinding) (error, *rbacv1.ClusterRoleBinding)

func UpdateDeployment 

func UpdateDeployment(
	opt TestOptions,
	isHub bool,
	name string,
	namespace string,
	dep *appv1.Deployment) (*appv1.Deployment, error)

func UpdateDeploymentReplicas 

func UpdateDeploymentReplicas(
	opt TestOptions,
	deployName, crProperty string,
	desiredReplicas, expectedReplicas int32,
) error

func UpdateObservabilityFromManagedCluster 

func UpdateObservabilityFromManagedCluster(opt TestOptions, enableObservability bool) error

func UpdateSA 

func UpdateSA(opt TestOptions, isHub bool, namespace string,
	sa *v1.ServiceAccount) (error, *v1.ServiceAccount)

Types

type APIKeys 

type APIKeys struct {
	AWS   AWSAPIKey   `yaml:"aws,omitempty"`
	GCP   GCPAPIKey   `yaml:"gcp,omitempty"`
	Azure AzureAPIKey `yaml:"azure,omitempty"`
}

type AWSAPIKey 

type AWSAPIKey struct {
	AWSAccessID     string `yaml:"awsAccessKeyID"`
	AWSAccessSecret string `yaml:"awsSecretAccessKeyID"`
	BaseDnsDomain   string `yaml:"baseDnsDomain"`
	Region          string `yaml:"region"`
}

type AzureAPIKey 

type AzureAPIKey struct {
	BaseDnsDomain  string `yaml:"baseDnsDomain"`
	BaseDomainRGN  string `yaml:"azureBaseDomainRGN"`
	Region         string `yaml:"region"`
	SubscriptionID string `yaml:"subscriptionID"`
	TenantID       string `yaml:"tenantID"`
	ClientID       string `yaml:"clientID"`
	ClientSecret   string `yaml:"clientSecret"`
}

type Baremetal 

type Baremetal struct {
	ExternalBridge               string `yaml:"externalBridge,omitempty"`
	ProvisioningBridge           string `yaml:"provisioningBridge,omitempty"`
	LibvirtURI                   string `yaml:"libvirtURI,omitempty"`
	ProvisioningNetworkInterface string `yaml:"provisioningNetworkInterface,omitempty"`
	ProvisioningNetworkCIDR      string `yaml:"provisioningNetworkCIDR,omitempty"`
	APIVIP                       string `yaml:"apiVIP,omitempty"`
	DNSVIP                       string `yaml:"dnsVIP,omitempty"`
	IngressVIP                   string `yaml:"ingressVIP,omitempty"`
	Hosts                        []Host `yaml:"hosts,omitempty"`
	SSHKnownHosts                string `yaml:"sshKnownHosts,omitempty"`
}

Baremetal specs for target baremetal provisioning.

type Bmc 

type Bmc struct {
	Address  string `yaml:"address"`
	Username string `yaml:"username"`
	Password string `yaml:"password"`
}

Bmc definition.

type CloudConnection 

type CloudConnection struct {
	PullSecret    string  `yaml:"pullSecret"`
	SSHPrivateKey string  `yaml:"sshPrivatekey"`
	SSHPublicKey  string  `yaml:"sshPublickey"`
	Keys          APIKeys `yaml:"apiKeys,omitempty"`
	OCPRelease    string  `yaml:"ocpRelease,omitempty"`
}

CloudConnection struct for bits having to do with Connections

type Cluster 

type Cluster struct {
	Name             string          `yaml:"name,omitempty"`
	Namespace        string          `yaml:"namespace,omitempty"`
	Tags             map[string]bool `yaml:"tags,omitempty"`
	BaseDomain       string          `yaml:"baseDomain"`
	User             string          `yaml:"user,omitempty"`
	Password         string          `yaml:"password,omitempty"`
	KubeContext      string          `yaml:"kubecontext,omitempty"`
	ClusterServerURL string          `yaml:"clusterServerURL,omitempty"`
	GrafanaURL       string          `yaml:"grafanaURL,omitempty"`
	GrafanaHost      string          `yaml:"grafanaHost,omitempty"`
	KubeConfig       string          `yaml:"kubeconfig,omitempty"`
}

Define the shape of clusters that may be added under management

func GetCluster 

func GetCluster(tag string, clusters []Cluster) *Cluster

GetCluster returns the first cluster with a given tag

func GetClusters 

func GetClusters(tag string, clusters []Cluster) []*Cluster

GetClusters returns all clusters with a given tag

type ClusterDeploy 

type ClusterDeploy struct {
	Kind       string  `yaml:"kind"`
	APIVersion string  `yaml:"apiVersion"`
	Items      []Items `yaml:"items"`
}

ClusterDeploy defines the data passed to Hive.

type CollectRule 

type CollectRule struct {
	Collect     string            `yaml:"collect"`
	Annotations map[string]string `yaml:"annotations"`
	Expr        string            `yaml:"expr"`
	For         string            `yaml:"for"`
	Metrics     DynamicMetrics    `yaml:"dynamic_metrics"`
}

type CollectRuleGroup 

type CollectRuleGroup struct {
	Name            string              `yaml:"group"`
	Annotations     map[string]string   `yaml:"annotations"`
	Selector        CollectRuleSelector `yaml:"selector"`
	CollectRuleList []CollectRule       `yaml:"rules"`
}

CollectRuleGroup structure contains information of a group of collect rules used for dnamically collecting metrics.

type CollectRuleSelector 

type CollectRuleSelector struct {
	MatchExpression []metav1.LabelSelectorRequirement `yaml:"matchExpressions"`
}

type DynamicMetrics 

type DynamicMetrics struct {
	NameList  []string `yaml:"names"`
	MatchList []string `yaml:"matches"`
}

type GCPAPIKey 

type GCPAPIKey struct {
	ProjectID             string `yaml:"gcpProjectID"`
	ServiceAccountJsonKey string `yaml:"gcpServiceAccountJsonKey"`
	BaseDnsDomain         string `yaml:"baseDnsDomain"`
	Region                string `yaml:"region"`
}

type Host 

type Host struct {
	Name            string `yaml:"name"`
	Role            string `yaml:"role"`
	Bmc             Bmc    `yaml:"bmc"`
	BootMACAddress  string `yaml:"bootMACAddress"`
	HardwareProfile string `yaml:"hardwareProfile"`
}

Host is an array of baremetal assets.

type InstallConfig 

type InstallConfig struct {
	BaseDomain string     `yaml:"baseDomain,omitempty"`
	Networking Networking `yaml:"networking,omitempty"`
	Metadata   Metadata   `yaml:"metadata"`
	Platform   Platform   `yaml:"platform,omitempty"`
	PullSecret string     `yaml:"pullSecret,omitempty"`
	SSHKey     string     `yaml:"sshKey,omitempty"`
}

InstallConfig definition for install config structure from install-config.yaml.

type Items 

type Items struct {
	Kind       string     `yaml:"kind"`
	Metadata   Metadata   `yaml:"metadata"`
	StringData StringData `yaml:"stringData,omitempty"`
	Spec       Spec       `yaml:"spec,omitempty"`
}

Items defines the list of items in the cluster deploy yaml.

type Metadata 

type Metadata struct {
	Name string `yaml:"name,omitempty"`
}

Metadata defines the name.

type MetricsAllowlist 

type MetricsAllowlist struct {
	NameList             []string           `yaml:"names"`
	MatchList            []string           `yaml:"matches"`
	RenameMap            map[string]string  `yaml:"renames"`
	RuleList             []RecordingRule    `yaml:"rules"` //deprecated
	RecordingRuleList    []RecordingRule    `yaml:"recording_rules"`
	CollectRuleGroupList []CollectRuleGroup `yaml:"collect_rules"`
}

type Networking 

type Networking struct {
	NetworkType string `yaml:"networkType"`
	MachineCIDR string `yaml:"machineCIDR"`
}

Networking definition.

type Platform 

type Platform struct {
	Baremetal Baremetal `yaml:"baremetal,omitempty"`
}

Platform definition.

type Provisioning 

type Provisioning struct {
	ReleaseImage  string   `yaml:"releaseImage,omitempty"`
	SSHKnownHosts []string `yaml:"sshKnownHosts,omitempty"`
}

Provisioning defines the data related to cluster creation.

type RecordingRule 

type RecordingRule struct {
	Record string `yaml:"record"`
	Expr   string `yaml:"expr"`
}

type Registry 

type Registry struct {
	// example: quay.io/stolostron
	Server   string `yaml:"server"`
	User     string `yaml:"user"`
	Password string `yaml:"password"`
}

Define the image registry

type Spec 

type Spec struct {
	BaseDomain   string       `yaml:"baseDomain,omitempty"`
	ClusterName  string       `yaml:"clusterName,omitempty"`
	Provisioning Provisioning `yaml:"provisioning,omitempty"`
}

Spec defines the kube specifications.

type StringData 

type StringData struct {
	Dockerconfigjson string `yaml:".dockerconfigjson,omitempty"`
	SSHPrivateKey    string `yaml:"ssh-privatekey,omitempty"`
}

StringData defiines the ssh values.

type TestOptions 

type TestOptions struct {
	HubCluster      Cluster         `yaml:"hub"`
	ManagedClusters []Cluster       `yaml:"clusters"`
	ImageRegistry   Registry        `yaml:"imageRegistry,omitempty"`
	KubeConfig      string          `yaml:"kubeconfig,omitempty"`
	Connection      CloudConnection `yaml:"cloudConnection,omitempty"`
	Headless        string          `yaml:"headless,omitempty"`
	OwnerPrefix     string          `yaml:"ownerPrefix,omitempty"`
}

Define options available for Tests to consume

type TestOptionsContainer 

type TestOptionsContainer struct {
	Options TestOptions `yaml:"options"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.