faas-rs/faas
1
0
Fork 0
mirror of https://github.com/openfaas/faas.git synced 2025-06-19 20:46:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update async for CallbackUrl

Browse Source 
Signed-off-by: Alex <alexellis2@gmail.com>
This commit is contained in:
Alex
2017-08-22 08:39:25 +01:00
committed by Alex Ellis
parent 3031531b3c
commit 2cca166dc0
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
docker-compose.extended.yml
View File

@ -33,7 +33,7 @@ services:
networks: networks:
- functions - functions
queue-worker: queue-worker:
image: functions/queue-worker:latest-dev image: functions/queue-worker:0.1
networks: networks:
- functions - functions
deploy: deploy:

2
gateway/handlers/queueproxy.go
View File

@ -28,7 +28,7 @@ func MakeQueuedProxy(metrics metrics.MetricOptions, wildcard bool, logger *logru
vars := mux.Vars(r) vars := mux.Vars(r)
name := vars["name"] name := vars["name"]
callbackURLHeader := r.Header.Get("X-Callback-URL") callbackURLHeader := r.Header.Get("X-Callback-Url")
var callbackURL *url.URL var callbackURL *url.URL
if len(callbackURLHeader) > 0 { if len(callbackURLHeader) > 0 {

2
gateway/queue/types.go
View File

@ -8,9 +8,9 @@ type Request struct {
Header http.Header Header http.Header
Body []byte Body []byte
Method string Method string
CallbackURL *url.URL
QueryString string QueryString string
Function string Function string
CallbackURL *url.URL `json:"CallbackUrl"`
} }
// CanQueueRequests can take on asynchronous requests // CanQueueRequests can take on asynchronous requests