Skip to content

Implement MetricsAggregator for Activity-based collection\n\nTask ID: task-4.1-metrics-aggregator#304

Draft
jadewang-db wants to merge 18 commits intomainfrom
stack/itr5-pr-metrics-pipeline
Draft

Implement MetricsAggregator for Activity-based collection\n\nTask ID: task-4.1-metrics-aggregator#304
jadewang-db wants to merge 18 commits intomainfrom
stack/itr5-pr-metrics-pipeline

Conversation

@jadewang-db
Copy link
Collaborator

@jadewang-db jadewang-db commented Mar 5, 2026

GetEndpointUrl now ensures the host has a scheme prefix before
constructing the telemetry endpoint URL.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
@jadewang-db jadewang-db force-pushed the stack/itr5-pr-metrics-pipeline branch from 6b29492 to 4cc1004 Compare March 5, 2026 18:31
Use JsonFormatter with PreserveProtoFieldNames(true) instead of
JsonFormatter.Default to produce snake_case field names (session_id,
system_configuration, etc.) matching the JDBC driver and proto schema.
Default produces camelCase (sessionId) which is incorrect.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
@jadewang-db jadewang-db force-pushed the stack/itr5-pr-metrics-pipeline branch from 4cc1004 to e84cfda Compare March 5, 2026 22:42
Jade Wang and others added 5 commits March 5, 2026 23:34
This file was accidentally committed and should not be tracked.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
@jadewang-db jadewang-db force-pushed the stack/itr5-pr-metrics-pipeline branch from e84cfda to 8e08391 Compare March 5, 2026 23:38
Jade Wang and others added 3 commits March 5, 2026 23:49
- Fix final flush no-op by using _closing flag before _disposed
- Drain all batches in FlushAsync instead of just one
- Fix race condition in TelemetryClientManager with lock-based synchronization
- Replace Debug.WriteLine with Activity.Current?.AddEvent() for tracing
- Change TelemetrySessionContext setters to internal
- Use Interlocked counter for queue size instead of ConcurrentQueue.Count
- Use blocking wait in FlushAsync during close
- Use test-isolated TelemetryClientManager instances with proper cleanup

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
@jadewang-db jadewang-db force-pushed the stack/itr5-pr-metrics-pipeline branch from 8e08391 to 4d04299 Compare March 5, 2026 23:53
…metryMetric

These are no longer used. TelemetryClient now uses a direct
enqueue → flush → export pipeline without the Activity-based
aggregation layer.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant