rrl

package

v0.0.0-...-11760fe Latest Latest Go to latest Published: Feb 10, 2023 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/replit/rrl

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type KubernetesClient
- func NewKubernetesClient(namespace, app string) (*KubernetesClient, error)
- func (c *KubernetesClient) PodCount(ctx context.Context) (int64, error)
type PodCounter
type RRL
- func (rrl *RRL) Name() string
- func (rrl *RRL) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg) (int, error)
type ResponseAccount

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	RequestsExceeded = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: plugin.Namespace,
		Subsystem: "rrl",
		Name:      "requests_exceeded_total",
		Help:      "Counter of requests exceeding QPS limit.",
	}, []string{"client_ip"})

	ResponsesExceeded = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: plugin.Namespace,
		Subsystem: "rrl",
		Name:      "responses_exceeded_total",
		Help:      "Counter of responses exceeding QPS limit.",
	}, []string{"client_ip"})
)

Variables declared for monitoring.

Functions ¶

This section is empty.

Types ¶

type KubernetesClient ¶

type KubernetesClient struct {
	// contains filtered or unexported fields
}

KubernetesClient is a wrapper over the kubernetes client used to communicate with the kubernetes API.

func NewKubernetesClient ¶

func NewKubernetesClient(namespace, app string) (*KubernetesClient, error)

NewKubernetesClient creates a new kubernetes client using in-cluster authn/authz.

func (*KubernetesClient) PodCount ¶

func (c *KubernetesClient) PodCount(ctx context.Context) (int64, error)

PodCount returns the number of healthy pods.

type PodCounter ¶

type PodCounter interface {
	PodCount(ctx context.Context) (int64, error)
}

PodCounter counts the number of healthy pods running.

type RRL ¶

type RRL struct {
	Next  plugin.Handler
	Zones []string
	// contains filtered or unexported fields
}

RRL performs response rate limiting

func (*RRL) Name ¶

func (rrl *RRL) Name() string

Name implements the Handler interface.

func (*RRL) ServeDNS ¶

func (rrl *RRL) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg) (int, error)

ServeDNS implements the Handler interface.

type ResponseAccount ¶

type ResponseAccount struct {
	// contains filtered or unexported fields
}

ResponseAccount holds accounting for a category of response

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cache

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL