e2e

Dec 18, 2024

Changes in this version

type Extension

+ func (e *Extension) Reconfigure(values map[string]string) error

+ func (e *Extension) ResetConfig() error

Oct 14, 2024

Changes in this version

type Minikube

+ func (m *Minikube) TailLogPrefixed(ctx context.Context, pod metav1.Object, prefix string)

May 8, 2024

Changes in this version

type MinikubeOpts

+ func (o MinikubeOpts) WithStartArgs(args ...string) MinikubeOpts

Apr 30, 2024

Changes in this version

type Iperf

+ ImageErr error

+ ImageOnce sync.Once

type Minikube

+ func (m *Minikube) BuildImage(url string, tag string) error

Jan 26, 2024

Changes in this version

type HelmExtensionFactory

+ ImageTag string

Nov 29, 2023

Changes in this version

type Minikube

+ func (m *Minikube) WaitForPodReady(pod metav1.Object, duration time.Duration) error

Nov 27, 2023

Changes in this version

type ServiceClient

+ func (c *ServiceClient) R() *resty.Request

Aug 30, 2023

Changes in this version

type Extension

+ func (e *Extension) DiscoverEnrichmentData(discoveryId string) ([]discovery_kit_api.EnrichmentData, error)

type MinikubeOpts

+ func DefaultMinikubeOpts() MinikubeOpts

+ func (o MinikubeOpts) AfterStart(f func(m *Minikube) error) MinikubeOpts

+ func (o MinikubeOpts) WithDriver(driver string) MinikubeOpts

+ func (o MinikubeOpts) WithRuntimes(runtimes ...Runtime) MinikubeOpts

Aug 22, 2023

Changes in this version

+ func ContainsAttribute(attributes map[string][]string, key, value string) bool

+ func PollForEnrichmentData(ctx context.Context, e *Extension, targetId string, ...) (discovery_kit_api.EnrichmentData, error)

Aug 21, 2023

Changes in this version

type Minikube

+ func (m *Minikube) CreateDeployment(deployment *appsv1.Deployment) (metav1.Object, []corev1.Pod, error)

+ func (m *Minikube) DeleteDeployment(deployment metav1.Object) error

+ func (m *Minikube) WaitForDeploymentPhase(deployment metav1.Object, phase corev1.PodPhase, labelSelector string, ...) ([]corev1.Pod, error)

+ type NginxDeployment struct

+ Deployment metav1.Object

+ Minikube *Minikube

+ Pods []corev1.Pod

+ Service metav1.Object

+ func (n *NginxDeployment) AssertIsReachable(t *testing.T, expected bool)

+ func (n *NginxDeployment) ContainerStatus() (*corev1.ContainerStatus, error)

+ func (n *NginxDeployment) Delete() error

+ func (n *NginxDeployment) Deploy(deploymentName string) error

+ func (n *NginxDeployment) IsReachable() error

+ func (n *NginxDeployment) Target() (*action_kit_api.Target, error)

Aug 16, 2023

Changes in this version

+ var Metrics = sync.Map

type Extension

+ func (e *Extension) GetMetrics(actionId string) *[]action_kit_api.Metric

Aug 10, 2023

Changes in this version

type Iperf

+ func (n *Iperf) AssertPackageLossWithRetry(min float64, max float64, maxRetries int) bool

Jun 27, 2023

Changes in this version

type ExtensionFactory

+ AfterAll func(t *testing.T, m *Minikube, e *Extension) error

+ AfterEach func(t *testing.T, m *Minikube, e *Extension) error

+ BeforeAll func(t *testing.T, m *Minikube, e *Extension) error

+ BeforeEach func(t *testing.T, m *Minikube, e *Extension) error

type HelmExtensionFactory

+ AfterAllFunc func(t *testing.T, m *Minikube, e *Extension) error

+ AfterEachFunc func(t *testing.T, m *Minikube, e *Extension) error

