testing

Apr 28, 2024

Changes in this version

+ func WaitForSwitchesReady(ctx context.Context, kube client.WithWatch, expectedSwitches []string, ...) error

+ type Duration struct

+ func (duration *Duration) UnmarshalJSON(b []byte) error

+ type Iperf3Report struct

+ End Iperf3ReportEnd

+ Intervals []Iperf3ReportInterval

+ func ParseIperf3Report(data string) (*Iperf3Report, error)

+ type Iperf3ReportEnd struct

+ SumReceived Iperf3ReportSum

+ SumSent Iperf3ReportSum

+ type Iperf3ReportInterval struct

+ Sum Iperf3ReportSum

+ type Iperf3ReportSum struct

+ BitsPerSecond float64

+ Bytes int64

+ type LStep struct

+ Enforce *string

+ Name string

+ Netconf *StepNetconf

+ TestConnectivity *StepTestConnectivity

+ Update *string

+ WaitReady *StepWaitReady

+ type LStepTestConnectivity struct

+ type LTest struct

+ Labels map[string]string

+ Steps []LStep

+ type LoaderFile struct

+ Blocks map[string]string

+ Tests map[string]LTest

+ type Runner struct

+ func NewRunner(cfg RunnerConfig) (*Runner, error)

+ func (r *Runner) Run(ctx context.Context) error

+ type RunnerConfig struct

+ RandomOrder bool

+ RepeatFor time.Duration

+ RepeatTimes uint

+ StepHelper StepHelper

+ TestFiles []string

+ TestNames []string

+ TestTimeout time.Duration

+ Timeout time.Duration

+ type Step interface

+ Run func(ctx context.Context, h StepHelper) error

+ type StepAPIAbbr struct

+ func (s *StepAPIAbbr) Run(ctx context.Context, h StepHelper) error

+ type StepHelper interface

+ Kube func() client.WithWatch

+ ServerExec func(ctx context.Context, server, cmd string, timeout time.Duration) (string, error)

+ type StepNetconf struct

+ func (s *StepNetconf) Run(ctx context.Context, h StepHelper) error

+ type StepTestConnectivity struct

+ IPerfSeconds uint

+ IPerfSpeed float64

+ PingCount uint

+ func (s *StepTestConnectivity) Run(ctx context.Context, h StepHelper) error

+ type StepWaitReady struct

+ Timeout Duration

+ func (s *StepWaitReady) Run(ctx context.Context, h StepHelper) error

+ type Test struct

+ type VLABStepHelper struct

+ func NewVLABStepHelper(kube client.WithWatch, sshPorts map[string]uint, sshKeyPath string) *VLABStepHelper

+ func (h *VLABStepHelper) Kube() client.WithWatch

+ func (h *VLABStepHelper) ServerExec(ctx context.Context, server, cmd string, timeout time.Duration) (string, error)