framework

package

Go to main page

Versions in this module

v1

v1.8.1

Oct 5, 2022

Changes in this version

+ const AppEgress

+ const ZoneEgress

+ var Serializer *k8sjson.Serializer

+ func DeleteAllResourcesUniversal(kumactl KumactlOptions, descriptor core_model.ResourceTypeDescriptor, ...) error

+ func DumpTempCerts(names ...string) (string, error)

+ func E2EAfterAll(fn func()) bool

+ func E2EDeferCleanup(args ...interface{})

+ func GetPublishedDockerPorts(t testing.TestingT, container string, ports []uint32) (map[uint32]uint32, error)

+ func IsDataplaneOnline(cluster Cluster, mesh, name string) (bool, bool, error)

+ func Logf(format string, args ...interface{})

+ func PodIPOfApp(cluster Cluster, name string, namespace string) (string, error)

+ func PodNameOfApp(cluster Cluster, name string, namespace string) (string, error)

+ func WaitForMesh(mesh string, clusters []Cluster) error

+ func WaitForResource(cluster Cluster, descriptor core_model.ResourceTypeDescriptor, ...) error

+ type AppDeploymentOption interface

+ ApplyApp func(*appDeploymentOptions)

+ func BoundToContainerIp() AppDeploymentOption

+ func WithAppendDataplaneYaml(config string) AppDeploymentOption

+ func WithConcurrency(concurrency int) AppDeploymentOption

+ func WithDockerContainerName(name string) AppDeploymentOption

+ func WithDockerVolumes(volumes ...string) AppDeploymentOption

+ func WithKumactlFlow() AppDeploymentOption

+ func WithReachableServices(services ...string) AppDeploymentOption

+ func WithServiceAddress(serviceAddress string) AppDeploymentOption

+ func WithServiceInstance(instance string) AppDeploymentOption

+ func WithoutDataplane() AppDeploymentOption

+ type AppOptionFunc func(*appDeploymentOptions)

+ func (f AppOptionFunc) ApplyApp(opts *appDeploymentOptions)

+ type BlockingReader struct

+ func (*BlockingReader) Read([]byte) (int, error)

type Cluster

+ DeleteDeployment func(name string) error

+ GetKumaCPLogs func() (string, error)

+ GetZoneEgressEnvoyTunnel func() envoy_admin.Tunnel

+ GetZoneIngressEnvoyTunnel func() envoy_admin.Tunnel

+ Verbose func() bool

+ type CniConf struct

+ BinDir string

+ ConfName string

+ NetDir string

+ type CompatibilitySuiteConfig struct

+ HelmVersion string

type ControlPlane

+ GenerateZoneEgressToken func(zone string) (string, error)

+ GetAPIServerAddress func() string

+ GetGlobalStatusAPI func() string

+ GetMetrics func() (string, error)

+ type E2eConfig struct

+ Arch string

+ CIDR string

+ CNIApp string

+ CNIConf CniConf

+ CNINamespace string

+ DefaultClusterStartupRetries int

+ DefaultClusterStartupTimeout time.Duration

+ DefaultGatewayNamespace string

+ DefaultObservabilityNamespace string

+ HelmChartName string

+ HelmChartPath string

+ HelmGlobalExtraYaml string

+ HelmRepoUrl string

+ HelmSubChartPrefix string

+ IPV6 bool

+ K8sType K8sType

+ KumaCPImageRepo string

+ KumaDPImageRepo string

+ KumaGlobalZoneSyncServiceName string

+ KumaImageRegistry string

+ KumaImageTag string

+ KumaInitImageRepo string

+ KumaK8sCtlFlags map[string]string

+ KumaNamespace string

+ KumaServiceName string

+ KumaUniversalEnvVars map[string]string

+ KumaUniversalImageRepo string

+ KumaZoneK8sCtlFlags map[string]string

+ KumaZoneUniversalEnvVars map[string]string

+ KumactlBin string

+ SuiteConfig SuiteConfig

+ UseHostnameInsteadOfIP bool

+ UseLoadBalancer bool

+ XDSApiVersion string

+ ZoneEgressApp string

+ ZoneIngressApp string

+ var Config E2eConfig

+ func (c E2eConfig) AutoConfigure() error

+ func (c E2eConfig) GetUniversalImage() string

+ func (c E2eConfig) Sanitize()

