multicluster

Documentation

Index

• func DeployAppResource(appConfiguration, testNamespace, kubeConfig string) error
• func DeployCompResource(compConfiguration, testNamespace, kubeConfig string) error
• func DeployVerrazzanoProject(projectConfiguration, kubeConfig string) error
• func TestNamespaceExists(kubeConfig string, namespace string) bool
• func VerifyAppResourcesInCluster(kubeConfig string, isAdminCluster bool, placedInThisCluster bool, ...) (bool, error)
• func VerifyDeleteOnAdminCluster(kubeConfig string, placedInCluster bool, namespace string, projectName string, ...) bool
• func VerifyDeleteOnManagedCluster(kubeConfig string, namespace string, projectName string, appConfigName string, ...) bool
• func VerifyMCResources(kubeConfig string, isAdminCluster bool, placedInThisCluster bool, ...) bool
• type Cluster
  • func AdminCluster() *Cluster
  • func ManagedClusters() []*Cluster
  • func (c *Cluster) Apply(data []byte)
  • func (c *Cluster) ConfigAdminCluster() error
  • func (c *Cluster) CreateCaSecOf(managed *Cluster) error
  • func (c *Cluster) CreateNamespace(ns string) error
  • func (c *Cluster) FindFluentdPod() *corev1.Pod
  • func (c *Cluster) FluentdLogs(lines int64, restartedAfter time.Time) string
  • func (c *Cluster) GenerateCA() string
  • func (c *Cluster) GetCR(waitForReady bool) *vzapi.Verrazzano
  • func (c *Cluster) GetManifest(name string) ([]byte, error)
  • func (c *Cluster) GetPrometheusIngress() string
  • func (c *Cluster) GetRegistration(name string) (*corev1.Secret, error)
  • func (c *Cluster) GetSecret(ns, name string) (*corev1.Secret, error)
  • func (c *Cluster) GetSecretData(ns, name, key string) ([]byte, error)
  • func (c *Cluster) GetSecretDataAsString(ns, name, key string) string
  • func (c *Cluster) GetVMC(name string) (*mcapi.VerrazzanoManagedCluster, error)
  • func (c *Cluster) PodLogs(ns, podName, container string, lines int64) string
  • func (c *Cluster) Register(managed *Cluster) error
  • func (c *Cluster) UpsertCaSec(managedClusterName string, bytes []byte) error
  • func (c *Cluster) UpsertManagedCluster(name string) error

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

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

func AdminCluster

func AdminCluster() *Cluster

func ManagedClusters

func ManagedClusters() []*Cluster

func (*Cluster) Apply

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

func (*Cluster) ConfigAdminCluster

func (c *Cluster) ConfigAdminCluster() error

func (*Cluster) CreateCaSecOf

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

func (*Cluster) CreateNamespace

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

func (*Cluster) FindFluentdPod

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

func (*Cluster) FluentdLogs

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

func (c *Cluster) GenerateCA() string

generate a custom CA

func (*Cluster) GetCR

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

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

func (*Cluster) GetManifest

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

func (*Cluster) GetPrometheusIngress

func (c *Cluster) GetPrometheusIngress() string

func (*Cluster) GetRegistration

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

func (*Cluster) GetSecret

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

func (*Cluster) GetSecretData

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

func (*Cluster) GetSecretDataAsString

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

func (*Cluster) GetVMC

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

func (*Cluster) PodLogs

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

func (*Cluster) Register

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

func (*Cluster) UpsertCaSec

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

func (*Cluster) UpsertManagedCluster

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