Method Shutdown

internal/discovery/discovery.go:280–318

Shutdown will stop any background maintenance of network activity for this memberlist, causing it to appear "dead". A leave message will not be broadcasted prior, so the cluster being left will have to detect this node's Shutdown using probing. If you wish to more gracefully exit the cluster, call L

()

//
// This method is safe to call multiple times.
func (d *Discovery) Shutdown() error {
	select {
	case <-d.ctx.Done():
		return nil
	default:
	}
	d.cancel()
	// We don't do that in a goroutine with a timeout mechanism
	// because this mechanism may cause goroutine leak.
	d.wg.Wait()

	if d.memberlist != nil {
		// Leave will broadcast a leave message but will not shutdown the background
		// listeners, meaning the node will continue participating in gossip and state
		// updates.
		d.log.V(2).Printf("[INFO] Broadcasting a leave message")
		if err := d.memberlist.Leave(d.config.LeaveTimeout); err != nil {
			d.log.V(3).Printf("[WARN] memberlist.Leave returned an error: %v", err)
		}
	}

	if d.serviceDiscovery != nil {
		defer func(serviceDiscovery service_discovery.ServiceDiscovery) {
			err := serviceDiscovery.Close()
			if err != nil {
				d.log.V(3).Printf("[ERROR] ServiceDiscovery.Close returned an error: %v", err)
			}
		}(d.serviceDiscovery)

		if err := d.serviceDiscovery.Deregister(); err != nil {
			d.log.V(3).Printf("[ERROR] ServiceDiscovery.Deregister returned an error: %v", err)
		}
	}

	if d.memberlist != nil {
		return d.memberlist.Shutdown()
	}
	return nil
}