+ func (c E2eConfig) Validate() error

type ExecOptions

+ Retries int

+ Timeout time.Duration

+ type GenericOption struct

+ App AppOptionFunc

+ Kuma KumaOptionFunc

+ func WithVerbose() *GenericOption

+ func (o *GenericOption) ApplyApp(opts *appDeploymentOptions)

+ func (o *GenericOption) ApplyKuma(opts *kumaDeploymentOptions)

+ type HelmSuiteConfig struct

+ Versions []string

type InstallFunc

+ func DemoClientK8sCustomized(mesh string, namespace string, deploymentYaml string) InstallFunc

+ func DemoClientK8sWithAffinity(mesh string, namespace string) InstallFunc

+ func EgressUniversal(tokenProvider func(zone string) (string, error)) InstallFunc

+ func GatewayProxyUniversal(mesh, name string) InstallFunc

+ func MTLSMeshKubernetes(name string) InstallFunc

+ func MTLSMeshUniversal(name string) InstallFunc

+ func MeshKubernetes(name string) InstallFunc

+ func MeshUniversal(name string) InstallFunc

+ func NamespaceWithSidecarInjection(namespace string) InstallFunc

+ func NamespaceWithSidecarInjectionOnAnnotation(namespace string) InstallFunc

+ func ResourceUniversal(resource model.Resource) InstallFunc

+ func TestServerExternalServiceUniversal(name string, mesh string, port int, tls bool) InstallFunc

+ func WaitUntilJobSucceed(namespace, app string) InstallFunc

+ func YamlK8sObject(obj runtime.Object) InstallFunc

type K8sCluster

+ func NewK8sCluster(t testing.TestingT, clusterName string, verbose bool) *K8sCluster

+ func (c *K8sCluster) AddPortForward(portForwards PortFwd, name string) error

+ func (c *K8sCluster) CreateNode(name string, label string) error

+ func (c *K8sCluster) DeleteDeployment(name string) error

+ func (c *K8sCluster) DeleteMesh(mesh string) error

+ func (c *K8sCluster) DeleteNode(name string) error

+ func (c *K8sCluster) DeleteNodeViaApi(node string) error

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

+ func (c *K8sCluster) GetZoneEgressEnvoyTunnel() envoy_admin.Tunnel

+ func (c *K8sCluster) GetZoneEgressPortForward() PortFwd

+ func (c *K8sCluster) GetZoneIngressEnvoyTunnel() envoy_admin.Tunnel

+ func (c *K8sCluster) GetZoneIngressPortForward() PortFwd

+ func (c *K8sCluster) Install(fn InstallFunc) error

+ func (c *K8sCluster) KillAppPod(app, namespace string) error

+ func (c *K8sCluster) LoadImages(names ...string) error

+ func (c *K8sCluster) RestartControlPlane() error

+ func (c *K8sCluster) SetCP(cp *K8sControlPlane)

+ func (c *K8sCluster) StartZoneEgress() error

+ func (c *K8sCluster) StartZoneIngress() error

+ func (c *K8sCluster) StopControlPlane() error

+ func (c *K8sCluster) StopZoneEgress() error

+ func (c *K8sCluster) StopZoneIngress() error

+ func (c *K8sCluster) TriggerDeleteNamespace(namespace string) error

+ func (c *K8sCluster) Verbose() bool

+ func (c *K8sCluster) WaitNodeDelete(node string) (string, error)

type K8sClusters

+ func (cs *K8sClusters) CreateNode(name string, label string) error

+ func (cs *K8sClusters) DeleteDeployment(deploymentName string) error

+ func (cs *K8sClusters) DeleteNode(name string) error

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

+ func (cs *K8sClusters) GetZoneEgressEnvoyTunnel() envoy_admin.Tunnel

+ func (cs *K8sClusters) GetZoneIngressEnvoyTunnel() envoy_admin.Tunnel

+ func (cs *K8sClusters) LoadImages(names ...string) error

+ func (cs *K8sClusters) Verbose() bool

type K8sControlPlane

+ func (c *K8sControlPlane) ClosePortForwards()

+ func (c *K8sControlPlane) FinalizeAddWithPortFwd(portFwd PortFwd) error

+ func (c *K8sControlPlane) GenerateZoneEgressToken(zone string) (string, error)

