MCPcopy Create free account

hub / github.com/zalando/skipper / functions

Functions5,794 in github.com/zalando/skipper

↓ 2 callersMethodClose
Close should be used on teardown to cleanup a refresher goroutine. Implementers should check of this interface should check nil pointer, such that cal
secrets/readers.go:13
↓ 2 callersMethodClose
Close delegates to the wrapped SecretsReader.
secrets/readers.go:56
↓ 2 callersMethodClose
Close closes the underlying reader if it implements io.Closer.
io/read_stream.go:166
↓ 2 callersMethodClose
Close stops all background goroutines.
net/httpclient.go:144
↓ 2 callersFunctionCopyFilters
CopyFilters creates a new slice with the copy of each filter in the input slice.
eskip/copy.go:45
↓ 2 callersFunctionCopyPredicates
CopyPredicates creates a new slice with the copy of each predicate in the input slice.
eskip/copy.go:23
↓ 2 callersMethodCount
Count returns the recorded messages that match exp.
logging/loggingtest/logger.go:177
↓ 2 callersMethodCreateFilter
CreateFilter creates an OpenID Connect authorization filter. first arg: a provider, for example "https://accounts.google.com", which has the path /.w
filters/auth/oidc.go:210
↓ 2 callersMethodCreateFilter
(args []interface{})
filters/diag/logheader.go:23
↓ 2 callersMethodCreateFilter
(args []interface{})
filters/ratelimit/backendratelimit.go:23
↓ 2 callersMethodCreateUnstarted
()
proxy/proxytest/proxytest.go:79
↓ 2 callersMethodDataClients
()
routing/export_test.go:27
↓ 2 callersMethodDelay
(d time.Duration)
net/nettest/listener.go:39
↓ 2 callersMethodDeleteAllIf
delete all items in 'routes' that fulfil 'cond'.
cmd/eskip/writeclient.go:13
↓ 2 callersMethodDialContext
DialContext wraps net.Dialer's DialContext and returns an error, that can be checked if it was a Transport (TCP/TLS handshake) error or timeout, or a
proxy/proxy.go:764
↓ 2 callersMethodDialError
DialError returns true if the error was caused while dialing TCP or TLS connections, before HTTP data was sent. It is safe to retry a call, if this re
proxy/proxy.go:534
↓ 2 callersFunctionEq
Eq implements canonical equivalence comparison of routes based on Skipper semantics. Duplicate IDs are considered invalid for Eq, and it returns fals
eskip/eq.go:138
↓ 2 callersMethodError
()
etcd/etcd.go:65
↓ 2 callersMethodErrorf
(f string, a ...any)
logging/logger.go:37
↓ 2 callersMethodFloat64Gauge
(name string, opts ...metric.Float64GaugeOption)
metrics/otel_test.go:53
↓ 2 callersMethodFlush
()
logging/loggingwriter.go:38
↓ 2 callersMethodFlush
()
io/iotest/writer.go:42
↓ 2 callersMethodFormat
(entry *log.Entry)
script/script_test.go:998
↓ 2 callersFunctionForwardPreProcessor
(s string)
eskip/eskip.go:220
↓ 2 callersMethodGather
()
metrics/prometheus.go:560
↓ 2 callersMethodGet
(ctx context.Context, key string)
net/redisclient.go:412
↓ 2 callersMethodGetAuthURLParameters
(redirectURI string)
filters/auth/grantconfig.go:353
↓ 2 callersMethodGetBytes
()
logging/loggingwriter.go:54
↓ 2 callersMethodGetCertFromHello
GetCertFromHello reads the SNI from a TLS client and returns the appropriate certificate. If no certificate is found for the host it will return nil.
secrets/certregistry/certregistry.go:65
↓ 2 callersMethodGetEndpointSlicesByService
GetEndpointSlicesByService returns the skipper endpointslices for kubernetes endpointslices.
dataclients/kubernetes/clusterstate.go:82
↓ 2 callersMethodGetEndpointsByService
GetEndpointsByService returns the skipper endpoints for kubernetes endpoints.
dataclients/kubernetes/clusterstate.go:54
↓ 2 callersMethodGetEndpointsByTarget
GetEndpointsByTarget returns the skipper endpoints for kubernetes endpoints.
dataclients/kubernetes/clusterstate.go:146
↓ 2 callersMethodGetEnvoyMetadata
()
filters/openpolicyagent/openpolicyagent.go:400
↓ 2 callersMethodGetSecret
()
secrets/encrypter.go:19
↓ 2 callersFunctionGetTraceID
GetTraceID retrieves TraceID from HTTP request, for example to search for this trace in the UI of your tracing solution and to get more context about
tracing/tracing.go:162
↓ 2 callersMethodGetWeight
()
dataclients/kubernetes/definitions/definitions.go:45
↓ 2 callersMethodHandleErrorResponse
HandleErrorResponse returns true if a filter wants to get called
proxy/proxy.go:2057
↓ 2 callersMethodHandleInstanceNotReadyError
(fc filters.FilterContext, span opentracing.Span, serve bool)
filters/openpolicyagent/response.go:22
↓ 2 callersMethodHasConfig
HasConfig indicates that the current filter provides the queue queue settings for the group.
scheduler/scheduler.go:295
↓ 2 callersMethodHeader
()
logging/loggingwriter.go:34
↓ 2 callersMethodIncCounterBy
(key string, value int64)
metrics/metricstest/metricsmock.go:102
↓ 2 callersMethodIncFloatCounterBy
(key string, value float64)
metrics/metricstest/metricsmock.go:113
↓ 2 callersMethodIncRequests
(o IncRequestsOptions)
routing/endpointregistry.go:28
↓ 2 callersFunctionInitPassiveHealthChecker
(o map[string]string)
proxy/proxy.go:183
↓ 2 callersFunctionInitTracer
InitTracer initializes an opentracing tracer. The first option item is the tracer implementation name.
tracing/tracing.go:74
↓ 2 callersMethodInsecure
When set, the proxy will skip the TLS verification on outgoing requests.
proxy/proxy.go:441
↓ 2 callersMethodInstanceConfig
()
filters/openpolicyagent/openpolicyagent.go:1154
↓ 2 callersMethodIsStale
IsStale reports whether the entry is past its TTL but still within the stale-while-revalidate window relative to now.
filters/cache/storage.go:48
↓ 2 callersFunctionLBEndpointString
(eps []*LBEndpoint)
eskip/eskip.go:372
↓ 2 callersMethodLess
(i, j int)
routing/matcher.go:67
↓ 2 callersMethodLoadRouteGroups
()
dataclients/kubernetes/clusterclient.go:419
↓ 2 callersFunctionLogKV
LogKV will add a log to the span from the given context
tracing/tracing.go:150
↓ 2 callersMethodLookup
Lookup returns the content of the X-Forwarded-For header or the clientIP if not set.
ratelimit/ratelimit.go:194
↓ 2 callersMethodLookup
Lookup returns the content of the Authorization header.
ratelimit/ratelimit.go:214
↓ 2 callersMethodMarshalJSON
()
dataclients/kubernetes/definitions/ingressv1.go:157
↓ 2 callersMethodMatch
Match should return true and the object to be returned by the lookup, when the argument value fulfils the conditions defined by the custom logic in th
pathmux/tree.go:23
↓ 2 callersMethodMeasureBackend5xx
MeasureBackend5xx satisfies Metrics interface.
metrics/prometheus.go:530
↓ 2 callersMethodMeasureFilterRequest
MeasureFilterRequest satisfies Metrics interface.
metrics/prometheus.go:412
↓ 2 callersMethodMeasureFilterResponse
MeasureFilterResponse satisfies Metrics interface.
metrics/prometheus.go:448
↓ 2 callersMethodMeasureRouteLookup
MeasureRouteLookup satisfies Metrics interface.
metrics/prometheus.go:401
↓ 2 callersMethodMeasureSince
MeasureSince satisfies Metrics interface.
metrics/prometheus.go:374
↓ 2 callersMethodMetrics
()
net/httptest/client.go:74
↓ 2 callersMethodMute
()
logging/loggingtest/logger.go:195
↓ 2 callersMethodName
()
predicates/auth/jwt.go:151
↓ 2 callersMethodName
()
filters/builtin/header_encode.go:38
↓ 2 callersMethodName
()
filters/builtin/timeout.go:40
↓ 2 callersFunctionNew
New creates a specification for the xforward filter that appends the remote IP of the incoming request to the X-Forwarded-For header, and sets the X-F
filters/xforward/xforward.go:25
↓ 2 callersFunctionNew
()
filters/tls/pass_client.go:14
↓ 2 callersFunctionNew
New creates a new instance of the flowId filter spec which uses the StandardGenerator. To use another type of Generator use NewWithGenerator()
filters/flowid/filter.go:52
↓ 2 callersFunctionNew
New creates a path generator with the provided options, falling back to the default value for each non-specified option field.
routing/pathgen/pathgen.go:74
↓ 2 callersFunctionNewAbsorb
NewAbsorb initializes a filter spec for the absorb filter. The absorb filter reads and discards the payload of the incoming requests. It logs with IN
filters/diag/absorb.go:54
↓ 2 callersFunctionNewAccessLogDisabled
NewAccessLogDisabled creates a filter spec for overriding the state of the AccessLogDisabled setting. (By default global setting is used.) accessLog
filters/accesslog/disable.go:21
↓ 2 callersFunctionNewAppendContextRequestHeader
NewAppendContextRequestHeader returns a filter specification used to append request headers with a given name and a value taken from the filter contex
filters/builtin/headerfilter.go:125
↓ 2 callersFunctionNewAppendContextResponseHeader
NewAppendContextResponseHeader returns a filter specification used to append response headers with a given name and a value taken from the filter cont
filters/builtin/headerfilter.go:139
↓ 2 callersFunctionNewBackendBandwidth
NewBackendBandwidth is the equivalent of NewBandwidth but for outgoing backend requests. Eskip example: r: * -> backendBandwidth(30) -> "https://www
filters/diag/diag.go:199
↓ 2 callersFunctionNewBackendChunks
NewBackendChunks is the equivalent of NewChunks but for outgoing backend requests. Eskip example: r: * -> backendChunks(1024, 120) -> "https://www.e
filters/diag/diag.go:205
↓ 2 callersFunctionNewBackendIsProxy
NewBackendIsProxy returns a filter specification that is used to specify that the backend is also a proxy.
filters/builtin/backendisproxy.go:10
↓ 2 callersFunctionNewBackendLatency
NewBackendLatency is the equivalent of NewLatency but for outgoing backend requests. Eskip example: r: * -> backendLatency(120) -> "https://www.exam
filters/diag/diag.go:193
↓ 2 callersFunctionNewBandwidth
NewBandwidth creates a filter specification whose filter instances can be used to maximize the bandwidth of the responses. It expects the bandwidth in
filters/diag/diag.go:180
↓ 2 callersFunctionNewBlockHex
(maxMatcherBufferSize uint64)
filters/block/block.go:41
↓ 2 callersFunctionNewCertificate
(hosts ...string)
proxy/proxytest/cert.go:17
↓ 2 callersFunctionNewChunks
NewChunks creates a filter specification whose filter instances can be used set artificial delays in between response chunks. It expects the byte leng
filters/diag/diag.go:187
↓ 2 callersFunctionNewClientKubernetes
NewClientKubernetes creates and initializes a Kubernetes client to find peers. A partial copy of the Kubernetes dataclient.
swarm/kubernetes.go:95
↓ 2 callersFunctionNewClone
NewClone creates a Clone PreProcessor, that matches routes and replaces the content of the cloned routes. For example to migrate from Source to Client
eskip/eskip.go:58
↓ 2 callersFunctionNewConsecutiveBreaker
NewConsecutiveBreaker creates a filter specification to instantiate consecutiveBreaker() filters. These filters set a breaker for the current route t
filters/circuit/breaker.go:64
↓ 2 callersFunctionNewConsistentHashBalanceFactor
NewConsistentHashBalanceFactor creates a filter Spec, whose instances set the balancer factor used by the `consistentHash` algorithm to avoid popular
filters/consistenthash/balancefactor.go:17
↓ 2 callersFunctionNewConsistentHashKey
NewConsistentHashKey creates a filter Spec, whose instances set the request key used by the `consistentHash` algorithm to select backend endpoint
filters/consistenthash/key.go:15
↓ 2 callersFunctionNewDecompress
NewDecompress creates a filter specification for the decompress() filter. The filter attempts to decompress the response body, if it was compressed wi
filters/builtin/decompress.go:190
↓ 2 callersFunctionNewDefaultHandler
NewDefaultHandler returns a default metrics handler.
metrics/metrics.go:225
↓ 2 callersFunctionNewDisableBreaker
NewDisableBreaker disables the circuit breaker for a route. It doesn't accept any arguments.
filters/circuit/breaker.go:82
↓ 2 callersFunctionNewDropRequestCookie
()
filters/cookie/cookie.go:83
↓ 2 callersFunctionNewDropRequestHeader
NewDropRequestHeader returns a filter specification that is used to delete headers for requests. Instances expect one parameter: the header name. Name
filters/builtin/headerfilter.go:88
↓ 2 callersFunctionNewDropRequestHeaderValueRegexp
()
filters/builtin/headerfilter.go:165
↓ 2 callersFunctionNewDropResponseCookie
()
filters/cookie/cookie.go:89
↓ 2 callersFunctionNewDropResponseHeader
NewDropResponseHeader returns a filter specification that is used to delete headers for responses. Instances expect one parameter: the header name. Na
filters/builtin/headerfilter.go:111
↓ 2 callersFunctionNewDropResponseHeaderValueRegexp
()
filters/builtin/headerfilter.go:169
↓ 2 callersFunctionNewEditor
NewEditor creates an Editor PreProcessor, that matches routes and replaces the content. For example to replace Source predicates with ClientIP predica
eskip/eskip.go:35
↓ 2 callersFunctionNewEncodeRequestHeader
()
filters/builtin/header_encode.go:27
↓ 2 callersFunctionNewEncodeResponseHeader
()
filters/builtin/header_encode.go:32
↓ 2 callersFunctionNewFalse
NewFalse provides a predicate spec to create a Predicate instance that evaluates to false
predicates/primitive/false.go:20
← previousnext →1,201–1,300 of 5,794, ranked by callers