Skip to content

Commit 76d8b84

Browse files
authored
Overload Control - fix headers (#349)
1 parent 699ea8a commit 76d8b84

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

context.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -376,11 +376,11 @@ func applyContextSettings(ctx context.Context, req Request) contextSettings {
376376
if v := ctx.Value(keyMaxQueueTime); v != nil {
377377
if timeout, ok := v.(time.Duration); ok {
378378
result.MaxQueueTime = timeout
379-
req.SetHeader("arangodb-max-queue-time-seconds", fmt.Sprint(timeout.Seconds()))
379+
req.SetHeader("x-arango-queue-time-seconds", fmt.Sprint(timeout.Seconds()))
380380
}
381381
} else if deadline, ok := ctx.Deadline(); ok {
382382
timeout := deadline.Sub(time.Now())
383-
req.SetHeader("arangodb-max-queue-time-seconds", fmt.Sprint(timeout.Seconds()))
383+
req.SetHeader("x-arango-queue-time-seconds", fmt.Sprint(timeout.Seconds()))
384384
}
385385
}
386386
}

v2/connection/modifiers.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,11 +58,11 @@ func applyGlobalSettings(ctx context.Context) RequestModifier {
5858
if useQueueTimeout, ok := v.(bool); ok && useQueueTimeout {
5959
if v := ctx.Value(keyMaxQueueTime); v != nil {
6060
if timeout, ok := v.(time.Duration); ok {
61-
r.AddHeader("arangodb-max-queue-time-seconds", fmt.Sprint(timeout.Seconds()))
61+
r.AddHeader("x-arango-queue-time-seconds", fmt.Sprint(timeout.Seconds()))
6262
}
6363
} else if deadline, ok := ctx.Deadline(); ok {
6464
timeout := deadline.Sub(time.Now())
65-
r.AddHeader("arangodb-max-queue-time-seconds", fmt.Sprint(timeout.Seconds()))
65+
r.AddHeader("x-arango-queue-time-seconds", fmt.Sprint(timeout.Seconds()))
6666
}
6767
}
6868
}

0 commit comments

Comments
 (0)