notifylimiter

Documentation

Index

• type Limiter
  • func NewLimiter(archetype *baseservice.Archetype, waitDuration time.Duration) *Limiter
  • func (l *Limiter) ShouldTrigger(topic string) bool
• type NotifyFunc

Types

type Limiter

type Limiter struct {
	baseservice.BaseService
	// contains filtered or unexported fields
}

func NewLimiter

func NewLimiter(archetype *baseservice.Archetype, waitDuration time.Duration) *Limiter

NewLimiter creates a new Limiter, calling the NotifyFunc no more than once per waitDuration. The function must be fast as it is called within a mutex.

func (*Limiter) ShouldTrigger

func (l *Limiter) ShouldTrigger(topic string) bool

type NotifyFunc

type NotifyFunc func(name string)