diff --git a/e2e/sink/cmd/main.go b/e2e/sink/cmd/main.go index 5fd6d062..91df19b0 100644 --- a/e2e/sink/cmd/main.go +++ b/e2e/sink/cmd/main.go @@ -1,6 +1,8 @@ package main import ( + "os" + "github.com/kyma-project/eventing-manager/sink/internal/handler" "go.uber.org/zap" ) @@ -12,8 +14,13 @@ func main() { } defer logger.Sync() + port := os.Getenv("PORT") + if port == "" { + port = "8080" // default port + } + sHandler := handler.NewSinkHandler(logger) - err = sHandler.Start() + err = sHandler.Start(port) if err != nil { logger.Error("failed to start SinkHandler", zap.Error(err)) } diff --git a/e2e/sink/internal/handler/handler.go b/e2e/sink/internal/handler/handler.go index 9813158d..2ebbeeb7 100644 --- a/e2e/sink/internal/handler/handler.go +++ b/e2e/sink/internal/handler/handler.go @@ -34,12 +34,12 @@ func NewSinkHandler(logger *zap.Logger) *SinkHandler { } } -func (h *SinkHandler) Start() error { +func (h *SinkHandler) Start(port string) error { router := mux.NewRouter() router.HandleFunc("/events", h.StoreEvent).Methods(http.MethodPost) router.HandleFunc("/events/{eventID}", h.GetEvent).Methods(http.MethodGet) - return http.ListenAndServe(":8080", router) + return http.ListenAndServe(":"+port, router) } type sinkEvent struct {