MCPcopy Create free account

hub / github.com/zalando/skipper / functions

Functions5,794 in github.com/zalando/skipper

⨍ Functions 5,794◇ Types & classes 1,022
↓ 18 callersFunctionnewGrantTestAuthServer
(testToken, testAccessCode string)
filters/auth/grant_test.go:95
↓ 18 callersFunctionparseEskipFixture
(t *testing.T, fileName string)
routesrv/routesrv_test.go:90
↓ 18 callersFunctiontestService
(namespace, name string, labels map[string]string, clusterIP string, ports map[string]int)
dataclients/kubernetes/kube_test.go:110
↓ 17 callersMethodAdd
Add registers path to a file or directory to find secrets. Background refresher discovers files added or removed later to the directory path. The path
secrets/file.go:75
↓ 17 callersMethodClose
()
net/redisclient.go:395
↓ 17 callersMethodDo
Do delegates the given http.Request to the underlying http.Client and adds a Bearer token to the authorization header, if Client has a secrets.Secrets
net/httpclient.go:272
↓ 17 callersMethodFinishedSpans
()
tracing/tracingtest/mocktracer.go:38
↓ 17 callersMethodInfof
(format string, args ...interface{})
filters/filters.go:147
↓ 17 callersMethodLookup
Lookup is used to get the string which is used to define how the bucket of a ratelimiter looks like, which is used to decide to ratelimit or not. For
ratelimit/ratelimit.go:162
↓ 17 callersMethodSetLevel
(level logrus.Level)
logging/export_test.go:10
↓ 17 callersMethodWarnf
(format string, args ...interface{})
filters/filters.go:148
↓ 17 callersFunctionnewRing
(maxSize int64)
queuelistener/ring.go:11
↓ 17 callersFunctiontestEndpoints
(namespace, name string, labels map[string]string, base string, n int, ports map[string]int)
dataclients/kubernetes/kube_test.go:62
↓ 16 callersMethodFlush
()
filters/builtin/compress.go:48
↓ 16 callersFunctionListen
Listen creates and initializes a listener that can be used to limit the concurrently accepted incoming client connections. The queue listener will re
queuelistener/listener.go:193
↓ 16 callersFunctionLoopbackNames
LoopbackNames replaces net.DefaultResolver with a resolver that resolves configured names to 127.0.0.1 and fails to resolve any other name. Uses t.Cle
net/dnstest/dnstest.go:18
↓ 16 callersMethodMeasureSince
MeasureSince adds values to a timer with a custom key.
filters/filters.go:157
↓ 16 callersMethodMetrics
Allow filters to collect metrics other than the default metrics (Filter Request, Filter Response methods)
filters/filters.go:108
↓ 16 callersFunctionNewCodaHale
NewCodaHale returns a new CodaHale backend of metrics.
metrics/codahale.go:57
↓ 16 callersFunctionNewSetPath
NewSetPath returns a new setPath filter Spec, whose instances replace the request path. Instances expect one parameter: the new path to be set, or th
filters/builtin/path.go:37
↓ 16 callersFunctioncheckBackendHostCounter
(host string, count int)
proxy/breaker_test.go:248
↓ 16 callersMethodcheckGetRequest
(url string)
routing/routing_test.go:103
↓ 16 callersFunctioncreateApiserver
(t *testing.T, spec string)
redis_test.go:533
↓ 16 callersFunctionnewClusterRateLimiterSwim
newClusterRateLimiter creates a new clusterLimitSwim for given Settings and use the given Swarmer. Group is used in log messages to identify the ratel
ratelimit/swim.go:42
↓ 16 callersFunctionnewRatelimit
(s Settings, sw Swarmer, redisRing *net.RedisRingClient, valkeyRing *net.ValkeyRingClient)
ratelimit/ratelimit.go:430
↓ 16 callersFunctionnewResourceID
(namespace, name string)
dataclients/kubernetes/resources.go:5
↓ 16 callersFunctionnewTestAPI
(t *testing.T, s *serviceList, i *definitions.IngressV1List)
dataclients/kubernetes/kube_test.go:366
↓ 16 callersMethodtick
(set bool)
circuit/binarysampler.go:41
↓ 16 callersFunctiontimes
(n int, f func())
circuit/breaker_test.go:9
↓ 15 callersMethodAccept
()
queuelistener/listener_test.go:61
↓ 15 callersMethodAdd
Add a value to the tree associated with a path. Paths may contain wildcards. Wildcards can be of two types: - simple wildcard: e.g. /some/:wildcard/p
pathmux/tree.go:282
↓ 15 callersMethodApply
(*LBContext)
routing/routing.go:172
↓ 15 callersMethodConfig
Config will be called by the registry once during processing the routing to get the right queue settings from the filter.
scheduler/scheduler.go:266
↓ 15 callersMethodGetSecret
GetSecret returns secret and if found or not for a given name.
secrets/file.go:66
↓ 15 callersFunctionNewTagFromResponseIfStatus
()
filters/tracing/tag.go:42
↓ 15 callersMethodPost
(url, contentType string, body io.Reader)
net/httpclient.go:254
↓ 15 callersMethodShutdown
()
swarm/swarmtest/transport.go:63
↓ 15 callersMethodSuccess
()
net/httptest/client.go:78
↓ 15 callersMethodWriteHeader
(statusCode int)
routesrv/eskipbytes.go:27
↓ 15 callersFunctionbenchSource
(b *testing.B, k int, spec routing.PredicateSpec)
predicates/source/source_test.go:395
↓ 15 callersFunctioncheckRedirect
(t *testing.T, rsp *http.Response, expectedLocationWithoutQuery string)
filters/auth/grant_test.go:262
↓ 15 callersFunctioncheckRoutes
(t *testing.T, r []*eskip.Route, expected map[string]string)
dataclients/kubernetes/kube_test.go:293
↓ 15 callersFunctionlistenWith
(nl net.Listener, o Options)
queuelistener/listener.go:145
↓ 15 callersFunctionrequestAndExpect
(t *testing.T, url string, repeat int, expectCode int, expectHeader http.Header)
proxy/ratelimit_test.go:172
↓ 14 callersMethodAddr
()
net/nettest/listener.go:62
↓ 14 callersMethodDo
(routes []*Route)
routing/endpointregistry.go:121
↓ 14 callersMethodHealthy
()
filters/openpolicyagent/openpolicyagent.go:943
↓ 14 callersMethodLeave
Leave sends a signal for the local node to leave the Swarm.
swarm/swarm.go:407
↓ 14 callersFunctionNewLBEndpoints
(eps []string)
eskip/eskip.go:357
↓ 14 callersFunctionNewOpaAuthorizeRequestSpec
(registry *openpolicyagent.OpenPolicyAgentRegistry)
filters/openpolicyagent/opaauthorizerequest/opaauthorizerequest.go:31
↓ 14 callersMethodSetOutgoingHost
Allows explicitly setting the Host header to be sent to the backend, overriding the strategy used by the implementation, which can be either the Host
filters/filters.go:105
↓ 14 callersFunctionStartControllableBundleServer
(bundleName string, respCode int, delay time.Duration)
filters/openpolicyagent/internal/opatestutils/openpolicyagent_helpers.go:26
↓ 14 callersMethodValues
Values is used to get global information about current rates.
ratelimit/swim.go:20
↓ 14 callersMethodWaitForN
(exp string, n int, to time.Duration)
proxy/proxy_test.go:126
↓ 14 callersFunctionblockMatcher
(matches []toBlockKeys)
io/read_stream_test.go:19
↓ 14 callersFunctioncloseAll
(conns []net.Conn)
queuelistener/listener_test.go:192
↓ 14 callersFunctionrequestHost
(host string, expectedStatus int)
proxy/breaker_test.go:201
↓ 14 callersFunctiontestAccessLogDefault
(t *testing.T, entry *AccessEntry, expectedOutput string)
logging/access_test.go:94
↓ 13 callersMethodApplyContext
ApplyContext evaluates the template using template context to resolve the placeholders. Returns true if all placeholders resolved to non-empty values.
eskip/template.go:58
↓ 13 callersMethodFindSpan
FindSpan returns the first span with the defined operation name and true, if at least one was collected; otherwise, nil and false.
tracing/tracingtest/testtracer.go:72
↓ 13 callersFunctionNewAccessLogger
(o Options)
logging/log.go:101
↓ 13 callersFunctionParsePredicates
ParsePredicates parses a set of predicates (combined by '&&') into a list of parsed predicate definitions.
eskip/eskip.go:762
↓ 13 callersMethodServeHTTP
(w http.ResponseWriter, r *http.Request)
metrics/all_kind.go:226
↓ 13 callersFunctioncheckNotRatelimited
(t *testing.T, rl *Ratelimit, client string)
ratelimit/ratelimit_test.go:20
↓ 13 callersMethodgetTokeninfo
(token string, ctx filters.FilterContext)
filters/auth/authclient.go:34
↓ 13 callersFunctionmakeHTTPRequest
(t *testing.T, proxy *proxytest.TestProxy, path string)
filters/openpolicyagent/opaauthorizerequest/openpolicyagent_routeupdate_test.go:146
↓ 13 callersFunctionnewEditor
( input io.Reader, pattern *regexp.Regexp, replacement []byte, delimiter []byte, maxBufferSize int, mbh
filters/sed/editor.go:78
↓ 13 callersFunctionnewIngressPayload
(modifier func(metadata map[string]any))
validation/validation_test.go:502
↓ 13 callersFunctiontestWithFilter
( t *testing.T, filterCreate func() (filters.Filter, error), method string, url string, resStatus int, e
filters/apiusagemonitoring/testutils_test.go:37
↓ 12 callersMethodAttack
(w io.Writer, d time.Duration, name string)
net/httptest/client.go:62
↓ 12 callersMethodClose
()
metrics/codahale.go:273
↓ 12 callersMethodClose
()
metrics/metricstest/metricsmock.go:240
↓ 12 callersMethodDelete
Delete removes the entry for key. It is not an error if the key does not exist.
filters/cache/storage.go:62
↓ 12 callersMethodGetRequests
()
proxy/backendtest/backendrecorder.go:53
↓ 12 callersMethodGetSecret
GetSecret finds secret by name and returns secret and if found or not
secrets/readers.go:8
↓ 12 callersMethodGetURL
()
proxy/backendtest/backendrecorder.go:60
↓ 12 callersFunctionHandler
(admitter admitter)
dataclients/kubernetes/admission/admission.go:64
↓ 12 callersFunctionNewMtlsSanDNS
NewMtlsSanDNS returns a filter spec for the mtlsSanDNS filter. Each argument must be a valid hostname.
filters/tls/mtls.go:142
↓ 12 callersFunctionNewSecretPaths
NewSecretPaths creates a SecretPaths, that implements a SecretsProvider. It runs every d interval background refresher as a side effect. On tear down
secrets/file.go:49
↓ 12 callersFunctionNewTrue
NewTrue provides a predicate spec to create a Predicate instance that evaluates to true
predicates/primitive/true.go:20
↓ 12 callersFunctionWithTracer
(tracer opentracing.Tracer)
filters/openpolicyagent/openpolicyagent.go:201
↓ 12 callersMethodWrite
(p []byte)
filters/diag/absorb.go:118
↓ 12 callersFunctionbuildFakeJwtWithBody
(jwtBodyJson map[string]interface{})
filters/apiusagemonitoring/testutils_test.go:304
↓ 12 callersMethodcalls
()
net/helper_test.go:34
↓ 12 callersFunctionfail
(t *testing.T, b *Breaker)
circuit/breaker_test.go:33
↓ 12 callersFunctionmakeMTLSCA
makeMTLSCA generates a CA cert/key for use in mTLS tests.
proxy/proxy_mtls_test.go:130
↓ 12 callersFunctionmakeRequest
Helper functions
filters/openpolicyagent/internal/opatestutils/openpolicyagent_helpers_test.go:52
↓ 12 callersFunctionmockControlPlaneWithResourceBundle
(opts ...ControlPlaneOption)
filters/openpolicyagent/openpolicyagent_test.go:178
↓ 12 callersFunctionnewAuthProxy
(t *testing.T, config *auth.OAuthConfig, routes []*eskip.Route, hosts ...string)
filters/auth/grant_test.go:188
↓ 12 callersFunctionnewFakeSwarm
(nodeName string, leaveTimeout time.Duration)
ratelimit/swim_test.go:17
↓ 12 callersFunctionnewMatcher
constructs a matcher based on the provided definitions. If `ignoreTrailingSlash` is true, the matcher handles paths with or without a trailing slash
routing/matcher.go:312
↓ 12 callersFunctionnewRouteServer
(t *testing.T, kubeServer *httptest.Server)
routesrv/routesrv_test.go:73
↓ 12 callersFunctionnewTestRoutingWithPredicates
(cps []routing.PredicateSpec, dc ...routing.DataClient)
routing/routing_test.go:75
↓ 12 callersMethodnow
()
filters/auth/tokeninfocache_test.go:54
↓ 12 callersFunctionrepeat
(b bool, n int)
ratelimit/helper_test.go:3
↓ 12 callersFunctionrequestErrorf
(f string, args ...interface{})
filters/auth/auth.go:86
↓ 12 callersMethodsinceS
(start time.Time)
metrics/otel.go:395
↓ 12 callersMethodsinceS
sinceS returns the seconds passed since the start time until now.
metrics/prometheus.go:339
↓ 12 callersFunctionwaitForOK
(t *testing.T, url string, timeout time.Duration)
redis_test.go:589
↓ 11 callersMethodClose
Close will close all Encryption of the Registry
secrets/registry.go:57
← previousnext →201–300 of 5,794, ranked by callers