diff --git a/pkg/adapter/adapter.go b/pkg/adapter/adapter.go index cd1485820..243e4108a 100644 --- a/pkg/adapter/adapter.go +++ b/pkg/adapter/adapter.go @@ -20,6 +20,7 @@ import ( "context" "fmt" "net/http" + "time" cloudevents "github.com/cloudevents/sdk-go/v2" "go.uber.org/zap" @@ -79,8 +80,10 @@ func (a *gitHubAdapter) Start(ctx context.Context) error { done := make(chan bool, 1) server := &http.Server{ - Addr: ":" + a.port, - Handler: a.newRouter(), + ReadTimeout: 10 * time.Second, + ReadHeaderTimeout: 2 * time.Second, + Addr: ":" + a.port, + Handler: a.newRouter(), } go common.GracefulShutdown(server, a.logger, ctx.Done(), done) diff --git a/pkg/mtadapter/adapter.go b/pkg/mtadapter/adapter.go index b9cc1020a..6bf8872c5 100644 --- a/pkg/mtadapter/adapter.go +++ b/pkg/mtadapter/adapter.go @@ -20,6 +20,7 @@ import ( "context" "fmt" "net/http" + "time" cloudevents "github.com/cloudevents/sdk-go/v2" "go.uber.org/zap" @@ -87,8 +88,10 @@ func NewAdapter(ctx context.Context, processed adapter.EnvConfigAccessor, ceClie func (a *gitHubAdapter) Start(ctx context.Context) error { // Start our multi-tenant server receiving GitHub events server := &http.Server{ - Addr: fmt.Sprintf(":%d", a.port), - Handler: a.router, + ReadTimeout: 10 * time.Second, + ReadHeaderTimeout: 2 * time.Second, + Addr: fmt.Sprintf(":%d", a.port), + Handler: a.router, } done := make(chan bool, 1)