+ func (c *K8sControlPlane) GetAPIServerAddress() string

+ func (c *K8sControlPlane) GetGlobalStatusAPI() string

+ func (c *K8sControlPlane) GetMetrics() (string, error)

+ func (c *K8sControlPlane) PortFwd() PortFwd

+ func (c *K8sControlPlane) UpdateObject(typeName string, objectName string, ...) error

+ type K8sNetworkingState struct

+ KumaCp PortFwd

+ ZoneEgress PortFwd

+ ZoneIngress PortFwd

+ type K8sType string

+ const AwsK8sType

+ const AzureK8sType

+ const K3dCalicoK8sType

+ const K3dK8sType

+ const KindK8sType

+ type KumaDeploymentOption interface

+ ApplyKuma func(options *kumaDeploymentOptions)

+ func WithCtlOpts(opts map[string]string) KumaDeploymentOption

+ func WithEgress() KumaDeploymentOption

+ func WithEgressEnvoyAdminTunnel() KumaDeploymentOption

+ func WithEnvs(entries map[string]string) KumaDeploymentOption

+ func WithExperimentalCNI() KumaDeploymentOption

+ func WithIngressEnvoyAdminTunnel() KumaDeploymentOption

+ func WithMeshUpdate(mesh string, u MeshUpdateFunc) KumaDeploymentOption

+ type KumaOptionFunc func(options *kumaDeploymentOptions)

+ func (f KumaOptionFunc) ApplyKuma(opts *kumaDeploymentOptions)

type KumactlOptions

+ func (k *KumactlOptions) KumactlInstallObservability(namespace string, components []string) (string, error)

+ func (k *KumactlOptions) KumactlUpdateObject(typeName string, objectName string, ...) error

+ type MeshUpdateFunc func(mesh *mesh_proto.Mesh) *mesh_proto.Mesh

type PortFwd

+ ApiServerEndpoint string

+ type SuiteConfig struct

+ Compatibility CompatibilitySuiteConfig

+ Helm HelmSuiteConfig

type UniversalApp

+ func (s *UniversalApp) GetContainerName() string

+ func (s *UniversalApp) GetIP() string

type UniversalCluster

+ func (c *UniversalCluster) AddNetworking(networking UniversalNetworking, name string) error

+ func (c *UniversalCluster) CreateZoneEgress(app *UniversalApp, name, ip, dpYAML, token string, builtinDNS bool) error

+ func (c *UniversalCluster) DeleteDeployment(name string) error

+ func (c *UniversalCluster) DeleteMesh(mesh string) error

+ func (c *UniversalCluster) DeleteMeshApps(mesh string) error

+ func (c *UniversalCluster) ExecWithCustomRetries(namespace, podName, appname string, retries int, timeout time.Duration, ...) (string, string, error)

+ func (c *UniversalCluster) GetKumaCPLogs() (string, error)

+ func (c *UniversalCluster) GetZoneEgressEnvoyTunnel() envoy_admin.Tunnel

+ func (c *UniversalCluster) GetZoneEgressEnvoyTunnelE() (envoy_admin.Tunnel, error)

+ func (c *UniversalCluster) GetZoneEgressNetworking() UniversalNetworking

+ func (c *UniversalCluster) GetZoneIngressEnvoyTunnel() envoy_admin.Tunnel

+ func (c *UniversalCluster) GetZoneIngressEnvoyTunnelE() (envoy_admin.Tunnel, error)

+ func (c *UniversalCluster) GetZoneIngressNetworking() UniversalNetworking

+ func (c *UniversalCluster) Install(fn InstallFunc) error

+ func (c *UniversalCluster) SetCp(cp *UniversalControlPlane)

+ func (c *UniversalCluster) Verbose() bool

type UniversalClusters

+ func (cs *UniversalClusters) DeleteDeployment(deploymentName string) error

+ func (cs *UniversalClusters) GetKumaCPLogs() (string, error)

+ func (cs *UniversalClusters) GetZoneEgressEnvoyTunnel() envoy_admin.Tunnel

+ func (cs *UniversalClusters) GetZoneEgressEnvoyTunnelE() (envoy_admin.Tunnel, error)

+ func (cs *UniversalClusters) GetZoneIngressEnvoyTunnel() envoy_admin.Tunnel

+ func (cs *UniversalClusters) GetZoneIngressEnvoyTunnelE() (envoy_admin.Tunnel, error)

