mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-14 06:15:45 +00:00
Merge pull request #685 from smarterclayton/error_on_empty_service
Cleanly delete service without endpoints key
This commit is contained in:
commit
e10d85efce
@ -274,6 +274,10 @@ func (registry *EtcdRegistry) GetService(name string) (*api.Service, error) {
|
||||
return &svc, nil
|
||||
}
|
||||
|
||||
func makeServiceEndpointsKey(name string) string {
|
||||
return "/registry/services/endpoints/" + name
|
||||
}
|
||||
|
||||
// DeleteService deletes a Service specified by its name.
|
||||
func (registry *EtcdRegistry) DeleteService(name string) error {
|
||||
key := makeServiceKey(name)
|
||||
@ -284,9 +288,12 @@ func (registry *EtcdRegistry) DeleteService(name string) error {
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
key = "/registry/services/endpoints/" + name
|
||||
key = makeServiceEndpointsKey(name)
|
||||
_, err = registry.etcdClient.Delete(key, true)
|
||||
return err
|
||||
if !tools.IsEtcdNotFound(err) {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
// UpdateService replaces an existing Service.
|
||||
|
Loading…
Reference in New Issue
Block a user