MCPcopy Create free account

hub / github.com/zalando/skipper / functions

Functions5,794 in github.com/zalando/skipper

↓ 2 callersFunctionNewFilterOptionsWithDefaults
(opaControlPlaneURL string)
filters/openpolicyagent/opaauthorizerequest/benchmark_test.go:779
↓ 2 callersFunctionNewFirst
NewFirst creates a specification for the xforwardFirst filter that prepends the remote IP of the incoming request to the X-Forwarded-For header, and s
filters/xforward/xforward.go:33
↓ 2 callersFunctionNewFlowId
NewFlowId creates a new standard generator with the defined length and returns a Flow ID. Deprecated: For backward compatibility this exported functi
filters/flowid/filter.go:42
↓ 2 callersMethodNewGrant
()
filters/auth/grantconfig.go:287
↓ 2 callersMethodNewGrantCallback
()
filters/auth/grantconfig.go:291
↓ 2 callersMethodNewGrantClaimsQuery
()
filters/auth/grantconfig.go:295
↓ 2 callersFunctionNewGrantCookiesWithHost
(t *testing.T, config *OAuthConfig, host string)
filters/auth/grantcookie_test.go:66
↓ 2 callersMethodNewGrantLogout
()
filters/auth/grantconfig.go:303
↓ 2 callersFunctionNewHeaderToQuery
NewHeaderToQuery creates a filter which converts the headers from the incoming Request to query params headerToQuery("X-Foo-Header", "foo-query-para
filters/builtin/headertoquery.go:25
↓ 2 callersFunctionNewHistogramRequestLatency
NewHistogramRequestLatency creates filters that add latency to requests according to the histogram distribution. It expects a list of interleaved dura
filters/diag/histogram.go:38
↓ 2 callersFunctionNewHistogramResponseLatency
NewHistogramResponseLatency creates filters that add latency to responses according to the histogram distribution, similar to NewHistogramRequestLaten
filters/diag/histogram.go:43
↓ 2 callersFunctionNewHost
NewHost creates a filter specification for the rfcHost() filter, that removes a trailing dot in the host header. See also the PatchHost documentation
filters/rfc/rfc.go:42
↓ 2 callersFunctionNewJwtValidationKeys
NewJwtValidationKeys creates a filter spec for JWT validation using a direct JWKS URL. Unlike jwtValidation which discovers JWKS via .well-known/open
filters/auth/jwt_validation.go:182
↓ 2 callersFunctionNewLIFOGroup
()
filters/scheduler/lifo.go:46
↓ 2 callersFunctionNewLatency
NewLatency creates a filter specification whose filter instances can be used to add additional latency to responses. It expects the latency in millise
filters/diag/diag.go:173
↓ 2 callersFunctionNewLogHeader
NewLogHeader creates a filter specification for the 'logHeader()' filter.
filters/diag/logheader.go:16
↓ 2 callersFunctionNewModResponseHeader
NewModResponseHeader returns a new filter Spec, whose instances execute regexp.ReplaceAllString on the request host. Instances expect three parameters
filters/builtin/mod_header.go:87
↓ 2 callersFunctionNewOAuthOidcAllClaimsWithOptions
NewOAuthOidcAllClaimsWithOptions creates a filter spec which verifies that the token has all the claims specified
filters/auth/oidc.go:174
↓ 2 callersFunctionNewOAuthOidcUserInfosWithOptions
NewOAuthOidcUserInfosWithOptions creates filter spec which tests user info.
filters/auth/oidc.go:152
↓ 2 callersFunctionNewOAuthTokenintrospectionAllClaims
(timeout time.Duration)
filters/auth/tokenintrospection.go:153
↓ 2 callersFunctionNewOpaServeResponseWithReqBodySpec
(registry *openpolicyagent.OpenPolicyAgentRegistry)
filters/openpolicyagent/opaserveresponse/opaserveresponse.go:33
↓ 2 callersFunctionNewOpenPolicyAgentConfig
(opts ...func(*OpenPolicyAgentInstanceConfig) error)
filters/openpolicyagent/openpolicyagent.go:407
↓ 2 callersFunctionNewPath
NewPath creates a filter specification for the rfcPath() filter, that reencodes the reserved characters in the request path, if it detects that they a
filters/rfc/rfc.go:25
↓ 2 callersFunctionNewQueryToHeader
NewQueryToHeader creates a filter which converts query params from the incoming Request to headers queryToHeader("foo-query-param", "X-Foo-Header")
filters/builtin/querytoheader.go:33
↓ 2 callersFunctionNewRandom
NewRandom creates a filter specification whose filter instances can be used to respond to requests with random text of specified length. It expects th
filters/diag/diag.go:134
↓ 2 callersFunctionNewRateBreaker
NewRateBreaker creates a filter specification to instantiate rateBreaker() filters. These filters set a breaker for the current route that open if th
filters/circuit/breaker.go:77
↓ 2 callersFunctionNewReadTimeout
()
filters/builtin/timeout.go:28
↓ 2 callersFunctionNewRoundTripper
(log logging.Logger, addr, filename string)
proxy/fastcgi/fastcgi.go:23
↓ 2 callersFunctionNewScript
(src string)
net/valkey.go:591
↓ 2 callersFunctionNewSetContextRequestHeader
NewSetContextRequestHeader returns a filter specification used to set request headers with a given name and a value taken from the filter context stat
filters/builtin/headerfilter.go:118
↓ 2 callersFunctionNewSetContextResponseHeader
NewSetContextResponseHeader returns a filter specification used to set response headers with a given name and a value taken from the filter context st
filters/builtin/headerfilter.go:132
↓ 2 callersFunctionNewSetDynamicBackendHostFromHeader
NewSetDynamicBackendHostFromHeader returns a filter specification that is used to set dynamic backend host from a header. Instances expect one paramet
filters/builtin/dynamicbackendfilter.go:45
↓ 2 callersFunctionNewSetDynamicBackendSchemeFromHeader
NewSetDynamicBackendSchemeFromHeader returns a filter specification that is used to set dynamic backend scheme from a header. Instances expect one par
filters/builtin/dynamicbackendfilter.go:54
↓ 2 callersFunctionNewSetDynamicBackendUrlFromHeader
NewSetDynamicBackendUrlFromHeader returns a filter specification that is used to set dynamic backend url from a header. Instances expect one parameter
filters/builtin/dynamicbackendfilter.go:64
↓ 2 callersFunctionNewShardedClusterRateLimit
NewShardedClusterRateLimit creates a cluster rate limiter that uses multiple group shards to count hits. Based on the configured group and maxHits eac
filters/ratelimit/ratelimit.go:143
↓ 2 callersFunctionNewShutdown
NewShutdown provides a predicate spec to create predicates that evaluate to true if Skipper is shutting down
predicates/primitive/shutdown.go:22
↓ 2 callersFunctionNewSlowReader
NewSlowReader creates a new slowReader wrapping the given io.Reader with a delay after each byte.
io/iotest/reader.go:15
↓ 2 callersFunctionNewStaticNodeInfo
(name, addr string)
swarm/nodeinfo.go:29
↓ 2 callersFunctionNewSwarm
NewSwarm creates a Swarm for given Options.
swarm/swarm.go:124
↓ 2 callersFunctionNewSwarmRegistry
NewSwarmRegistry initializes a registry with an optional swarm and the provided default settings.
ratelimit/registry.go:39
↓ 2 callersFunctionNewTarpit
()
filters/diag/tarpit.go:16
↓ 2 callersFunctionNewTeeDeprecated
NewTeeDeprecated returns a new tee filter Spec, whose instances execute the exact same Request against a shadow backend. parameters: shadow backend ur
filters/tee/tee.go:138
↓ 2 callersFunctionNewTestAdmitter
()
dataclients/kubernetes/admission/admission_test.go:60
↓ 2 callersMethodNewTransport
(tr http.RoundTripper, opts opatracing.Options)
filters/openpolicyagent/tracing.go:49
↓ 2 callersFunctionNewULIDGeneratorWithEntropyProvider
NewULIDGeneratorWithEntropyProvider behaves like NewULIDGenerator but allows you to specify your own source of entropy. Access to the entropy provider
filters/flowid/ulid.go:32
↓ 2 callersFunctionNewWebhook
NewWebhook creates a new auth filter specification to validate authorization for requests via an external web hook.
filters/auth/webhook.go:45
↓ 2 callersFunctionNewWrap
NewWrap creates a filter specification whose filter instances can be used to add prefix and suffix to the response. Eskip example: r: * -> wrapConte
filters/diag/diag.go:158
↓ 2 callersFunctionNewWriteTimeout
()
filters/builtin/timeout.go:34
↓ 2 callersMethodNode
()
swarm/nodeinfo.go:13
↓ 2 callersMethodNodes
()
swarm/nodeinfo.go:18
↓ 2 callersMethodParse
()
config/config.go:799
↓ 2 callersFunctionParseIPCIDRs
ParseIPCIDRs returns a valid IPSet when there is no parsing error.
net/net.go:136
↓ 2 callersFunctionParseIngressV1JSON
ParseIngressV1JSON parse JSON into an IngressV1List
dataclients/kubernetes/definitions/ingressv1.go:106
↓ 2 callersFunctionParseRouteGroupsJSON
ParseRouteGroupsJSON parses a json list of RouteGroups into RouteGroupList
dataclients/kubernetes/definitions/routegroups.go:267
↓ 2 callersMethodPathParam
Provides the wildcard parameter values from the request path by their name as the key.
filters/filters.go:83
↓ 2 callersFunctionPutDataToTTL
Saves a route with TTL in etcd with the specified prefix.
etcd/etcdtest/mocketcd.go:190
↓ 2 callersMethodReconfigure
Reconfigure updates the configuration of the FifoQueue. It will reset the current state.
scheduler/scheduler.go:333
↓ 2 callersMethodRedirectURLs
RedirectURLs constructs the redirect URI based on the request and the configured CallbackPath.
filters/auth/grantconfig.go:367
↓ 2 callersMethodRequest
()
proxy/context.go:207
↓ 2 callersMethodRequest
(ctx filters.FilterContext)
filters/diag/logheader.go:88
↓ 2 callersMethodReset
Reset clears the recorded spans and sets the trace content to defined value.
tracing/tracingtest/testtracer.go:83
↓ 2 callersMethodResponse
()
eskip/template.go:28
↓ 2 callersMethodResponse
(ctx filters.FilterContext)
filters/diag/logheader.go:54
↓ 2 callersMethodResponseController
()
proxy/context.go:161
↓ 2 callersMethodRingAvailable
()
net/redisclient.go:351
↓ 2 callersMethodRingAvailable
(ctx context.Context)
net/valkey.go:500
↓ 2 callersMethodRouteId
RouteId Returns the route ID of the currently matched route or an empty string if no route has been matched yet.
filters/filters.go:141
↓ 2 callersFunctionSchemeHost
SchemeHost parses URI string (without #fragment part) and returns schema used in this URI as first return value and host[:port] part as second return
net/net.go:167
↓ 2 callersMethodScopedPrometheusRegisterer
(subsystem string)
metrics/metrics.go:67
↓ 2 callersMethodServeHTTP
(w http.ResponseWriter, r *http.Request)
net/query.go:14
↓ 2 callersMethodServeHTTP
(w http.ResponseWriter, r *http.Request)
net/host.go:58
↓ 2 callersMethodServeHTTP
(w http.ResponseWriter, r *http.Request)
net/headers.go:84
↓ 2 callersMethodSet
(ctx context.Context, key string, value interface{}, expiration time.Duration)
net/redisclient.go:417
↓ 2 callersMethodSetAddr
(addr []string)
net/valkey.go:199
↓ 2 callersMethodSetAddrs
(ctx context.Context, addrs []string)
net/redisclient.go:405
↓ 2 callersMethodSetBaggageItem
SetBaggageItem sets a key:value pair on this Span and its SpanContext that also propagates to descendants of this Span.
tracing/tracingtest/testtracer.go:189
↓ 2 callersMethodSetInvalidRoute
(routeID, reason string)
metrics/metricstest/metricsmock.go:235
↓ 2 callersMethodShortTimeFormat
ShortTimeFormat provides a time formatted of 20060102.
filters/awssigner/internal/time.go:18
↓ 2 callersFunctionSplitBackend
SplitBackend splits the backend address into separate scheme and host variables. This function is exported to be used by validation components.
routing/datasource.go:224
↓ 2 callersMethodStart
()
proxy/proxytest/proxytest.go:129
↓ 2 callersMethodStartMetricsCollection
()
net/redisclient.go:365
↓ 2 callersFunctionStartMultiBundleProxyServer
StartMultiBundleProxyServer starts a proxy server that routes requests to multiple controllable bundle servers. Accepts a slice of ControllableBundleS
filters/openpolicyagent/internal/opatestutils/openpolicyagent_helpers.go:114
↓ 2 callersFunctionStartValidation
StartValidation launches the validation webhook server and keeps serving until the returned listener encounters an unrecoverable error, or the process
validation/validation.go:35
↓ 2 callersMethodStateBag
()
proxy/context.go:212
↓ 2 callersFunctionStop
()
etcd/etcdtest/mocketcd.go:123
↓ 2 callersMethodString
()
config/regexplistflag.go:10
↓ 2 callersMethodString
()
config/routechangerconfig.go:21
↓ 2 callersMethodStrs
(min, max, minLength, maxLength int)
routing/pathgen/pathgen.go:107
↓ 2 callersMethodSwap
(i, j int)
filters/builtin/compress.go:106
↓ 2 callersMethodTemporary
()
queuelistener/listener_test.go:38
↓ 2 callersMethodTotalSuccess
()
net/httptest/client.go:86
↓ 2 callersMethodTraceID
()
tracing/tracing.go:157
↓ 2 callersMethodUnmute
()
logging/loggingtest/logger.go:199
↓ 2 callersMethodUpdateGauge
(key string, value float64)
metrics/metricstest/metricsmock.go:221
↓ 2 callersMethodUpsertAll
(routes []*eskip.Route)
cmd/eskip/writeclient.go:11
↓ 2 callersMethodWaitForN
WaitForN returns nil when n logging events matching exp were received or returns ErrWaitTimeout when to timeout expired.
logging/loggingtest/logger.go:158
↓ 2 callersMethodWarnf
(f string, a ...any)
logging/logger.go:39
↓ 2 callersMethodWeight
Extra Weight of the predicate
routing/routing.go:89
↓ 2 callersFunctionWithBackgroundTaskBufferSize
(size int)
filters/openpolicyagent/openpolicyagent.go:294
↓ 2 callersFunctionWithBearerToken
WithBearerToken adds an Authorization header with "Bearer " prefix and add the given bearerToken as value to all requests. To regular update your toke
net/httpclient.go:509
← previousnext →1,301–1,400 of 5,794, ranked by callers