Method Stop

scheduler/scheduler.go:327–380

Stop stops the scheduler server.

()

// Stop stops the scheduler server.
func (s *Server) Stop() {
	// Stop dynconfig.
	if err := s.dynconfig.Stop(); err != nil {
		logger.Errorf("stop dynconfig failed %s", err.Error())
	} else {
		logger.Info("stop dynconfig closed")
	}

	// Stop resource.
	s.resource.Stop()
	logger.Info("stop resource closed")

	// Stop GC.
	s.gc.Stop()
	logger.Info("gc closed")

	// Stop metrics server.
	if s.metricsServer != nil {
		if err := s.metricsServer.Shutdown(context.Background()); err != nil {
			logger.Errorf("metrics server failed to stop: %s", err.Error())
		} else {
			logger.Info("metrics server closed under request")
		}
	}

	// Stop announcer.
	s.announcer.Stop()
	logger.Info("stop announcer closed")

	// Stop manager client.
	if s.managerClient != nil {
		if err := s.managerClient.Close(); err != nil {
			logger.Errorf("manager client failed to stop: %s", err.Error())
		} else {
			logger.Info("manager client closed")
		}
	}

	// Stop GRPC server.
	stopped := make(chan struct{})
	go func() {
		s.grpcServer.GracefulStop()
		logger.Info("grpc server closed under request")
		close(stopped)
	}()

	t := time.NewTimer(gracefulStopTimeout)
	select {
	case <-t.C:
		s.grpcServer.Stop()
	case <-stopped:
		t.Stop()
	}
}