in logsapi/subscribe.go [66:83]
func (lc *Client) startHTTPServer() (string, error) {
listener, err := net.Listen("tcp", lc.listenerAddr)
if err != nil {
return "", fmt.Errorf("failed to listen on %s: %w", lc.listenerAddr, err)
}
addr := listener.Addr().String()
go func() {
lc.logger.Infof("Extension listening for Lambda Logs API events on %s", addr)
if err := lc.server.Serve(listener); err != nil && !errors.Is(err, http.ErrServerClosed) {
lc.logger.Errorf("Error upon Logs API server start : %v", err)
}
}()
return addr, nil
}