MCPcopy Create free account

hub / github.com/zalando/skipper / functions

Functions5,794 in github.com/zalando/skipper

⨍ Functions 5,794◇ Types & classes 1,022
↓ 3 callersFunctionfireVegeta
(t *testing.T, ps *httptest.Server, freq int, per time.Duration, timeout time.Duration)
proxy/healthy_endpoints_test.go:58
↓ 3 callersFunctionformatEndpointString
(ip, scheme string, port int)
dataclients/kubernetes/endpoints.go:25
↓ 3 callersFunctionfromExternalIPs
(ips []string)
dataclients/kubernetes/clusterclient.go:719
↓ 3 callersMethodgetExistingInstance
(bundleName string)
filters/openpolicyagent/openpolicyagent.go:576
↓ 3 callersFunctiongetFloat64Arg
(a interface{})
filters/shedder/admission.go:40
↓ 3 callersMethodgetHandler
(path string)
metrics/codahale.go:303
↓ 3 callersFunctiongetLookuper
(s string)
filters/ratelimit/ratelimit.go:331
↓ 3 callersFunctiongetPayload
(ctx filters.FilterContext, cacheKey string)
filters/auth/forwardtokenfield.go:80
↓ 3 callersMethodgetShard
getShard routes a key to its shard via xxhash. Keys are expected to be pre-hashed (e.g. SHA-256) by the caller.
filters/cache/lru.go:143
↓ 3 callersFunctiongetSwarmRegistryDefaultSettings
()
ratelimit/registry.go:56
↓ 3 callersFunctiongetTestOidcConfig
()
filters/auth/tokenintrospection_test.go:25
↓ 3 callersFunctiongetUrl
(path string)
proxy/loopback_test.go:450
↓ 3 callersFunctiongoDialN
(t *testing.T, addr net.Addr, n int)
queuelistener/listener_test.go:272
↓ 3 callersFunctionhasAll
(a []string, set map[string]struct{})
net/redisclient.go:302
↓ 3 callersMethodignoreTrailingSlash
()
routing/routing.go:47
↓ 3 callersMethodinc
()
loadbalancer/concurrency_test.go:28
↓ 3 callersMethodinterpolateConfigTemplate
Config sets the configuration file to use on the OPA instance.
filters/openpolicyagent/openpolicyagent.go:681
↓ 3 callersFunctioninvalidArg
(opt string, err error)
tracing/tracers/jaeger/jaeger.go:132
↓ 3 callersFunctionisDecimalChar
(c byte)
eskip/lexer.go:80
↓ 3 callersFunctionisDigit
(c byte)
eskip/lexer.go:78
↓ 3 callersFunctionisTimeout
(err error)
etcd/etcd.go:168
↓ 3 callersFunctionisTreePredicate
check if a predicate is a distinguished, path tree predicate
routing/datasource.go:281
↓ 3 callersFunctionlistenAndServeQuit
( proxy http.Handler, o *Options, sigs chan os.Signal, idleConnsCH chan struct{}, mtr metrics.Metrics, c
skipper.go:1536
↓ 3 callersFunctionloadOrCompileRegex
(pattern string)
filters/apiusagemonitoring/spec.go:32
↓ 3 callersMethodlogEvent
(span ot.Span, eventName, eventValue string)
proxy/tracing.go:88
↓ 3 callersFunctionlogFifoMetrics
(t *testing.T, mockMetrics *metricstest.MockMetrics)
proxy/fifo_backendtimeout_with_teeloopback_test.go:292
↓ 3 callersFunctionmakeTestingFilter
(claims []string)
filters/auth/oidc_test.go:393
↓ 3 callersMethodmarkUnused
(inUse map[*OpenPolicyAgentInstance]struct{})
filters/openpolicyagent/openpolicyagent.go:607
↓ 3 callersFunctionmarshalBase64JSON
(tb testing.TB, v interface{})
jwt/token_test.go:62
↓ 3 callersFunctionmarshalJSONNoEscape
(v interface{})
eskip/json.go:47
↓ 3 callersMethodmatchesRequest
(r *http.Request)
net/request.go:23
↓ 3 callersFunctionmax
(i, j int)
filters/shedder/admission_test.go:754
↓ 3 callersFunctionmissingArg
(opt string)
tracing/tracers/basic/basic.go:110
↓ 3 callersFunctionmtlsWriteTempFiles
(t *testing.T, certPEM, keyPEM []byte)
skipper_mtls_test.go:69
↓ 3 callersFunctionmultiply
(k float64, d time.Duration)
proxy/fadein_internal_test.go:52
↓ 3 callersFunctionmustAvailablePort
(t *testing.T)
metricsinit_test.go:26
↓ 3 callersMethodnameError
(w dns.ResponseWriter, r *dns.Msg)
net/dnstest/dnstest.go:81
↓ 3 callersFunctionnatural
(arg interface{})
filters/ratelimit/leakybucket.go:127
↓ 3 callersFunctionnewConsistentHash
(endpoints []string)
loadbalancer/algorithm.go:129
↓ 3 callersFunctionnewCounter
()
loadbalancer/concurrency_test.go:22
↓ 3 callersFunctionnewCtxWithRoute
(method, rawURL, authHeader, routeID string)
filters/cache/filter_test.go:80
↓ 3 callersFunctionnewDecoder
(enc string)
filters/builtin/decompress.go:80
↓ 3 callersMethodnewFifoQueue
(name string, c Config)
scheduler/scheduler.go:426
↓ 3 callersFunctionnewFilter
(opts LuaOptions, script string, params ...string)
script/script_test.go:920
↓ 3 callersFunctionnewFlowState
(secrets *secrets.Registry, secretsFile string)
filters/auth/grantflowstate.go:25
↓ 3 callersFunctionnewListFlag
(sep string, allowed ...string)
config/listflag.go:15
↓ 3 callersFunctionnewOAuthTokeninfoSpec
(authType string, options TokeninfoOptions)
filters/auth/tokeninfo_test.go:25
↓ 3 callersFunctionnewOTelWithReader
(opts Options, reader sdkmetric.Reader)
metrics/otel.go:65
↓ 3 callersFunctionnewTestAPIWithEndpoints
(t *testing.T, s *serviceList, i *definitions.IngressV1List, e *endpointList, sec *secretList)
dataclients/kubernetes/kube_test.go:370
↓ 3 callersFunctionnewTestRedisWithOptions
(t testing.TB, opts options)
net/redistest/redistest.go:32
↓ 3 callersFunctionnewTestRoutingWithFiltersPredicates
(fr filters.Registry, cps []routing.PredicateSpec, dc ...routing.DataClient)
routing/routing_test.go:59
↓ 3 callersFunctionnewTokeninfoCache
(client tokeninfoClient, metrics metrics.Metrics, size int, ttl time.Duration)
filters/auth/tokeninfocache.go:37
↓ 3 callersFunctionnewValidationHandler
(enableAdvancedValidation bool, routingOptions routing.Options)
validation/validation.go:69
↓ 3 callersFunctionnormalizePath
returns a cleaned path where all wildcard names have been replaced with *
routing/matcher.go:170
↓ 3 callersFunctionparse
(start int, code string)
eskip/eskip.go:683
↓ 3 callersFunctionparseLocation
(arg interface{}, loc **time.Location)
predicates/interval/interval.go:143
↓ 3 callersFunctionping
(rw io.ReadWriter, message string)
queuelistener/listener_test.go:137
↓ 3 callersFunctionping
(ctx context.Context, address, username, password string)
net/redistest/redistest.go:107
↓ 3 callersFunctionprintTotalMutexWaitTime
(b *testing.B)
routing/endpointregistry_test.go:263
↓ 3 callersFunctionprocessRouteDefs
processes a set of route definitions for the routing table
routing/datasource.go:572
↓ 3 callersFunctionreject
( ctx filters.FilterContext, status int, certInput string, reason rejectReason, hostname string, )
filters/tls/mtls.go:319
↓ 3 callersFunctionrequestHostForStatus
(c *breakerTestContext, host string, expectedStatus int)
proxy/breaker_test.go:189
↓ 3 callersFunctionresetCmd
command executed for reset.
cmd/eskip/write.go:77
↓ 3 callersFunctionresolvePlaceholders
(s string, r *http.Request)
filters/auth/grantconfig.go:341
↓ 3 callersMethodresolveTTL
resolveTTL decides the TTL to use for a stored entry. Force mode (rfcMode==false): operator ttl/errorTTL is authoritative; upstream freshness directi
filters/cache/filter.go:694
↓ 3 callersFunctionrgRouteID
(namespace, name, subName string, index, subIndex int, internal bool)
dataclients/kubernetes/routegroup.go:126
↓ 3 callersFunctionrouteIDForRedirectRoute
(baseID string, enable bool)
dataclients/kubernetes/redirect.go:78
↓ 3 callersFunctionrunFilter
(opts LuaOptions, test *testContext)
script/script_test.go:932
↓ 3 callersFunctionsanitize
sanitize the raw certificates, remove the useless data and make it http request compliant.
filters/tls/pass_client.go:44
↓ 3 callersFunctionsendGetRequest
(t *testing.T, ps *httptest.Server, consistentHashKey int)
proxy/healthy_endpoints_test.go:35
↓ 3 callersFunctionsendGetRequests
(t *testing.T, ps *httptest.Server)
proxy/healthy_endpoints_test.go:46
↓ 3 callersFunctionsendRequests
(t *testing.T, N int, p *proxytest.TestProxy, client *skpnet.Client, resCH chan int)
proxy/fifo_backendtimeout_with_teeloopback_test.go:306
↓ 3 callersMethodset
(key string, data []byte)
filters/cache/lru.go:47
↓ 3 callersFunctionsetAgeHeader
setAgeHeader computes and sets the Age header per RFC 9111 §4.2.3. For new entries (ResponseTime set), uses precise corrected_initial_age formula. For
filters/cache/filter.go:789
↓ 3 callersMethodsetCommonSpanInfo
(u *url.URL, r *http.Request, s ot.Span)
proxy/proxy.go:1917
↓ 3 callersMethodsetDeadline
setDeadline sets the current deadline.
filters/shedder/netconn_test.go:408
↓ 3 callersMethodsetGaugeToCurrentTime
(name string)
routesrv/polling.go:217
↓ 3 callersMethodsetMetricsPrefix
(prefix string)
proxy/context.go:286
↓ 3 callersMethodsetResponse
(r *http.Response, preserveOriginal bool)
proxy/context.go:199
↓ 3 callersMethodsetTag
(ctx filters.FilterContext)
filters/tracing/tag.go:129
↓ 3 callersFunctionsetupProxyWithCustomProxyParams
(t *testing.T, doc string, proxyParams Params)
proxy/healthy_endpoints_test.go:96
↓ 3 callersMethodshallowCopy
()
net/httpclient.go:515
↓ 3 callersFunctionshuntRoute
shuntRoute creates a route that returns a 502 status code when there are no endpoints found, see https://github.com/zalando/skipper/issues/1525
dataclients/kubernetes/kube.go:482
↓ 3 callersMethodstartTimes
(route *routing.Route)
filters/builtin/creationmetrics.go:88
↓ 3 callersFunctionstaticServer
(content string)
filters/auth/forwardtoken_test.go:16
↓ 3 callersMethodsucceed
()
proxy/failingbackend_test.go:50
↓ 3 callersFunctiontestAccessLogExtended
(t *testing.T, entry *AccessEntry, additional map[string]any, expectedOutput string, o Options, )
logging/access_test.go:73
↓ 3 callersFunctiontestRequest
(name string, test testItem)
filters/sed/sed_test.go:67
↓ 3 callersMethodtimeoutAndSucceedInitial
()
eskipfile/watch_test.go:126
↓ 3 callersFunctiontoDuration
(v interface{})
filters/cache/filter.go:989
↓ 3 callersFunctionvalkeySetError
(span opentracing.Span, msg string, tagValue string)
ratelimit/valkey.go:213
↓ 3 callersFunctionverifyAttempts
(t *testing.T, capacity int, emission time.Duration, increment int, attempts []attempt)
ratelimit/leakybucket_test.go:66
↓ 3 callersMethodwaitForNRouteSettings
(n int)
routing/routing_test.go:87
↓ 3 callersMethodwaitForRouteSetting
()
routing/routing_test.go:91
↓ 3 callersFunctionwithLogger
(silent bool, l logging.Logger)
filters/diag/absorb.go:29
↓ 3 callersFunctionzoneAwarenessAnnotationFilter
(m *definitions.Metadata)
dataclients/kubernetes/ingress.go:275
↓ 2 callersFunctionAdaptToExtAuthRequest
(req *http.Request, metadata *ext_authz_v3_core.Metadata, contextExtensions map[string]string, rawBody []byte)
filters/openpolicyagent/internal/envoy/skipperadapter.go:14
↓ 2 callersMethodBackendUrl
Gives filters access to the backend url specified in the route or an empty value if it's a shunt, loopback. In case of dynamic backend is empty.
filters/filters.go:91
↓ 2 callersFunctionBuildLabelSet
BuildLabelSet builds pprof label pairs for OPA filter profiling. It always includes opa.task and opa.bundle_name, and adds opa.ctx.<key>=<value> for e
filters/openpolicyagent/openpolicyagent.go:1225
↓ 2 callersMethodBundleName
()
filters/openpolicyagent/openpolicyagent.go:1218
← previousnext →1,101–1,200 of 5,794, ranked by callers