multicluster

package
v1.7.0 Latest Latest
Warning

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

Go to latest
Published: Oct 13, 2023 License: UPL-1.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DeployAppResource

func DeployAppResource(appConfiguration, testNamespace, kubeConfig string) error

DeployAppResource deploys the OAM Application resource to the cluster with the given kubeConfig

func DeployCompResource

func DeployCompResource(compConfiguration, testNamespace, kubeConfig string) error

DeployCompResource deploys the OAM Component resource to the cluster with the given kubeConfig

func DeployVerrazzanoProject

func DeployVerrazzanoProject(projectConfiguration, kubeConfig string) error

DeployVerrazzanoProject deploys the VerrazzanoProject to the cluster with the given kubeConfig

func TestNamespaceExists

func TestNamespaceExists(kubeConfig string, namespace string) bool

TestNamespaceExists returns true if the test namespace exists in the given cluster

func VerifyAppResourcesInCluster

func VerifyAppResourcesInCluster(kubeConfig string, isAdminCluster bool, placedInThisCluster bool, projectName string, namespace string, appPods []string) (bool, error)

VerifyAppResourcesInCluster verifies that the app resources are either present or absent depending on whether the app is placed in this cluster

func VerifyDeleteOnAdminCluster

func VerifyDeleteOnAdminCluster(kubeConfig string, placedInCluster bool, namespace string, projectName string, appConfigName string, appPods []string) bool

VerifyDeleteOnAdminCluster verifies that the app resources have been deleted from the admin cluster after the application has been deleted

func VerifyDeleteOnManagedCluster

func VerifyDeleteOnManagedCluster(kubeConfig string, namespace string, projectName string, appConfigName string, appPods []string) bool

VerifyDeleteOnManagedCluster verifies that the app resources have been deleted from the managed cluster after the application has been deleted

func VerifyMCResources

func VerifyMCResources(kubeConfig string, isAdminCluster bool, placedInThisCluster bool, namespace string, appConfigName string, expectedComps []string) bool

VerifyMCResources verifies that the MC resources are present or absent depending on whether this is an admin cluster and whether the resources are placed in the given cluster

Types

type Cluster added in v1.4.0

type Cluster struct {
	Name           string
	KubeConfigPath string
	// contains filtered or unexported fields
}

func AdminCluster added in v1.4.0

func AdminCluster() *Cluster

func ManagedClusters added in v1.4.0

func ManagedClusters() []*Cluster

func (*Cluster) Apply added in v1.5.0

func (c *Cluster) Apply(data []byte)

func (*Cluster) ConfigAdminCluster added in v1.4.0

func (c *Cluster) ConfigAdminCluster() error

func (*Cluster) CreateCaSecOf added in v1.4.0

func (c *Cluster) CreateCaSecOf(managed *Cluster) error

func (*Cluster) CreateNamespace added in v1.4.0

func (c *Cluster) CreateNamespace(ns string) error

func (*Cluster) FindFluentdPod added in v1.4.0

func (c *Cluster) FindFluentdPod() *corev1.Pod

func (*Cluster) FluentdLogs added in v1.4.0

func (c *Cluster) FluentdLogs(lines int64, restartedAfter time.Time) string

FluentdLogs gets fluentd logs if the fluentd pod has been restarted sinc the time specified

func (*Cluster) GenerateCA added in v1.4.0

func (c *Cluster) GenerateCA() string

generate a custom CA

func (*Cluster) GetCR added in v1.4.0

func (c *Cluster) GetCR(waitForReady bool) *vzapi.Verrazzano

GetCR gets the CR. If it is not "Ready", wait for up to 10 minutes for it to be "Ready".

func (*Cluster) GetManifest added in v1.4.0

func (c *Cluster) GetManifest(name string) ([]byte, error)

func (*Cluster) GetPrometheusIngress added in v1.4.0

func (c *Cluster) GetPrometheusIngress() string

func (*Cluster) GetQueryIngress added in v1.6.0

func (c *Cluster) GetQueryIngress() string

func (*Cluster) GetRegistration added in v1.4.0

func (c *Cluster) GetRegistration(name string) (*corev1.Secret, error)

func (*Cluster) GetSecret added in v1.4.0

func (c *Cluster) GetSecret(ns, name string) (*corev1.Secret, error)

func (*Cluster) GetSecretData added in v1.4.0

func (c *Cluster) GetSecretData(ns, name, key string) ([]byte, error)

func (*Cluster) GetSecretDataAsString added in v1.4.0

func (c *Cluster) GetSecretDataAsString(ns, name, key string) string

func (*Cluster) GetThanosIngress added in v1.6.0

func (c *Cluster) GetThanosIngress() string

func (*Cluster) GetVMC added in v1.5.0

func (c *Cluster) GetVMC(name string) (*mcapi.VerrazzanoManagedCluster, error)

func (*Cluster) PodLogs added in v1.4.0

func (c *Cluster) PodLogs(ns, podName, container string, lines int64) string

func (*Cluster) Register added in v1.4.0

func (c *Cluster) Register(managed *Cluster) error

func (*Cluster) UpsertCaSec added in v1.4.0

func (c *Cluster) UpsertCaSec(managedClusterName string, bytes []byte) error

func (*Cluster) UpsertManagedCluster added in v1.4.0

func (c *Cluster) UpsertManagedCluster(name string) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL