mirror of
https://github.com/openfaas/faas.git
synced 2025-06-21 14:23:25 +00:00
Add QueueName to async requests
The queue's name will be consumed by the queue worker to publish to other topics / slow queues. Signed-off-by: Alex Ellis (OpenFaaS Ltd) <alexellis2@gmail.com>
This commit is contained in:
@ -3,21 +3,47 @@
|
|||||||
|
|
||||||
package queue
|
package queue
|
||||||
|
|
||||||
import "net/url"
|
import (
|
||||||
import "net/http"
|
"net/http"
|
||||||
|
"net/url"
|
||||||
|
)
|
||||||
|
|
||||||
// Request for asynchronous processing
|
// Request for asynchronous processing
|
||||||
type Request struct {
|
type Request struct {
|
||||||
Header http.Header
|
// Header from HTTP request
|
||||||
Host string
|
Header http.Header
|
||||||
Body []byte
|
|
||||||
Method string
|
// Host from HTTP request
|
||||||
Path string
|
Host string
|
||||||
|
|
||||||
|
// Body from HTTP request to use for invocation
|
||||||
|
Body []byte
|
||||||
|
|
||||||
|
// Method from HTTP request
|
||||||
|
Method string
|
||||||
|
|
||||||
|
// Path from HTTP request
|
||||||
|
Path string
|
||||||
|
|
||||||
|
// QueryString from HTTP request
|
||||||
QueryString string
|
QueryString string
|
||||||
Function string
|
|
||||||
|
// Function name to invoke
|
||||||
|
Function string
|
||||||
|
|
||||||
|
// QueueName to publish the request to, leave blank
|
||||||
|
// for default.
|
||||||
|
QueueName string
|
||||||
|
|
||||||
|
// Used by queue worker to submit a result
|
||||||
CallbackURL *url.URL `json:"CallbackUrl"`
|
CallbackURL *url.URL `json:"CallbackUrl"`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// RequestQueuer can public a request to be executed asynchronously
|
||||||
|
type RequestQueuer interface {
|
||||||
|
Queue(req *Request) error
|
||||||
|
}
|
||||||
|
|
||||||
// CanQueueRequests can take on asynchronous requests
|
// CanQueueRequests can take on asynchronous requests
|
||||||
type CanQueueRequests interface {
|
type CanQueueRequests interface {
|
||||||
Queue(req *Request) error
|
Queue(req *Request) error
|
||||||
|
Reference in New Issue
Block a user