+ func (cs *UniversalClusters) Verbose() bool

type UniversalControlPlane

+ func (c *UniversalControlPlane) GenerateZoneEgressToken(zone string) (string, error)

+ func (c *UniversalControlPlane) GetAPIServerAddress() string

+ func (c *UniversalControlPlane) GetGlobalStatusAPI() string

+ func (c *UniversalControlPlane) GetMetrics() (string, error)

+ func (c *UniversalControlPlane) Networking() UniversalNetworking

+ func (c *UniversalControlPlane) UpdateObject(typeName string, objectName string, ...) error

+ type UniversalNetworking struct

+ ApiServerPort string

+ IP string

+ SshPort string

+ func (u UniversalNetworking) BootstrapAddress() string

+ type UniversalNetworkingState struct

+ KumaCp UniversalNetworking

+ ZoneEgress UniversalNetworking

+ ZoneIngress UniversalNetworking

v1.5.0-rc2

Feb 18, 2022

v1.2.1

Jun 30, 2021

Changes in this version

+ const AppIngress

+ const AppModeCP

+ const AppModeDemoClient

+ const AppModeEchoServer

+ const AppModeHttpsEchoServer

+ const DefaultRetries

+ const DefaultTimeout

+ const DemoClientDataplane

+ const DemoClientDataplaneTransparentProxy

+ const DemoClientDataplaneWithServiceProbe

+ const EchoServerDataplane

+ const EchoServerDataplaneTransparentProxy

+ const EchoServerDataplaneWithServiceProbe

+ const IngressDataplaneOldType

+ const Kuma1

+ const Kuma2

+ const Kuma3

+ const Kuma4

+ const Kuma5

+ const Kuma6

+ const KumaUniversalImage

+ const Silent

+ const TestNamespace

+ const Verbose

+ const ZoneIngress

+ var CNIApp = "kuma-cni"

+ var CNINamespace = "kube-system"

+ var HelmChartPath = "../../../deployments/charts/kuma"

+ var HelmInstallationMode = InstallationMode("helm")

+ var HelmRepo = "kuma/kuma"

+ var HelmSubChartPrefix = ""

+ var KumaCPImageRepo = "kuma-cp"

+ var KumaDPImageRepo = "kuma-dp"

+ var KumaGlobalZoneSyncServiceName = "kuma-global-zone-sync"

+ var KumaImageRegistry = "kumahq"

+ var KumaInitImageRepo = "kuma-init"

+ var KumaK8sDeployOpts []DeployOptionsFunc

+ var KumaNamespace = "kuma-system"

+ var KumaServiceName = "kuma-control-plane"

+ var KumaUniversalDeployOpts []DeployOptionsFunc

+ var KumaZoneK8sDeployOpts []DeployOptionsFunc

+ var KumactlInstallationMode = InstallationMode("kumactl")

+ func CreateCertsFor(names []string) (cert, key string, err error)

+ func E2EAfterEach(fn func())

+ func E2EAfterSuite(fn func())

+ func E2EBeforeSuite(fn func())

+ func GetApiVersion() string

+ func GetCniConfName() string

+ func GetCpImageRegistry() string

+ func GetDefaultRetries() int

+ func GetDefaultTimeout() time.Duration

+ func GetDpImageRegistry() string

+ func GetDpInitImageRegistry() string

+ func GetGlobalImageRegistry() string

+ func GetGlobalImageTag() string

+ func GetHelmChartPath() string

+ func GetKumactlBin() string

+ func GetUniversalImage() string

+ func HasApiVersion() bool

+ func HasCniConfName() bool

+ func HasCpImageRegistry() bool

+ func HasDpImageRegistry() bool

+ func HasDpInitImageRegistry() bool

+ func HasGlobalImageRegistry() bool

+ func HasGlobalImageTag() bool

+ func HasHelmChartPath() bool

+ func IsIPv6() bool

+ func IsInEKS() bool

+ func IsK8sClustersStarted() bool

+ func ShouldSkipCleanup() bool

+ func SshCmd(port string, env []string, args []string) *exec.Cmd

+ func UseLoadBalancer() bool

+ func WaitUntilPodCompleteE(t testing.TestingT, options *k8s.KubectlOptions, podName string, retries int, ...) error

+ type AppMode string

