scottk/kubernetes
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/kubernetes.git synced 2025-11-03 19:58:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #93535 from gnufied/create-service-for-endpoint

Browse Source 
Create service for gluster endpoint
This commit is contained in:
Kubernetes Prow Robot
2020-08-03 16:10:33 -07:00
committed by GitHub
parent 107bc5dc7c 20934d7e50
commit ae9f76153f
2 changed files with 33 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
test/e2e/framework/volume/fixtures.go
View File

@@ -173,6 +173,23 @@ func NewGlusterfsServer(cs clientset.Interface, namespace string) (config TestCo
} }
pod, ip = CreateStorageServer(cs, config) pod, ip = CreateStorageServer(cs, config)
service := &v1.Service{
ObjectMeta: metav1.ObjectMeta{
Name: config.Prefix + "-server",
},
Spec: v1.ServiceSpec{
Ports: []v1.ServicePort{
{
Protocol: v1.ProtocolTCP,
Port: 24007,
},
},
},
}
_, err := cs.CoreV1().Services(namespace).Create(context.TODO(), service, metav1.CreateOptions{})
framework.ExpectNoError(err, "failed to create service for Gluster server")
ginkgo.By("creating Gluster endpoints") ginkgo.By("creating Gluster endpoints")
endpoints := &v1.Endpoints{ endpoints := &v1.Endpoints{
TypeMeta: metav1.TypeMeta{ TypeMeta: metav1.TypeMeta{
@@ -199,7 +216,7 @@ func NewGlusterfsServer(cs clientset.Interface, namespace string) (config TestCo
}, },
}, },
} }
_, err := cs.CoreV1().Endpoints(namespace).Create(context.TODO(), endpoints, metav1.CreateOptions{}) _, err = cs.CoreV1().Endpoints(namespace).Create(context.TODO(), endpoints, metav1.CreateOptions{})
framework.ExpectNoError(err, "failed to create endpoints for Gluster server") framework.ExpectNoError(err, "failed to create endpoints for Gluster server")
return config, pod, ip return config, pod, ip

18
test/e2e/storage/drivers/in_tree.go
View File

@@ -324,14 +324,26 @@ func (v *glusterVolume) DeleteVolume() {
name := v.prefix + "-server" name := v.prefix + "-server"
framework.Logf("Deleting Gluster endpoints %q...", name) nameSpaceName := fmt.Sprintf("%s/%s", ns.Name, name)
framework.Logf("Deleting Gluster endpoints %s...", nameSpaceName)
err := cs.CoreV1().Endpoints(ns.Name).Delete(context.TODO(), name, metav1.DeleteOptions{}) err := cs.CoreV1().Endpoints(ns.Name).Delete(context.TODO(), name, metav1.DeleteOptions{})
if err != nil { if err != nil {
if !apierrors.IsNotFound(err) { if !apierrors.IsNotFound(err) {
framework.Failf("Gluster delete endpoints failed: %v", err) framework.Failf("Gluster deleting endpoint %s failed: %v", nameSpaceName, err)
} }
framework.Logf("Gluster endpoints %q not found, assuming deleted", name) framework.Logf("Gluster endpoints %q not found, assuming deleted", nameSpaceName)
} }
framework.Logf("Deleting Gluster service %s...", nameSpaceName)
err = cs.CoreV1().Services(ns.Name).Delete(context.TODO(), name, metav1.DeleteOptions{})
if err != nil {
if !apierrors.IsNotFound(err) {
framework.Failf("Gluster deleting service %s failed: %v", nameSpaceName, err)
}
framework.Logf("Gluster service %q not found, assuming deleted", nameSpaceName)
}
framework.Logf("Deleting Gluster server pod %q...", v.serverPod.Name) framework.Logf("Deleting Gluster server pod %q...", v.serverPod.Name)
err = e2epod.DeletePodWithWait(cs, v.serverPod) err = e2epod.DeletePodWithWait(cs, v.serverPod)
if err != nil { if err != nil {