ratelimit

Documentation

Index

• Constants
• func ConvertActions(ctx context.Context, actions []*gloorl.Action) []*envoy_config_route_v3.RateLimit_Action
• func DetermineFilterStage(rateLimitBeforeAuth bool) plugins.FilterStage
• func GenerateEnvoyConfigForFilterWith(ref core.ResourceRef, domain string, currentState uint32, ...) *envoyratelimit.RateLimit
• type Plugin
  • func NewPlugin() *Plugin
  • func (p *Plugin) HttpFilters(_ plugins.Params, listener *v1.HttpListener) ([]plugins.StagedHttpFilter, error)
  • func (p *Plugin) Init(params plugins.InitParams) error
  • func (p *Plugin) ProcessRoute(params plugins.RouteParams, in *v1.Route, out *envoy_config_route_v3.Route) error
  • func (p *Plugin) ProcessVirtualHost(params plugins.VirtualHostParams, in *v1.VirtualHost, ...) error

Constants

const (
	ExtensionName      = "rate-limit"
	EnvoyExtensionName = "envoy-rate-limit"
	CustomDomain       = "custom"

	CustomStage    = 1
	DefaultTimeout = 100 * time.Millisecond
)

Functions

func ConvertActions

func ConvertActions(ctx context.Context, actions []*gloorl.Action) []*envoy_config_route_v3.RateLimit_Action

func DetermineFilterStage

func DetermineFilterStage(rateLimitBeforeAuth bool) plugins.FilterStage

figure out what stage the rate limit plugin should run in given some configuration

func GenerateEnvoyConfigForFilterWith

func GenerateEnvoyConfigForFilterWith(
	ref core.ResourceRef,
	domain string,
	currentState uint32,
	timeout *time.Duration,
	denyOnFail bool,
) *envoyratelimit.RateLimit

Types

type Plugin

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

func NewPlugin

func NewPlugin() *Plugin

func (*Plugin) HttpFilters

func (p *Plugin) HttpFilters(_ plugins.Params, listener *v1.HttpListener) ([]plugins.StagedHttpFilter, error)

func (*Plugin) Init

func (p *Plugin) Init(params plugins.InitParams) error

func (*Plugin) ProcessRoute

func (p *Plugin) ProcessRoute(params plugins.RouteParams, in *v1.Route, out *envoy_config_route_v3.Route) error

func (*Plugin) ProcessVirtualHost

func (p *Plugin) ProcessVirtualHost(
	params plugins.VirtualHostParams,
	in *v1.VirtualHost, out *envoy_config_route_v3.VirtualHost,
) error