Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/zalando/skipper
/ functions
Functions
5,794 in github.com/zalando/skipper
⨍
Functions
5,794
◇
Types & classes
1,022
↓ 5 callers
Method
MeasureAllFiltersResponse
(routeId string, start time.Time)
metrics/metrics.go:46
↓ 5 callers
Method
MeasureBackend
(routeId string, start time.Time)
metrics/metrics.go:43
↓ 5 callers
Method
MeasureFilterResponse
(filterName string, start time.Time)
metrics/metrics.go:45
↓ 5 callers
Function
New
()
predicates/tee/tee.go:26
↓ 5 callers
Function
New
New returns an initialized Proxy. Deprecated, see WithParams and Params instead.
proxy/proxy.go:784
↓ 5 callers
Function
New
New creates a data client that parses a string of eskip routes and serves it for the routing package.
dataclients/routestring/string.go:20
↓ 5 callers
Function
NewBaggageToTagFilter
()
filters/tracing/baggagetotag.go:49
↓ 5 callers
Function
NewContext
NewContext returns a new context with associated routing context. It does nothing and returns ctx if it already has associated routing context.
routing/context.go:14
↓ 5 callers
Function
NewForwardTokenField
NewForwardTokenField creates a filter to forward fields from token info or token introspection or oidc user info as headers to the backend server.
filters/auth/forwardtokenfield.go:25
↓ 5 callers
Function
NewInlineContent
NewInlineContent creates a filter spec for the inlineContent() filter. Usage of the filter: r: * -> status(420) -> inlineContent("Enhance Your Calm
filters/builtin/inlinecontent.go:32
↓ 5 callers
Function
NewJWTPayloadAnyKVRegexp
()
predicates/auth/jwt.go:121
↓ 5 callers
Function
NewListener
(opt Options)
proxylistener/proxylistener.go:28
↓ 5 callers
Function
NewMaskAccessLogQuery
NewMaskAccessLogQuery creates a filter spec to mask specific query parameters from the access log for a specific route. Takes in query param keys as a
filters/accesslog/control.go:123
↓ 5 callers
Function
NewMtlsSanIP
NewMtlsSanIP returns a filter spec for the mtlsSanIP filter. Each argument must be a valid IP address. IP addresses are combined into a single netipx.
filters/tls/mtls.go:150
↓ 5 callers
Function
NewOAuthTokeninfoAllScopeWithOptions
(to TokeninfoOptions)
filters/auth/tokeninfo.go:114
↓ 5 callers
Function
NewOrigin
NewOrigin creates a CORS origin handler that can check for allowed origin or set an all allowed header
filters/cors/cors.go:20
↓ 5 callers
Function
NewSigningKeyDeriver
()
filters/awssigner/internal/cache.go:25
↓ 5 callers
Function
NewSigningTime
(t time.Time)
filters/awssigner/internal/time.go:46
↓ 5 callers
Function
NewSpanName
NewSpanName creates a filter spec for setting the name of the outgoing span. (By default "proxy".) tracingSpanName("example-operation")
filters/tracing/spanname.go:27
↓ 5 callers
Function
NewStateBagToTag
()
filters/tracing/statebagtotag.go:52
↓ 5 callers
Function
NewStaticDelegateSecret
NewStaticDelegateSecret creates a wrapped SecretsReader, that use given s to the underlying SecretsReader to return the secret.
secrets/readers.go:42
↓ 5 callers
Method
OnConfig
(ctx context.Context, config *config.Config)
filters/openpolicyagent/internal/confighook.go:28
↓ 5 callers
Function
Open
Open opens an eskip file and parses it, returning a DataClient implementation. If reading or parsing the file fails, returns an error. This implementa
eskipfile/file.go:17
↓ 5 callers
Method
OriginalRequest
The copy (deep) of the original incoming request or nil if the implementation does not provide it. The object received from this method contains an e
filters/filters.go:60
↓ 5 callers
Method
ParseQuery
()
filters/openpolicyagent/internal/envoy/envoyplugin.go:68
↓ 5 callers
Method
PreProcessor
()
filters/shedder/admission.go:219
↓ 5 callers
Function
PutDataTo
Saves a route in etcd with the specified prefix.
etcd/etcdtest/mocketcd.go:185
↓ 5 callers
Method
RefreshCiphers
RefreshCiphers rotates the list of cipher.AEAD initialized with SecretSource from the Encrypter.
secrets/encrypter.go:126
↓ 5 callers
Function
RemoteHost
RemoteHost is *deprecated* use RemoteAddr
net/net.go:52
↓ 5 callers
Function
Run
Run skipper.
skipper.go:2636
↓ 5 callers
Method
ScheduleBackgroundTask
ScheduleBackgroundTask schedules a task to be executed in the background with limited parallelism (1) Returns a BackgroundTask that can be used to wai
filters/openpolicyagent/openpolicyagent.go:1438
↓ 5 callers
Method
SetInvalidRoute
(routeId, reason string)
metrics/metrics.go:57
↓ 5 callers
Method
SetLastSeen
(lastSeen time.Time)
routing/endpointregistry.go:22
↓ 5 callers
Method
ShareValue
ShareValue is used to share the local information with its peers.
ratelimit/swim.go:18
↓ 5 callers
Method
Stop
()
swarm/kubernetes.go:87
↓ 5 callers
Method
Str
(min, max int)
routing/pathgen/pathgen.go:97
↓ 5 callers
Function
String
String is the same as Print but defaulting to pretty=false.
eskip/string.go:211
↓ 5 callers
Method
String
String converts BackendPort to string
dataclients/kubernetes/definitions/ingressv1.go:121
↓ 5 callers
Method
UpdateGauge
(key string, v float64)
metrics/codahale.go:115
↓ 5 callers
Function
WithEnvoyMetadataBytes
(content []byte)
filters/openpolicyagent/openpolicyagent.go:376
↓ 5 callers
Function
WithMaxRequestBodyBytes
(n int64)
filters/openpolicyagent/openpolicyagent.go:154
↓ 5 callers
Function
WithPreloadingEnabled
(enabled bool)
filters/openpolicyagent/openpolicyagent.go:280
↓ 5 callers
Function
WithReadBodyBufferSize
(n int64)
filters/openpolicyagent/openpolicyagent.go:168
↓ 5 callers
Method
Write
([]byte)
queuelistener/listener_test.go:41
↓ 5 callers
Method
Write
(p []byte)
net/size.go:43
↓ 5 callers
Method
Write
(p []byte)
routesrv/eskipbytes.go:36
↓ 5 callers
Method
ZCard
(ctx context.Context, key string)
net/redisclient.go:442
↓ 5 callers
Method
ZCard
(ctx context.Context, key string)
net/valkey.go:551
↓ 5 callers
Method
apply
(*eskip.Route)
dataclients/kubernetes/traffic.go:50
↓ 5 callers
Function
assertOpaInstanceHealth
(t *testing.T, registry *openpolicyagent.OpenPolicyAgentRegistry, bundleName string, expectedHealth bool)
filters/openpolicyagent/opaauthorizerequest/openpolicyagent_routeupdate_test.go:152
↓ 5 callers
Function
benchmarkAccessLog
(b *testing.B, filter string, responseCode int)
proxy/proxy_test.go:2236
↓ 5 callers
Function
buildConnStateWithSubject
buildConnStateWithSubject generates a certificate whose Subject is set to subjectName by signing it with a CA that has issuerName "testCA" as its Subj
filters/tls/mtls_test.go:532
↓ 5 callers
Function
buildRequest
(serviceName, region, body string)
filters/awssigner/awssigv4/sigv4_test.go:458
↓ 5 callers
Function
buildfilterContext
(headers ...string)
filters/flowid/filter_test.go:127
↓ 5 callers
Method
calcTotalRequestRate
(now int64, swarmValues map[string]interface{})
ratelimit/swim.go:115
↓ 5 callers
Function
checkMedium
(t *testing.T, left, right *medium, testIndex, itemIndex int)
cmd/eskip/media_test.go:22
↓ 5 callers
Method
checkRequest
(req *http.Request)
routing/routing_test.go:95
↓ 5 callers
Function
cloneHeader
(h http.Header)
proxy/proxy.go:554
↓ 5 callers
Function
cloneRequest
copies requests changes URL and Host in request. If 2nd and 3rd params are given path is also modified by applying regexp Returns the cloned request a
filters/tee/tee.go:264
↓ 5 callers
Method
close
()
scheduler/scheduler.go:133
↓ 5 callers
Method
coalesce
coalesce gates concurrent cold misses for the same key behind a single upstream fetch. All waiters block until the leader's fetch completes, then all
filters/cache/filter.go:332
↓ 5 callers
Function
createOIDCServer
returns a localhost instance implementation of an OpenID Connect server with configendpoint, tokenendpoint, authenticationserver endpoint, userinfor e
filters/auth/oidc_test.go:155
↓ 5 callers
Function
createOpaFilter
(opts FilterOptions)
filters/openpolicyagent/opaauthorizerequest/benchmark_test.go:604
↓ 5 callers
Function
defaultBody
()
proxy/context.go:69
↓ 5 callers
Function
docToMatcher
create a matcher from a routing document with default matching options
routing/matcher_test.go:156
↓ 5 callers
Function
findRouteWithRx
(r []*eskip.Route)
dataclients/kubernetes/path_test.go:32
↓ 5 callers
Function
generateCert
(opts certOptions)
net/httpclient_example_test.go:612
↓ 5 callers
Function
getCompiledRxs
compiles all rxs or fails
routing/matcher.go:99
↓ 5 callers
Function
getFreeStringArgs
(count int, p *eskip.Predicate)
routing/datasource.go:292
↓ 5 callers
Method
getMinTLSVersion
()
config/config.go:1315
↓ 5 callers
Function
getStringArg
(a interface{})
filters/ratelimit/ratelimit.go:433
↓ 5 callers
Method
getTimer
(key string)
metrics/codahale.go:99
↓ 5 callers
Function
getZoneAwareRoutesWithHeaders
(rs *routesrv.RouteServer, zone string, headers map[string]string)
routesrv/routesrv_test.go:138
↓ 5 callers
Function
healthcheckRoutes
(reverseSourcePredicate bool)
dataclients/kubernetes/kube.go:497
↓ 5 callers
Function
initBenchmark
(b *testing.B, init func())
routing/matcher_test.go:272
↓ 5 callers
Function
initializeEndpoints
(endpointAges []float64, algorithmName string, fadeInDuration time.Duration)
proxy/fadein_internal_test.go:56
↓ 5 callers
Method
lock
()
filters/shedder/netconn_test.go:46
↓ 5 callers
Function
matchHeaders
matches a set of request headers to the fix and regexp header conditions
routing/matcher.go:408
↓ 5 callers
Function
matchRegexps
matches the path regexp conditions in a leaf matcher.
routing/matcher.go:387
↓ 5 callers
Function
newEncoder
(enc string, level int)
filters/builtin/compress.go:329
↓ 5 callers
Function
newLeaf
creates a new leaf matcher. preprocesses the Host, PathRegexp, Header and HeaderRegexp conditions. Using a set of regular expressions shared in the c
routing/matcher.go:215
↓ 5 callers
Function
newLogger
newLogger creates a logger that logs each unique message once for the resource identified by kind, namespace and name. It logs nothing when disabled.
dataclients/kubernetes/logger.go:20
↓ 5 callers
Function
newTestClient
(t *testing.T, opts kubernetes.Options, specPath string)
dataclients/kubernetes/client_test.go:14
↓ 5 callers
Function
newYamlFlag
(ptr **T)
config/yamlflag.go:14
↓ 5 callers
Function
parseCacheControl
parseCacheControl parses Cache-Control response directives from h. Uses Header.Values to handle multiple header lines; matches names case-insensitivel
filters/cache/cache_control.go:70
↓ 5 callers
Function
printStderr
(args ...interface{})
cmd/eskip/eskip.go:66
↓ 5 callers
Function
readPluginConfig
(plugin string)
plugins.go:352
↓ 5 callers
Function
runExampleWithOptions
(opts LuaOptions, ctx *testContext)
script/script_test.go:978
↓ 5 callers
Function
safeFileClose
(t *testing.T, fd *os.File)
dataclients/kubernetes/kubernetestest/fixtures.go:145
↓ 5 callers
Method
search
(path string, m Matcher)
pathmux/tree.go:189
↓ 5 callers
Function
setupServices
(t *testing.T, healthy, unhealthy int)
proxy/healthy_endpoints_test.go:109
↓ 5 callers
Function
stringsToUrls
(strs ...string)
cmd/eskip/args.go:130
↓ 5 callers
Function
stripHopByHop
stripHopByHop removes hop-by-hop headers from h in-place. Also removes any header named in the Connection value per RFC 9110 §7.6.1.
filters/cache/filter.go:952
↓ 5 callers
Function
testPrinting
(routestr string, expected string, t *testing.T, i int, prettyPrintInfo PrettyPrintInfo, multi bool)
eskip/string_test.go:269
↓ 5 callers
Function
toSymbol
(p string)
dataclients/kubernetes/routegroup.go:110
↓ 5 callers
Method
unlock
h unlocks h.
filters/shedder/netconn_test.go:281
↓ 5 callers
Function
upsertCmd
command executed for upsert.
cmd/eskip/write.go:61
↓ 5 callers
Method
validateAnyClaims
(h map[string]interface{})
filters/auth/oidc.go:383
↓ 5 callers
Method
value
()
loadbalancer/concurrency_test.go:33
↓ 5 callers
Function
withFile
(name string, content string, action func(f *os.File))
cmd/eskip/load_test.go:34
← previous
next →
601–700 of 5,794, ranked by callers