limits

Documentation

Overview

Package limit provides a module object that can be used to restrict the concurrency and rate of the messages flow globally or on per-source, per-destination basis.

Note, all domain inputs are interpreted with the assumption they are already normalized.

Low-level components are available in the limiters/ subpackage.

Index

• func New(_, instName string, _, _ []string) (module.Module, error)
• type Group
  • func (g *Group) Init(cfg *config.Map) error
  • func (g *Group) InstanceName() string
  • func (g *Group) Name() string
  • func (g *Group) ReleaseDest(domain string)
  • func (g *Group) ReleaseMsg(addr net.IP, sourceDomain string)
  • func (g *Group) TakeDest(ctx context.Context, domain string) error
  • func (g *Group) TakeMsg(ctx context.Context, addr net.IP, sourceDomain string) error

Functions

func New

func New(_, instName string, _, _ []string) (module.Module, error)

Types

type Group

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

func (*Group) Init

func (g *Group) Init(cfg *config.Map) error

func (*Group) InstanceName

func (g *Group) InstanceName() string

func (*Group) Name

func (g *Group) Name() string

func (*Group) ReleaseDest

func (g *Group) ReleaseDest(domain string)

func (*Group) ReleaseMsg

func (g *Group) ReleaseMsg(addr net.IP, sourceDomain string)

func (*Group) TakeDest

func (g *Group) TakeDest(ctx context.Context, domain string) error

func (*Group) TakeMsg

func (g *Group) TakeMsg(ctx context.Context, addr net.IP, sourceDomain string) error