README
¶
pubsub-push-middleware
Helper for handling GCP pubsub push messages in Go HTTP servers.
Why?
This middleware allows you to use your normal HTTP handlers with pubsub push messages. It does this by "promoting" the data in the pubsub push message to the HTTP request body. I use this with both RESTful and Twirp APIs. This allows me to use the same handlers for pubsub push without changing them.
Usage
import push "github.com/bakins/pubsub-push-middleware"
// assume handler is you normal HTTP handler.
mw := push.New(handler)
http.ListenAndServe(":8080", mw)
LICENSE
See LICENSE
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultDetect ¶
DefaultDetect checks if the body contains subscription and message json fields
Types ¶
type DetectFunc ¶
DetectFunc detects if the request is a pubsub push request. Request will have already been tested to see if body is json and method is POST.
type Option ¶
type Option func(*Options)
Option is a single option when creating middleware.
func WithDetector ¶
func WithDetector(detect DetectFunc) Option
WithDetector sets the function to call to detect if the request body is a pubsub push request. If not set, DefaultDetect is used.
func WithPrefixes ¶
WithPrefixes sets the middleware to only run for the given prefixes. By default, all requests are checked. Prefixes are checked using simple string prefix checks.
Source Files