framework

Documentation

Index

• Constants
• func IsK8sClustersStarted() bool
• type Cluster
• type Clusters
  • func NewK8sClusters(clusterNames []string, verbose bool) (Clusters, error)
• type K8sCluster
  • func (c *K8sCluster) Apply(namespace string, yamlPath string) error
  • func (c *K8sCluster) ApplyAndWaitServiceOnK8sCluster(namespace string, service string, yamlPath string) error
  • func (c *K8sCluster) CleanupPortForwards()
  • func (c *K8sCluster) DeleteKuma() error
  • func (c *K8sCluster) DeleteKumaNamespace() error
  • func (c *K8sCluster) DeployKuma(mode ...string) error
  • func (c *K8sCluster) GetKubectlOptions(namespace ...string) *k8s.KubectlOptions
  • func (c *K8sCluster) GetKumaCPLogs() (string, error)
  • func (c *K8sCluster) GetKumaCPPods() []v1.Pod
  • func (c *K8sCluster) GetPodLogs(pod v1.Pod) (string, error)
  • func (c *K8sCluster) GetTesting() testing.TestingT
  • func (c *K8sCluster) LabelNamespaceForSidecarInjection(namespace string) error
  • func (c *K8sCluster) PortForwardKumaCP() uint32
  • func (c *K8sCluster) PortForwardPod(namespace string, podName string, localPort, remotePort uint32)
  • func (c *K8sCluster) VerifyKuma() error
  • func (c *K8sCluster) VerifyKumaCtl() error
  • func (c *K8sCluster) VerifyKumaREST() error
  • func (c *K8sCluster) WaitKumaNamespaceDelete()
• type K8sClusters
  • func (cs *K8sClusters) DeleteKuma() error
  • func (cs *K8sClusters) DeployKuma(mode ...string) error
  • func (cs *K8sClusters) GetCluster(name string) Cluster
  • func (cs *K8sClusters) GetKubectlOptions(namespace ...string) *k8s.KubectlOptions
  • func (cs *K8sClusters) GetKumaCPLogs() (string, error)
  • func (cs *K8sClusters) GetTesting() testing.TestingT
  • func (cs *K8sClusters) LabelNamespaceForSidecarInjection(namespace string) error
  • func (cs *K8sClusters) VerifyKuma() error
• type KumactlOptions
  • func NewKumactlOptions(t testing.TestingT, cpname string, verbose bool) (*KumactlOptions, error)
  • func (o *KumactlOptions) KumactlApply(configPath string) error
  • func (o *KumactlOptions) KumactlApplyFromString(configData string) error
  • func (o *KumactlOptions) KumactlConfigControlPlanesAdd(name, address string) error
  • func (o *KumactlOptions) KumactlDelete(kumatype string, name string) error
  • func (o *KumactlOptions) KumactlInstallCP(mode ...string) (string, error)
  • func (o *KumactlOptions) KumactlInstallMetrics() (string, error)
  • func (o *KumactlOptions) KumactlInstallTracing() (string, error)
  • func (o *KumactlOptions) RunKumactl(args ...string) error
  • func (o *KumactlOptions) RunKumactlAndGetOutput(args ...string) (string, error)
  • func (o *KumactlOptions) RunKumactlAndGetOutputV(verbose bool, args ...string) (string, error)
• type TestingT
  • func NewTestingT() *TestingT
  • func (i *TestingT) Helper()
  • func (i *TestingT) Name() string

Constants

const (
	Verbose = true
	Silent  = false

	Kuma1 = "kuma-1"
	Kuma2 = "kuma-2"
	Kuma3 = "kuma-3"
)

Functions

func IsK8sClustersStarted

func IsK8sClustersStarted() bool

Types

type Cluster

type Cluster interface {
	DeployKuma(mode ...string) error
	VerifyKuma() error
	GetKumaCPLogs() (string, error)
	DeleteKuma() error

	// K8s
	GetKubectlOptions(namespace ...string) *k8s.KubectlOptions
	LabelNamespaceForSidecarInjection(namespace string) error

	// Testing
	GetTesting() testing.TestingT
}

type Clusters

type Clusters interface {
	GetCluster(name string) Cluster
	Cluster
}

func NewK8sClusters

func NewK8sClusters(clusterNames []string, verbose bool) (Clusters, error)

type K8sCluster

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

func (*K8sCluster) Apply

func (c *K8sCluster) Apply(namespace string, yamlPath string) error

func (*K8sCluster) ApplyAndWaitServiceOnK8sCluster

func (c *K8sCluster) ApplyAndWaitServiceOnK8sCluster(namespace string, service string, yamlPath string) error

func (*K8sCluster) CleanupPortForwards

func (c *K8sCluster) CleanupPortForwards()

func (*K8sCluster) DeleteKuma

