github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-26 05:03:09 +00:00
Code Issues Projects Releases Wiki Activity

remove duplicate functions

Browse Source
This commit is contained in:
Antonio Ojea 2021-02-22 17:39:50 +01:00
parent a2b57b9fb2
commit c9cbe41347
2 changed files with 2 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
test/e2e/framework/service/jig.go
View File

@ -1026,24 +1026,8 @@ func (j *TestJig) CheckServiceReachability(svc *v1.Service, pod *v1.Pod) error {
} }
} }
// CreateServicePods creates a replication controller with the label same as service. Service listens to HTTP. // CreateServicePods creates a replication controller with the label same as service. Service listens to TCP and UDP.
func (j *TestJig) CreateServicePods(replica int) error { func (j *TestJig) CreateServicePods(replica int) error {
config := testutils.RCConfig{
Client: j.Client,
Name: j.Name,
Image: framework.ServeHostnameImage,
Command: []string{"/agnhost", "serve-hostname"},
Namespace: j.Namespace,
Labels: j.Labels,
PollInterval: 3 * time.Second,
Timeout: framework.PodReadyBeforeTimeout,
Replicas: replica,
}
return e2erc.RunRC(config)
}
// CreateTCPUDPServicePods creates a replication controller with the label same as service. Service listens to TCP and UDP.
func (j *TestJig) CreateTCPUDPServicePods(replica int) error {
config := testutils.RCConfig{ config := testutils.RCConfig{
Client: j.Client, Client: j.Client,
Name: j.Name, Name: j.Name,

2
test/e2e/network/service.go
View File

@ -1228,7 +1228,7 @@ var _ = SIGDescribe("Services", func() {
}) })
framework.ExpectNoError(err) framework.ExpectNoError(err)
err = jig.CreateTCPUDPServicePods(2) err = jig.CreateServicePods(2)
framework.ExpectNoError(err) framework.ExpectNoError(err)
execPod := e2epod.CreateExecPodOrFail(cs, ns, "execpod", nil) execPod := e2epod.CreateExecPodOrFail(cs, ns, "execpod", nil)
err = jig.CheckServiceReachability(nodePortService, execPod) err = jig.CheckServiceReachability(nodePortService, execPod)