Skip to content

[Graphite MQ] Draft PR GROUP:spec_33b0f8 (PRs 3332, 3333, 3358) #3367

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 3 commits into from
Closed

[Graphite MQ] Draft PR GROUP:spec_33b0f8 (PRs 3332, 3333, 3358) #3367

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
1633914
chore: misc bug fixes, add logs for outbound req (#3332)
MasterPtato Nov 5, 2025
f0f4d2b
chore: change log levels (#3333)
MasterPtato Nov 5, 2025
3b4f526
fix: fix all dashboards (#3358)
MasterPtato Nov 5, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
212 changes: 96 additions & 116 deletions engine/docker/dev-host/grafana/dashboards/api.json
View file
Open in desktop

Large diffs are not rendered by default.

643 changes: 272 additions & 371 deletions engine/docker/dev-host/grafana/dashboards/cache.json
View file
Open in desktop

Large diffs are not rendered by default.

78 changes: 48 additions & 30 deletions engine/docker/dev-host/grafana/dashboards/futures.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@
"editable": true,
"fiscalYearStartMonth": 0,
"graphTooltip": 0,
"id": 3,
"links": [],
"panels": [
{
Expand Down Expand Up @@ -100,8 +101,11 @@
"editorMode": "code",
"editorType": "sql",
"format": 1,
"meta": {},
"pluginVersion": "4.11.2",
"queryType": "table",
"range": true,
"rawSql": "WITH\n $__timeInterval(TimeUnix) as time_bucket,\n arrayJoin(arrayEnumerate(BucketCounts)) AS idx,\n ExplicitBounds AS bounds\nSELECT\n time_bucket as Time,\n bounds[idx+1] AS le,\n sum(BucketCounts[idx]) AS count\nFROM otel.otel_metrics_histogram\nWHERE\n MetricName = 'rivet_instrumented_future_duration'\n AND $__conditionalAll(Attributes['name'], $name)\n AND $__conditionalAll(Attributes['location'], $location)\n AND $__timeFilter(TimeUnix)\nGROUP BY Time, le\nORDER BY Time, le",
"rawSql": "WITH\n 30 as collector_rate_s\n\nSELECT Time, bucket, count\nFROM (\n SELECT\n Time,\n bucket,\n greatest(0, count - lagInFrame(count, 1, 0) OVER (PARTITION BY bucket ORDER BY Time)) AS count\n FROM (\n WITH\n $__timeInterval(TimeUnix) as time_bucket,\n arrayJoin(arrayEnumerate(BucketCounts)) AS idx,\n case when idx = length(BucketCounts) then inf else ExplicitBounds[idx] end as bucket\n SELECT\n time_bucket as Time,\n bucket,\n sum(BucketCounts[idx]) AS count\n FROM otel.otel_metrics_histogram\n WHERE\n MetricName = 'rivet_instrumented_future_duration'\n -- AND ResourceAttributes['rivet.project'] IN array($project)\n -- AND ResourceAttributes['rivet.datacenter'] IN array($datacenter)\n AND Attributes['name'] IN array($name)\n AND Attributes['location'] IN array($location)\n AND TimeUnix >= $__fromTime_ms() - toIntervalMillisecond(greatest(collector_rate_s * 1000, $__interval_s * 1000))\n AND TimeUnix <= $__toTime_ms()\n AND AggregationTemporality = 2\n GROUP BY Time, bucket\n )\n)\nWHERE $__timeFilter(Time)",
"refId": "A"
}
],
Expand All @@ -110,7 +114,7 @@
{
"id": "groupingToMatrix",
"options": {
"columnField": "le",
"columnField": "bucket",
"emptyValue": "zero",
"rowField": "Time",
"valueField": "count"
Expand All @@ -122,7 +126,7 @@
"conversions": [
{
"destinationType": "time",
"targetField": "Time\\le"
"targetField": "Time\\bucket"
}
],
"fields": {}
Expand All @@ -138,6 +142,39 @@
"tags": [],
"templating": {
"list": [
{
"current": {
"text": ["All"],
"value": ["$__all"]
},
"definition": "SELECT DISTINCT ResourceAttributes['rivet.project'] FROM otel.otel_metrics_gauge WHERE ServiceName = 'rivet' ORDER BY ResourceAttributes['rivet.project']",
"description": "",
"includeAll": true,
"label": "project",
"multi": true,
"name": "project",
"options": [],
"query": "SELECT DISTINCT ResourceAttributes['rivet.project'] FROM otel.otel_metrics_gauge WHERE ServiceName = 'rivet' ORDER BY ResourceAttributes['rivet.project']",
"refresh": 1,
"regex": "",
"type": "query"
},
{
"current": {
"text": "All",
"value": "$__all"
},
"definition": "SELECT DISTINCT ResourceAttributes['rivet.datacenter'] FROM otel.otel_metrics_gauge WHERE ServiceName = 'rivet' AND ResourceAttributes['rivet.project'] IN array($project) ORDER BY ResourceAttributes['rivet.datacenter']",
"includeAll": true,
"label": "datacenter",
"multi": true,
"name": "datacenter",
"options": [],
"query": "SELECT DISTINCT ResourceAttributes['rivet.datacenter'] FROM otel.otel_metrics_gauge WHERE ServiceName = 'rivet' AND ResourceAttributes['rivet.project'] IN array($project) ORDER BY ResourceAttributes['rivet.datacenter']",
"refresh": 1,
"regex": "",
"type": "query"
},
{
"current": {
"text": ["All"],
Expand All @@ -147,17 +184,13 @@
"type": "grafana-clickhouse-datasource",
"uid": "clickhouse"
},
"definition": "SELECT DISTINCT Attributes['name'] as name FROM otel.otel_metrics_histogram WHERE MetricName = 'rivet_instrumented_future_duration' ORDER BY name",
"definition": "SELECT DISTINCT Attributes['name'] FROM otel.otel_metrics_histogram WHERE ServiceName = 'rivet' AND MetricName = 'rivet_instrumented_future_duration' AND ResourceAttributes['rivet.project'] IN array($project) ORDER BY Attributes['name']",
"includeAll": true,
"label": "Name",
"label": "name",
"multi": true,
"name": "name",
"options": [],
"query": {
"qryType": 1,
"rawSql": "SELECT DISTINCT Attributes['name'] as name FROM otel.otel_metrics_histogram WHERE MetricName = 'rivet_instrumented_future_duration' ORDER BY name",
"refId": "ClickHouseVariableQueryEditor-VariableQuery"
},
"query": "SELECT DISTINCT Attributes['name'] FROM otel.otel_metrics_histogram WHERE ServiceName = 'rivet' AND MetricName = 'rivet_instrumented_future_duration' AND ResourceAttributes['rivet.project'] IN array($project) ORDER BY Attributes['name']",
"refresh": 1,
"regex": "",
"type": "query"
Expand All @@ -171,32 +204,16 @@
"type": "grafana-clickhouse-datasource",
"uid": "clickhouse"
},
"definition": "SELECT DISTINCT Attributes['location'] as location FROM otel.otel_metrics_histogram WHERE MetricName = 'rivet_instrumented_future_duration' ORDER BY location",
"definition": "SELECT DISTINCT Attributes['location'] FROM otel.otel_metrics_histogram WHERE ServiceName = 'rivet' AND MetricName = 'rivet_instrumented_future_duration' AND ResourceAttributes['rivet.project'] IN array($project) ORDER BY Attributes['location']",
"includeAll": true,
"label": "Location",
"label": "location",
"multi": true,
"name": "location",
"options": [],
"query": {
"qryType": 1,
"rawSql": "SELECT DISTINCT Attributes['location'] as location FROM otel.otel_metrics_histogram WHERE MetricName = 'rivet_instrumented_future_duration' ORDER BY location",
"refId": "ClickHouseVariableQueryEditor-VariableQuery"
},
"query": "SELECT DISTINCT Attributes['location'] FROM otel.otel_metrics_histogram WHERE ServiceName = 'rivet' AND MetricName = 'rivet_instrumented_future_duration' AND ResourceAttributes['rivet.project'] IN array($project) ORDER BY Attributes['location']",
"refresh": 1,
"regex": "",
"type": "query"
},
{
"current": {
"text": "30",
"value": "30"
},
"hide": 2,
"label": "Metric Export Interval (seconds)",
"name": "metric_interval",
"query": "30",
"skipUrlSync": true,
"type": "constant"
}
]
},
Expand All @@ -207,6 +224,7 @@
"timepicker": {},
"timezone": "browser",
"title": "Futures",
"version": 0,
"uid": "ef353ektqu4g0e",
"version": 1,
"weekStart": ""
}
Loading
Loading