+ BeforeAllFunc func(t *testing.T, m *Minikube, e *Extension) error

+ BeforeEachFunc func(t *testing.T, m *Minikube, e *Extension) error

+ func (h *HelmExtensionFactory) AfterAll(t *testing.T, m *Minikube, e *Extension) error

+ func (h *HelmExtensionFactory) AfterEach(t *testing.T, m *Minikube, e *Extension) error

+ func (h *HelmExtensionFactory) BeforeAll(t *testing.T, m *Minikube, e *Extension) error

+ func (h *HelmExtensionFactory) BeforeEach(t *testing.T, m *Minikube, e *Extension) error

Jun 14, 2023

Changes in this version

type Minikube

+ func (m *Minikube) PodExec(pod metav1.Object, containername string, cmd ...string) (string, error)

+ func (m *Minikube) SshExec(arg ...string) *exec.Cmd

Jun 7, 2023

Changes in this version

+ func AssertLogContainsWithTimeout(t *testing.T, m *Minikube, pod metav1.Object, expectedLog string, ...)

May 16, 2023

Changes in this version

+ var AllRuntimes = []Runtime

+ var DefaultMiniKubeOpts = MinikubeOpts

+ func AddPrefix(containerId string, runtime Runtime) string

+ func AssertLogContains(t *testing.T, m *Minikube, pod metav1.Object, expectedLog string)

+ func AssertProcessNOTRunningInContainer(t *testing.T, m *Minikube, pod metav1.Object, containername string, ...)

+ func AssertProcessRunningInContainer(t *testing.T, m *Minikube, pod metav1.Object, containername string, ...)

+ func GetContainerStatus(m *Minikube, pod metav1.Object, containername string) (*corev1.ContainerStatus, error)

+ func HasAttribute(target discovery_kit_api.Target, key, value string) bool

+ func NewContainerTarget(m *Minikube, pod metav1.Object, containername string) (*action_kit_api.Target, error)

+ func PollForTarget(ctx context.Context, e *Extension, targetId string, ...) (discovery_kit_api.Target, error)

+ func RemovePrefix(containerId string) string

+ func Retry(t *testing.T, maxAttempts int, sleep time.Duration, f func(r *R)) bool

+ func WaitForContainerStatusUsingContainerEngine(m *Minikube, containerId string, wantedStatus string) error

+ func WithDefaultMinikube(t *testing.T, ext ExtensionFactory, testCases []WithMinikubeTestCase)

+ func WithMinikube(t *testing.T, mOpts MinikubeOpts, ext ExtensionFactory, ...)

+ type ActionExecution struct

+ func (a *ActionExecution) Cancel() error

+ func (a *ActionExecution) Wait() error

+ type Extension struct

+ Client *resty.Client

+ Pod metav1.Object

+ func (e *Extension) DiscoverTargets(targetId string) ([]discovery_kit_api.Target, error)

+ func (e *Extension) RunAction(actionId string, target *action_kit_api.Target, config interface{}, ...) (ActionExecution, error)

+ func (e *Extension) RunActionWithFiles(actionId string, target *action_kit_api.Target, config interface{}, ...) (ActionExecution, error)

+ type ExtensionFactory interface

+ CreateImage func() error

+ Start func(minikube *Minikube) (*Extension, error)

+ type File struct

+ Content []byte

+ FileName string

+ ParameterName string

+ type HelmExtensionFactory struct

+ ChartPath string

+ ExtraArgs func(minikube *Minikube) []string

+ ImageName string

+ Name string

+ PodLabelSelector string

+ Port uint16

+ func (h *HelmExtensionFactory) CreateImage() error

+ func (h *HelmExtensionFactory) Start(minikube *Minikube) (*Extension, error)

+ type Iperf struct

+ ClientPod metav1.Object

+ Minikube *Minikube

+ ServerIp string

+ ServerPod metav1.Object

