filters

package
v0.21.4-rc.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 16, 2021 License: Apache-2.0 Imports: 32 Imported by: 377

Documentation

Overview

Package filters contains all the http handler chain filters which are not api related.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BasicLongRunningRequestCheck

func BasicLongRunningRequestCheck(longRunningVerbs, longRunningSubresources sets.String) apirequest.LongRunningRequestCheck

BasicLongRunningRequestCheck returns true if the given request has one of the specified verbs or one of the specified subresources, or is a profiler request.

func StartMaxInFlightWatermarkMaintenance added in v0.19.5

func StartMaxInFlightWatermarkMaintenance(stopCh <-chan struct{})

StartMaxInFlightWatermarkMaintenance starts the goroutines to observe and maintain watermarks for max-in-flight requests.

func StartPriorityAndFairnessWatermarkMaintenance added in v0.19.5

func StartPriorityAndFairnessWatermarkMaintenance(stopCh <-chan struct{})

StartPriorityAndFairnessWatermarkMaintenance starts the goroutines to observe and maintain watermarks for priority-and-fairness requests.

func WithCORS

func WithCORS(handler http.Handler, allowedOriginPatterns []string, allowedMethods []string, allowedHeaders []string, exposedHeaders []string, allowCredentials string) http.Handler

WithCORS is a simple CORS implementation that wraps an http Handler. Pass nil for allowedMethods and allowedHeaders to use the defaults. If allowedOriginPatterns is empty or nil, no CORS support is installed.

func WithContentType

func WithContentType(handler http.Handler, contentType string) http.Handler

WithContentType sets both the Content-Type and the X-Content-Type-Options (nosniff) header

func WithHSTS added in v0.21.0

func WithHSTS(handler http.Handler, hstsDirectives []string) http.Handler

WithHSTS is a simple HSTS implementation that wraps an http Handler. If hstsDirectives is empty or nil, no HSTS support is installed.

func WithMaxInFlightLimit

func WithMaxInFlightLimit(
	handler http.Handler,
	nonMutatingLimit int,
	mutatingLimit int,
	longRunningRequestCheck apirequest.LongRunningRequestCheck,
) http.Handler

WithMaxInFlightLimit limits the number of in-flight requests to buffer size of the passed in channel.

func WithPanicRecovery

func WithPanicRecovery(handler http.Handler, resolver request.RequestInfoResolver) http.Handler

WithPanicRecovery wraps an http Handler to recover and log panics (except in the special case of http.ErrAbortHandler panics, which suppress logging).

func WithPriorityAndFairness added in v0.18.0

func WithPriorityAndFairness(
	handler http.Handler,
	longRunningRequestCheck apirequest.LongRunningRequestCheck,
	fcIfc utilflowcontrol.Interface,
) http.Handler

WithPriorityAndFairness limits the number of in-flight requests in a fine-grained way.

func WithProbabilisticGoaway added in v0.18.0

func WithProbabilisticGoaway(inner http.Handler, chance float64) http.Handler

WithProbabilisticGoaway returns an http.Handler that send GOAWAY probabilistically according to the given chance for HTTP2 requests. After client receive GOAWAY, the in-flight long-running requests will not be influenced, and the new requests will use a new TCP connection to re-balancing to another server behind the load balance.

func WithTimeout

func WithTimeout(h http.Handler, timeoutFunc timeoutFunc) http.Handler

WithTimeout returns an http.Handler that runs h with a timeout determined by timeoutFunc. The new http.Handler calls h.ServeHTTP to handle each request, but if a call runs for longer than its time limit, the handler responds with a 504 Gateway Timeout error and the message provided. (If msg is empty, a suitable default message will be sent.) After the handler times out, writes by h to its http.ResponseWriter will return http.ErrHandlerTimeout. If timeoutFunc returns a nil timeout channel, no timeout will be enforced. recordFn is a function that will be invoked whenever a timeout happens.

func WithTimeoutForNonLongRunningRequests

func WithTimeoutForNonLongRunningRequests(handler http.Handler, longRunning apirequest.LongRunningRequestCheck) http.Handler

WithTimeoutForNonLongRunningRequests times out non-long-running requests after the time given by timeout.

func WithWaitGroup

func WithWaitGroup(handler http.Handler, longRunning apirequest.LongRunningRequestCheck, wg *utilwaitgroup.SafeWaitGroup) http.Handler

WithWaitGroup adds all non long-running requests to wait group, which is used for graceful shutdown.

Types

type GoawayDecider added in v0.18.0

type GoawayDecider interface {
	Goaway(r *http.Request) bool
}

GoawayDecider decides if server should send a GOAWAY

type PriorityAndFairnessClassification added in v0.18.0

type PriorityAndFairnessClassification struct {
	FlowSchemaName    string
	FlowSchemaUID     apitypes.UID
	PriorityLevelName string
	PriorityLevelUID  apitypes.UID
}

PriorityAndFairnessClassification identifies the results of classification for API Priority and Fairness

func GetClassification added in v0.18.0

func GetClassification(ctx context.Context) *PriorityAndFairnessClassification

GetClassification returns the classification associated with the given context, if any, otherwise nil

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL