 Documentation
      ¶
      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
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Group ¶
type Group struct {
	// contains filtered or unexported fields
}
    func (*Group) InstanceName ¶
func (*Group) ReleaseDest ¶
 Click to show internal directories. 
   Click to hide internal directories.