MCPcopy Create free account

hub / github.com/zalando/skipper / functions

Functions5,794 in github.com/zalando/skipper

↓ 5 callersMethodMeasureAllFiltersResponse
(routeId string, start time.Time)
metrics/metrics.go:46
↓ 5 callersMethodMeasureBackend
(routeId string, start time.Time)
metrics/metrics.go:43
↓ 5 callersMethodMeasureFilterResponse
(filterName string, start time.Time)
metrics/metrics.go:45
↓ 5 callersFunctionNew
()
predicates/tee/tee.go:26
↓ 5 callersFunctionNew
New returns an initialized Proxy. Deprecated, see WithParams and Params instead.
proxy/proxy.go:784
↓ 5 callersFunctionNew
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 callersFunctionNewBaggageToTagFilter
()
filters/tracing/baggagetotag.go:49
↓ 5 callersFunctionNewContext
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 callersFunctionNewForwardTokenField
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 callersFunctionNewInlineContent
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 callersFunctionNewJWTPayloadAnyKVRegexp
()
predicates/auth/jwt.go:121
↓ 5 callersFunctionNewListener
(opt Options)
proxylistener/proxylistener.go:28
↓ 5 callersFunctionNewMaskAccessLogQuery
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 callersFunctionNewMtlsSanIP
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 callersFunctionNewOAuthTokeninfoAllScopeWithOptions
(to TokeninfoOptions)
filters/auth/tokeninfo.go:114
↓ 5 callersFunctionNewOrigin
NewOrigin creates a CORS origin handler that can check for allowed origin or set an all allowed header
filters/cors/cors.go:20
↓ 5 callersFunctionNewSigningKeyDeriver
()
filters/awssigner/internal/cache.go:25
↓ 5 callersFunctionNewSigningTime
(t time.Time)
filters/awssigner/internal/time.go:46
↓ 5 callersFunctionNewSpanName
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 callersFunctionNewStateBagToTag
()
filters/tracing/statebagtotag.go:52
↓ 5 callersFunctionNewStaticDelegateSecret
NewStaticDelegateSecret creates a wrapped SecretsReader, that use given s to the underlying SecretsReader to return the secret.
secrets/readers.go:42
↓ 5 callersMethodOnConfig
(ctx context.Context, config *config.Config)
filters/openpolicyagent/internal/confighook.go:28
↓ 5 callersFunctionOpen
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 callersMethodOriginalRequest
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 callersMethodParseQuery
()
filters/openpolicyagent/internal/envoy/envoyplugin.go:68
↓ 5 callersMethodPreProcessor
()
filters/shedder/admission.go:219
↓ 5 callersFunctionPutDataTo
Saves a route in etcd with the specified prefix.
etcd/etcdtest/mocketcd.go:185
↓ 5 callersMethodRefreshCiphers
RefreshCiphers rotates the list of cipher.AEAD initialized with SecretSource from the Encrypter.
secrets/encrypter.go:126
↓ 5 callersFunctionRemoteHost
RemoteHost is *deprecated* use RemoteAddr
net/net.go:52
↓ 5 callersFunctionRun
Run skipper.
skipper.go:2636
↓ 5 callersMethodScheduleBackgroundTask
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 callersMethodSetInvalidRoute
(routeId, reason string)
metrics/metrics.go:57
↓ 5 callersMethodSetLastSeen
(lastSeen time.Time)
routing/endpointregistry.go:22
↓ 5 callersMethodShareValue
ShareValue is used to share the local information with its peers.
ratelimit/swim.go:18
↓ 5 callersMethodStop
()
swarm/kubernetes.go:87
↓ 5 callersMethodStr
(min, max int)
routing/pathgen/pathgen.go:97
↓ 5 callersFunctionString
String is the same as Print but defaulting to pretty=false.
eskip/string.go:211
↓ 5 callersMethodString
String converts BackendPort to string
dataclients/kubernetes/definitions/ingressv1.go:121
↓ 5 callersMethodUpdateGauge
(key string, v float64)
metrics/codahale.go:115
↓ 5 callersFunctionWithEnvoyMetadataBytes
(content []byte)
filters/openpolicyagent/openpolicyagent.go:376
↓ 5 callersFunctionWithMaxRequestBodyBytes
(n int64)
filters/openpolicyagent/openpolicyagent.go:154
↓ 5 callersFunctionWithPreloadingEnabled
(enabled bool)
filters/openpolicyagent/openpolicyagent.go:280
↓ 5 callersFunctionWithReadBodyBufferSize
(n int64)
filters/openpolicyagent/openpolicyagent.go:168
↓ 5 callersMethodWrite
([]byte)
queuelistener/listener_test.go:41
↓ 5 callersMethodWrite
(p []byte)
net/size.go:43
↓ 5 callersMethodWrite
(p []byte)
routesrv/eskipbytes.go:36
↓ 5 callersMethodZCard
(ctx context.Context, key string)
net/redisclient.go:442
↓ 5 callersMethodZCard
(ctx context.Context, key string)
net/valkey.go:551
↓ 5 callersMethodapply
(*eskip.Route)
dataclients/kubernetes/traffic.go:50
↓ 5 callersFunctionassertOpaInstanceHealth
(t *testing.T, registry *openpolicyagent.OpenPolicyAgentRegistry, bundleName string, expectedHealth bool)
filters/openpolicyagent/opaauthorizerequest/openpolicyagent_routeupdate_test.go:152
↓ 5 callersFunctionbenchmarkAccessLog
(b *testing.B, filter string, responseCode int)
proxy/proxy_test.go:2236
↓ 5 callersFunctionbuildConnStateWithSubject
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 callersFunctionbuildRequest
(serviceName, region, body string)
filters/awssigner/awssigv4/sigv4_test.go:458
↓ 5 callersFunctionbuildfilterContext
(headers ...string)
filters/flowid/filter_test.go:127
↓ 5 callersMethodcalcTotalRequestRate
(now int64, swarmValues map[string]interface{})
ratelimit/swim.go:115
↓ 5 callersFunctioncheckMedium
(t *testing.T, left, right *medium, testIndex, itemIndex int)
cmd/eskip/media_test.go:22
↓ 5 callersMethodcheckRequest
(req *http.Request)
routing/routing_test.go:95
↓ 5 callersFunctioncloneHeader
(h http.Header)
proxy/proxy.go:554
↓ 5 callersFunctioncloneRequest
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 callersMethodclose
()
scheduler/scheduler.go:133
↓ 5 callersMethodcoalesce
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 callersFunctioncreateOIDCServer
returns a localhost instance implementation of an OpenID Connect server with configendpoint, tokenendpoint, authenticationserver endpoint, userinfor e
filters/auth/oidc_test.go:155
↓ 5 callersFunctioncreateOpaFilter
(opts FilterOptions)
filters/openpolicyagent/opaauthorizerequest/benchmark_test.go:604
↓ 5 callersFunctiondefaultBody
()
proxy/context.go:69
↓ 5 callersFunctiondocToMatcher
create a matcher from a routing document with default matching options
routing/matcher_test.go:156
↓ 5 callersFunctionfindRouteWithRx
(r []*eskip.Route)
dataclients/kubernetes/path_test.go:32
↓ 5 callersFunctiongenerateCert
(opts certOptions)
net/httpclient_example_test.go:612
↓ 5 callersFunctiongetCompiledRxs
compiles all rxs or fails
routing/matcher.go:99
↓ 5 callersFunctiongetFreeStringArgs
(count int, p *eskip.Predicate)
routing/datasource.go:292
↓ 5 callersMethodgetMinTLSVersion
()
config/config.go:1315
↓ 5 callersFunctiongetStringArg
(a interface{})
filters/ratelimit/ratelimit.go:433
↓ 5 callersMethodgetTimer
(key string)
metrics/codahale.go:99
↓ 5 callersFunctiongetZoneAwareRoutesWithHeaders
(rs *routesrv.RouteServer, zone string, headers map[string]string)
routesrv/routesrv_test.go:138
↓ 5 callersFunctionhealthcheckRoutes
(reverseSourcePredicate bool)
dataclients/kubernetes/kube.go:497
↓ 5 callersFunctioninitBenchmark
(b *testing.B, init func())
routing/matcher_test.go:272
↓ 5 callersFunctioninitializeEndpoints
(endpointAges []float64, algorithmName string, fadeInDuration time.Duration)
proxy/fadein_internal_test.go:56
↓ 5 callersMethodlock
()
filters/shedder/netconn_test.go:46
↓ 5 callersFunctionmatchHeaders
matches a set of request headers to the fix and regexp header conditions
routing/matcher.go:408
↓ 5 callersFunctionmatchRegexps
matches the path regexp conditions in a leaf matcher.
routing/matcher.go:387
↓ 5 callersFunctionnewEncoder
(enc string, level int)
filters/builtin/compress.go:329
↓ 5 callersFunctionnewLeaf
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 callersFunctionnewLogger
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 callersFunctionnewTestClient
(t *testing.T, opts kubernetes.Options, specPath string)
dataclients/kubernetes/client_test.go:14
↓ 5 callersFunctionnewYamlFlag
(ptr **T)
config/yamlflag.go:14
↓ 5 callersFunctionparseCacheControl
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 callersFunctionprintStderr
(args ...interface{})
cmd/eskip/eskip.go:66
↓ 5 callersFunctionreadPluginConfig
(plugin string)
plugins.go:352
↓ 5 callersFunctionrunExampleWithOptions
(opts LuaOptions, ctx *testContext)
script/script_test.go:978
↓ 5 callersFunctionsafeFileClose
(t *testing.T, fd *os.File)
dataclients/kubernetes/kubernetestest/fixtures.go:145
↓ 5 callersMethodsearch
(path string, m Matcher)
pathmux/tree.go:189
↓ 5 callersFunctionsetupServices
(t *testing.T, healthy, unhealthy int)
proxy/healthy_endpoints_test.go:109
↓ 5 callersFunctionstringsToUrls
(strs ...string)
cmd/eskip/args.go:130
↓ 5 callersFunctionstripHopByHop
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 callersFunctiontestPrinting
(routestr string, expected string, t *testing.T, i int, prettyPrintInfo PrettyPrintInfo, multi bool)
eskip/string_test.go:269
↓ 5 callersFunctiontoSymbol
(p string)
dataclients/kubernetes/routegroup.go:110
↓ 5 callersMethodunlock
h unlocks h.
filters/shedder/netconn_test.go:281
↓ 5 callersFunctionupsertCmd
command executed for upsert.
cmd/eskip/write.go:61
↓ 5 callersMethodvalidateAnyClaims
(h map[string]interface{})
filters/auth/oidc.go:383
↓ 5 callersMethodvalue
()
loadbalancer/concurrency_test.go:33
↓ 5 callersFunctionwithFile
(name string, content string, action func(f *os.File))
cmd/eskip/load_test.go:34
← previousnext →601–700 of 5,794, ranked by callers