MCPcopy Create free account

hub / github.com/zalando/skipper / functions

Functions5,794 in github.com/zalando/skipper

⨍ Functions 5,794◇ Types & classes 1,022
↓ 6 callersMethodClose
()
filters/openpolicyagent/openpolicyagent.go:427
↓ 6 callersMethodConfigureCertificate
ConfigureCertificate for the host if no configuration exists or if certificate is valid (`NotBefore` field) after previously configured certificate.
secrets/certregistry/certregistry.go:33
↓ 6 callersMethodCreateNonce
()
secrets/registry.go:13
↓ 6 callersFunctionFprint
(w io.Writer, prettyPrintInfo PrettyPrintInfo, routes ...*Route)
eskip/string.go:251
↓ 6 callersMethodGenerate
Generate returns a new Flow ID using the implementation specific format or an error in case of failure.
filters/flowid/filter.go:22
↓ 6 callersMethodGet
(ctx context.Context, key string)
net/valkey.go:523
↓ 6 callersMethodGetBody
GetBody issues a GET to the specified URL, reads and closes response body and returns response, response body bytes and error if any.
proxy/proxytest/proxytest.go:166
↓ 6 callersFunctionHandleValidationError
(mtr metrics.Metrics, err error, routeId string)
routing/errors.go:31
↓ 6 callersMethodIncRoutingFailures
IncRoutingFailures satisfies Metrics interface.
metrics/prometheus.go:520
↓ 6 callersMethodInit
()
filters/auth/grantconfig.go:144
↓ 6 callersFunctionInitTracer
(opts []string)
tracing/tracers/basic/basic.go:26
↓ 6 callersMethodLogger
()
proxy/context.go:222
↓ 6 callersMethodMeasureRouteLookup
Additional methods
metrics/metrics.go:38
↓ 6 callersFunctionMustParsePredicates
MustParsePredicates parses a set of predicates (combined by '&&') into a list of parsed predicate definitions and panics in case of error
eskip/eskip.go:732
↓ 6 callersFunctionNewAppendRequestHeader
NewAppendRequestHeader returns a filter specification that is used to append headers for requests. Instances expect two parameters: the header name an
filters/builtin/headerfilter.go:81
↓ 6 callersFunctionNewBasicAuth
()
filters/auth/basic.go:28
↓ 6 callersFunctionNewBlock
(maxMatcherBufferSize uint64)
filters/block/block.go:35
↓ 6 callersFunctionNewGrantCookiesWithTokens
(t *testing.T, config *OAuthConfig, refreshToken string, accessToken string)
filters/auth/grantcookie_test.go:58
↓ 6 callersFunctionNewJWTPayloadAnyKV
()
predicates/auth/jwt.go:105
↓ 6 callersFunctionNewLRUStorage
NewLRUStorage returns an LRUStorage backed by a ShardedByteLRU sized to totalMaxBytes.
filters/cache/lru_storage.go:21
↓ 6 callersFunctionNewMtlsAuthn
NewMtlsAuthn returns a filter spec for the mtlsAuthn filter. You need to pass the x509.CertPool that it will use to validate client certificates for a
filters/tls/mtls.go:116
↓ 6 callersFunctionNewOpaAuthorizeRequestWithBodySpec
(registry *openpolicyagent.OpenPolicyAgentRegistry)
filters/openpolicyagent/opaauthorizerequest/opaauthorizerequest.go:38
↓ 6 callersMethodNewPreProcessor
NewPreProcessor creates a pre-processor that pre-loads OPA instances Only used when pre-loading is enabled via command line flag
filters/openpolicyagent/preprocessor.go:25
↓ 6 callersFunctionNewRepeat
NewRepeat creates a filter specification whose filter instances can be used to respond to requests with a repeated text. It expects the text and the b
filters/diag/diag.go:142
↓ 6 callersFunctionNewTeeLoopback
()
filters/tee/teeloopback.go:35
↓ 6 callersFunctionParseCIDRs
ParseCIDRs is *deprecated* use ParseIPCIDRs.
net/net.go:120
↓ 6 callersMethodPreserveOriginal
When set, the filters will receive an unmodified clone of the original incoming request and response.
proxy/proxy.go:445
↓ 6 callersFunctionPrint
Print serializes a set of routes into a string. If there's only a single route, and its ID is not set, it prints only a route expression. If it has mu
eskip/string.go:219
↓ 6 callersFunctionPutData
Saves a route in etcd with the prefix '/skippertest'.
etcd/etcdtest/mocketcd.go:180
↓ 6 callersMethodServeResponse
(fc filters.FilterContext, span opentracing.Span, result *envoyauth.EvalResult)
filters/openpolicyagent/response.go:75
↓ 6 callersMethodSet
(_ context.Context, key string, entry *Entry)
filters/cache/lru_storage.go:51
↓ 6 callersMethodSetAddrs
(ctx context.Context, addrs []string)
net/valkey.go:492
↓ 6 callersMethodSetLevel
(level logging.Level)
filters/openpolicyagent/openpolicyagent.go:1412
↓ 6 callersMethodSetRespCode
(respCode int)
filters/openpolicyagent/internal/opatestutils/openpolicyagent_helpers.go:68
↓ 6 callersMethodStateBag
()
filters/filtertest/filtertest.go:50
↓ 6 callersMethodTimeout
()
queuelistener/listener_test.go:37
↓ 6 callersMethodValidate
(resource R)
dataclients/kubernetes/definitions/validator.go:30
↓ 6 callersFunctionWatch
Watch creates a route configuration client with file watching. Watch doesn't follow file system nodes, it always reads from the file identified by the
eskipfile/watch.go:32
↓ 6 callersMethodWrite
(p []byte)
filters/tee/tee_loop_detected_test.go:44
↓ 6 callersFunctionaddLeafToPath
(pms map[string]*pathMatcher, path string, l *leafMatcher)
routing/matcher.go:276
↓ 6 callersMethodaddPath
(path string)
pathmux/tree.go:69
↓ 6 callersFunctionappendAnnotationFilters
(annotationFilters []AnnotationFilters, annotations map[string]string, r *eskip.Route)
dataclients/kubernetes/annotations.go:29
↓ 6 callersFunctionappendAnnotationPredicates
(annotationPredicates []AnnotationPredicates, annotations map[string]string, r *eskip.Route)
dataclients/kubernetes/annotations.go:19
↓ 6 callersFunctionappendFmt
(s []string, format string, args ...interface{})
eskip/string.go:34
↓ 6 callersMethodapplyFiltersOnError
(ctx *context, filters []*routing.RouteFilter)
proxy/proxy.go:2060
↓ 6 callersFunctionauthorized
(ctx filters.FilterContext, username string)
filters/auth/auth.go:144
↓ 6 callersFunctionbenchmarkPredicateHost
Benchmarks multi-host setup where request matches only one host out of many using different host predicates. Creates R routes parametrized by sequence
routing/host_test.go:49
↓ 6 callersFunctionbuildAPIURL
(o Options)
dataclients/kubernetes/kube.go:379
↓ 6 callersFunctionbuildHTTPClient
(certFilePath string, inCluster bool, quit <-chan struct{})
dataclients/kubernetes/clusterclient.go:94
↓ 6 callersFunctioncreateFile
(t *testing.T)
eskipfile/watch_test.go:66
↓ 6 callersFunctiondocToMatcherOpts
create a matcher from a routing document with matching options
routing/matcher_test.go:146
↓ 6 callersFunctionensureUTF8
(s string)
proxy/proxy.go:2009
↓ 6 callersFunctioneskipTokname
(c int)
eskip/parser.go:226
↓ 6 callersMethodget
(s ratelimit.Settings)
filters/ratelimit/ratelimit.go:38
↓ 6 callersFunctiongetDurationArg
(a interface{})
filters/ratelimit/ratelimit.go:441
↓ 6 callersFunctiongetField
(o map[string]interface{}, names ...string)
dataclients/kubernetes/kubernetestest/api_test.go:194
↓ 6 callersFunctiongetIntArg
(a interface{})
filters/circuit/breaker.go:34
↓ 6 callersFunctiongetStringArgs
Expects exactly n arguments of type string, or fails.
eskip/eskip.go:512
↓ 6 callersFunctiongetStrings
(args []interface{})
filters/auth/auth.go:148
↓ 6 callersFunctiongetToken
(r *http.Request)
filters/auth/auth.go:92
↓ 6 callersFunctiongetZoneAwareRoutesGzip
(rs *routesrv.RouteServer, zone string)
routesrv/routesrv_test.go:129
↓ 6 callersMethodincCounter
(key string, value int64)
metrics/codahale.go:244
↓ 6 callersFunctionintArg
(a interface{})
filters/scheduler/lifo.go:50
↓ 6 callersFunctionisUpgradeRequest
isUpgradeRequest returns true if and only if there is a "Connection" key with the value "Upgrade" in Headers of the given request.
proxy/upgrade.go:22
↓ 6 callersFunctionmeasuredMethod
(m string)
metrics/utils.go:27
↓ 6 callersFunctionmissingArg
(opt string)
tracing/tracers/jaeger/jaeger.go:128
↓ 6 callersFunctionnewClusterLeakyBucketRedis
(ringClient *net.RedisRingClient, capacity int, emission time.Duration, now func() time.Time)
ratelimit/leakybucket_redis.go:33
↓ 6 callersFunctionnewClusterLeakyBucketValkey
(ringClient *net.ValkeyRingClient, capacity int, emission time.Duration, now func() time.Time)
ratelimit/leakybucket_valkey.go:33
↓ 6 callersFunctionnewGrantCookies
(t *testing.T, config *OAuthConfig, host string, token oauth2.Token)
filters/auth/grantcookie_test.go:20
↓ 6 callersFunctionnewTestHandler
(t *testing.T, name string)
filters/tee/tee_test.go:121
↓ 6 callersFunctionparseAnnotationFilters
(s []string)
config/config.go:1452
↓ 6 callersFunctionparseAnnotationPredicates
(s []string)
config/config.go:1437
↓ 6 callersFunctionparseHTTPTime
parseHTTPTime parses an HTTP date per RFC 9111 §4.2. Rejects dates with non-GMT zone abbreviations that http.ParseTime would silently accept with a wr
filters/cache/filter.go:746
↓ 6 callersMethodparseSingleArg
parseSingleArg calls [yamlConfigParser.parse] with the first string argument. If args slice does not contain a single string, it returns an error.
filters/auth/yamlconfig.go:45
↓ 6 callersMethodselectEndpoint
(ctx *context)
proxy/proxy.go:640
↓ 6 callersFunctionserve
(w http.ResponseWriter, r *http.Request, resources []byte, name string)
dataclients/kubernetes/kubernetestest/api.go:222
↓ 6 callersFunctionserverError
(ctx filters.FilterContext)
filters/auth/grant.go:50
↓ 6 callersFunctionsetAnnotation
(i *definitions.IngressV1Item, key, value string)
dataclients/kubernetes/kube_test.go:164
↓ 6 callersFunctionsetupOpaTestEnvironment
setupOpaTestEnvironment sets up the OPA test environment with the given bundle server URL and control loop setting.
filters/openpolicyagent/opaauthorizerequest/openpolicyagent_routeupdate_test.go:644
↓ 6 callersFunctionstripPort
strip port from addresses with hostname, ipv4 or ipv6
net/net.go:15
↓ 6 callersFunctionsucceed
(t *testing.T, b *Breaker)
circuit/breaker_test.go:32
↓ 6 callersFunctiontestPathMatch
(t *testing.T, s []pathSpec)
routing/tree_test.go:136
↓ 6 callersMethodunlock
()
filters/shedder/netconn_test.go:53
↓ 6 callersMethodupdate
update returns non empty subsequences of addrs, e.g. for [foo bar baz] it returns: 1: [foo] 2: [foo bar] 3: [foo bar baz] 4: [foo] 5: [foo bar] 6: [fo
net/helper_test.go:25
↓ 6 callersMethodvalidate
TODO: we need to pass namespace/name in all errors
dataclients/kubernetes/definitions/routegroupvalidator.go:208
↓ 6 callersMethodvalidateAllClaims
(h map[string]interface{})
filters/auth/oidc.go:399
↓ 6 callersFunctionverifyNoTag
(t *testing.T, span *tracingtest.MockSpan, name string)
proxy/tracing_test.go:899
↓ 6 callersFunctionwait
(d time.Duration)
proxy/breaker_test.go:276
↓ 6 callersMethodwaitAndSucceedInitial
()
eskipfile/watch_test.go:148
↓ 6 callersFunctionwaitFor
(f func() bool)
queuelistener/listener_test.go:169
↓ 6 callersFunctionwriteTempCertFiles
(t *testing.T, cert, key []byte)
net/httpclient_test.go:1048
↓ 5 callersMethodCloseIdleConnections
()
net/httpclient.go:536
↓ 5 callersFunctionCopy
Copy creates a canonical copy of the input route. See also Canonical().
eskip/copy.go:55
↓ 5 callersMethodCreateFilter
(args []interface{})
filters/builtin/timeout.go:52
↓ 5 callersMethodDelta
Delta is used to get the duration until the next call is possible, negative durations allow immediate calls
ratelimit/ratelimit.go:351
↓ 5 callersMethodExtract
Extract() returns a SpanContext instance given `format` and `carrier`. It copies the X-Trace-Header value to the TraceContent field.
tracing/tracingtest/testtracer.go:126
↓ 5 callersMethodGetEncrypter
(refreshInterval time.Duration, file string)
secrets/registry.go:33
↓ 5 callersFunctionHMACSHA256
(key []byte, data []byte)
filters/awssigner/internal/hmac.go:8
↓ 5 callersMethodInt64Counter
(name string, opts ...metric.Int64CounterOption)
metrics/otel_test.go:39
↓ 5 callersMethodLen
()
loadbalancer/algorithm.go:109
← previousnext →501–600 of 5,794, ranked by callers