+ type Cluster interface

+ CreateNamespace func(namespace string) error

+ DeleteApp func(namespace, appname string) error

+ DeleteKuma func(opts ...DeployOptionsFunc) error

+ DeleteNamespace func(namespace string) error

+ Deploy func(deployment Deployment) error

+ DeployApp func(fs ...DeployOptionsFunc) error

+ DeployKuma func(mode string, opts ...DeployOptionsFunc) error

+ Deployment func(name string) Deployment

+ DismissCluster func() error

+ Exec func(namespace, podName, containerName string, cmd ...string) (string, string, error)

+ ExecWithRetries func(namespace, podName, containerName string, cmd ...string) (string, string, error)

+ GetKubectlOptions func(namespace ...string) *k8s.KubectlOptions

+ GetKuma func() ControlPlane

+ GetKumactlOptions func() *KumactlOptions

+ GetTesting func() testing.TestingT

+ InjectDNS func(namespace ...string) error

+ Name func() string

+ VerifyKuma func() error

+ WithRetries func(retries int) Cluster

+ WithTimeout func(timeout time.Duration) Cluster

+ func NewK8SCluster(t *TestingT, clusterName string, verbose bool) (Cluster, error)

+ func NewK8sClusterWithTimeout(t *TestingT, clusterName string, verbose bool, timeout time.Duration) (Cluster, error)

+ type ClusterSetup struct

+ func NewClusterSetup() *ClusterSetup

+ func (cs *ClusterSetup) Install(fn InstallFunc) *ClusterSetup

+ func (cs *ClusterSetup) Setup(cluster Cluster) error

+ type Clusters interface

+ GetCluster func(name string) Cluster

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

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

+ type ControlPlane interface

+ GenerateDpToken func(mesh, appname string) (string, error)

+ GenerateZoneIngressToken func(zone string) (string, error)

+ GetGlobaStatusAPI func() string

+ GetKDSServerAddress func() string

+ GetKumaCPLogs func() (string, error)

+ GetName func() string

+ type DeployOptionsFunc func(*deployOptions)

+ func ProxyOnly() DeployOptionsFunc

+ func ServiceProbe() DeployOptionsFunc

+ func WithAppname(appname string) DeployOptionsFunc

+ func WithArgs(appArgs []string) DeployOptionsFunc

+ func WithBuiltinDNS(builtindns bool) DeployOptionsFunc

+ func WithCNI() DeployOptionsFunc

+ func WithCPReplicas(cpReplicas int) DeployOptionsFunc

+ func WithCtlOpt(name, value string) DeployOptionsFunc

+ func WithDPVersion(version string) DeployOptionsFunc

+ func WithEnv(name, value string) DeployOptionsFunc

+ func WithGlobalAddress(address string) DeployOptionsFunc

+ func WithHDS(enabled bool) DeployOptionsFunc

+ func WithHelmChartPath(path string) DeployOptionsFunc

+ func WithHelmChartVersion(version string) DeployOptionsFunc

+ func WithHelmOpt(name, value string) DeployOptionsFunc

+ func WithHelmReleaseName(name string) DeployOptionsFunc

+ func WithIPv6(isipv6 bool) DeployOptionsFunc

+ func WithIngress() DeployOptionsFunc

+ func WithInstallationMode(mode InstallationMode) DeployOptionsFunc

+ func WithMesh(mesh string) DeployOptionsFunc

+ func WithName(name string) DeployOptionsFunc

+ func WithNamespace(namespace string) DeployOptionsFunc

+ func WithPostgres(envVars map[string]string) DeployOptionsFunc

+ func WithProtocol(protocol string) DeployOptionsFunc

+ func WithServiceName(name string) DeployOptionsFunc

+ func WithServiceVersion(version string) DeployOptionsFunc

+ func WithSkipDefaultMesh(skip bool) DeployOptionsFunc

+ func WithToken(token string) DeployOptionsFunc

+ func WithTransparentProxy(transparent bool) DeployOptionsFunc

+ func WithYaml(appYaml string) DeployOptionsFunc

+ func WithoutHelmOpt(name string) DeployOptionsFunc

+ type Deployment interface

+ Delete func(cluster Cluster) error

+ Deploy func(cluster Cluster) error

+ Name func() string

+ type ExecOptions struct

+ CaptureStderr bool

+ CaptureStdout bool

