framework

package
v0.0.0-...-4760111 Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2020 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Verbose = true
	Silent  = false

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

Variables

This section is empty.

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

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.