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 callersMethodOnConfigDiscovery
(ctx context.Context, config *config.Config)
filters/openpolicyagent/internal/confighook.go:36
↓ 3 callersFunctionParseBackendTrafficAlgorithm
ParseBackendTrafficAlgorithm parses a string into a BackendTrafficAlgorithm
dataclients/kubernetes/traffic.go:35
↓ 3 callersFunctionPatchHost
PatchHost returns a host string without trailing dot. For details see also the discussion in https://lists.w3.org/Archives/Public/ietf-http-wg/2016Jan
rfc/patchhost.go:8
↓ 3 callersFunctionPatchPath
PatchPath attempts to patch a request path based on an interpretation of the standards RFC 2616 and RFC 3986 where the reserved characters should not
rfc/patchpath.go:66
↓ 3 callersFunctionPreserveHost
PreserveHost returns a filter specification whose filter instances are used to override the `proxyPreserveHost` behavior for individual routes. Insta
filters/builtin/preservehost.go:37
↓ 3 callersMethodPreserveHost
When set, the proxy will set the, by default, the Host header value of the outgoing requests to the one of the incoming request.
proxy/proxy.go:449
↓ 3 callersMethodRegisterHandler
(path string, handler *http.ServeMux)
metrics/metrics.go:55
↓ 3 callersMethodRequest
* sigV4Filter is a request filter that signs the request. In case a non empty is body is present in request, the body is read and signed. The body is
filters/awssigner/awssigv4/sigv4.go:101
↓ 3 callersMethodResize
Resize is used to resize the buffer depending on the number of nodes available
ratelimit/ratelimit.go:358
↓ 3 callersMethodRoundTrip
(req *http.Request)
proxy/fastcgi/fastcgi.go:55
↓ 3 callersFunctionRun
Run starts a route server set up according to the passed options. It is a blocking call designed to be used as a single call/entry point, when running
routesrv/routesrv.go:385
↓ 3 callersMethodRunScript
(ctx context.Context, script *valkey.Lua, keys []string, args ...string)
net/valkey.go:322
↓ 3 callersMethodSelf
Self returns NodeInfo about itself
swarm/nodeinfoclient.go:20
↓ 3 callersMethodServeHTTP
(w http.ResponseWriter, r *http.Request)
filters/tee/tee_test.go:129
↓ 3 callersMethodServeHTTP
ServeHTTP renders the list of current routes.
routing/routing.go:332
↓ 3 callersMethodServed
()
filters/filtertest/filtertest.go:48
↓ 3 callersMethodServed
()
routesrv/filter.go:32
↓ 3 callersMethodSet
(value string)
config/routechangerconfig.go:33
↓ 3 callersMethodSetDelay
(delay time.Duration)
filters/openpolicyagent/internal/opatestutils/openpolicyagent_helpers.go:72
↓ 3 callersFunctionSetNow
(rs *RouteServer, now func() time.Time)
routesrv/export_test.go:9
↓ 3 callersFunctionSetNow
(r *EndpointRegistry, now func() time.Time)
routing/export_test.go:19
↓ 3 callersMethodSetWithExpire
(ctx context.Context, key string, value string, expire time.Duration)
net/valkey.go:533
↓ 3 callersMethodSignHTTP
SignHTTP will modify the passed *http.Request in place.
filters/awssigner/awssigv4/httpsigner.go:305
↓ 3 callersFunctionStart
Start will find Swarm peers based on the chosen swarm type and join the Swarm.
swarm/swarm.go:195
↓ 3 callersMethodStart
()
filters/openpolicyagent/openpolicyagent.go:891
↓ 3 callersFunctionStartProjectRoot
StartProjectRoot starts an etcd server. If projectRoot is not empty, then it checks if the .bin/etcd binary exists, and uses that instead of the one i
etcd/etcdtest/mocketcd.go:49
↓ 3 callersMethodStartScheduled
()
filters/openpolicyagent/openpolicyagent.go:957
↓ 3 callersMethodString
()
ratelimit/ratelimit.go:320
↓ 3 callersMethodTimeFormat
()
filters/awssigner/internal/time.go:13
↓ 3 callersMethodUpdateGauge
UpdateGauge satisfies Metrics interface.
metrics/prometheus.go:396
↓ 3 callersFunctionValidateRoute
ValidateRoute processes a route definition through all configured preprocessors and validates that all resulting routes can be successfully processed.
routing/datasource.go:500
↓ 3 callersFunctionWithEnableDataPreProcessingOptimization
(enabled bool)
filters/openpolicyagent/openpolicyagent.go:222
↓ 3 callersMethodWithFloatCounters
(f func(floatCounters map[string]float64))
metrics/metricstest/metricsmock.go:40
↓ 3 callersFunctionWithSpanName
WithSpanName sets the name of the span, if you have an enabled tracing Transport.
net/httpclient.go:491
↓ 3 callersMethodWrite
(p []byte)
filters/scheduler/fifo_test.go:192
↓ 3 callersMethodWriteHeader
(code int)
logging/loggingwriter.go:26
↓ 3 callersMethodZAdd
(ctx context.Context, key, val string, score float64)
net/valkey.go:297
↓ 3 callersMethodZCard
(ctx context.Context, key string)
net/valkey.go:302
↓ 3 callersMethodZRangeByScoreWithScoresFirst
(ctx context.Context, key, min, max string, offset, count int64)
net/valkey.go:317
↓ 3 callersMethodZRem
(ctx context.Context, key string, members ...interface{})
net/redisclient.go:427
↓ 3 callersMethodZRem
(ctx context.Context, key string, members ...string)
net/valkey.go:556
↓ 3 callersMethodZRemRangeByScore
(ctx context.Context, key, min, max string)
net/valkey.go:312
↓ 3 callersFunctionacceptN
(t *testing.T, l net.Listener, n int)
queuelistener/listener_test.go:198
↓ 3 callersMethodadd
(d time.Duration)
filters/auth/tokeninfocache_test.go:48
↓ 3 callersFunctionaddInflightRequests
(registry *routing.EndpointRegistry, endpoint routing.LBEndpoint, count int)
loadbalancer/algorithm_test.go:477
↓ 3 callersMethodaddInstances
(n int)
proxy/fadeintesting_test.go:259
↓ 3 callersFunctionall
all checks that all strings in the left are also in the right. Right can be a superset of left.
filters/auth/auth.go:163
↓ 3 callersFunctionapplyCompatibilityDefaults
(o Options)
metrics/utils.go:44
↓ 3 callersFunctionbaseNoExt
(n string)
dataclients/kubernetes/kubernetestest/fixtures.go:65
↓ 3 callersFunctionbenchmarkCompressJSON
(b *testing.B, n int64, encoding []string)
filters/builtin/compress_test.go:845
↓ 3 callersFunctionbindContext
(ctx filters.FilterContext, req *http.Request)
filters/auth/authclient.go:70
↓ 3 callersFunctionbrowserRequest
browserRequest returns request copied as cURL and masked from a real browser request.
net/size_test.go:81
↓ 3 callersFunctionbuildTracingOptions
(tracer opentracing.Tracer, bundleName string, manager *plugins.Manager)
filters/openpolicyagent/openpolicyagent.go:698
↓ 3 callersFunctionbuildfilterContext
(serviceName string, region string, method string, body *strings.Reader, queryParams string, headers http.Head
filters/awssigner/awssigv4/sigv4_test.go:411
↓ 3 callersFunctioncaptureLog
(t *testing.T, level log.Level)
dataclients/kubernetes/logger_test.go:12
↓ 3 callersFunctioncheckCookies
(t *testing.T, rsp *http.Response, expectedDomain string)
filters/auth/grant_test.go:282
↓ 3 callersFunctioncheckDistribution
(t *testing.T, counters map[string]counter, tolerance int)
loadbalancer/concurrency_test.go:389
↓ 3 callersFunctioncheckMainRouteIsFine
(t *testing.T, p *proxytest.TestProxy, client *skpnet.Client)
proxy/fifo_backendtimeout_with_teeloopback_test.go:252
↓ 3 callersFunctioncheckOpen
(t *testing.T, b *Breaker)
circuit/breaker_test.go:42
↓ 3 callersFunctioncheckStatusCode
(t *testing.T, resCH chan int, N int)
proxy/fifo_backendtimeout_with_teeloopback_test.go:276
↓ 3 callersFunctioncheckWithTolerance
(start time.Time, expected time.Duration)
filters/diag/diag_test.go:51
↓ 3 callersMethodclean
()
predicates/auth/jwt.go:87
↓ 3 callersMethodclose
()
proxy/failingbackend_test.go:119
↓ 3 callersFunctioncontains
(s string, a []string)
script/script.go:919
↓ 3 callersFunctioncopyAsync
(dir string, src io.Reader, dst io.Writer, done chan<- struct{})
proxy/upgrade.go:218
↓ 3 callersMethodcount
(name string)
net/connmanager.go:91
↓ 3 callersMethodcountContaining
(sub string)
filters/openpolicyagent/opaauthorizerequest/opaauthorizerequest_test.go:1432
↓ 3 callersFunctioncreateAddressMap
(addrs []string)
net/redisclient.go:294
↓ 3 callersMethodcreateAndCacheInstance
(bundleName string)
filters/openpolicyagent/openpolicyagent.go:592
↓ 3 callersFunctioncreateBackend
(t *testing.T)
proxy/fifo_backendtimeout_with_teeloopback_test.go:236
↓ 3 callersFunctioncreateClient
(p *proxytest.TestProxy, timeout, rspHeaderTimeout time.Duration)
proxy/fifo_backendtimeout_with_teeloopback_test.go:169
↓ 3 callersFunctioncreateFileWith
(content string, t *testing.T)
eskipfile/watch_test.go:48
↓ 3 callersFunctioncreateFilterRegistry
(specs ...filters.Spec)
skipper_test.go:487
↓ 3 callersFunctioncreateIngressEnableHTTPSRedirect
(r *eskip.Route, code int)
dataclients/kubernetes/redirect.go:130
↓ 3 callersFunctioncreateOpaRegistry
createOpaRegistry creates a new OpenPolicyAgentRegistry with the given configuration
filters/openpolicyagent/opaauthorizerequest/openpolicyagent_routeupdate_test.go:594
↓ 3 callersFunctioncreateProxy
(t *testing.T, backend *httptest.Server, slowBackend *httptest.Server)
proxy/fifo_backendtimeout_with_teeloopback_test.go:185
↓ 3 callersFunctioncreateRoutesFile
(route string)
skipper_test.go:495
↓ 3 callersFunctioncreateTokenWithKey
(t *testing.T, key *rsa.PrivateKey, claims jwt.MapClaims)
filters/auth/jwt_validation_test.go:149
↓ 3 callersFunctioncreateWriteClient
(out *medium)
cmd/eskip/writeclient.go:18
↓ 3 callersFunctiondecodeBase64Value
decodeBase64Value decodes a base64-encoded string or a specific part of it. If partIndex is nil, it decodes the entire value. If partIndex is provided
filters/builtin/decode_base64.go:91
↓ 3 callersFunctiondecodeMessage
(b []byte)
swarm/message.go:110
↓ 3 callersFunctiondecompressGzip
(t *testing.T, b *bytes.Buffer)
routesrv/routesrv_test.go:148
↓ 3 callersFunctiondefaultEndpointRegistry
()
proxy/healthy_endpoints_test.go:25
↓ 3 callersFunctiondeleteCmd
command executed for delete.
cmd/eskip/write.go:108
↓ 3 callersMethoddialBackend
(req *http.Request)
proxy/upgrade.go:188
↓ 3 callersFunctiondifference
(a, b []string)
net/valkey.go:602
↓ 3 callersFunctiondurationArg
(a interface{})
filters/scheduler/lifo.go:61
↓ 3 callersFunctionencodeBase64Value
encodeBase64Value encodes a value (or a specific part of it) to base64. If partIndex is nil, it encodes the entire value. If partIndex is provided, it
filters/builtin/header_base64.go:90
↓ 3 callersFunctionencodeMessage
(m *message)
swarm/message.go:98
↓ 3 callersFunctionescape
(s string, chars string)
eskip/string.go:17
↓ 3 callersFunctioneskipStatename
(s int)
eskip/parser.go:235
↓ 3 callersMethodevict
()
filters/auth/tokeninfocache.go:119
↓ 3 callersFunctionexit
(err error)
cmd/eskip/eskip.go:88
↓ 3 callersFunctionexpectErrorResponse
(t *testing.T, rsp roundTripResponse)
proxy/longpoll_test.go:154
↓ 3 callersMethodfail
()
proxy/failingbackend_test.go:64
↓ 3 callersMethodfetchClusterState
()
dataclients/kubernetes/clusterclient.go:648
↓ 3 callersMethodfilterCipherSuites
()
config/config.go:1348
↓ 3 callersMethodfindAndLoadPlugins
()
plugins.go:16
↓ 3 callersFunctionfindDiffPos
(left, right string)
eskip/string_test.go:10
↓ 3 callersFunctionfindRouteWithPathPrefix
(r []*eskip.Route)
dataclients/kubernetes/path_test.go:42
← previousnext →1,001–1,100 of 5,794, ranked by callers