+ Command []string

+ ContainerName string

+ Namespace string

+ PodName string

+ PreserveWhitespace bool

+ Stdin io.Reader

+ type InstallFunc func(cluster Cluster) error

+ func Combine(fs ...InstallFunc) InstallFunc

+ func DemoClientJobK8s(mesh, destination string) InstallFunc

+ func DemoClientK8s(mesh string) InstallFunc

+ func DemoClientUniversal(name, mesh, token string, fs ...DeployOptionsFunc) InstallFunc

+ func EchoServerK8s(mesh string) InstallFunc

+ func EchoServerK8sIngress() InstallFunc

+ func EchoServerK8sIngressWithMeshDNS() InstallFunc

+ func EchoServerUniversal(name, mesh, echo, token string, fs ...DeployOptionsFunc) InstallFunc

+ func IngressUniversal(token string) InstallFunc

+ func IngressUniversalOldType(mesh, token string) InstallFunc

+ func Kuma(mode string, fs ...DeployOptionsFunc) InstallFunc

+ func KumaDNS() InstallFunc

+ func Namespace(name string) InstallFunc

+ func TestServerUniversal(name, mesh, token string, fs ...DeployOptionsFunc) InstallFunc

+ func WaitNumPods(num int, app string) InstallFunc

+ func WaitNumPodsNamespace(namespace string, num int, app string) InstallFunc

+ func WaitPodsAvailable(namespace, app string) InstallFunc

+ func WaitPodsComplete(namespace, app string) InstallFunc

+ func WaitPodsNotAvailable(namespace, app string) InstallFunc

+ func WaitService(namespace, service string) InstallFunc

+ func YamlK8s(yaml string) InstallFunc

+ func YamlPathK8s(path string) InstallFunc

+ func YamlUniversal(yaml string) InstallFunc

+ type InstallationMode string

+ type K8sCluster struct

+ 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) CreateNamespace(namespace string) error

+ func (c *K8sCluster) DeleteApp(namespace, appname string) error

+ func (c *K8sCluster) DeleteKuma(fs ...DeployOptionsFunc) error

+ func (c *K8sCluster) DeleteNamespace(namespace string) error

+ func (c *K8sCluster) Deploy(deployment Deployment) error

+ func (c *K8sCluster) DeployApp(fs ...DeployOptionsFunc) error

+ func (c *K8sCluster) DeployKuma(mode string, fs ...DeployOptionsFunc) error

+ func (c *K8sCluster) Deployment(name string) Deployment

+ func (c *K8sCluster) DismissCluster() (errs error)

+ func (c *K8sCluster) Exec(namespace, podName, containerName string, cmd ...string) (string, string, error)

+ func (c *K8sCluster) ExecWithOptions(options ExecOptions) (string, string, error)

+ func (c *K8sCluster) ExecWithRetries(namespace, podName, containerName string, cmd ...string) (string, string, error)

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

+ func (c *K8sCluster) GetKuma() ControlPlane

+ func (c *K8sCluster) GetKumactlOptions() *KumactlOptions

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

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

+ func (c *K8sCluster) InjectDNS(namespace ...string) error

+ func (c *K8sCluster) Name() string

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

+ func (c *K8sCluster) UpgradeKuma(mode string, fs ...DeployOptionsFunc) error

+ func (c *K8sCluster) VerifyKuma() error

+ func (c *K8sCluster) WaitApp(name, namespace string, replicas int) error

+ func (c *K8sCluster) WaitNamespaceCreate(namespace string)

+ func (c *K8sCluster) WaitNamespaceDelete(namespace string)

+ func (c *K8sCluster) WithRetries(retries int) Cluster

+ func (c *K8sCluster) WithTimeout(timeout time.Duration) Cluster

+ type K8sClusters struct

+ func (c *K8sClusters) GetKumactlOptions() *KumactlOptions

+ func (cs *K8sClusters) CreateNamespace(namespace string) error

+ func (cs *K8sClusters) DeleteApp(namespace, appname string) error

+ func (cs *K8sClusters) DeleteKuma(opts ...DeployOptionsFunc) error

+ func (cs *K8sClusters) DeleteNamespace(namespace string) error

+ func (cs *K8sClusters) Deploy(deployment Deployment) error

+ func (cs *K8sClusters) DeployApp(fs ...DeployOptionsFunc) error

