@@ -54,7 +54,7 @@ func (t *TestModule) GetWorkersKV(ctx context.Context, rc *cloudflare.ResourceCo
54
54
return nil , err
55
55
}
56
56
57
- req , err := http .NewRequest ( http .MethodPost , t .baseUrl + "/getworkerskvvaluebykey" , bytes .NewReader (marshalledBody ))
57
+ req , err := http .NewRequestWithContext ( ctx , http .MethodPost , t .baseUrl + "/getworkerskvvaluebykey" , bytes .NewReader (marshalledBody ))
58
58
59
59
if err != nil {
60
60
log .Println ("Error occur in /getworkerskvvaluebykey > making http call" )
@@ -95,7 +95,7 @@ func (t *TestModule) WriteWorkersKVEntry(ctx context.Context, rc *cloudflare.Res
95
95
return cloudflare.Response {}, err
96
96
}
97
97
98
- req , err := http .NewRequest ( http .MethodPost , t .baseUrl + "/writeworkerskvkeyvaluepair" , bytes .NewReader (marshalledBody ))
98
+ req , err := http .NewRequestWithContext ( ctx , http .MethodPost , t .baseUrl + "/writeworkerskvkeyvaluepair" , bytes .NewReader (marshalledBody ))
99
99
100
100
if err != nil {
101
101
log .Println ("Error occur in /writeworkerskvkeyvaluepair > making http call" )
@@ -134,7 +134,7 @@ func (t *TestModule) DeleteWorkersKVEntry(ctx context.Context, rc *cloudflare.Re
134
134
return cloudflare.Response {}, err
135
135
}
136
136
137
- req , err := http .NewRequest ( http .MethodDelete , t .baseUrl + "/deleteworkerskvpairbykey" , bytes .NewReader (marshalledBody ))
137
+ req , err := http .NewRequestWithContext ( ctx , http .MethodDelete , t .baseUrl + "/deleteworkerskvpairbykey" , bytes .NewReader (marshalledBody ))
138
138
139
139
if err != nil {
140
140
log .Println ("Error occur in /deleteworkerskvpairbykey > making http call" )
@@ -173,7 +173,7 @@ func (t *TestModule) ListWorkersKVKeys(ctx context.Context, rc *cloudflare.Resou
173
173
return cloudflare.ListStorageKeysResponse {}, err
174
174
}
175
175
176
- req , err := http .NewRequest ( http .MethodPost , t .baseUrl + "/listworkerskvkeys" , bytes .NewReader (marshalledBody ))
176
+ req , err := http .NewRequestWithContext ( ctx , http .MethodPost , t .baseUrl + "/listworkerskvkeys" , bytes .NewReader (marshalledBody ))
177
177
178
178
if err != nil {
179
179
log .Println ("Error occur in /listworkerskvkeys > making http call" )
@@ -225,7 +225,7 @@ func (t *TestModule) DeleteWorkersKVEntries(ctx context.Context, rc *cloudflare.
225
225
return cloudflare.Response {}, err
226
226
}
227
227
228
- req , err := http .NewRequest ( http .MethodDelete , t .baseUrl + "/deleteworkerskventries" , bytes .NewReader (marshalledBody ))
228
+ req , err := http .NewRequestWithContext ( ctx , http .MethodDelete , t .baseUrl + "/deleteworkerskventries" , bytes .NewReader (marshalledBody ))
229
229
230
230
if err != nil {
231
231
log .Println ("Error occur in /deleteworkerskventries > making new request" )
0 commit comments