@@ -15,7 +15,6 @@ type retriesResponse struct {
15
15
func HandleRetries (w http.ResponseWriter , r * http.Request ) {
16
16
requestID := r .URL .Query ().Get ("request-id" )
17
17
numRetriesStr := r .URL .Query ().Get ("num-retries" )
18
- includeHeaderTimeout := r .URL .Query ().Get ("included-header-timeout" )
19
18
20
19
numRetries := 3
21
20
if numRetriesStr != "" {
@@ -28,17 +27,6 @@ func HandleRetries(w http.ResponseWriter, r *http.Request) {
28
27
}
29
28
}
30
29
31
- var headerTimeout int
32
- if includeHeaderTimeout != "" {
33
- var err error
34
- headerTimeout , err = strconv .Atoi (includeHeaderTimeout )
35
- if err != nil {
36
- w .WriteHeader (http .StatusBadRequest )
37
- _ , _ = w .Write ([]byte ("included-header-timeout must be an integer" ))
38
- return
39
- }
40
- }
41
-
42
30
if requestID == "" {
43
31
w .WriteHeader (http .StatusBadRequest )
44
32
_ , _ = w .Write ([]byte ("request-id is required" ))
@@ -52,9 +40,8 @@ func HandleRetries(w http.ResponseWriter, r *http.Request) {
52
40
callCounts [requestID ]++
53
41
54
42
if callCounts [requestID ] < numRetries {
55
- if headerTimeout > 0 {
56
- w .Header ().Set ("Retry-After" , strconv .Itoa (headerTimeout ))
57
- }
43
+ // static one second retry after timeout
44
+ w .Header ().Set ("Retry-After" , 1 )
58
45
w .WriteHeader (http .StatusServiceUnavailable )
59
46
_ , _ = w .Write ([]byte ("request failed please retry" ))
60
47
return
0 commit comments