Function NewService

internal/telemetry/telemetry.go:213–247

NewService creates a new telemetry service with the provided flush function and options.

(flusher func(SendTelemetryPayload), opts ...telemetryServiceOption)

// NewService creates a new telemetry service with the provided flush function and options.
func NewService(flusher func(SendTelemetryPayload), opts ...telemetryServiceOption) ghtelemetry.Service {
	telemetryServiceOpts := telemetryServiceOpts{
		additionalDimensions: make(ghtelemetry.Dimensions),
	}
	for _, opt := range opts {
		opt(&telemetryServiceOpts)
	}

	deviceID, err := deviceIDFunc()
	if err != nil {
		deviceID = "<unknown>"
	}

	invocationID := uuid.NewString()

	var commonDimensions = ghtelemetry.Dimensions{
		"device_id":     deviceID,
		"invocation_id": invocationID,
		"os":            runtime.GOOS,
		"architecture":  runtime.GOARCH,
	}
	maps.Copy(commonDimensions, telemetryServiceOpts.additionalDimensions)

	hash := uuid.NewSHA1(uuid.Nil, []byte(invocationID))
	sampleBucket := byte(binary.BigEndian.Uint32(hash[:4]) % 100)

	s := &service{
		flush:            flusher,
		commonDimensions: commonDimensions,
		sampleRate:       telemetryServiceOpts.sampleRate,
		sampleBucket:     sampleBucket,
	}

	return s
}

type recordedEvent struct {
	event      ghtelemetry.Event