-
Notifications
You must be signed in to change notification settings - Fork 50
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
4ea6545
commit eb0d760
Showing
7 changed files
with
217 additions
and
8 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,109 @@ | ||
| package server | ||
|
|
||
| import ( | ||
| "context" | ||
| "fmt" | ||
| "net/http" | ||
| "strings" | ||
|
|
||
| "github.com/andydunstall/pico/pkg/log" | ||
| "github.com/andydunstall/pico/serverv2/server/middleware" | ||
| "github.com/gin-gonic/gin" | ||
| "github.com/prometheus/client_golang/prometheus" | ||
| "go.uber.org/zap" | ||
| ) | ||
|
|
||
| // Server is the HTTP server for the proxy, which is used for both upstream | ||
| // listeners and downstream clients. | ||
| // | ||
| // /pico is reserved for upstream listeners, all other routes will be proxied. | ||
| type Server struct { | ||
| addr string | ||
|
|
||
| router *gin.Engine | ||
|
|
||
| httpServer *http.Server | ||
|
|
||
| logger *log.Logger | ||
| } | ||
|
|
||
| func NewServer( | ||
| addr string, | ||
| registry *prometheus.Registry, | ||
| logger *log.Logger, | ||
| ) *Server { | ||
| router := gin.New() | ||
| server := &Server{ | ||
| addr: addr, | ||
| router: router, | ||
| httpServer: &http.Server{ | ||
| Addr: addr, | ||
| Handler: router, | ||
| }, | ||
| logger: logger.WithSubsystem("proxy.server"), | ||
| } | ||
|
|
||
| // Recover from panics. | ||
| server.router.Use(gin.CustomRecovery(server.panicRoute)) | ||
|
|
||
| server.router.Use(middleware.NewLogger(logger)) | ||
| if registry != nil { | ||
| router.Use(middleware.NewMetrics("proxy", registry)) | ||
| } | ||
|
|
||
| server.registerRoutes() | ||
|
|
||
| return server | ||
| } | ||
|
|
||
| func (s *Server) Serve() error { | ||
| s.logger.Info("starting http server", zap.String("addr", s.addr)) | ||
|
|
||
| if err := s.httpServer.ListenAndServe(); err != nil && err != http.ErrServerClosed { | ||
| return fmt.Errorf("http serve: %w", err) | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| func (s *Server) Shutdown(ctx context.Context) error { | ||
| return s.httpServer.Shutdown(ctx) | ||
| } | ||
|
|
||
| func (s *Server) registerRoutes() { | ||
| pico := s.router.Group("/pico/v1") | ||
| pico.GET("/listener/:endpointID", s.listenerRoute) | ||
|
|
||
| // Handle not found routes, which includes all proxied endpoints. | ||
| s.router.NoRoute(s.notFoundRoute) | ||
| } | ||
|
|
||
| func (s *Server) listenerRoute(c *gin.Context) { | ||
| c.Status(http.StatusNotImplemented) | ||
| } | ||
|
|
||
| func (s *Server) proxyRoute(c *gin.Context) { | ||
| c.Status(http.StatusNotImplemented) | ||
| } | ||
|
|
||
| func (s *Server) notFoundRoute(c *gin.Context) { | ||
| // All /pico endpoints are reserved. All others are proxied. | ||
| if strings.HasPrefix(c.Request.URL.Path, "/pico") { | ||
| c.Status(http.StatusNotFound) | ||
| return | ||
| } | ||
| s.proxyRoute(c) | ||
| } | ||
|
|
||
| func (s *Server) panicRoute(c *gin.Context, err any) { | ||
| s.logger.Error( | ||
| "handler panic", | ||
| zap.String("path", c.FullPath()), | ||
| zap.Any("err", err), | ||
| ) | ||
| c.AbortWithStatus(http.StatusInternalServerError) | ||
| } | ||
|
|
||
| func init() { | ||
| // Disable Gin debug logs. | ||
| gin.SetMode(gin.ReleaseMode) | ||
| } |