CloseIdleConnections delegates the call to the underlying http.Client.

Local is a getter to the local member of a swarm.

NewCertRegistry initializes the certificate registry.

NewStatus creates a filter specification whose instances set the status of the response to a fixed value regardless of backend response.

New parses a template string and returns a reusable *Template object. The template string can contain named placeholders of the format: Hello, ${who

ServeHTTP serves kept eskip-formatted routes under /routes endpoint. Additionally it provides a simple health check under health and Prometheus-compat

Implements http.ResponseWriter.Write. When WriteHeader was not called before Write, it calls it with the default 200 status code.

shardForKey does the lookup for valkey most operations to find the valkey ring shard

Name of the predicate as used in the route definitions.

NewRegistry returns a Registry and implements EncrypterCreator to store and manage secrets

NewSegment creates a new traffic segment predicate specification

NewXForwardedForLookuper returns an empty XForwardedForLookuper

Updates the current set of routes with new/modified and deleted route definitions in eskip format. In case the parsing of the document fails, it retur

load routes from input medium.

load, parse routes and print parse errors if any.

withFilters returns an http.Handler that runs the given filter chain before delegating to h. If any filter calls ctx.Serve(), the chain stops and h is

Check returns Settings used and the retry-after duration in case of request is ratelimited. Otherwise, return the Settings and 0. It is only used in t

NewCacheFilter returns a Spec for the cache() filter. maxBytes is the in-memory storage budget for the shared LRU cache backing all filter instances c

NewHandler returns a collection of metrics handlers.

NewRegistry initializes a registry with the provided default settings.

NewTag creates a filter specification for the tracingTag filter.

Allow filters to add Tags, Baggage to the trace or set the ComponentName. Deprecated: OpenTracing is deprecated, see https://github.com/zalando/skipp

cacheKey builds a deterministic cache key from the route ID and request. routeID is included so entries from different routes never collide when all r

command executed for check.

parse a routing doc and process it to runtime routes

generateCert handles creating customized test certificates based on options

newTestFilterRFC creates a filter in pure RFC mode (zero args). Upstream Cache-Control is fully authoritative. Use this for tests that exercise Expire

parseJwtBody parses the JWT token from a HTTP request. It returns `nil` if it was not possible to parse the JWT body.

TODO: find a nicer way to autogenerate route IDs

Canonical returns the canonical representation of a route, that uses the standard, non-legacy representation of the predicates and the backends. Canon

Deletes the 'routes' directory from etcd with the prefix '/skippertest'.

Deletes the 'routes' directory with the specified prefix.

GetEndpointAddresses returns the list of all addresses for the given service loaded by previous call to LoadAll or LoadUpdate.

InspectReader wraps the given ReadCloser such that the given function f can inspect the streaming while streaming to the target. A target can be any i

NewMetrics creates a metrics collector instance based on the Format option.

NewMtlsSanCIDR returns a filter spec for the mtlsSanCIDR filter. Each argument must be a valid CIDR block. CIDRs are combined into a single netipx.IPS