+ func (n *Iperf) AssertBandwidth(t *testing.T, min float64, max float64)

+ func (n *Iperf) AssertPackageLoss(t *testing.T, min float64, max float64)

+ func (n *Iperf) Delete() error

+ func (n *Iperf) Deploy(name string, ...) error

+ func (n *Iperf) MeasureBandwidth() (float64, error)

+ func (n *Iperf) MeasurePackageLoss() (float64, error)

+ func (n *Iperf) Target() (*action_kit_api.Target, error)

+ type Minikube struct

+ Client *kubernetes.Clientset

+ ClientConfig *rest.Config

+ Driver string

+ Profile string

+ Runtime Runtime

+ func (m *Minikube) Config() *rest.Config

+ func (m *Minikube) CreatePod(pod *acorev1.PodApplyConfiguration) (metav1.Object, error)

+ func (m *Minikube) CreateService(service *acorev1.ServiceApplyConfiguration) (metav1.Object, error)

+ func (m *Minikube) DeletePod(pod metav1.Object) error

+ func (m *Minikube) DeleteService(service metav1.Object) error

+ func (m *Minikube) Exec(pod metav1.Object, containername string, cmd ...string) (string, error)

+ func (m *Minikube) GetClient() *kubernetes.Clientset

+ func (m *Minikube) GetPod(pod metav1.Object) (*corev1.Pod, error)

+ func (m *Minikube) GetRuntime() Runtime

+ func (m *Minikube) ListPods(ctx context.Context, namespace, matchLabels string) ([]corev1.Pod, error)

+ func (m *Minikube) LoadImage(image string) error

+ func (m *Minikube) NewRestClientForService(service metav1.Object) (*ServiceClient, error)

+ func (m *Minikube) PortForward(pod metav1.Object, remotePort uint16, stopCh <-chan struct{}) (uint16, error)

+ func (m *Minikube) TailLog(ctx context.Context, pod metav1.Object)

+ func (m *Minikube) TunnelService(service metav1.Object) (string, func(), error)

+ func (m *Minikube) WaitForPodPhase(pod metav1.Object, phase corev1.PodPhase, duration time.Duration) error

+ type MinikubeOpts struct

+ Driver string

+ Runtimes []Runtime

+ type Netperf struct

+ ClientPod metav1.Object

+ Minikube *Minikube

+ ServerIp string

+ ServerPod metav1.Object

+ func (n *Netperf) AssertLatency(t *testing.T, min time.Duration, max time.Duration)

+ func (n *Netperf) Delete() error

+ func (n *Netperf) Deploy(name string, ...) error

+ func (n *Netperf) MeasureLatency() (time.Duration, error)

+ func (n *Netperf) Target() (*action_kit_api.Target, error)

+ type Nginx struct

+ Minikube *Minikube

+ Pod metav1.Object

+ Service metav1.Object

+ func (n *Nginx) AssertCanReach(t *testing.T, url string, expected bool)

+ func (n *Nginx) AssertCannotReach(t *testing.T, url string, errContains string)

+ func (n *Nginx) AssertIsReachable(t *testing.T, expected bool)

+ func (n *Nginx) CanReach(url string) error

+ func (n *Nginx) ContainerStatus() (*corev1.ContainerStatus, error)

+ func (n *Nginx) Delete() error

+ func (n *Nginx) Deploy(podName string, opts ...func(c *acorev1.PodApplyConfiguration)) error

+ func (n *Nginx) IsReachable() error

+ func (n *Nginx) Target() (*action_kit_api.Target, error)

+ type R struct

+ Attempt int

+ Failed bool

+ Log *bytes.Buffer

+ type Runtime string

+ const RuntimeContainerd

+ const RuntimeCrio

+ const RuntimeDocker

+ type ServiceClient struct

+ func (c *ServiceClient) Close()

+ type WithMinikubeTestCase struct

+ Name string

+ Test func(t *testing.T, minikube *Minikube, e *Extension)