Documentation
Overview ¶
Package network are the end-to-end tests for Kubernetes networking.
Index ¶
- Constants
- func CheckSCTPModuleLoadedOnNodes(f *framework.Framework, nodes *v1.NodeList) bool
- func DescribeSvc(ns string)
- func GetHTTPContent(host string, port int, timeout time.Duration, url string) bytes.Buffer
- func GetHTTPContentFromTestContainer(config *e2enetwork.NetworkingTestConfig, host string, port int, ...) (string, error)
- func SIGDescribe(text string, body func()) bool
- func StartServeHostnameService(c clientset.Interface, svc *v1.Service, ns string, replicas int) ([]string, string, error)
- func StopServeHostnameService(clientset clientset.Interface, ns, name string) error
- func TestHTTPHealthCheckNodePort(host string, port int, request string, timeout time.Duration, ...) error
- type IPerfResult
- type IPerfResults
- type StrSlice
- type TestFixture
- func (t *TestFixture) BuildServiceSpec() *v1.Service
- func (t *TestFixture) Cleanup() []error
- func (t *TestFixture) CreateRC(rc *v1.ReplicationController) (*v1.ReplicationController, error)
- func (t *TestFixture) CreateService(service *v1.Service) (*v1.Service, error)
- func (t *TestFixture) DeleteService(serviceName string) error
- type UDPPokeParams
- type UDPPokeResult
- type UDPPokeStatus
Constants ¶
const ( // AffinityTimeout is the maximum time that CheckAffinity is allowed to take; this // needs to be more than long enough for AffinityConfirmCount HTTP requests to // complete in a busy CI cluster, but shouldn't be too long since we will end up // waiting the entire time in the tests where affinity is not expected. AffinityTimeout = 2 * time.Minute // AffinityConfirmCount is the number of needed continuous requests to confirm that // affinity is enabled. AffinityConfirmCount = 15 )
const ( // RespondingTimeout is how long to wait for a service to be responding. RespondingTimeout = 2 * time.Minute )
Variables ¶
Functions ¶
func CheckSCTPModuleLoadedOnNodes ¶
CheckSCTPModuleLoadedOnNodes checks whether any node on the list has the sctp.ko module loaded For security reasons, and also to allow clusters to use userspace SCTP implementations, we require that just creating an SCTP Pod/Service/NetworkPolicy must not do anything that would cause the sctp kernel module to be loaded.
func DescribeSvc ¶
func DescribeSvc(ns string)
DescribeSvc logs the output of kubectl describe svc for the given namespace
func GetHTTPContent ¶
GetHTTPContent returns the content of the given url by HTTP.
func GetHTTPContentFromTestContainer ¶
func GetHTTPContentFromTestContainer(config *e2enetwork.NetworkingTestConfig, host string, port int, timeout time.Duration, dialCmd string) (string, error)
GetHTTPContentFromTestContainer returns the content of the given url by HTTP via a test container.
func SIGDescribe ¶
SIGDescribe annotates the test with the SIG label.
func StartServeHostnameService ¶
func StartServeHostnameService(c clientset.Interface, svc *v1.Service, ns string, replicas int) ([]string, string, error)
StartServeHostnameService creates a replication controller that serves its hostname and a service on top of it.
func StopServeHostnameService ¶
StopServeHostnameService stops the given service.
Types ¶
type IPerfResult ¶
type IPerfResult struct {
// contains filtered or unexported fields
}
IPerfResult struct modelling an iperf record.... 20160314154239,172.17.0.3,34152,172.17.0.2,5001,3,0.0-10.0,33843707904,27074774092
func NewIPerf ¶
func NewIPerf(csvLine string) *IPerfResult
NewIPerf parses an IPerf CSV output line into an IPerfResult.
type IPerfResults ¶
IPerfResults is a struct that stores some IPerfResult
func (*IPerfResults) Add ¶
func (i *IPerfResults) Add(ipr *IPerfResult)
Add adds a new result to the Results struct.
func (*IPerfResults) ToTSV ¶
func (i *IPerfResults) ToTSV() string
ToTSV exports an easily readable tab delimited format of all IPerfResults.
type TestFixture ¶
type TestFixture struct { ServiceName string Namespace string Client clientset.Interface TestID string Labels map[string]string Name string Image string // contains filtered or unexported fields }
TestFixture is a simple helper class to avoid too much boilerplate in tests
func NewServerTest ¶
func NewServerTest(client clientset.Interface, namespace string, serviceName string) *TestFixture
NewServerTest creates a new TestFixture for the tests.
func (*TestFixture) BuildServiceSpec ¶
func (t *TestFixture) BuildServiceSpec() *v1.Service
BuildServiceSpec builds default config for a service (which can then be changed)
func (*TestFixture) Cleanup ¶
func (t *TestFixture) Cleanup() []error
Cleanup cleans all ReplicationControllers and Services which this object holds.
func (*TestFixture) CreateRC ¶
func (t *TestFixture) CreateRC(rc *v1.ReplicationController) (*v1.ReplicationController, error)
CreateRC creates a replication controller and records it for cleanup.
func (*TestFixture) CreateService ¶
CreateService creates a service, and record it for cleanup
func (*TestFixture) DeleteService ¶
func (t *TestFixture) DeleteService(serviceName string) error
DeleteService deletes a service, and remove it from the cleanup list
type UDPPokeParams ¶
UDPPokeParams is a struct for UDP poke parameters.
type UDPPokeResult ¶
type UDPPokeResult struct { Status UDPPokeStatus Error error // if there was any error Response []byte // if code != 0 }
UDPPokeResult is a struct for UDP poke result.
type UDPPokeStatus ¶
type UDPPokeStatus string
UDPPokeStatus is string for representing UDP poke status.
const ( // UDPSuccess is UDP poke status which is success. UDPSuccess UDPPokeStatus = "Success" // UDPError is UDP poke status which is error. UDPError UDPPokeStatus = "UnknownError" // UDPTimeout is UDP poke status which is timeout. UDPTimeout UDPPokeStatus = "TimedOut" // UDPRefused is UDP poke status which is connection refused. UDPRefused UDPPokeStatus = "ConnectionRefused" // UDPBadResponse is UDP poke status which is bad response. UDPBadResponse UDPPokeStatus = "BadResponse" )
Source Files
- conntrack.go
- dns.go
- dns_common.go
- dns_configmap.go
- dns_scale_records.go
- doc.go
- dual_stack.go
- endpointslice.go
- endpointslicemirroring.go
- example_cluster_dns.go
- firewall.go
- fixture.go
- framework.go
- ingress.go
- ingress_scale.go
- ingressclass.go
- kube_proxy.go
- network_policy.go
- network_tiers.go
- networking.go
- networking_perf.go
- no_snat.go
- proxy.go
- service.go
- service_latency.go
- util.go
- util_iperf.go
Directories
Path | Synopsis |
---|---|
scale | |
scale/localrun |