Function Upload

internal/telemetry/telemetry.go:279–308

()

)

func Upload() {
	wg := sync.WaitGroup{} //nolint:varnamelen
	wg.Add(2)
	go func() {
		defer wg.Done()

		if !initSentryClient(appName) {
			return
		}

		events := restoreEvents[sentry.Event](sentryBufferDir)
		for _, e := range events {
			sentry.CaptureEvent(&e)
		}
		sentry.Flush(3 * time.Second)
	}()
	go func() {
		defer wg.Done()

		if !initSegmentClient() {
			return
		}
		events := restoreEvents[segment.Track](segmentBufferDir)
		for _, e := range events {
			segmentClient.Enqueue(e) //nolint:errcheck
		}
		segmentClient.Close()
	}()
	wg.Wait()
}

func restoreEvents[E any](dir string) []E {
	dirEntries, err := os.ReadDir(dir)