gateway

package

Go to main page

Versions in this module

v1

v1.148.0

Aug 11, 2023

v1.147.0

Mar 30, 2023

v1.146.0

Mar 22, 2023

v1.145.0

Mar 1, 2023

v1.144.0

Feb 17, 2023

v1.143.0

Feb 17, 2023

v1.142.0

Jan 27, 2023

v1.141.0

Jan 21, 2023

v1.140.0

Jan 21, 2023

Changes in this version

type SourceExtractor

+ func NewDefaultSourceExtractor(authCookieName string) SourceExtractor

v1.122.0

Sep 23, 2021

Changes in this version

+ type LimiterMetricManager interface

+ RegisterAcceptedConnection func()

+ RegisterLimitedConnection func()

type Option

+ func OptionSourceRateLimitingManager(m LimiterMetricManager) Option

+ func OptionTCPGlobalRateLimitingManager(m LimiterMetricManager) Option

v1.121.0

Jul 5, 2021

Changes in this version

+ const CORSOriginMirror

type Option

+ func OptionCORSAllowCredentials(allow bool) Option

v1.120.0

Jun 25, 2020

Changes in this version

type Option

+ func OptionRateLimiting(enabled bool, cps int, burst int) Option

+ func OptionTCPRateLimiting(enabled bool, cps float64, burst int, maxConnections int) Option

v1.113.0

Jan 4, 2021

v1.112.2

Apr 6, 2021

v1.112.1

Mar 23, 2021

Changes in this version

+ var ErrUpstreamerTooManyRequests = errors.New("Please retry in a moment")

+ type ErrorWriter func(w http.ResponseWriter, r *http.Request, eerr elemental.Error)

+ type Gateway interface

+ Start func()

+ Stop func()

+ func New(listenAddr string, upstreamer Upstreamer, options ...Option) (Gateway, error)

+ type InterceptorAction int

+ const InterceptorActionForward

+ const InterceptorActionForwardDirect

+ const InterceptorActionForwardWS

+ const InterceptorActionStop

+ type InterceptorFunc func(w http.ResponseWriter, req *http.Request, ew ErrorWriter, corsInjector func()) (action InterceptorAction, upstream string, err error)

+ type LatencyBasedUpstreamer interface

+ CollectLatency func(address string, responseTime time.Duration)

+ type Option func(*gwconfig)

+ func OptionAdditionnalAllowedCORSOrigin(origins []string) Option

+ func OptionAllowedCORSOrigin(origin string) Option

+ func OptionBlockOpenTracingHeaders(block bool) Option

+ func OptionEnableMaintenance(enabled bool) Option

+ func OptionEnableProxyProtocol(enabled bool, subnet string) Option

+ func OptionEnableTrace(enabled bool) Option

+ func OptionExposePrivateAPIs(enabled bool) Option

+ func OptionHTTPTimeouts(read, write, idle time.Duration, disableKeepAlive bool) Option

+ func OptionMetricsManager(metricsManager bahamut.MetricsManager) Option

+ func OptionRegisterExactInterceptor(path string, f InterceptorFunc) Option

+ func OptionRegisterPrefixInterceptor(prefix string, f InterceptorFunc) Option

+ func OptionRegisterSuffixInterceptor(prefix string, f InterceptorFunc) Option

+ func OptionServerTLSConfig(tlsConfig *tls.Config) Option

+ func OptionSetCustomRequestRewriter(r RequestRewriter) Option

+ func OptionSetCustomResponseRewriter(r ResponseRewriter) Option

+ func OptionSourceRateLimiting(rps rate.Limit, burst int) Option

+ func OptionSourceRateLimitingDynamic(rateExtractor RateExtractor) Option

+ func OptionSourceRateLimitingSourceExtractor(sourceExtractor SourceExtractor) Option

+ func OptionTCPClientMaxConnections(maxConnections int) Option

+ func OptionTCPClientMaxConnectionsSourceExtractor(sourceExtractor SourceExtractor) Option

+ func OptionTCPGlobalRateLimiting(cps rate.Limit, burst int) Option

+ func OptionTrustForwardHeader(trust bool) Option

+ func OptionUpstreamConfig(upstreamMaxConnsPerHost int, upstreamMaxIdleConns int, ...) Option

+ func OptionUpstreamEnableCompression(enable bool) Option

+ func OptionUpstreamTLSConfig(tlsConfig *tls.Config) Option

+ func OptionUpstreamURLScheme(scheme string) Option

+ type RateExtractor interface

+ ExtractRates func(r *http.Request) (rate.Limit, int, error)

+ type RequestRewriter func(req *http.Request, private bool) error

+ type ResponseRewriter func(*http.Response) error

+ type SourceExtractor interface

+ ExtractSource func(req *http.Request) (token string, err error)

+ type Upstreamer interface

+ Upstream func(req *http.Request) (upstream string, err error)

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