throttle

Documentation

Index

• type TelegramThrottle
  • func NewTelegramThrottle(ctx context.Context, cfg *TelegramThrottleCfg) (t *TelegramThrottle, err error)
  • func (t *TelegramThrottle) Allow(alertType string) (ok bool)
• type TelegramThrottleCfg

Types

type TelegramThrottle

type TelegramThrottle struct {
	sync.Mutex
	// contains filtered or unexported fields
}

TelegramThrottle throttle for telegram monitor

func NewTelegramThrottle

func NewTelegramThrottle(ctx context.Context, cfg *TelegramThrottleCfg) (t *TelegramThrottle, err error)

NewTelegramThrottle create new TelegramThrottle

func (*TelegramThrottle) Allow

func (t *TelegramThrottle) Allow(alertType string) (ok bool)

Allow is allow alertType to push

type TelegramThrottleCfg

type TelegramThrottleCfg struct {
	TotleNPerSec, TotleBurst         int
	EachTitleNPerSec, EachTitleBurst int
}

TelegramThrottleCfg configuration for TelegramThrottle