...

Package scale

import "k8s.io/kubernetes/test/e2e/network/scale"
Overview
Index
Subdirectories

Overview ▾

type IngressScaleFramework

IngressScaleFramework defines the framework for ingress scale testing.

type IngressScaleFramework struct {
    Clientset     clientset.Interface
    Jig           *e2eingress.TestJig
    GCEController *gce.IngressController
    CloudConfig   framework.CloudConfig
    Logger        e2eingress.TestLogger

    Namespace        string
    EnableTLS        bool
    NumIngressesTest []int
    OutputFile       string

    ScaleTestDeploy *appsv1.Deployment
    ScaleTestSvcs   []*v1.Service
    ScaleTestIngs   []*networkingv1.Ingress

    // BatchCreateLatencies stores all ingress creation latencies, in different
    // batches.
    BatchCreateLatencies [][]time.Duration
    // BatchDurations stores the total duration for each ingress batch creation.
    BatchDurations []time.Duration
    // StepCreateLatencies stores the single ingress creation latency, which happens
    // after each ingress batch creation is complete.
    StepCreateLatencies []time.Duration
    // StepCreateLatencies stores the single ingress update latency, which happens
    // after each ingress batch creation is complete.
    StepUpdateLatencies []time.Duration
}

func NewIngressScaleFramework

func NewIngressScaleFramework(cs clientset.Interface, ns string, cloudConfig framework.CloudConfig) *IngressScaleFramework

NewIngressScaleFramework returns a new framework for ingress scale testing.

func (*IngressScaleFramework) CleanupScaleTest

func (f *IngressScaleFramework) CleanupScaleTest(ctx context.Context) []error

CleanupScaleTest cleans up framework for ingress scale testing.

func (*IngressScaleFramework) GetFormattedLatencies

func (f *IngressScaleFramework) GetFormattedLatencies() string

GetFormattedLatencies returns the formatted latencies output. TODO: Need a better way/format for data output.

func (*IngressScaleFramework) PrepareScaleTest

func (f *IngressScaleFramework) PrepareScaleTest(ctx context.Context) error

PrepareScaleTest prepares framework for ingress scale testing.

func (*IngressScaleFramework) RunScaleTest

func (f *IngressScaleFramework) RunScaleTest(ctx context.Context) []error

RunScaleTest runs ingress scale testing.

Subdirectories

Name Synopsis
..
localrun