Rename internal/logger to internal/ilogger

master
René Jochum 2 years ago
parent 60142e9052
commit 6c959bb2f8
Signed by: jochum
GPG Key ID: F7D906F5E51E8E5E

@ -16,7 +16,7 @@ import (
"google.golang.org/protobuf/types/known/emptypb" "google.golang.org/protobuf/types/known/emptypb"
"jochum.dev/jo-micro/auth2" "jochum.dev/jo-micro/auth2"
auth "jochum.dev/jo-micro/auth2" auth "jochum.dev/jo-micro/auth2"
iLogger "jochum.dev/jo-micro/router/internal/logger" "jochum.dev/jo-micro/router/internal/ilogger"
"jochum.dev/jo-micro/router/internal/proto/routerclientpb" "jochum.dev/jo-micro/router/internal/proto/routerclientpb"
"jochum.dev/jo-micro/router/internal/proto/routerserverpb" "jochum.dev/jo-micro/router/internal/proto/routerserverpb"
"jochum.dev/jo-micro/router/internal/util" "jochum.dev/jo-micro/router/internal/util"
@ -54,21 +54,21 @@ func (h *Handler) Init(service micro.Service, engine *gin.Engine, routerAuth aut
for { for {
services, err := util.FindByEndpoint(h.service, "RouterClientService.Routes") services, err := util.FindByEndpoint(h.service, "RouterClientService.Routes")
if err != nil { if err != nil {
iLogger.Logrus().Error(err) ilogger.Logrus().Error(err)
continue continue
} }
for _, s := range services { for _, s := range services {
iLogger.Logrus().WithField("service", s.Name).Tracef("Found service") ilogger.Logrus().WithField("service", s.Name).Tracef("Found service")
client := routerclientpb.NewRouterClientService(s.Name, h.service.Client()) client := routerclientpb.NewRouterClientService(s.Name, h.service.Client())
sCtx, err := auth2.ClientAuthRegistry().Plugin().ServiceContext(ctx) sCtx, err := auth2.ClientAuthRegistry().Plugin().ServiceContext(ctx)
if err != nil { if err != nil {
iLogger.Logrus().Error(err) ilogger.Logrus().Error(err)
continue continue
} }
resp, err := client.Routes(sCtx, &emptypb.Empty{}) resp, err := client.Routes(sCtx, &emptypb.Empty{})
if err != nil { if err != nil {
iLogger.Logrus().Error(err) ilogger.Logrus().Error(err)
// failure in getting routes, silently ignore // failure in getting routes, silently ignore
continue continue
} }
@ -88,7 +88,7 @@ func (h *Handler) Init(service micro.Service, engine *gin.Engine, routerAuth aut
pathMethod := fmt.Sprintf("%s:%s%s", route.GetMethod(), g.BasePath(), route.GetPath()) pathMethod := fmt.Sprintf("%s:%s%s", route.GetMethod(), g.BasePath(), route.GetPath())
path := fmt.Sprintf("%s%s", g.BasePath(), route.GetPath()) path := fmt.Sprintf("%s%s", g.BasePath(), route.GetPath())
if _, ok := h.routes[pathMethod]; !ok { if _, ok := h.routes[pathMethod]; !ok {
iLogger.Logrus(). ilogger.Logrus().
WithField("service", s.Name). WithField("service", s.Name).
WithField("endpoint", route.GetEndpoint()). WithField("endpoint", route.GetEndpoint()).
WithField("method", route.GetMethod()). WithField("method", route.GetMethod()).
@ -197,7 +197,7 @@ func (h *Handler) proxy(serviceName string, route *routerclientpb.RoutesReply_Ro
var response json.RawMessage var response json.RawMessage
err = h.service.Client().Call(ctx, req, &response) err = h.service.Client().Call(ctx, req, &response)
if err != nil { if err != nil {
iLogger.Logrus().Error(err) ilogger.Logrus().Error(err)
pErr := errors.FromError(err) pErr := errors.FromError(err)
code := int(http.StatusInternalServerError) code := int(http.StatusInternalServerError)

@ -15,7 +15,7 @@ import (
"jochum.dev/jo-micro/router/cmd/microrouterd/config" "jochum.dev/jo-micro/router/cmd/microrouterd/config"
"jochum.dev/jo-micro/router/cmd/microrouterd/handler" "jochum.dev/jo-micro/router/cmd/microrouterd/handler"
iLogger "jochum.dev/jo-micro/router/internal/logger" "jochum.dev/jo-micro/router/internal/ilogger"
"jochum.dev/jo-micro/router/internal/proto/routerserverpb" "jochum.dev/jo-micro/router/internal/proto/routerserverpb"
"jochum.dev/jo-micro/router/internal/util" "jochum.dev/jo-micro/router/internal/util"
) )
@ -28,7 +28,7 @@ func internalService(routerHandler *handler.Handler) {
micro.Version(config.Version), micro.Version(config.Version),
micro.Action(func(c *cli.Context) error { micro.Action(func(c *cli.Context) error {
if err := auth2.ClientAuthRegistry().Init(c, srv); err != nil { if err := auth2.ClientAuthRegistry().Init(c, srv); err != nil {
iLogger.Logrus().Fatal(err) ilogger.Logrus().Fatal(err)
} }
routerserverpb.RegisterRouterServerServiceHandler(srv.Server(), routerHandler) routerserverpb.RegisterRouterServerServiceHandler(srv.Server(), routerHandler)
@ -51,17 +51,17 @@ func internalService(routerHandler *handler.Handler) {
// Run server // Run server
if err := srv.Run(); err != nil { if err := srv.Run(); err != nil {
iLogger.Logrus().Fatal(err) ilogger.Logrus().Fatal(err)
} }
// Stop the handler // Stop the handler
if err := routerHandler.Stop(); err != nil { if err := routerHandler.Stop(); err != nil {
iLogger.Logrus().Fatal(err) ilogger.Logrus().Fatal(err)
} }
// Stop the client/service auth plugin // Stop the client/service auth plugin
if err := auth2.ClientAuthRegistry().Stop(); err != nil { if err := auth2.ClientAuthRegistry().Stop(); err != nil {
iLogger.Logrus().Fatal(err) ilogger.Logrus().Fatal(err)
} }
} }
@ -72,7 +72,7 @@ func main() {
routerAuthReg := auth2.RouterAuthRegistry() routerAuthReg := auth2.RouterAuthRegistry()
flags := iLogger.AppendFlags(routerAuthReg.AppendFlags(auth2.ClientAuthRegistry().AppendFlags([]cli.Flag{ flags := ilogger.AppendFlags(routerAuthReg.AppendFlags(auth2.ClientAuthRegistry().AppendFlags([]cli.Flag{
// General // General
&cli.BoolFlag{ &cli.BoolFlag{
Name: "router_debugmode", Name: "router_debugmode",
@ -112,14 +112,14 @@ func main() {
micro.Flags(flags...), micro.Flags(flags...),
micro.Action(func(c *cli.Context) error { micro.Action(func(c *cli.Context) error {
// Start the logger // Start the logger
if err := iLogger.Start(c); err != nil { if err := ilogger.Start(c); err != nil {
log.Fatal(err) log.Fatal(err)
return err return err
} }
// Initialize the Auth Plugin over RouterAuthRegistry // Initialize the Auth Plugin over RouterAuthRegistry
if err := routerAuthReg.Init(c, srv); err != nil { if err := routerAuthReg.Init(c, srv); err != nil {
iLogger.Logrus().Fatal(err) ilogger.Logrus().Fatal(err)
} }
// Initialize GIN // Initialize GIN
@ -132,15 +132,15 @@ func main() {
// Initalize the Handler // Initalize the Handler
if err := routerHandler.Init(srv, r, routerAuthReg.Plugin(), c.Int("router_refresh")); err != nil { if err := routerHandler.Init(srv, r, routerAuthReg.Plugin(), c.Int("router_refresh")); err != nil {
iLogger.Logrus().Fatal(err) ilogger.Logrus().Fatal(err)
} }
// Add middlewares to gin // Add middlewares to gin
r.Use(ginlogrus.Logger(iLogger.Logrus()), gin.Recovery()) r.Use(ginlogrus.Logger(ilogger.Logrus()), gin.Recovery())
// Register gin with micro // Register gin with micro
if err := micro.RegisterHandler(srv.Server(), r); err != nil { if err := micro.RegisterHandler(srv.Server(), r); err != nil {
iLogger.Logrus().Fatal(err) ilogger.Logrus().Fatal(err)
} }
return nil return nil
@ -152,16 +152,16 @@ func main() {
// Run server // Run server
if err := srv.Run(); err != nil { if err := srv.Run(); err != nil {
iLogger.Logrus().Fatal(err) ilogger.Logrus().Fatal(err)
} }
// Stop the plugin in RouterAuthRegistry // Stop the plugin in RouterAuthRegistry
if err := routerAuthReg.Stop(); err != nil { if err := routerAuthReg.Stop(); err != nil {
iLogger.Logrus().Fatal(err) ilogger.Logrus().Fatal(err)
} }
// Stop the logger // Stop the logger
if err := iLogger.Stop(); err != nil { if err := ilogger.Stop(); err != nil {
iLogger.Logrus().Fatal(err) ilogger.Logrus().Fatal(err)
} }
} }

@ -1,4 +1,4 @@
package logger package ilogger
import ( import (
"fmt" "fmt"
Loading…
Cancel
Save