func (c *K8sCluster) DeleteKuma() error

func (*K8sCluster) DeleteKumaNamespace

func (c *K8sCluster) DeleteKumaNamespace() error

func (*K8sCluster) DeployKuma

func (c *K8sCluster) DeployKuma(mode ...string) error

func (*K8sCluster) GetKubectlOptions

func (c *K8sCluster) GetKubectlOptions(namespace ...string) *k8s.KubectlOptions

func (*K8sCluster) GetKumaCPLogs

func (c *K8sCluster) GetKumaCPLogs() (string, error)

func (*K8sCluster) GetKumaCPPods

func (c *K8sCluster) GetKumaCPPods() []v1.Pod

func (*K8sCluster) GetPodLogs

func (c *K8sCluster) GetPodLogs(pod v1.Pod) (string, error)

func (*K8sCluster) GetTesting

func (c *K8sCluster) GetTesting() testing.TestingT

func (*K8sCluster) LabelNamespaceForSidecarInjection

func (c *K8sCluster) LabelNamespaceForSidecarInjection(namespace string) error

func (*K8sCluster) PortForwardKumaCP

func (c *K8sCluster) PortForwardKumaCP() uint32

func (*K8sCluster) PortForwardPod

func (c *K8sCluster) PortForwardPod(namespace string, podName string, localPort, remotePort uint32)

func (*K8sCluster) VerifyKuma

func (c *K8sCluster) VerifyKuma() error

func (*K8sCluster) VerifyKumaCtl

func (c *K8sCluster) VerifyKumaCtl() error

func (*K8sCluster) VerifyKumaREST

func (c *K8sCluster) VerifyKumaREST() error

func (*K8sCluster) WaitKumaNamespaceDelete

func (c *K8sCluster) WaitKumaNamespaceDelete()

type K8sClusters

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

func (*K8sClusters) DeleteKuma

func (cs *K8sClusters) DeleteKuma() error

func (*K8sClusters) DeployKuma

func (cs *K8sClusters) DeployKuma(mode ...string) error

func (*K8sClusters) GetCluster

func (cs *K8sClusters) GetCluster(name string) Cluster

func (*K8sClusters) GetKubectlOptions

func (cs *K8sClusters) GetKubectlOptions(namespace ...string) *k8s.KubectlOptions

func (*K8sClusters) GetKumaCPLogs

func (cs *K8sClusters) GetKumaCPLogs() (string, error)

func (*K8sClusters) GetTesting

func (cs *K8sClusters) GetTesting() testing.TestingT

func (*K8sClusters) LabelNamespaceForSidecarInjection

func (cs *K8sClusters) LabelNamespaceForSidecarInjection(namespace string) error

func (*K8sClusters) VerifyKuma

func (cs *K8sClusters) VerifyKuma() error

type KumactlOptions

type KumactlOptions struct {
	CPName     string
	Kumactl    string
	ConfigPath string
	Verbose    bool
	// contains filtered or unexported fields
}

func NewKumactlOptions

func NewKumactlOptions(t testing.TestingT, cpname string, verbose bool) (*KumactlOptions, error)

func (*KumactlOptions) KumactlApply

func (o *KumactlOptions) KumactlApply(configPath string) error

func (*KumactlOptions) KumactlApplyFromString

func (o *KumactlOptions) KumactlApplyFromString(configData string) error

func (*KumactlOptions) KumactlConfigControlPlanesAdd

func (o *KumactlOptions) KumactlConfigControlPlanesAdd(name, address string) error

func (*KumactlOptions) KumactlDelete

func (o *KumactlOptions) KumactlDelete(kumatype string, name string) error

func (*KumactlOptions) KumactlInstallCP

func (o *KumactlOptions) KumactlInstallCP(mode ...string) (string, error)

func (*KumactlOptions) KumactlInstallMetrics

func (o *KumactlOptions) KumactlInstallMetrics() (string, error)

func (*KumactlOptions) KumactlInstallTracing

func (o *KumactlOptions) KumactlInstallTracing() (string, error)

func (*KumactlOptions) RunKumactl

func (o *KumactlOptions) RunKumactl(args ...string) error

func (*KumactlOptions) RunKumactlAndGetOutput

func (o *KumactlOptions) RunKumactlAndGetOutput(args ...string) (string, error)

func (*KumactlOptions) RunKumactlAndGetOutputV

func (o *KumactlOptions) RunKumactlAndGetOutputV(verbose bool, args ...string) (string, error)

type TestingT

type TestingT struct {
	ginkgo.GinkgoTInterface
	// contains filtered or unexported fields
}

func NewTestingT

func NewTestingT() *TestingT

func (*TestingT) Helper

func (i *TestingT) Helper()

func (*TestingT) Name

func (i *TestingT) Name() string