main.go

Documentation: edge-infra.dev/cmd/edge/logging/logreplay

     1  package main
     2  
     3  import (
     4  	"log/slog"
     5  	"os"
     6  
     7  	"edge-infra.dev/pkg/edge/logging/logreplay"
     8  )
     9  
    10  func main() {
    11  	jh := slog.NewJSONHandler(os.Stdout, &slog.HandlerOptions{
    12  		ReplaceAttr: func(_ []string, a slog.Attr) slog.Attr {
    13  			// use "message" instead of "msg" for the output since "message" has a special meaning in GCP
    14  			if a.Key == slog.MessageKey {
    15  				a.Key = "message"
    16  			}
    17  			return a
    18  		},
    19  	})
    20  
    21  	log := slog.New(jh)
    22  
    23  	// setup logger and read environment variables
    24  	cfg, err := logreplay.NewConfig()
    25  	if err != nil {
    26  		log.Error("config err", "could not create config", err)
    27  		os.Exit(1)
    28  	}
    29  
    30  	// setup the log replay client
    31  	lrc, err := logreplay.New(cfg)
    32  	if err != nil {
    33  		log.Error("k8s client error", "could not create log replay client", err)
    34  		os.Exit(1)
    35  	}
    36  
    37  	// run the log replay
    38  	if err = lrc.Run(); err != nil {
    39  		log.Error("log replay err", "error", err)
    40  		os.Exit(1)
    41  	}
    42  }
    43
View as plain text