MCPcopy Create free account

hub / github.com/zalando/skipper / functions

Functions5,794 in github.com/zalando/skipper

⨍ Functions 5,794◇ Types & classes 1,022
↓ 1,368 callersMethodError
Log with level ERROR
logging/logger.go:12
↓ 1,100 callersMethodErrorf
Log formatted messages with level ERROR
logging/logger.go:15
↓ 688 callersMethodClose
()
metrics/metrics.go:58
↓ 597 callersMethodGet
Get returns the entry for key, or (nil, nil) if the key is not found.
filters/cache/storage.go:56
↓ 552 callersMethodClose
()
filters/auth/authclient.go:35
↓ 540 callersMethodRequest
The Request method is called while processing the incoming request.
filters/filters.go:178
↓ 416 callersMethodErrorf
(format string, args ...interface{})
filters/filters.go:149
↓ 414 callersMethodSet
Set stores or overwrites the entry for key.
filters/cache/storage.go:59
↓ 351 callersMethodString
()
metrics/metrics.go:59
↓ 249 callersMethodCreateFilter
CreateFilter creates a Filter instance. Called with the parameters in the route definition while initializing a route.
filters/filters.go:203
↓ 232 callersMethodNew
New returns the object initialized with a valid plugin configuration.
filters/openpolicyagent/internal/envoy/envoyplugin.go:17
↓ 214 callersMethodAdd
Add adds the given source that contains a secret to the automatically updated secrets store
secrets/file.go:32
↓ 200 callersMethodDo
([]*eskip.Route)
routing/routing.go:250
↓ 199 callersMethodRegister
Register a filter specification.
filters/filters.go:213
↓ 180 callersMethodAdd
(ctx context.Context, label string, increment int)
filters/ratelimit/leakybucket.go:16
↓ 162 callersMethodString
()
filters/tls/mtls.go:68
↓ 161 callersMethodWriteHeader
It sets the status code for the outgoing response, and signals that the header is done.
filters/serve/serve.go:80
↓ 155 callersMethodClose
()
routing/tree_test.go:15
↓ 154 callersFunctionnewCtx
(method, rawURL string, authHeader string)
filters/cache/filter_test.go:68
↓ 146 callersMethodResponse
The Response method is called while processing the response to be returned.
filters/filters.go:182
↓ 143 callersMethodName
Name gives the name of the Spec. It is used to identify filters in a route definition.
filters/filters.go:199
↓ 136 callersMethodLog
Deprecated: use LogFields or LogKV
tracing/tracingtest/testtracer.go:212
↓ 136 callersMethodWriteString
(string)
filters/tls/mtls.go:67
↓ 132 callersMethodError
(s string)
eskip/parser.go:202
↓ 124 callersMethodContext
Context() yields the SpanContext for this Span. Note that the return value of Context() is still valid after a call to Span.Finish(), as is a call to
tracing/tracingtest/testtracer.go:161
↓ 111 callersMethodJoin
(nodesToJoin []string)
swarm/swarmtest/swarmtestutil.go:64
↓ 111 callersFunctionMustParse
MustParse parses a route expression or a routing document to a set of route definitions and panics in case of error
eskip/eskip.go:722
↓ 108 callersFunctiontestMatch
(t testing.TB, method, path, host string)
routing/matcher_test.go:303
↓ 106 callersMethodClient
()
proxy/proxytest/proxytest.go:149
↓ 103 callersMethodStateBag
Provides a read-write state bag, unique to a request and shared by all the filters in the route.
filters/filters.go:87
↓ 99 callersFunctionMakeRegistry
MakeRegistry returns a Registry object initialized with the default set of filter specifications found in the filters package. (including the builtin
filters/builtin/builtin.go:262
↓ 95 callersMethodParse
(eskipLexer)
eskip/parser.go:206
↓ 89 callersMethodCopy
Copy copies a route to a new route instance with all the slice and map fields copied deep.
eskip/eskip.go:423
↓ 88 callersMethodLoadAll
()
routing/routing.go:54
↓ 82 callersMethodInfof
Log formatted messages with level INFO
logging/logger.go:27
↓ 80 callersMethodCreate
Creates a predicate instance with concrete arguments.
routing/routing.go:82
↓ 80 callersMethodReset
(io.Writer)
filters/builtin/compress.go:47
↓ 77 callersMethodLogger
()
filters/filters.go:137
↓ 74 callersMethodDebugf
Log formatted messages with level DEBUG
logging/logger.go:33
↓ 74 callersFunctionNew
(fr filters.Registry, routes ...*eskip.Route)
proxy/proxytest/proxytest.go:75
↓ 71 callersMethodclose
()
proxy/proxy_test.go:273
↓ 70 callersMethodWrite
(p []byte)
proxy/proxy.go:576
↓ 69 callersFunctionParse
Parse a route expression or a routing document to a set of route definitions.
eskip/eskip.go:701
↓ 69 callersMethodWaitFor
(exp string, to time.Duration)
proxy/proxy_test.go:143
↓ 67 callersMethodStart
()
proxy/stopwatch.go:17
↓ 67 callersFunctionsub
(title string, tests ...func(*testing.T))
proxy/fadeintesting_test.go:574
↓ 66 callersFunctionnewTestFilter
(t *testing.T, ttl, errorTTL, swrWindow time.Duration, extra ...time.Duration)
filters/cache/filter_test.go:21
↓ 65 callersMethodAllow
Allow is used to get a decision if you should allow the call with context, to pass or to ratelimit
ratelimit/ratelimit.go:343
↓ 65 callersMethodLen
()
filters/awssigner/awssigv4/sigv4_test.go:431
↓ 64 callersMethodenqueue
(c net.Conn)
queuelistener/ring.go:33
↓ 62 callersMethodSetTag
Adds a tag to the span.
tracing/tracingtest/testtracer.go:172
↓ 61 callersFunctionNew
New initializes a routing instance, and starts listening for route definition updates.
routing/routing.go:266
↓ 60 callersMethodAdd
(ctx context.Context, label string, increment int)
ratelimit/leakybucket.go:24
↓ 59 callersFunctionNew
New creates and initializes a Kubernetes DataClient.
dataclients/kubernetes/kube.go:295
↓ 59 callersFunctionNewTracer
()
tracing/tracingtest/mocktracer.go:24
↓ 59 callersMethodRead
Read extracts the token from the request cookies.
filters/auth/grantcookie.go:21
↓ 57 callersMethodGetMetrics
(hostPort string)
routing/endpointregistry.go:222
↓ 57 callersFunctionNewTestValkey
(t testing.TB)
net/valkeytest/valkeytest.go:21
↓ 55 callersMethodServe
Serve a request with the provided response. It can be used by filters that handle the requests themselves. FilterContext implementations should flag t
filters/filters.go:79
↓ 55 callersFunctionupstreamResponseCC
(status int, body, cacheControl string)
filters/cache/filter_test.go:94
↓ 54 callersMethodBytes
Bytes returns the total number of bytes currently stored across all shards.
filters/cache/lru.go:165
↓ 54 callersMethodIncCounter
IncCounter increments a custom counter identified by its key.
filters/filters.go:160
↓ 54 callersFunctionNewDoc
NewDoc creates a Client with an initial set of route definitions in eskip format. If parsing the eskip document fails, returns an error.
routing/testdataclient/dataclient.go:49
↓ 54 callersFunctionverifyTag
(t *testing.T, span *tracingtest.MockSpan, name string, expected interface{})
proxy/tracing_test.go:892
↓ 53 callersFunctionexact
(expected string)
predicates/auth/jwt_test.go:50
↓ 52 callersMethodHeader
()
routesrv/eskipbytes.go:32
↓ 52 callersMethodWrite
(b []byte)
filters/log/log.go:87
↓ 51 callersFunctioncheckBackendCounter
(count int)
proxy/breaker_test.go:255
↓ 50 callersMethodSetOutput
(out io.Writer)
logging/export_test.go:9
↓ 50 callersFunctionrequest
(expectedStatus int)
proxy/breaker_test.go:208
↓ 49 callersMethodCountStatus
(code int)
net/httptest/client.go:90
↓ 49 callersMethodWriteHeader
(statusCode int)
proxy/proxy_test.go:187
↓ 48 callersMethodLogKV
LogKV is a concise, readable way to record key:value logging data about a Span, though unfortunately this also makes it less efficient and less type-s
tracing/tracingtest/testtracer.go:185
↓ 48 callersFunctioncommaListFlag
(allowed ...string)
config/listflag.go:28
↓ 46 callersMethodDone
()
proxy/backendtest/backendrecorder.go:64
↓ 45 callersMethodGetOrStartInstance
GetOrStartInstance returns an existing instance immediately, or creates one using registry config
filters/openpolicyagent/openpolicyagent.go:546
↓ 45 callersFunctionNew
New creates a Client with an initial set of route definitions.
routing/testdataclient/dataclient.go:34
↓ 45 callersFunctionNewEndpointRegistry
(o RegistryOptions)
routing/endpointregistry.go:198
↓ 45 callersFunctionNewOpenPolicyAgentRegistry
(opts ...func(*OpenPolicyAgentRegistry) error)
filters/openpolicyagent/openpolicyagent.go:301
↓ 45 callersFunctionWithOpenPolicyAgentInstanceConfig
(opts ...func(*OpenPolicyAgentInstanceConfig) error)
filters/openpolicyagent/openpolicyagent.go:189
↓ 44 callersFunctionWithConfigTemplate
(configTemplate []byte)
filters/openpolicyagent/openpolicyagent.go:354
↓ 44 callersFunctionloadKubeYAML
(t *testing.T, path string)
routesrv/routesrv_test.go:64
↓ 43 callersMethodWithCounters
Public thread safe access to metrics
metrics/metricstest/metricsmock.go:31
↓ 42 callersMethodFinish
Sets the end timestamp and finalizes Span state.
tracing/tracingtest/testtracer.go:147
↓ 42 callersMethodHeader
()
filters/serve/serve.go:63
↓ 42 callersFunctionmakeRoute
(id string, zoneEndpoints map[string]int, optOut ...bool)
routesrv/polling_test.go:10
↓ 41 callersMethodHeader
()
proxy/proxy_test.go:183
↓ 41 callersMethodMatch
(jwtValue string)
predicates/auth/jwt.go:43
↓ 41 callersMethodStop
()
proxy/stopwatch.go:23
↓ 40 callersFunctiontestFadeInMonotony
( t *testing.T, name string, algorithmName string, endpointAges ...float64, )
proxy/fadein_internal_test.go:121
↓ 38 callersMethodTotalRequests
()
net/httptest/client.go:82
↓ 38 callersFunctionnewKubeServer
(t *testing.T, specs ...io.Reader)
routesrv/routesrv_test.go:58
↓ 37 callersMethodCount
(exp string)
proxy/proxy_test.go:147
↓ 37 callersMethodFirstLoad
FirstLoad, when enabled, blocks until the first routing configuration was received by the routing during the startup. When disabled, it doesn't block.
routing/routing.go:457
↓ 37 callersFunctiontestCase
https://github.com/golang/go/issues/52751
net/net_test.go:23
↓ 36 callersMethodInfo
Log with level INFO
logging/logger.go:24
↓ 36 callersFunctionendpointStartTest
( proxies, initialEndpoints, addEndpoints int, withFadeIn, withCreated bool, expectFadeIn ...bool, )
proxy/fadeintesting_test.go:542
↓ 36 callersFunctiontestPath
(t *testing.T, tree *node, path string, expectPath string, expectedParams []string)
pathmux/tree_test.go:23
↓ 35 callersMethodStore
Store is an implementation of the envoyauth.EvalContext interface
filters/openpolicyagent/openpolicyagent.go:1360
↓ 35 callersFunctiontestIngress
(ns, name, defaultService, ratelimitCfg, filterString, predicateString, routesString, pathModeString, lbAlgori
dataclients/kubernetes/kube_test.go:176
next →1–100 of 5,794, ranked by callers