agent

Documentation

Index

• type TrafficTest
  • func (t *TrafficTest) TestTraffic() (float64, error)

Types

type TrafficTest

type TrafficTest struct {
	Framework *framework.Framework
	// The deployment builder is needed instead of deployment, in order
	// to inject the server container to the deployment
	TrafficServerDeploymentBuilder *manifest.DeploymentBuilder
	// Port on which the server should listen for traffic
	ServerPort int
	// TCP/UPD are the supported protocols
	ServerProtocol string
	// The number of client pods to create for testing connection to
	// each server Pod
	ClientCount int
	// Server count is the number of server pods to be created
	ServerCount int
	// Server Pod Label Key/Val is required in order to get the list of
	// pods belonging to the server deployment
	ServerPodLabelKey string
	ServerPodLabelVal string
	// Client Pod Label Key/Val is required in order to get the list of
	// pods belonging to the client job
	ClientPodLabelKey string
	ClientPodLabelVal string
	// If supplied the function will be used to validate the pods are as expected
	// For instance, to validate server/client pods are using Branch ENI
	ValidateServerPods func(list v1.PodList) error
	ValidateClientPods func(list v1.PodList) error
	// Boolean that indicates if IPv6 mode is enabled
	IsV6Enabled bool
}

TrafficTest is used to execute a traffic test for TCP/UDP traffic

func (*TrafficTest) TestTraffic

func (t *TrafficTest) TestTraffic() (float64, error)

Tests traffic by creating multiple server pods using a deployment and multiple client pods using a Job. Each client Pod tests connectivity to each Server Pod.