14759730518

Committed 30 Apr 2025 04:28PM UTC coverage: 68.056%. Remained the same

Build # 14759730518

Build Type

Pull #87

github

Committed by

seapasulli

Commit Message

update schema validation to include annotations

Pull Request Pull Request #87: Expose annotations for service

Run Details

245 of 360 relevant lines covered (68.06%)

4.24 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/main.go

package main

import (
        "encoding/json"
        "flag"
        "os"
        "os/signal"
        "syscall"

        "net/http"
        _ "net/http/pprof"

        "github.com/prometheus/client_golang/prometheus/promhttp"
        log "github.com/sirupsen/logrus"
)

var (
        Version string
)

func main() {
        cfgFile := flag.String("config", "", "Path to a config file")
        flag.Parse()

        cfg, err := configLoad(*cfgFile)
        if err != nil {
                log.Fatal(err)
        }

        if cfg.ListenPprof != "" {
                go func() {
                        if err := http.ListenAndServe(cfg.ListenPprof, nil); err != nil {
                                log.Fatalf("Unable to listen on %s: %s", cfg.ListenPprof, err)
                        }
                }()
        }

        go func() {
                http.Handle("/metrics", promhttp.Handler())
                if err := http.ListenAndServe(cfg.ListenMetricsAddress, nil); err != nil {
                        log.Fatalf("Unable to listen on %s: %s", cfg.ListenMetricsAddress, err)
                }
        }()

        lvl, err := log.ParseLevel(cfg.LogLevel)
        if err != nil {
                log.Fatalf("Unable to parse log level: %s", err)
        }

        log.SetLevel(lvl)

        cfgJSON, _ := json.Marshal(cfg)
        log.Warnf("Effective config: %+v", string(cfgJSON))

        proc := newProcessor(*cfg)

        if err = proc.run(); err != nil {
                log.Fatalf("Unable to start: %s", err)
        }

        log.Warnf("Listening on %s, sending to %s", cfg.Listen, cfg.Target)
        log.Warnf("Started v%s", Version)

        ch := make(chan os.Signal, 1)
        signal.Notify(ch, syscall.SIGTERM, os.Interrupt)
        <-ch

        log.Warn("Shutting down, draining requests")
        if err = proc.close(); err != nil {
                log.Errorf("Error during shutdown: %s", err)
        }

        log.Warnf("Finished")
}

1	package main
2
3	import (
4	"encoding/json"
5	"flag"
6	"os"
7	"os/signal"
8	"syscall"
9
10	"net/http"
11	_ "net/http/pprof"
12
13	"github.com/prometheus/client_golang/prometheus/promhttp"
14	log "github.com/sirupsen/logrus"
15	)
16
17	var (
18	Version string
19	)
20
21	func main() {	×
22	cfgFile := flag.String("config", "", "Path to a config file")	×
23	flag.Parse()	×
24		×
25	cfg, err := configLoad(*cfgFile)	×
26	if err != nil {	×
27	log.Fatal(err)	×
28	}	×
29
30	if cfg.ListenPprof != "" {	×
31	go func() {	×
32	if err := http.ListenAndServe(cfg.ListenPprof, nil); err != nil {	×
33	log.Fatalf("Unable to listen on %s: %s", cfg.ListenPprof, err)	×
34	}	×
35	}()
36	}
37
38	go func() {	×
39	http.Handle("/metrics", promhttp.Handler())	×
40	if err := http.ListenAndServe(cfg.ListenMetricsAddress, nil); err != nil {	×
41	log.Fatalf("Unable to listen on %s: %s", cfg.ListenMetricsAddress, err)	×
42	}	×
43	}()
44
45	lvl, err := log.ParseLevel(cfg.LogLevel)	×
46	if err != nil {	×
47	log.Fatalf("Unable to parse log level: %s", err)	×
48	}	×
49
50	log.SetLevel(lvl)	×
51		×
52	cfgJSON, _ := json.Marshal(cfg)	×
53	log.Warnf("Effective config: %+v", string(cfgJSON))	×
54		×
55	proc := newProcessor(*cfg)	×
56		×
57	if err = proc.run(); err != nil {	×
58	log.Fatalf("Unable to start: %s", err)	×
59	}	×
60
61	log.Warnf("Listening on %s, sending to %s", cfg.Listen, cfg.Target)	×
62	log.Warnf("Started v%s", Version)	×
63		×
64	ch := make(chan os.Signal, 1)	×
65	signal.Notify(ch, syscall.SIGTERM, os.Interrupt)	×
66	<-ch	×
67		×
68	log.Warn("Shutting down, draining requests")	×
69	if err = proc.close(); err != nil {	×
70	log.Errorf("Error during shutdown: %s", err)	×
71	}	×
72
73	log.Warnf("Finished")	×
74	}

blind-oracle / cortex-tenant / 14759730518

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous