return nil
		})
		s.addTerminatingStartFunc("status reporter", func(stop <-chan struct{}) error {
			if writeStatus {
				s.statusReporter.Start(s.kubeClient.Kube(), args.Namespace, args.PodName, stop)
			}
			return nil
		})
		s.XDSServer.StatusReporter = s.statusReporter
	}
	if writeStatus {
		s.addTerminatingStartFunc("status distribution", func(stop <-chan struct{}) error {

	s.readinessProbes[name] = fn
}

// addTerminatingStartFunc adds a function that should terminate before the serve shuts down
// This is useful to do cleanup activities
// This is does not guarantee they will terminate gracefully - best effort only
// Function should be synchronous; once it returns it is considered "done"
func (s *Server) addTerminatingStartFunc(name string, fn server.Component) {