grpcd/main.go at default · sonic-original-software/grpcd · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
//revive:disable:package-comments
package main

import (
	"context"
	"fmt"
	"log/slog"
	"os"

	service_lib "git.sonicoriginal.software/grpcd-go/service"
	"git.sonicoriginal.software/grpcd/internal/service"
	"git.sonicoriginal.software/grpcd/internal/storage/resolver"

	grpcd "git.sonicoriginal.software/grpcd-protos"

	foundationotel "git.sonicoriginal.software/grpc-foundation/otel"
	"git.sonicoriginal.software/grpc-protos/diagnostics"
	"git.sonicoriginal.software/grpc-protos/info"

	"go.opentelemetry.io/otel"
	"google.golang.org/grpc"
)

const serviceName = "grpcd"

func main() {
	ctx := context.Background()

	log, shutdown, err := foundationotel.Init(ctx, serviceName)
	if err != nil {
		fmt.Fprintf(os.Stderr, "failed to initialize otel: %v\n", err)
		os.Exit(1)
	}
	defer shutdown(ctx)

	// Create OpenTelemetry meter
	meter := otel.Meter(serviceName)

	store, err := resolver.Resolve(ctx, log)
	if err != nil {
		log.Error("Could not resolve storage backend", slog.Any("error", err))
		os.Exit(1)
	}

	grpcdServer := service.NewGRPCDServer(log, store, meter)

	// Start gRPC server (blocking)
	err = service_lib.Run(
		ctx, serviceName, log,
		func(s grpc.ServiceRegistrar) {
			info.RegisterInfoServiceServer(s, grpcdServer)
			diagnostics.RegisterDiagnosticsServiceServer(s, grpcdServer)

			grpcd.RegisterGRPCDServiceServer(s, grpcdServer)
		},
		nil,
	)
	if err != nil {
		log.Error("Server failed", slog.Any("error", err))
		os.Exit(1)
	}
}