+ func (cs *K8sClusters) DeployKuma(mode string, fs ...DeployOptionsFunc) error

+ func (cs *K8sClusters) Deployment(name string) Deployment

+ func (cs *K8sClusters) DismissCluster() error

+ func (cs *K8sClusters) Exec(namespace, podName, containerName string, cmd ...string) (string, string, error)

+ func (cs *K8sClusters) ExecWithRetries(namespace, podName, containerName string, cmd ...string) (string, string, error)

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

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

+ func (cs *K8sClusters) GetKuma() ControlPlane

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

+ func (cs *K8sClusters) InjectDNS(namespace ...string) error

+ func (cs *K8sClusters) Name() string

+ func (cs *K8sClusters) UpgradeKuma(mode string, fs ...DeployOptionsFunc) error

+ func (cs *K8sClusters) VerifyKuma() error

+ func (cs *K8sClusters) WithRetries(retries int) Cluster

+ func (cs *K8sClusters) WithTimeout(timeout time.Duration) Cluster

+ type K8sControlPlane struct

+ func NewK8sControlPlane(t testing.TestingT, mode core.CpMode, clusterName string, kubeconfig string, ...) *K8sControlPlane

+ func (c *K8sControlPlane) FinalizeAdd() error

+ func (c *K8sControlPlane) GenerateDpToken(mesh, service string) (string, error)

+ func (c *K8sControlPlane) GenerateZoneIngressToken(zone string) (string, error)

+ func (c *K8sControlPlane) GetGlobaStatusAPI() string

+ func (c *K8sControlPlane) GetKDSServerAddress() string

+ func (c *K8sControlPlane) GetKubectlOptions(namespace ...string) *k8s.KubectlOptions

+ func (c *K8sControlPlane) GetKumaCPLogs() (string, error)

+ func (c *K8sControlPlane) GetKumaCPPods() []v1.Pod

+ func (c *K8sControlPlane) GetKumaCPSvcs() []v1.Service

+ func (c *K8sControlPlane) GetName() string

+ func (c *K8sControlPlane) InjectDNS(args ...string) error

+ func (c *K8sControlPlane) InstallCP(args ...string) (string, error)

+ func (c *K8sControlPlane) PortForwardKumaCP() error

+ func (c *K8sControlPlane) VerifyKumaCtl() error

+ func (c *K8sControlPlane) VerifyKumaGUI() error

+ func (c *K8sControlPlane) VerifyKumaREST() error

+ type KumactlOptions struct

+ CPName string

+ ConfigPath string

+ Env map[string]string

+ Kumactl string

+ Verbose bool

+ 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, name, mesh string) error

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

+ func (o *KumactlOptions) KumactlInstallDNS(args ...string) (string, error)

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

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

