Nail/fission-src
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix object-type header passed to event handlers

Browse Source
This commit is contained in:
Soam Vasani
2016-12-20 14:16:33 -08:00
parent c5425180e8
commit d721df998d
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kubewatcher/webhookPublisher.go
+4 -3
View File
@@ -98,13 +98,14 @@ func (p *WebhookPublisher) makeHttpRequest(r *publishRequest) {
// Event and object type aren't in the serialized object // Event and object type aren't in the serialized object
req.Header.Add("Content-Type", "application/json") req.Header.Add("Content-Type", "application/json")
req.Header.Add("X-Kubernetes-Event-Type", string(r.watchEvent.Type)) req.Header.Add("X-Kubernetes-Event-Type", string(r.watchEvent.Type))
req.Header.Add("X-Kubernetes-Object-Type", reflect.TypeOf(r.watchEvent.Object).Name()) req.Header.Add("X-Kubernetes-Object-Type", reflect.TypeOf(r.watchEvent.Object).Elem().Name())
// Make the request // Make the request
resp, err := http.DefaultClient.Do(req) resp, err := http.DefaultClient.Do(req)
// All done if the request succeeded with 200 OK.
if err == nil && resp.StatusCode == 200 { if err == nil && resp.StatusCode == 200 {
resp.Body.Close() resp.Body.Close()
// all done.
return return
} }
@@ -120,7 +121,7 @@ func (p *WebhookPublisher) makeHttpRequest(r *publishRequest) {
} }
} }
// Schedule a retry, or give up // Schedule a retry, or give up if out of retries
r.retries-- r.retries--
if r.retries > 0 { if r.retries > 0 {
r.retryDelay *= time.Duration(2) r.retryDelay *= time.Duration(2)