@@ -162,14 +162,14 @@ var (
162
162
)
163
163
164
164
func queryToolHandler (ctx context.Context , request mcp.CallToolRequest ) (* mcp.CallToolResult , error ) {
165
- arguments := request .Params .Arguments
166
- query , ok := arguments ["query" ].(string )
165
+ args := request .Params .Arguments
166
+ query , ok := args ["query" ].(string )
167
167
if ! ok {
168
168
return nil , errors .New ("query must be a string" )
169
169
}
170
170
171
171
ts := time .Now ()
172
- if argTs , ok := arguments ["timestamp" ].(string ); ok {
172
+ if argTs , ok := args ["timestamp" ].(string ); ok {
173
173
parsedTs , err := mcpProm .ParseTimestamp (argTs )
174
174
if err != nil {
175
175
return nil , fmt .Errorf ("failed to get ts from args: %#v" , argTs )
@@ -183,8 +183,8 @@ func queryToolHandler(ctx context.Context, request mcp.CallToolRequest) (*mcp.Ca
183
183
}
184
184
185
185
func rangeQueryToolHandler (ctx context.Context , request mcp.CallToolRequest ) (* mcp.CallToolResult , error ) {
186
- arguments := request .Params .Arguments
187
- query , ok := arguments ["query" ].(string )
186
+ args := request .Params .Arguments
187
+ query , ok := args ["query" ].(string )
188
188
if ! ok {
189
189
return nil , errors .New ("query must be a string" )
190
190
}
@@ -197,7 +197,7 @@ func rangeQueryToolHandler(ctx context.Context, request mcp.CallToolRequest) (*m
197
197
// Convert seconds to nanoseconds such that time.Duration parses correctly.
198
198
step := time .Duration (resolution ) * time .Second
199
199
200
- if argEndTime , ok := arguments ["end_time" ].(string ); ok {
200
+ if argEndTime , ok := args ["end_time" ].(string ); ok {
201
201
parsedEndTime , err := mcpProm .ParseTimestamp (argEndTime )
202
202
if err != nil {
203
203
return nil , fmt .Errorf ("failed to parse end_time %s from args: %w" , argEndTime , err )
@@ -206,7 +206,7 @@ func rangeQueryToolHandler(ctx context.Context, request mcp.CallToolRequest) (*m
206
206
endTs = parsedEndTime
207
207
}
208
208
209
- if argStartTime , ok := arguments ["start_time" ].(string ); ok {
209
+ if argStartTime , ok := args ["start_time" ].(string ); ok {
210
210
parsedStartTime , err := mcpProm .ParseTimestamp (argStartTime )
211
211
if err != nil {
212
212
return nil , fmt .Errorf ("failed to parse start_time %s from args: %w" , argStartTime , err )
@@ -215,7 +215,7 @@ func rangeQueryToolHandler(ctx context.Context, request mcp.CallToolRequest) (*m
215
215
startTs = parsedStartTime
216
216
}
217
217
218
- if argStep , ok := arguments ["step" ].(string ); ok {
218
+ if argStep , ok := args ["step" ].(string ); ok {
219
219
parsedStep , err := time .ParseDuration (argStep )
220
220
if err != nil {
221
221
return nil , fmt .Errorf ("failed to parse duration %s for step: %w" , argStep , err )
@@ -228,8 +228,8 @@ func rangeQueryToolHandler(ctx context.Context, request mcp.CallToolRequest) (*m
228
228
}
229
229
230
230
func seriesToolHandler (ctx context.Context , request mcp.CallToolRequest ) (* mcp.CallToolResult , error ) {
231
- arguments := request .Params .Arguments
232
- argMatchers , ok := arguments ["matchers" ].([]any )
231
+ args := request .Params .Arguments
232
+ argMatchers , ok := args ["matchers" ].([]any )
233
233
if ! ok {
234
234
return nil , errors .New ("matchers must be an array" )
235
235
}
@@ -242,7 +242,7 @@ func seriesToolHandler(ctx context.Context, request mcp.CallToolRequest) (*mcp.C
242
242
endTs := time .Now ()
243
243
startTs := endTs .Add (DefaultLookbackDelta )
244
244
245
- if argEndTime , ok := arguments ["end_time" ].(string ); ok {
245
+ if argEndTime , ok := args ["end_time" ].(string ); ok {
246
246
parsedEndTime , err := mcpProm .ParseTimestamp (argEndTime )
247
247
if err != nil {
248
248
return nil , fmt .Errorf ("failed to parse end_time %s from args: %w" , argEndTime , err )
@@ -251,7 +251,7 @@ func seriesToolHandler(ctx context.Context, request mcp.CallToolRequest) (*mcp.C
251
251
endTs = parsedEndTime
252
252
}
253
253
254
- if argStartTime , ok := arguments ["start_time" ].(string ); ok {
254
+ if argStartTime , ok := args ["start_time" ].(string ); ok {
255
255
parsedStartTime , err := mcpProm .ParseTimestamp (argStartTime )
256
256
if err != nil {
257
257
return nil , fmt .Errorf ("failed to parse start_time %s from args: %w" , argStartTime , err )
@@ -265,8 +265,8 @@ func seriesToolHandler(ctx context.Context, request mcp.CallToolRequest) (*mcp.C
265
265
}
266
266
267
267
func labelNamesToolHandler (ctx context.Context , request mcp.CallToolRequest ) (* mcp.CallToolResult , error ) {
268
- arguments := request .Params .Arguments
269
- argMatchers , ok := arguments ["matchers" ].([]any )
268
+ args := request .Params .Arguments
269
+ argMatchers , ok := args ["matchers" ].([]any )
270
270
if ! ok {
271
271
return nil , errors .New ("matchers must be an array" )
272
272
}
@@ -279,7 +279,7 @@ func labelNamesToolHandler(ctx context.Context, request mcp.CallToolRequest) (*m
279
279
endTs := time .Now ()
280
280
startTs := endTs .Add (DefaultLookbackDelta )
281
281
282
- if argEndTime , ok := arguments ["end_time" ].(string ); ok {
282
+ if argEndTime , ok := args ["end_time" ].(string ); ok {
283
283
parsedEndTime , err := mcpProm .ParseTimestamp (argEndTime )
284
284
if err != nil {
285
285
return nil , fmt .Errorf ("failed to parse end_time %s from args: %w" , argEndTime , err )
@@ -288,7 +288,7 @@ func labelNamesToolHandler(ctx context.Context, request mcp.CallToolRequest) (*m
288
288
endTs = parsedEndTime
289
289
}
290
290
291
- if argStartTime , ok := arguments ["start_time" ].(string ); ok {
291
+ if argStartTime , ok := args ["start_time" ].(string ); ok {
292
292
parsedStartTime , err := mcpProm .ParseTimestamp (argStartTime )
293
293
if err != nil {
294
294
return nil , fmt .Errorf ("failed to parse start_time %s from args: %w" , argStartTime , err )
@@ -302,13 +302,13 @@ func labelNamesToolHandler(ctx context.Context, request mcp.CallToolRequest) (*m
302
302
}
303
303
304
304
func labelValuesToolHandler (ctx context.Context , request mcp.CallToolRequest ) (* mcp.CallToolResult , error ) {
305
- arguments := request .Params .Arguments
306
- label , ok := arguments ["label" ].(string )
305
+ args := request .Params .Arguments
306
+ label , ok := args ["label" ].(string )
307
307
if ! ok {
308
308
return nil , errors .New ("label must be a string" )
309
309
}
310
310
311
- argMatchers , ok := arguments ["matchers" ].([]any )
311
+ argMatchers , ok := args ["matchers" ].([]any )
312
312
if ! ok {
313
313
return nil , errors .New ("matchers must be an array" )
314
314
}
@@ -321,7 +321,7 @@ func labelValuesToolHandler(ctx context.Context, request mcp.CallToolRequest) (*
321
321
endTs := time .Now ()
322
322
startTs := endTs .Add (DefaultLookbackDelta )
323
323
324
- if argEndTime , ok := arguments ["end_time" ].(string ); ok {
324
+ if argEndTime , ok := args ["end_time" ].(string ); ok {
325
325
parsedEndTime , err := mcpProm .ParseTimestamp (argEndTime )
326
326
if err != nil {
327
327
return nil , fmt .Errorf ("failed to parse end_time %s from args: %w" , argEndTime , err )
@@ -330,7 +330,7 @@ func labelValuesToolHandler(ctx context.Context, request mcp.CallToolRequest) (*
330
330
endTs = parsedEndTime
331
331
}
332
332
333
- if argStartTime , ok := arguments ["start_time" ].(string ); ok {
333
+ if argStartTime , ok := args ["start_time" ].(string ); ok {
334
334
parsedStartTime , err := mcpProm .ParseTimestamp (argStartTime )
335
335
if err != nil {
336
336
return nil , fmt .Errorf ("failed to parse start_time %s from args: %w" , argStartTime , err )
@@ -389,20 +389,20 @@ func targetsToolHandler(ctx context.Context, request mcp.CallToolRequest) (*mcp.
389
389
}
390
390
391
391
func targetsMetadataToolHandler (ctx context.Context , request mcp.CallToolRequest ) (* mcp.CallToolResult , error ) {
392
- arguments := request .Params .Arguments
392
+ args := request .Params .Arguments
393
393
394
394
matchTarget := ""
395
- if argMatchTarget , ok := arguments ["match_target" ].(string ); ok {
395
+ if argMatchTarget , ok := args ["match_target" ].(string ); ok {
396
396
matchTarget = argMatchTarget
397
397
}
398
398
399
399
metric := ""
400
- if argMetric , ok := arguments ["metric" ].(string ); ok {
400
+ if argMetric , ok := args ["metric" ].(string ); ok {
401
401
metric = argMetric
402
402
}
403
403
404
404
limit := ""
405
- if argLimit , ok := arguments ["limit" ].(string ); ok {
405
+ if argLimit , ok := args ["limit" ].(string ); ok {
406
406
limit = argLimit
407
407
}
408
408
@@ -413,15 +413,15 @@ func targetsMetadataToolHandler(ctx context.Context, request mcp.CallToolRequest
413
413
// // Metadata returns metadata about metrics currently scraped by the metric name.
414
414
// Metadata(ctx context.Context, metric, limit string) (map[string][]Metadata, error)
415
415
func metricMetadataToolHandler (ctx context.Context , request mcp.CallToolRequest ) (* mcp.CallToolResult , error ) {
416
- arguments := request .Params .Arguments
416
+ args := request .Params .Arguments
417
417
418
418
metric := ""
419
- if argMetric , ok := arguments ["metric" ].(string ); ok {
419
+ if argMetric , ok := args ["metric" ].(string ); ok {
420
420
metric = argMetric
421
421
}
422
422
423
423
limit := ""
424
- if argLimit , ok := arguments ["limit" ].(string ); ok {
424
+ if argLimit , ok := args ["limit" ].(string ); ok {
425
425
limit = argLimit
426
426
}
427
427
0 commit comments