public/grafana
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

TestData: Support a steps scenario (#104736)

Browse Source
This commit is contained in:
Ryan McKinley
2025-04-30 16:22:59 +03:00
committed by GitHub
parent da32b9e16f
commit 439df585e0
8 changed files with 59 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/tsdb/grafana-testdata-datasource/kinds/query.go
+1
View File
@@ -77,6 +77,7 @@ const (
TestDataQueryTypeRandomWalkWithError TestDataQueryType = "random_walk_with_error"
TestDataQueryTypeRawFrame TestDataQueryType = "raw_frame"
TestDataQueryTypeServerError500 TestDataQueryType = "server_error_500"
TestDataQueryTypeSteps TestDataQueryType = "steps"
TestDataQueryTypeSimulation TestDataQueryType = "simulation"
TestDataQueryTypeSlowQuery TestDataQueryType = "slow_query"
TestDataQueryTypeStreamingClient TestDataQueryType = "streaming_client"
pkg/tsdb/grafana-testdata-datasource/kinds/query.panel.schema.json
+2 -1
View File
@@ -229,7 +229,7 @@
"additionalProperties": false
},
"scenarioId": {
"description": "Possible enum values:\n - `\"annotations\"` \n - `\"arrow\"` \n - `\"csv_content\"` \n - `\"csv_file\"` \n - `\"csv_metric_values\"` \n - `\"datapoints_outside_range\"` \n - `\"error_with_source\"` \n - `\"exponential_heatmap_bucket_data\"` \n - `\"flame_graph\"` \n - `\"grafana_api\"` \n - `\"linear_heatmap_bucket_data\"` \n - `\"live\"` \n - `\"logs\"` \n - `\"manual_entry\"` \n - `\"no_data_points\"` \n - `\"node_graph\"` \n - `\"predictable_csv_wave\"` \n - `\"predictable_pulse\"` \n - `\"random_walk\"` \n - `\"random_walk_table\"` \n - `\"random_walk_with_error\"` \n - `\"raw_frame\"` \n - `\"server_error_500\"` \n - `\"simulation\"` \n - `\"slow_query\"` \n - `\"streaming_client\"` \n - `\"table_static\"` \n - `\"trace\"` \n - `\"usa\"` \n - `\"variables-query\"` ",
"description": "Possible enum values:\n - `\"annotations\"` \n - `\"arrow\"` \n - `\"csv_content\"` \n - `\"csv_file\"` \n - `\"csv_metric_values\"` \n - `\"datapoints_outside_range\"` \n - `\"error_with_source\"` \n - `\"exponential_heatmap_bucket_data\"` \n - `\"flame_graph\"` \n - `\"grafana_api\"` \n - `\"linear_heatmap_bucket_data\"` \n - `\"live\"` \n - `\"logs\"` \n - `\"manual_entry\"` \n - `\"no_data_points\"` \n - `\"node_graph\"` \n - `\"predictable_csv_wave\"` \n - `\"predictable_pulse\"` \n - `\"random_walk\"` \n - `\"random_walk_table\"` \n - `\"random_walk_with_error\"` \n - `\"raw_frame\"` \n - `\"server_error_500\"` \n - `\"steps\"` \n - `\"simulation\"` \n - `\"slow_query\"` \n - `\"streaming_client\"` \n - `\"table_static\"` \n - `\"trace\"` \n - `\"usa\"` \n - `\"variables-query\"` ",
"type": "string",
"enum": [
"annotations",
@@ -255,6 +255,7 @@
"random_walk_with_error",
"raw_frame",
"server_error_500",
"steps",
"simulation",
"slow_query",
"streaming_client",
pkg/tsdb/grafana-testdata-datasource/kinds/query.request.schema.json
+2 -1
View File
@@ -239,7 +239,7 @@
"additionalProperties": false
},
"scenarioId": {
"description": "Possible enum values:\n - `\"annotations\"` \n - `\"arrow\"` \n - `\"csv_content\"` \n - `\"csv_file\"` \n - `\"csv_metric_values\"` \n - `\"datapoints_outside_range\"` \n - `\"error_with_source\"` \n - `\"exponential_heatmap_bucket_data\"` \n - `\"flame_graph\"` \n - `\"grafana_api\"` \n - `\"linear_heatmap_bucket_data\"` \n - `\"live\"` \n - `\"logs\"` \n - `\"manual_entry\"` \n - `\"no_data_points\"` \n - `\"node_graph\"` \n - `\"predictable_csv_wave\"` \n - `\"predictable_pulse\"` \n - `\"random_walk\"` \n - `\"random_walk_table\"` \n - `\"random_walk_with_error\"` \n - `\"raw_frame\"` \n - `\"server_error_500\"` \n - `\"simulation\"` \n - `\"slow_query\"` \n - `\"streaming_client\"` \n - `\"table_static\"` \n - `\"trace\"` \n - `\"usa\"` \n - `\"variables-query\"` ",
"description": "Possible enum values:\n - `\"annotations\"` \n - `\"arrow\"` \n - `\"csv_content\"` \n - `\"csv_file\"` \n - `\"csv_metric_values\"` \n - `\"datapoints_outside_range\"` \n - `\"error_with_source\"` \n - `\"exponential_heatmap_bucket_data\"` \n - `\"flame_graph\"` \n - `\"grafana_api\"` \n - `\"linear_heatmap_bucket_data\"` \n - `\"live\"` \n - `\"logs\"` \n - `\"manual_entry\"` \n - `\"no_data_points\"` \n - `\"node_graph\"` \n - `\"predictable_csv_wave\"` \n - `\"predictable_pulse\"` \n - `\"random_walk\"` \n - `\"random_walk_table\"` \n - `\"random_walk_with_error\"` \n - `\"raw_frame\"` \n - `\"server_error_500\"` \n - `\"steps\"` \n - `\"simulation\"` \n - `\"slow_query\"` \n - `\"streaming_client\"` \n - `\"table_static\"` \n - `\"trace\"` \n - `\"usa\"` \n - `\"variables-query\"` ",
"type": "string",
"enum": [
"annotations",
@@ -265,6 +265,7 @@
"random_walk_with_error",
"raw_frame",
"server_error_500",
"steps",
"simulation",
"slow_query",
"streaming_client",
pkg/tsdb/grafana-testdata-datasource/kinds/query.types.json
+3 -2
View File
@@ -8,7 +8,7 @@
{
"metadata": {
"name": "default",
"resourceVersion": "1728405292506",
"resourceVersion": "1745998648052",
"creationTimestamp": "2024-03-01T02:53:35Z"
},
"spec": {
@@ -151,7 +151,7 @@
"type": "string"
},
"scenarioId": {
"description": "Possible enum values:\n - `\"annotations\"` \n - `\"arrow\"` \n - `\"csv_content\"` \n - `\"csv_file\"` \n - `\"csv_metric_values\"` \n - `\"datapoints_outside_range\"` \n - `\"error_with_source\"` \n - `\"exponential_heatmap_bucket_data\"` \n - `\"flame_graph\"` \n - `\"grafana_api\"` \n - `\"linear_heatmap_bucket_data\"` \n - `\"live\"` \n - `\"logs\"` \n - `\"manual_entry\"` \n - `\"no_data_points\"` \n - `\"node_graph\"` \n - `\"predictable_csv_wave\"` \n - `\"predictable_pulse\"` \n - `\"random_walk\"` \n - `\"random_walk_table\"` \n - `\"random_walk_with_error\"` \n - `\"raw_frame\"` \n - `\"server_error_500\"` \n - `\"simulation\"` \n - `\"slow_query\"` \n - `\"streaming_client\"` \n - `\"table_static\"` \n - `\"trace\"` \n - `\"usa\"` \n - `\"variables-query\"` ",
"description": "Possible enum values:\n - `\"annotations\"` \n - `\"arrow\"` \n - `\"csv_content\"` \n - `\"csv_file\"` \n - `\"csv_metric_values\"` \n - `\"datapoints_outside_range\"` \n - `\"error_with_source\"` \n - `\"exponential_heatmap_bucket_data\"` \n - `\"flame_graph\"` \n - `\"grafana_api\"` \n - `\"linear_heatmap_bucket_data\"` \n - `\"live\"` \n - `\"logs\"` \n - `\"manual_entry\"` \n - `\"no_data_points\"` \n - `\"node_graph\"` \n - `\"predictable_csv_wave\"` \n - `\"predictable_pulse\"` \n - `\"random_walk\"` \n - `\"random_walk_table\"` \n - `\"random_walk_with_error\"` \n - `\"raw_frame\"` \n - `\"server_error_500\"` \n - `\"steps\"` \n - `\"simulation\"` \n - `\"slow_query\"` \n - `\"streaming_client\"` \n - `\"table_static\"` \n - `\"trace\"` \n - `\"usa\"` \n - `\"variables-query\"` ",
"enum": [
"annotations",
"arrow",
@@ -176,6 +176,7 @@
"random_walk_with_error",
"raw_frame",
"server_error_500",
"steps",
"simulation",
"slow_query",
"streaming_client",
pkg/tsdb/grafana-testdata-datasource/scenarios.go
+9 -3
View File
@@ -12,13 +12,13 @@ import (
"strings"
"time"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/trace"
"github.com/grafana/grafana-plugin-sdk-go/backend"
"github.com/grafana/grafana-plugin-sdk-go/backend/log"
"github.com/grafana/grafana-plugin-sdk-go/backend/tracing"
"github.com/grafana/grafana-plugin-sdk-go/data"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/trace"
"github.com/grafana/grafana/pkg/tsdb/grafana-testdata-datasource/kinds"
)
@@ -110,6 +110,12 @@ Timestamps will line up evenly on timeStepSeconds (For example, 60 seconds means
handler: s.handleClientSideScenario,
})
s.registerScenario(&Scenario{
ID: kinds.TestDataQueryTypeSteps,
Name: "Steps",
handler: s.handleClientSideScenario,
})
s.registerScenario(&Scenario{
ID: kinds.TestDataQueryTypeSimulation,
Name: "Simulation",
public/app/plugins/datasource/grafana-testdata-datasource/QueryEditor.tsx
+4
View File
@@ -117,6 +117,9 @@ export const QueryEditor = ({ query, datasource, onChange, onRunQuery }: Props)
case TestDataQueryType.Annotations:
update.lines = 10;
break;
case TestDataQueryType.Steps:
update.csvContent = 'a\nb\nc\n';
break;
case TestDataQueryType.USA:
update.usa = {
mode: usaQueryModes[0].value,
@@ -293,6 +296,7 @@ export const QueryEditor = ({ query, datasource, onChange, onRunQuery }: Props)
{scenarioId === TestDataQueryType.CSVContent && (
<CSVContentEditor onChange={onUpdate} query={query} ds={datasource} />
)}
{scenarioId === TestDataQueryType.Steps && <CSVContentEditor onChange={onUpdate} query={query} ds={datasource} />}
{scenarioId === TestDataQueryType.Logs && (
<InlineFieldRow>
<InlineField label="Lines" labelWidth={14}>
public/app/plugins/datasource/grafana-testdata-datasource/dataquery.ts
+1
View File
@@ -27,6 +27,7 @@ export enum TestDataQueryType {
RawFrame = 'raw_frame',
ServerError500 = 'server_error_500',
Simulation = 'simulation',
Steps = 'steps',
SlowQuery = 'slow_query',
StreamingClient = 'streaming_client',
TableStatic = 'table_static',
public/app/plugins/datasource/grafana-testdata-datasource/datasource.ts
+37
View File
@@ -17,6 +17,7 @@ import {
MutableDataFrame,
AnnotationQuery,
getSearchFilterScopedVar,
FieldType,
} from '@grafana/data';
import { DataSourceWithBackend, getBackendSrv, getGrafanaLiveSrv, getTemplateSrv, TemplateSrv } from '@grafana/runtime';
@@ -97,6 +98,9 @@ export class TestDataDataSource extends DataSourceWithBackend<TestDataDataQuery>
case 'flame_graph':
streams.push(this.flameGraphQuery(target));
break;
case 'steps':
streams.push(this.stepsQuery(target));
break;
case 'trace':
streams.push(this.trace(options));
break;
@@ -348,6 +352,39 @@ export class TestDataDataSource extends DataSourceWithBackend<TestDataDataQuery>
}
}
// Incremented with each refresh in a step query
step = 0;
stepsQuery(target: TestDataDataQuery): Observable<DataQueryResponse> {
let steps = (target.csvContent ?? `a\n,b\nc\n`)
.split('\n')
.map((v) => v.trim())
.filter((v) => Boolean(v.length));
this.step = this.step % steps.length;
const step = target.alias?.length ? target.alias : 'step';
const frame: DataFrame = {
refId: target.refId,
fields: [
{ name: 'time', type: FieldType.time, values: [Date.now()], config: {} },
{ name: 'index', type: FieldType.number, values: [this.step], config: {} },
{ name: step, type: FieldType.string, values: [steps[this.step]], config: {} },
],
length: 1,
};
for (let i = 0; i < steps.length; i++) {
frame.fields.push({
name: `${step}-${steps[i]}`,
type: FieldType.boolean,
values: [i <= this.step],
config: {},
});
}
this.step++;
return of({ data: [frame] }).pipe(delay(50));
}
serverErrorQuery(
target: TestDataDataQuery,
options: DataQueryRequest<TestDataDataQuery>