kubernetes: k8s.io/kubernetes/test/integration/ipamperf Index | Files

package ipamperf

import "k8s.io/kubernetes/test/integration/ipamperf"


Package Files

cloud.go results.go util.go

type Config Uses

type Config struct {
    CreateQPS     int                     // rate at which nodes are created
    KubeQPS       int                     // rate for communication with kubernetes API
    CloudQPS      int                     // rate for communication with cloud endpoint
    NumNodes      int                     // number of nodes to created and monitored
    AllocatorType ipam.CIDRAllocatorType  // type of allocator to run
    Cloud         cloudprovider.Interface // cloud provider

Config represents the test configuration that is being run

type JSONDuration Uses

type JSONDuration time.Duration

JSONDuration is an alias of time.Duration to support custom Marshal code

func (*JSONDuration) MarshalJSON Uses

func (jDuration *JSONDuration) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface

func (*JSONDuration) UnmarshalJSON Uses

func (jDuration *JSONDuration) UnmarshalJSON(b []byte) (err error)

UnmarshalJSON implements the json.Unmarshaler interface

type NodeDuration Uses

type NodeDuration struct {
    Name     string       // node name
    PodCIDR  string       // the podCIDR that was assigned to the node
    Duration JSONDuration // how long it took to assign podCIDR

NodeDuration represents the CIDR allocation time for each node

type Observer Uses

type Observer struct {
    // contains filtered or unexported fields

Observer represents the handle to test observer that watches for node changes and tracks behavior

func NewObserver Uses

func NewObserver(clientSet *clientset.Clientset, numNodes int) *Observer

NewObserver creates a new observer given a handle to the Clientset

func (*Observer) Results Uses

func (o *Observer) Results(name string, config *Config) *Results

Results returns the test results. It waits for the observer to finish and returns the computed results of the observations.

func (*Observer) StartObserving Uses

func (o *Observer) StartObserving() error

StartObserving starts an asynchronous loop to monitor for node changes. Call Results() to get the test results after starting observer.

type Results Uses

type Results struct {
    Name           string         // name for the test
    Config         *Config        // handle to the test config
    Succeeded      bool           // whether all nodes were assigned podCIDR
    MaxAllocTime   JSONDuration   // the maximum time take for assignment per node
    TotalAllocTime JSONDuration   // duration between first addition and last assignment
    NodeAllocTime  []NodeDuration // assignment time by node name

Results represents the observed test results.

func (*Results) String Uses

func (results *Results) String() string

String implements the Stringer interface and returns a multi-line representation of the test results.

Package ipamperf imports 26 packages (graph). Updated 2020-06-01. Refresh now. Tools for package owners.