diff options
Diffstat (limited to 'plugin/kubernetes')
| -rw-r--r-- | plugin/kubernetes/controller_test.go | 8 | ||||
| -rw-r--r-- | plugin/kubernetes/object/object.go | 6 |
2 files changed, 10 insertions, 4 deletions
diff --git a/plugin/kubernetes/controller_test.go b/plugin/kubernetes/controller_test.go index 99d7e92f7..7e1f9dd29 100644 --- a/plugin/kubernetes/controller_test.go +++ b/plugin/kubernetes/controller_test.go @@ -78,7 +78,7 @@ func generateEndpoints(cidr string, client kubernetes.Interface) { }, } ep.ObjectMeta.Name = "svc" + strconv.Itoa(count) - _, err = client.Core().Endpoints("testns").Create(ep) + _, err = client.CoreV1().Endpoints("testns").Create(ep) count += 1 } } @@ -121,7 +121,7 @@ func generateSvcs(cidr string, svcType string, client kubernetes.Interface) { } func createClusterIPSvc(suffix int, client kubernetes.Interface, ip net.IP) { - client.Core().Services("testns").Create(&api.Service{ + client.CoreV1().Services("testns").Create(&api.Service{ ObjectMeta: meta.ObjectMeta{ Name: "svc" + strconv.Itoa(suffix), Namespace: "testns", @@ -138,7 +138,7 @@ func createClusterIPSvc(suffix int, client kubernetes.Interface, ip net.IP) { } func createHeadlessSvc(suffix int, client kubernetes.Interface, ip net.IP) { - client.Core().Services("testns").Create(&api.Service{ + client.CoreV1().Services("testns").Create(&api.Service{ ObjectMeta: meta.ObjectMeta{ Name: "hdls" + strconv.Itoa(suffix), Namespace: "testns", @@ -150,7 +150,7 @@ func createHeadlessSvc(suffix int, client kubernetes.Interface, ip net.IP) { } func createExternalSvc(suffix int, client kubernetes.Interface, ip net.IP) { - client.Core().Services("testns").Create(&api.Service{ + client.CoreV1().Services("testns").Create(&api.Service{ ObjectMeta: meta.ObjectMeta{ Name: "external" + strconv.Itoa(suffix), Namespace: "testns", diff --git a/plugin/kubernetes/object/object.go b/plugin/kubernetes/object/object.go index 7a6ffac12..3809aaaf4 100644 --- a/plugin/kubernetes/object/object.go +++ b/plugin/kubernetes/object/object.go @@ -107,3 +107,9 @@ func (e *Empty) GetClusterName() string { return "" } // SetClusterName implements the metav1.Object interface. func (e *Empty) SetClusterName(clusterName string) {} + +// GetManagedFields implements the metav1.Object interface. +func (e *Empty) GetManagedFields() []v1.ManagedFieldsEntry { return nil } + +// SetManagedFields implements the metav1.Object interface. +func (e *Empty) SetManagedFields(managedFields []v1.ManagedFieldsEntry) {} |