NewPrometheus returns a new Prometheus metric backend.

NewSameBucketLookuper returns a SameBucketLookuper.

NewStandardGenerator creates a new FlowID generator that generates flow IDs with length l. The alphabet is limited to 64 elements and requires a rando

NewTagFromResponse creates a filter similar to NewTag, but applies tags after the request has been processed.

NewTestRegistry returns a singleton TestRegistry

RemoteWatch creates a route configuration client with (remote) file watching. Watch doesn't follow file system nodes, it always reads (or re-downloads

RetryAfter is used to inform the client how many seconds it should wait before making a new request

Log formatted messages with level WARN

Write implements the io.Writer interface. It writes one byte at a time to the underlying writer, sleeps for the specified delay, reading from buffer

makeMTLSClientCert generates a client cert signed by the given CA.

marshalECKey converts an ecdsa.PrivateKey to a PEM-encoded EC PRIVATE KEY block.

newClusterRateLimiterRedis creates a new clusterLimitRedis for given Settings. Group is used to identify the ratelimit instance, is used in log messag

newMTLSBackend starts a TLS server that requires client certs signed by clientCAs.

CanonicalList returns the canonical form of each route in the list, keeping the order. The returned slice is a new slice of the input slice but the ro

Sets the Client to fail on the next call to LoadAll or LoadUpdate. Repeated call to FailNext will result the Client to fail as many times as it was ca

MustGenerate behaves like Generate but panics on failure instead of returning an error.

New creates a new traffic control predicate specification.

NewAppendResponseHeader returns a filter specification that is used to append headers for responses. Instances expect two parameters: the header name

NewCompress returns a filter specification that is used to compress the response content. Example: r: * -> compress() -> "https://www.example.org";

NewLogBody creates a filter specification for the 'logBody()' filter.

NewMtlsSanURI returns a filter spec for the mtlsSanURI filter. Each argument must be a valid URI.

NewTee returns a new tee filter Spec, whose instances execute the exact same Request against a shadow backend. parameters: shadow backend url, optiona

NewTupleLookuper returns TupleLookuper configured to lookup the combined result of all given Lookuper

Node return its self

Number converts BackendPort to int

Returns the host that will be set for the outgoing proxy request as the 'Host' header.

Ping pings given shard by address:port

PreProcessor returns routing.PreProcessor that ensures single lifo filter instance per route Registry cannot implement routing.PreProcessor directly

RoundTrip the request with tracing, bearer token injection and add client tracing: DNS, TCP/IP, TLS handshake, connection pool access. Client traces a

Status returns the current status of a queue.

Inserts or updates a route in etcd.

assertEqualWithTolerance verifies that actual value is within predefined delta of the expected value.

buildConnStateWithIssuer generates a leaf certificate whose Issuer is set to issuerName by signing it with a CA that has issuerName as its Subject. Re

getUpgradeRequest returns the protocol name from the upgrade header

matches a request to the conditions in a leaf matcher

newClusterRateLimiterValkey creates a new clusterLimitValkey for given Settings. Group is used to identify the ratelimit instance, is used in log mess

parse parses a yaml configuration or returns a cached value if the exact configuration was already parsed before. Returned value is shared by multiple

serializes a given map of label selectors to a string that can be appended to a request URI to kubernetes Examples (note that the resulting value in t