Method Finish

internal/telemetry/telemetry.go:321–366

Finish snapshots the recorded events once and sends their payload after releasing the lock. Sampling and telemetry eligibility apply to immediate and pending events alike.

()

// Finish snapshots the recorded events once and sends their payload after releasing the lock.
// Sampling and telemetry eligibility apply to immediate and pending events alike.
func (s *service) Finish() {
	s.mu.Lock()

	if s.finished {
		s.mu.Unlock()
		return
	}
	s.finished = true

	if s.sampleRate > 0 && s.sampleRate < 100 && int(s.sampleBucket) >= s.sampleRate {
		s.mu.Unlock()
		return
	}

	// When the service has been disabled mid-invocation (e.g. an enterprise host
	// was contacted), discard any recorded events. We still call the flusher
	// with an empty payload so that the log-mode flusher can surface the
	// absence of telemetry rather than leaving the user staring at silence.
	events := s.events
	if s.disabled {
		events = nil
	}

	payload := SendTelemetryPayload{
		Events: make([]PayloadEvent, len(events)),
	}

	for i, recorded := range events {
		event := recorded.event

		dimensions := map[string]string{
			"timestamp": recorded.recordedAt.UTC().Format("2006-01-02T15:04:05.000Z"),
		}
		maps.Copy(dimensions, s.commonDimensions)
		maps.Copy(dimensions, event.Dimensions)

		payload.Events[i] = PayloadEvent{
			Type:       event.Type,
			Dimensions: dimensions,
			Measures:   maps.Clone(event.Measures),
		}
	}
	s.mu.Unlock()

	s.flush(payload)
}

type pendingEvent struct {
	service  *service