add telemetry error

Author: kamushadenes

cmd/dockersync/cmd/mergeYaml.go

@@ -11,7 +11,6 @@ import (
 
 var yamlFiles []string
 
-// mergeYamlCmd represents the mergeYaml command
 var mergeYamlCmd = &cobra.Command{
 	Use:   "mergeYaml",
 	Short: "Merge two yaml files",

internal/sync/images.go

@@ -1,12 +1,17 @@
 package sync
 
 import (
+	"context"
+
+	"github.com/Altinity/docker-sync/internal/telemetry"
 	"github.com/Altinity/docker-sync/structs"
 	"github.com/rs/zerolog/log"
+	"go.opentelemetry.io/otel/attribute"
+	"go.opentelemetry.io/otel/metric"
 	"go.uber.org/multierr"
 )
 
-func SyncImage(image *structs.Image) error {
+func SyncImage(ctx context.Context, image *structs.Image) error {
 	var merr error
 
 	tags, err := image.GetTags()
@@ -18,6 +23,18 @@ func SyncImage(image *structs.Image) error {
 		if serr := SyncTag(image, tag); serr != nil {
 			errs := multierr.Errors(serr)
 			if len(errs) > 0 {
+				telemetry.Errors.Add(ctx, int64(len(errs)),
+					metric.WithAttributes(
+						attribute.KeyValue{
+							Key:   "image",
+							Value: attribute.StringValue(image.Source),
+						},
+						attribute.KeyValue{
+							Key:   "tag",
+							Value: attribute.StringValue(tag),
+						},
+					),
+				)
 				log.Error().
 					Errs("errors", errs).
 					Msg("Failed to sync tag")

internal/telemetry/metrics.go

@@ -7,14 +7,6 @@ import (
 
 var meter = otel.Meter("docker-sync")
 
-// ReceivedBytes track the total number of bytes received.
-var ReceivedBytes = must(meter.Int64Counter("received_bytes",
-	metric.WithDescription("The total number of bytes received"),
-	metric.WithUnit("By"),
-))
-
-// SentBytes track the total number of bytes sent.
-var SentBytes = must(meter.Int64Counter("sent_bytes",
-	metric.WithDescription("The total number of bytes sent"),
-	metric.WithUnit("By"),
+var Errors = must(meter.Int64Counter("errors",
+	metric.WithDescription("The total number of errors"),
 ))

internal/telemetry/otel.go

@@ -28,7 +28,7 @@ func Start(ctx context.Context) error {
 		resource.WithContainer(),
 		resource.WithHost(),
 		resource.WithAttributes(
-			attribute.String("service", "docker-sync"),
+			attribute.String("service", "dockersync"),
 		),
 	)
 	if err != nil {

main.go

@@ -34,7 +34,7 @@ func Run(ctx context.Context) error {
 			default:
 				image := images[k]
 
-				if err := sync.SyncImage(image); err != nil {
+				if err := sync.SyncImage(ctx, image); err != nil {
 					log.Error().
 						Err(err).
 						Str("source", image.Source).