opensource/grafana
1
0
Fork 0
mirror of https://github.com/grafana/grafana.git synced 2025-08-03 04:12:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

add debug logs to search server distributor (#108679)

Browse Source
This commit is contained in:
Will Assis
2025-07-25 08:36:35 -04:00
committed by GitHub
parent 6747b60822
commit f67713726b
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/storage/unified/resource/search_server_distributor.go
View File

@ -131,11 +131,13 @@ func (ds *distributorServer) getClientToDistributeRequest(ctx context.Context, n
ringHasher := fnv.New32a()
_, err := ringHasher.Write([]byte(namespace))
if err != nil {
ds.log.Debug("error hashing namespace", "err", err, "namespace", namespace)
return ctx, nil, err
}
rs, err := ds.ring.GetWithOptions(ringHasher.Sum32(), searchRingRead, ring.WithReplicationFactor(ds.ring.ReplicationFactor()))
if err != nil {
ds.log.Debug("error getting replication set from ring", "err", err, "namespace", namespace)
return ctx, nil, err
}
@ -143,6 +145,7 @@ func (ds *distributorServer) getClientToDistributeRequest(ctx context.Context, n
inst := rs.Instances[rand.Intn(len(rs.Instances))]
client, err := ds.clientPool.GetClientForInstance(inst)
if err != nil {
ds.log.Debug("error getting instance client from pool", "err", err, "namespace", namespace, "searchApiInstanceId", inst.Id)
return ctx, nil, err
}
@ -153,7 +156,10 @@ func (ds *distributorServer) getClientToDistributeRequest(ctx context.Context, n
ds.log.Info("distributing request to ", "methodName", methodName, "instanceId", inst.Id, "namespace", namespace)
_ = grpc.SetHeader(ctx, metadata.Pairs("proxied-instance-id", inst.Id))
err = grpc.SetHeader(ctx, metadata.Pairs("proxied-instance-id", inst.Id))
if err != nil {
ds.log.Debug("error setting grpc header", err, "err")
}
return userutils.InjectOrgID(metadata.NewOutgoingContext(ctx, md), namespace), client.(*RingClient).Client, nil
}