rate_limiter

Documentation

Index

• Constants
• func Init(_ *coremain.BP, args any) (any, error)
• type Args
• type RateLimiter
  • func New(args Args) (*RateLimiter, error)
  • func (s *RateLimiter) Close() error
  • func (s *RateLimiter) Match(ctx context.Context, qCtx *query_context.Context) (bool, error)

Constants

const PluginType = "rate_limiter"

Functions

func Init

func Init(_ *coremain.BP, args any) (any, error)

Types

type Args

type Args struct {
	Qps   float64 `yaml:"qps"`
	Burst int     `yaml:"burst"`
	Mask4 int     `yaml:"mask4"`
	Mask6 int     `yaml:"mask6"`
}

type RateLimiter

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

func New

func New(args Args) (*RateLimiter, error)

func (*RateLimiter) Close

func (s *RateLimiter) Close() error

func (*RateLimiter) Match

func (s *RateLimiter) Match(ctx context.Context, qCtx *query_context.Context) (bool, error)