initDiscoveryService initializes discovery server on plain text port.
()
| 694 | |
| 695 | // initDiscoveryService initializes discovery server on plain text port. |
| 696 | func (s *Server) initDiscoveryService() { |
| 697 | log.Infof("starting discovery service") |
| 698 | // Implement EnvoyXdsServer grace shutdown |
| 699 | s.addStartFunc("xds server", func(stop <-chan struct{}) error { |
| 700 | log.Infof("Starting ADS server") |
| 701 | s.XDSServer.Start(stop) |
| 702 | return nil |
| 703 | }) |
| 704 | } |
| 705 | |
| 706 | // Wait for the stop, and do cleanups |
| 707 | func (s *Server) waitForShutdown(stop <-chan struct{}) { |
no test coverage detected