Close closes the server.
()
| 418 | |
| 419 | // Close closes the server. |
| 420 | func (c *Component) Close() { |
| 421 | c.cancelCtx() |
| 422 | |
| 423 | c.tcpListenersMu.Lock() |
| 424 | defer c.tcpListenersMu.Unlock() |
| 425 | for _, l := range c.tcpListeners { |
| 426 | err := l.Close() |
| 427 | if err != nil && c.ctx.Err() == nil { |
| 428 | c.logger.WithError(err).Errorf("Error while stopping to listen on %s", l.Addr()) |
| 429 | continue |
| 430 | } |
| 431 | c.logger.Debugf("Stopped listening on %s", l.Addr()) |
| 432 | } |
| 433 | |
| 434 | if c.loopback != nil { |
| 435 | c.logger.Debug("Stopping gRPC client...") |
| 436 | c.loopback.Close() |
| 437 | c.logger.Debug("Stopped gRPC client") |
| 438 | } |
| 439 | |
| 440 | if c.GRPC != nil { |
| 441 | c.logger.Debug("Stopping gRPC server...") |
| 442 | c.GRPC.Stop() |
| 443 | c.logger.Debug("Stopped gRPC server") |
| 444 | } |
| 445 | } |
| 446 | |
| 447 | // AllowInsecureForCredentials returns `true` if the component was configured to allow transmission of credentials |
| 448 | // over insecure transports. |