+ func (o *KumactlOptions) KumactlList(kumatype, mesh string) ([]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 PortFwd struct

+ type SshApp struct

+ func NewSshApp(verbose bool, port string, env []string, args []string) *SshApp

+ func (s *SshApp) Err() string

+ func (s *SshApp) Out() string

+ func (s *SshApp) Run() error

+ func (s *SshApp) SshCmd(env []string, args []string) *exec.Cmd

+ func (s *SshApp) Start() error

+ func (s *SshApp) Stop() error

+ func (s *SshApp) Wait() error

+ type TestingT struct

+ func NewTestingT() *TestingT

+ func (i *TestingT) Helper()

+ func (i *TestingT) Name() string

+ type UniversalApp struct

+ func NewUniversalApp(t testing.TestingT, clusterName, dpName string, mode AppMode, ...) (*UniversalApp, error)

+ func (s *UniversalApp) CreateDP(token, cpAddress, appname, ip, dpyaml string, builtindns, ingress bool)

+ func (s *UniversalApp) CreateMainApp(env []string, args []string)

+ func (s *UniversalApp) GetPublicPort(port string) string

+ func (s *UniversalApp) OverrideDpVersion(version string) error

+ func (s *UniversalApp) ReStart() error

+ func (s *UniversalApp) Stop() error

+ type UniversalCluster struct

+ func NewUniversalCluster(t *TestingT, name string, verbose bool) *UniversalCluster

+ func (c *UniversalCluster) CreateDP(app *UniversalApp, appname, ip, dpyaml, token string, builtindns bool) error

+ func (c *UniversalCluster) CreateNamespace(namespace string) error

+ func (c *UniversalCluster) CreateZoneIngress(app *UniversalApp, appname, ip, dpyaml, token string, builtindns bool) error

+ func (c *UniversalCluster) DeleteApp(namespace, appname string) error

+ func (c *UniversalCluster) DeleteKuma(opts ...DeployOptionsFunc) error

+ func (c *UniversalCluster) DeleteNamespace(namespace string) error

+ func (c *UniversalCluster) Deploy(deployment Deployment) error

+ func (c *UniversalCluster) DeployApp(fs ...DeployOptionsFunc) error

+ func (c *UniversalCluster) DeployKuma(mode string, fs ...DeployOptionsFunc) error

+ func (c *UniversalCluster) Deployment(name string) Deployment

+ func (c *UniversalCluster) DismissCluster() (errs error)

+ func (c *UniversalCluster) Exec(namespace, podName, appname string, cmd ...string) (string, string, error)

+ func (c *UniversalCluster) ExecWithRetries(namespace, podName, appname string, cmd ...string) (string, string, error)

+ func (c *UniversalCluster) GetApp(appName string) *UniversalApp

+ func (c *UniversalCluster) GetKubectlOptions(namespace ...string) *k8s.KubectlOptions

+ func (c *UniversalCluster) GetKuma() ControlPlane

+ func (c *UniversalCluster) GetKumactlOptions() *KumactlOptions

+ func (c *UniversalCluster) GetTesting() testing.TestingT

+ func (c *UniversalCluster) InjectDNS(namespace ...string) error

+ func (c *UniversalCluster) Name() string

+ func (c *UniversalCluster) VerifyKuma() error

+ func (c *UniversalCluster) WithRetries(retries int) Cluster

+ func (c *UniversalCluster) WithTimeout(timeout time.Duration) Cluster

+ type UniversalClusters struct

+ func (c *UniversalClusters) GetKumactlOptions() *KumactlOptions

+ func (cs *UniversalClusters) CreateNamespace(namespace string) error

+ func (cs *UniversalClusters) DeleteApp(namespace, appname string) error

+ func (cs *UniversalClusters) DeleteKuma(opts ...DeployOptionsFunc) error

+ func (cs *UniversalClusters) DeleteNamespace(namespace string) error

+ func (cs *UniversalClusters) Deploy(deployment Deployment) error

+ func (cs *UniversalClusters) DeployApp(fs ...DeployOptionsFunc) error

+ func (cs *UniversalClusters) DeployKuma(mode string, fs ...DeployOptionsFunc) error

+ func (cs *UniversalClusters) Deployment(name string) Deployment

+ func (cs *UniversalClusters) DismissCluster() error

+ func (cs *UniversalClusters) Exec(namespace, podName, containerName string, cmd ...string) (string, string, error)

+ func (cs *UniversalClusters) ExecWithRetries(namespace, podName, containerName string, cmd ...string) (string, string, error)

+ func (cs *UniversalClusters) GetCluster(name string) Cluster

+ func (cs *UniversalClusters) GetKubectlOptions(namespace ...string) *k8s.KubectlOptions

+ func (cs *UniversalClusters) GetKuma() ControlPlane

+ func (cs *UniversalClusters) GetTesting() testing.TestingT

+ func (cs *UniversalClusters) InjectDNS(namespace ...string) error

+ func (cs *UniversalClusters) Name() string

+ func (cs *UniversalClusters) VerifyKuma() error

+ func (cs *UniversalClusters) WithRetries(retries int) Cluster

+ func (cs *UniversalClusters) WithTimeout(timeout time.Duration) Cluster

+ type UniversalControlPlane struct

+ func NewUniversalControlPlane(t testing.TestingT, mode core.CpMode, clusterName string, ...) *UniversalControlPlane

+ func (c *UniversalControlPlane) GenerateDpToken(mesh, service string) (string, error)

+ func (c *UniversalControlPlane) GenerateZoneIngressToken(zone string) (string, error)

+ func (c *UniversalControlPlane) GetGlobaStatusAPI() string

+ func (c *UniversalControlPlane) GetKDSServerAddress() string

+ func (c *UniversalControlPlane) GetKumaCPLogs() (string, error)

+ func (c *UniversalControlPlane) GetName() string

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