gateway

Documentation

Index

• func WithContentType(contentType string, delegate http.HandlerFunc) http.HandlerFunc
• type Handle
  • func (gateway *Handle) GetWebhookSourceDefName(writeKey string) (name string, ok bool)
  • func (gateway *Handle) IncrementAckCount(count uint64)
  • func (gateway *Handle) IncrementRecvCount(count uint64)
  • func (gateway *Handle) NewSourceStat(writeKey, reqType string) *gwstats.SourceStat
  • func (gateway *Handle) ProcessWebRequest(w *http.ResponseWriter, r *http.Request, reqType string, payload []byte, ...) string
  • func (gateway *Handle) SaveWebhookFailures(reqs []*model.FailedWebhookPayload) error
  • func (gateway *Handle) Setup(ctx context.Context, config *config.Config, logger logger.Logger, ...) error
  • func (gateway *Handle) Shutdown() error
  • func (gateway *Handle) StartAdminHandler(ctx context.Context) error
  • func (gateway *Handle) StartWebHandler(ctx context.Context) error
  • func (gateway *Handle) TrackRequestMetrics(errorMessage string)
• type ImportRequestHandler
  • func (irh *ImportRequestHandler) ProcessRequest(w *http.ResponseWriter, r *http.Request, _ string, payload []byte, ...) string
• type RegularRequestHandler
  • func (rrh *RegularRequestHandler) ProcessRequest(w *http.ResponseWriter, r *http.Request, reqType string, payload []byte, ...) string
• type RequestHandler

Functions

func WithContentType

func WithContentType(contentType string, delegate http.HandlerFunc) http.HandlerFunc

Types

type Handle

type Handle struct {
	// contains filtered or unexported fields
}

func (*Handle) GetWebhookSourceDefName

func (gateway *Handle) GetWebhookSourceDefName(writeKey string) (name string, ok bool)

GetWebhookSourceDefName returns the webhook source definition name by write key

func (*Handle) IncrementAckCount

func (gateway *Handle) IncrementAckCount(count uint64)

IncrementAckCount increments the acknowledged count for gateway requests

func (*Handle) IncrementRecvCount

func (gateway *Handle) IncrementRecvCount(count uint64)

IncrementRecvCount increments the received count for gateway requests

func (*Handle) NewSourceStat

func (gateway *Handle) NewSourceStat(writeKey, reqType string) *gwstats.SourceStat

func (*Handle) ProcessWebRequest

func (gateway *Handle) ProcessWebRequest(w *http.ResponseWriter, r *http.Request, reqType string, payload []byte, writeKey string) string

ProcessWebRequest is an interface wrapper for webhook

func (*Handle) SaveWebhookFailures

func (gateway *Handle) SaveWebhookFailures(reqs []*model.FailedWebhookPayload) error

SaveErrors saves errors to the error db

func (*Handle) Setup

func (gateway *Handle) Setup(
	ctx context.Context,
	config *config.Config, logger logger.Logger, stat stats.Stats,
	application app.App, backendConfig backendconfig.BackendConfig, jobsDB, errDB jobsdb.JobsDB,
	rateLimiter throttler.Throttler, versionHandler func(w http.ResponseWriter, r *http.Request),
	rsourcesService rsources.JobService, sourcehandle sourcedebugger.SourceDebugger,
) error

Setup initializes this module: - Monitors backend config for changes. - Starts web request batching goroutine, that batches incoming messages. - Starts web request batch db writer goroutine, that writes incoming batches to JobsDB. - Starts debugging goroutine that prints gateway stats.

This function will block until backend config is initially received.

func (*Handle) Shutdown

func (gateway *Handle) Shutdown() error

func (*Handle) StartAdminHandler

func (gateway *Handle) StartAdminHandler(ctx context.Context) error

StartAdminHandler for Admin Operations

func (*Handle) StartWebHandler

func (gateway *Handle) StartWebHandler(ctx context.Context) error

StartWebHandler starts all gateway web handlers, listening on gateway port. Supports CORS from all origins. This function will block.

func (*Handle) TrackRequestMetrics

func (gateway *Handle) TrackRequestMetrics(errorMessage string)

TrackRequestMetrics updates the track counters (success and failure counts)

type ImportRequestHandler

type ImportRequestHandler struct {
	*Handle
}

ImportRequestHandler is an empty struct to capture import specific request handling functionality

func (*ImportRequestHandler) ProcessRequest

func (irh *ImportRequestHandler) ProcessRequest(w *http.ResponseWriter, r *http.Request, _ string, payload []byte, writeKey string) string

ProcessRequest on ImportRequestHandler splits payload by user and throws them into the webrequestQ and waits for all their responses before returning

type RegularRequestHandler

type RegularRequestHandler struct {
	*Handle
}

RegularRequestHandler is an empty struct to capture non-import specific request handling functionality

func (*RegularRequestHandler) ProcessRequest

func (rrh *RegularRequestHandler) ProcessRequest(w *http.ResponseWriter, r *http.Request, reqType string, payload []byte, writeKey string) string

ProcessRequest throws a webRequest into the queue and waits for the response before returning

type RequestHandler

type RequestHandler interface {
	ProcessRequest(w *http.ResponseWriter, r *http.Request, reqType string, payload []byte, writeKey string) string
}

RequestHandler interface for abstracting out server-side import request processing and rest of the calls