GitHub-Proxy/signoz
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/SigNoz/signoz synced 2025-08-13 22:35:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix api query context (#6268)

Browse Source 
* chore: fix naming api query context
This commit is contained in:
Shivanshu Raj Shrivastava 2024-10-25 14:06:54 +05:30 committed by GitHub
parent d7846338ce
commit a31c4b8339
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.github/workflows/staging-deployment.yaml vendored
View File

@ -31,6 +31,7 @@ jobs:
GCP_ZONE: ${{ secrets.GCP_ZONE }} GCP_ZONE: ${{ secrets.GCP_ZONE }}
GCP_INSTANCE: ${{ secrets.GCP_INSTANCE }} GCP_INSTANCE: ${{ secrets.GCP_INSTANCE }}
CLOUDSDK_CORE_DISABLE_PROMPTS: 1 CLOUDSDK_CORE_DISABLE_PROMPTS: 1
KAFKA_SPAN_EVAL: true
run: | run: |
read -r -d '' COMMAND <<EOF || true read -r -d '' COMMAND <<EOF || true
echo "GITHUB_BRANCH: ${GITHUB_BRANCH}" echo "GITHUB_BRANCH: ${GITHUB_BRANCH}"

2
pkg/query-service/app/http_handler.go
View File

@ -3099,7 +3099,7 @@ func (aH *APIHandler) getPartitionOverviewLatencyData(
return return
} }
queryRangeParams, err := mq.BuildQueryRangeParams(messagingQueue, "partition_latency") queryRangeParams, err := mq.BuildQueryRangeParams(messagingQueue, "producer-topic-throughput")
if err != nil { if err != nil {
zap.L().Error(err.Error()) zap.L().Error(err.Error())
RespondError(w, apiErr, nil) RespondError(w, apiErr, nil)

2
pkg/query-service/app/integrations/messagingQueues/kafka/model.go
View File

@ -5,7 +5,7 @@ const KafkaQueue = "kafka"
type MessagingQueue struct { type MessagingQueue struct {
Start int64 `json:"start"` Start int64 `json:"start"`
End int64 `json:"end"` End int64 `json:"end"`
EvalTime int64 `json:"eval_time"` EvalTime int64 `json:"eval_time,omitempty"`
Variables map[string]string `json:"variables,omitempty"` Variables map[string]string `json:"variables,omitempty"`
} }

1
pkg/query-service/app/integrations/messagingQueues/kafka/translator.go
View File

@ -254,7 +254,6 @@ func BuildClickHouseQuery(messagingQueue *MessagingQueue, queueType string, quer
if queryContext == "producer" || if queryContext == "producer" ||
queryContext == "consumer" || queryContext == "consumer" ||
queryContext == "consumer_partition_latency" || queryContext == "consumer_partition_latency" ||
queryContext == "producer-topic-throughput" ||
queryContext == "producer-throughput-details" || queryContext == "producer-throughput-details" ||
queryContext == "consumer-throughput-details" { queryContext == "consumer-throughput-details" {
var ok bool var ok bool