MCPcopy Create free account

hub / github.com/zalando/skipper / functions

Functions5,794 in github.com/zalando/skipper

↓ 35 callersFunctiontestIngresses
()
dataclients/kubernetes/kube_test.go:244
↓ 35 callersFunctiontestPathRule
(path, serviceName string, port definitions.BackendPortV1)
dataclients/kubernetes/kube_test.go:143
↓ 35 callersFunctiontestServices
()
dataclients/kubernetes/kube_test.go:233
↓ 34 callersFunctionNewApiUsageMonitoring
NewApiUsageMonitoring creates a new instance of the API Monitoring filter specification (its factory).
filters/apiusagemonitoring/spec.go:47
↓ 34 callersMethodServeHTTP
ServeHTTP is the proxy http.Handler implementation
proxy/proxy.go:1754
↓ 34 callersMethodSplit
Returns a clone of the FilterContext including a brand new request object. The stream body of the new request is shared with the original. Whenever th
filters/filters.go:129
↓ 33 callersMethodLoadUpdate
()
routing/routing.go:55
↓ 33 callersMethodStartUpdates
StartUpdates starts the data source polling process.
routesrv/routesrv.go:294
↓ 33 callersMethodStopUpdates
StopUpdates stop the data source polling process.
routesrv/routesrv.go:300
↓ 33 callersMethodURL
()
filters/openpolicyagent/internal/opatestutils/openpolicyagent_helpers.go:76
↓ 33 callersFunctionWithParams
WithParams returns an initialized Proxy.
proxy/proxy.go:794
↓ 33 callersFunctiontestRule
(host string, paths ...*definitions.PathRuleV1)
dataclients/kubernetes/kube_test.go:155
↓ 32 callersMethodClose
()
routing/endpointregistry.go:194
↓ 32 callersMethodDebugf
(format string, args ...interface{})
filters/filters.go:146
↓ 32 callersFunctionNewHeaderLookuper
NewHeaderLookuper returns HeaderLookuper configured to lookup header named k
ratelimit/ratelimit.go:209
↓ 32 callersMethodsetTag
(span ot.Span, key string, value any)
proxy/tracing.go:107
↓ 31 callersMethodClose
()
net/valkey.go:410
↓ 31 callersFunctionaddPath
(t *testing.T, tree *node, path string)
pathmux/tree_test.go:11
↓ 30 callersFunctionregister
(p *Prometheus, cs T)
metrics/prometheus.go:343
↓ 29 callersFunctionNewValkeyRingClient
(opt *ValkeyOptions)
net/valkey.go:344
↓ 29 callersMethodRoute
Route matches a request in the current routing tree. If the request matches a route, returns the route and a map of parameters constructed from the w
routing/routing.go:450
↓ 29 callersMethodStop
(ctx context.Context)
filters/openpolicyagent/internal/envoy/envoyplugin.go:87
↓ 29 callersMethodUpdate
Update creates a set of cookies that encodes the token and deletes previously existing cookies if necessary. When token is nil it only returns cookies
filters/auth/grantcookie.go:18
↓ 29 callersMethodWait
Wait blocks until the task completes and returns the result and error
filters/openpolicyagent/openpolicyagent.go:83
↓ 29 callersMethodWithFields
(fields map[string]interface{})
filters/openpolicyagent/openpolicyagent.go:1408
↓ 29 callersFunctionnewTestProxyWithParams
(doc string, params Params)
proxy/proxy_test.go:261
↓ 29 callersFunctionunauthorized
(ctx filters.FilterContext, username string, reason rejectReason, hostname, debuginfo string)
filters/auth/auth.go:136
↓ 28 callersMethodDebug
Log with level DEBUG
logging/logger.go:30
↓ 28 callersFunctionNewAlgorithmProvider
NewAlgorithmProvider creates a routing.PostProcessor used to initialize the algorithm of load balancing routes.
loadbalancer/algorithm.go:274
↓ 28 callersFunctionNewClient
NewClient creates a wrapped http.Client and uses Transport to support OpenTracing. On teardown you have to use Close() to not leak a goroutine. If se
net/httpclient.go:170
↓ 28 callersFunctionNewTestRedis
(t testing.TB)
net/redistest/redistest.go:22
↓ 28 callersMethodWithMeasures
(f func(measures map[string][]time.Duration))
metrics/metricstest/metricsmock.go:49
↓ 27 callersMethodClose
()
secrets/registry.go:16
↓ 27 callersMethodExit
()
swarm/swarmtest/swarmtestutil.go:86
↓ 27 callersFunctioncheckStatus
(t *testing.T, rsp *http.Response, expectedStatus int)
filters/auth/grant_test.go:251
↓ 27 callersFunctionnewRouteServerWithOptions
(t *testing.T, o skipper.Options)
routesrv/routesrv_test.go:81
↓ 27 callersFunctionnewTestProxy
(doc string, flags Flags, pr ...PriorityRoute)
proxy/proxy_test.go:269
↓ 27 callersFunctionrunExample
(ctx *testContext)
script/script_test.go:974
↓ 26 callersMethodClose
()
net/httpclient.go:225
↓ 26 callersMethodClose
Close is used to clean up underlying limiter implementations, if you want to stop a Ratelimiter
ratelimit/ratelimit.go:347
↓ 26 callersMethodDetectedTime
()
routing/endpointregistry.go:18
↓ 26 callersMethodGet
(url string)
net/httpclient.go:246
↓ 26 callersMethodUpdateGauge
(key string, value float64)
metrics/metrics.go:56
↓ 26 callersMethodWait
Wait blocks until a request can be processed or needs to be rejected. When it can be processed, calling done indicates that it has finished. It is man
scheduler/scheduler.go:346
↓ 26 callersFunctiongetRoutes
(rs *routesrv.RouteServer)
routesrv/routesrv_test.go:109
↓ 26 callersFunctionnewTestOTel
(t *testing.T, opts Options)
metrics/otel_test.go:60
↓ 26 callersFunctiontimes
as in scenario step N times
proxy/breaker_test.go:263
↓ 25 callersFunctionNew
New returns a new, initialized instance of Logger.
logging/loggingtest/logger.go:95
↓ 25 callersFunctionParseFilters
ParseFilters parses a filter chain into a list of parsed filter definitions.
eskip/eskip.go:751
↓ 25 callersFunctiontestAccessEntry
()
logging/access_test.go:52
↓ 24 callersFunctionMustParseFilters
MustParseFilters parses a set of filters (combined by '->') into a list of parsed filter definitions and panics in case of error
eskip/eskip.go:742
↓ 24 callersFunctiongrantQueryWithCookies
(t *testing.T, client *proxytest.TestClient, url string, cookies ...*http.Cookie)
filters/auth/grant_test.go:295
↓ 24 callersMethodmatch
tries to match a request against the available definitions. If a match is found, returns the associated value, and the wildcard parameters from the pa
routing/matcher.go:480
↓ 23 callersFunctionEqLists
EqLists compares lists of routes. It returns true if the routes contained by each list are equal by Eq(). Repeated route IDs are considered invalid an
eskip/eq.go:152
↓ 23 callersMethodGet
Get returns a circuit breaker for the provided settings. The BreakerSettings object is used here as a key, but typically it is enough to just set its
circuit/registry.go:102
↓ 23 callersFunctiontestEndpointList
()
dataclients/kubernetes/kube_test.go:51
↓ 23 callersFunctionupstreamResponse
(status int, body string)
filters/cache/filter_test.go:86
↓ 22 callersFunctionFindAddress
skipper.FindAddress returns an addr that you can listen on TCP. You need to hold skipper.MuFindAddress to call this function.
skipper_test.go:82
↓ 22 callersMethodResponse
()
filters/filtertest/filtertest.go:46
↓ 22 callersFunctionbuildConnStateWithSANs
buildConnStateWithSANs generates an ECDSA P-256 certificate with the given DNS names, IP addresses, and URI SANs and returns a *tls.ConnectionState wi
filters/tls/mtls_test.go:27
↓ 22 callersFunctioncheckRead
(t *testing.T, r io.Reader, n int, expected string)
filters/diag/diag_test.go:240
↓ 22 callersMethodclose
()
routing/routing_test.go:112
↓ 22 callersFunctionnewGrantTestConfig
(tokeninfoURL, providerURL string)
filters/auth/grant_test.go:172
↓ 22 callersFunctionregex
(pattern string)
predicates/auth/jwt_test.go:54
↓ 22 callersFunctiontestClientMetrics
(t *testing.T, testCase clientMetricsTest)
filters/apiusagemonitoring/testutils_test.go:182
↓ 21 callersMethodAddr
()
proxy/proxy_test.go:342
↓ 21 callersMethodCookies
(u *url.URL)
filters/auth/oidc_test.go:92
↓ 21 callersMethodInflightRequests
()
routing/endpointregistry.go:24
↓ 21 callersMethodMeasureServe
MeasureServe satisfies Metrics interface.
metrics/prometheus.go:490
↓ 21 callersFunctionNew
New creates a new Client with the provided options.
etcd/etcd.go:129
↓ 21 callersFunctionNewAny
NewAny creates a predicate specification, whose instances match request host. The HostAny predicate requires one or more string hostnames and matches
predicates/host/any.go:22
↓ 21 callersFunctionRegistryWith
RegistryWith (Options) creates a registry with the provided options.
scheduler/scheduler.go:390
↓ 21 callersFunctionwantHTTPCode
(t *testing.T, w *httptest.ResponseRecorder, want int)
routesrv/routesrv_test.go:201
↓ 20 callersFunctionFixturesToTest
(t *testing.T, dirs ...string)
dataclients/kubernetes/kubernetestest/fixtures.go:359
↓ 20 callersMethodFloat64Histogram
(name string, opts ...metric.Float64HistogramOption)
metrics/otel_test.go:32
↓ 20 callersMethodGetQueue
GetQueue is currently used only by tests.
scheduler/scheduler.go:262
↓ 20 callersFunctionNew
New creates a new Methods predicate specification
predicates/methods/methods.go:45
↓ 20 callersFunctionNewRedisRingClient
(ro *RedisOptions)
net/redisclient.go:198
↓ 20 callersMethodStartSpan
Create, start, and return a new Span with the given `operationName` and incorporate the given StartSpanOption `opts`.
tracing/tracingtest/testtracer.go:100
↓ 20 callersMethodSub
()
filters/auth/tokenintrospection.go:94
↓ 20 callersFunctionWithCleanInterval
(interval time.Duration)
filters/openpolicyagent/openpolicyagent.go:175
↓ 20 callersMethodWithGauges
(f func(map[string]float64))
metrics/metricstest/metricsmock.go:67
↓ 20 callersFunctionbenchmarkCompress
(b *testing.B, n int64, encoding []string)
filters/builtin/compress_test.go:120
↓ 20 callersFunctionstartTestServer
(payload []byte, parts int, check requestCheck)
proxy/proxy_test.go:300
↓ 19 callersMethodBuild
()
filters/awssigner/awssigv4/httpsigner.go:118
↓ 19 callersMethodEmpty
()
ratelimit/ratelimit.go:316
↓ 19 callersMethodFormat
(e *logrus.Entry)
logging/log.go:54
↓ 19 callersMethodNext
Next generates a random path. The path will be always absolute. The path may contain a closing slash, with a probability based on the `ClosingSlashI
routing/pathgen/pathgen.go:160
↓ 19 callersFunctionmatcher
(matcher string)
filters/apiusagemonitoring/spec_test.go:74
↓ 19 callersMethodmeasureSince
(key string, start time.Time)
metrics/codahale.go:131
↓ 19 callersFunctionnewGrantTestTokeninfo
(validToken string, tokenInfoJSON string)
filters/auth/grant_test.go:81
↓ 19 callersFunctionwriteFile
(t *testing.T, path string, content string)
secrets/file_test.go:18
↓ 18 callersMethodEnvoyPluginConfig
()
filters/openpolicyagent/openpolicyagent.go:1162
↓ 18 callersMethodIncInflightRequest
()
routing/endpointregistry.go:25
↓ 18 callersMethodLogger
()
filters/openpolicyagent/openpolicyagent.go:1113
↓ 18 callersFunctionNewRegistry
NewRegistry initializes a registry with the provided default settings. Settings with an empty Host field are considered as defaults. Settings with the
circuit/registry.go:21
↓ 18 callersMethodStartSpan
(operationName string, opts ...opentracing.StartSpanOption)
net/valkey.go:488
↓ 18 callersMethodWarn
Log with level WARN
logging/logger.go:18
↓ 18 callersFunctionWithReuseDuration
(duration time.Duration)
filters/openpolicyagent/openpolicyagent.go:147
↓ 18 callersFunctionWithRoutingOptions
(fr filters.Registry, o routing.Options, routes ...*eskip.Route)
proxy/proxytest/proxytest.go:63
← previousnext →101–200 of 5,794, ranked by callers