Skip to content

Commit

Permalink
Address feedback on backwards compatibility and full cross feature fu…
Browse files Browse the repository at this point in the history
…nctionality.
  • Loading branch information
tomelliot16 committed Oct 9, 2023
1 parent 00dad56 commit 7390b98
Showing 1 changed file with 16 additions and 4 deletions.
20 changes: 16 additions & 4 deletions pkg/metrics/server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -103,8 +103,7 @@ type Options struct {
TLSOpts []func(*tls.Config)

// ListenConfig contains options for listening to an address on the metric server.
// Note: This does not work with SecureServing=true
ListenConfig net.ListenConfig
ListenConfig *net.ListenConfig
}

// Filter is a func that is added around metrics and extra handlers on the metrics server.
Expand Down Expand Up @@ -253,7 +252,11 @@ func (s *defaultServer) Start(ctx context.Context) error {

func (s *defaultServer) createListener(ctx context.Context, log logr.Logger) (net.Listener, error) {
if !s.options.SecureServing {
return s.options.ListenConfig.Listen(context.Background(), "tcp", s.options.BindAddress)
if s.options.ListenConfig == nil {
return net.Listen("tcp", s.options.BindAddress)
} else {

Check warning on line 257 in pkg/metrics/server/server.go

View workflow job for this annotation

GitHub Actions / lint

indent-error-flow: if block ends with a return statement, so drop this else and outdent its block (revive)
return s.options.ListenConfig.Listen(context.Background(), "tcp", s.options.BindAddress)
}
}

cfg := &tls.Config{ //nolint:gosec
Expand Down Expand Up @@ -306,7 +309,16 @@ func (s *defaultServer) createListener(ctx context.Context, log logr.Logger) (ne
cfg.Certificates = []tls.Certificate{keyPair}
}

return tls.Listen("tcp", s.options.BindAddress, cfg)
var l net.Listener
var err error

if s.options.ListenConfig == nil {
l, err = net.Listen("tcp", s.options.BindAddress)
} else {
l, err = s.options.ListenConfig.Listen(context.Background(), "tcp", s.options.BindAddress)
}

return tls.NewListener(l, cfg), err
}

func (s *defaultServer) GetBindAddr() string {
Expand Down

0 comments on commit 7390b98

Please sign in to comment.