Skip to content
This repository has been archived by the owner on Apr 30, 2024. It is now read-only.

[main] Upgrade to latest dependencies #539

Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ require (
k8s.io/client-go v0.26.5
knative.dev/hack v0.0.0-20230524013611-5812c57cc1ac
knative.dev/networking v0.0.0-20230524170920-2a2f7d2d7c60
knative.dev/pkg v0.0.0-20230524013411-ec20442c6ead
knative.dev/pkg v0.0.0-20230525143525-9bda38b21643
)

require (
Expand Down
4 changes: 2 additions & 2 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -1163,8 +1163,8 @@ knative.dev/hack v0.0.0-20230524013611-5812c57cc1ac h1:XQrhtfWPsyuxwSxv4GhcFnqZh
knative.dev/hack v0.0.0-20230524013611-5812c57cc1ac/go.mod h1:yk2OjGDsbEnQjfxdm0/HJKS2WqTLEFg/N6nUs6Rqx3Q=
knative.dev/networking v0.0.0-20230524170920-2a2f7d2d7c60 h1:vErunGWa8pZNriLFaE4UbgdqNECKF7gJTYZE+DdOuOE=
knative.dev/networking v0.0.0-20230524170920-2a2f7d2d7c60/go.mod h1:ieNknBTSWl441656hZF1JNHbTXbab138w8qPEwuwC0Q=
knative.dev/pkg v0.0.0-20230524013411-ec20442c6ead h1:dcBDhkP6hd9VaV9nLukg75bIrvJs4YiSVOv0h2evOFc=
knative.dev/pkg v0.0.0-20230524013411-ec20442c6ead/go.mod h1:dqC6IrvyBE7E+oZocs5PkVhq1G59pDTA7r8U17EAKMk=
knative.dev/pkg v0.0.0-20230525143525-9bda38b21643 h1:DoGHeW3ckr509v87NcYSSuRHEnxKIxyJxWrrDO/71CY=
knative.dev/pkg v0.0.0-20230525143525-9bda38b21643/go.mod h1:dqC6IrvyBE7E+oZocs5PkVhq1G59pDTA7r8U17EAKMk=
rsc.io/binaryregexp v0.2.0/go.mod h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8=
rsc.io/quote/v3 v3.1.0/go.mod h1:yEA65RcK8LyAZtP9Kv3t0HmxON59tX3rD+tICJqUlj0=
rsc.io/sampler v1.3.0/go.mod h1:T1hPZKmBbMNahiBKFy5HrXp6adAjACjK9JXDnKaTXpA=
Expand Down
45 changes: 34 additions & 11 deletions vendor/knative.dev/pkg/webhook/webhook.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@ import (
"errors"
"fmt"
"html"
"log"
"net"
"net/http"
"time"

Expand Down Expand Up @@ -94,6 +96,9 @@ type Webhook struct {

// The TLS configuration to use for serving (or nil for non-TLS)
tlsConfig *tls.Config

// testListener is only used in testing so we don't get port conflicts
testListener net.Listener
}

// New constructs a Webhook
Expand Down Expand Up @@ -196,7 +201,6 @@ func New(
default:
return nil, fmt.Errorf("unknown webhook controller type: %T", controller)
}

}

return
Expand All @@ -209,6 +213,15 @@ func (wh *Webhook) InformersHaveSynced() {
wh.Logger.Info("Informers have been synced, unblocking admission webhooks.")
}

type zapWrapper struct {
logger *zap.SugaredLogger
}

func (z *zapWrapper) Write(p []byte) (n int, err error) {
z.logger.Errorw(string(p))
return len(p), nil
}

// Run implements the admission controller run loop.
func (wh *Webhook) Run(stop <-chan struct{}) error {
logger := wh.Logger
Expand All @@ -220,24 +233,34 @@ func (wh *Webhook) Run(stop <-chan struct{}) error {
}

server := &http.Server{
ErrorLog: log.New(&zapWrapper{logger}, "", 0),
Handler: drainer,
Addr: fmt.Sprint(":", wh.Options.Port),
TLSConfig: wh.tlsConfig,
ReadHeaderTimeout: time.Minute, //https://medium.com/a-journey-with-go/go-understand-and-mitigate-slowloris-attack-711c1b1403f6
}

var serve = server.ListenAndServe

if server.TLSConfig != nil && wh.testListener != nil {
serve = func() error {
return server.ServeTLS(wh.testListener, "", "")
}
} else if server.TLSConfig != nil {
serve = func() error {
return server.ListenAndServeTLS("", "")
}
} else if wh.testListener != nil {
serve = func() error {
return server.Serve(wh.testListener)
}
}

eg, ctx := errgroup.WithContext(ctx)
eg.Go(func() error {
if server.TLSConfig != nil {
if err := server.ListenAndServeTLS("", ""); err != nil && !errors.Is(err, http.ErrServerClosed) {
logger.Errorw("ListenAndServeTLS for admission webhook returned error", zap.Error(err))
return err
}
} else {
if err := server.ListenAndServe(); err != nil && !errors.Is(err, http.ErrServerClosed) {
logger.Errorw("ListenAndServe for admission webhook returned error", zap.Error(err))
return err
}
if err := serve(); err != nil && !errors.Is(err, http.ErrServerClosed) {
logger.Errorw("ListenAndServe for admission webhook returned error", zap.Error(err))
return err
}
return nil
})
Expand Down
2 changes: 1 addition & 1 deletion vendor/modules.txt
Original file line number Diff line number Diff line change
Expand Up @@ -934,7 +934,7 @@ knative.dev/networking/test/test_images/runtime/handlers
knative.dev/networking/test/test_images/timeout
knative.dev/networking/test/test_images/wsserver
knative.dev/networking/test/types
# knative.dev/pkg v0.0.0-20230524013411-ec20442c6ead
# knative.dev/pkg v0.0.0-20230525143525-9bda38b21643
## explicit; go 1.18
knative.dev/pkg/apis
knative.dev/pkg/apis/duck
Expand Down
Loading