limiter

Documentation

Index

• Constants
• func Inst() common.SendingService
• type Cleaner
• type Config
• type Kind
• type Limit
• type Limiter
• type Service
  • func (s *Service) Events() chan *common.SendEvent
  • func (s *Service) OnFinish()
  • func (s *Service) OnInit(event *common.ApplicationEvent)
  • func (s *Service) OnRun()

Constants

const (
	SecondKind Kind = "second"
	MinuteKind      = "minute"
	HourKind        = "hour"
	DayKind         = "day"
)

Functions

func Inst

func Inst() common.SendingService

создает сервис ограничений

Types

type Cleaner

type Cleaner struct{}

чистильщик, проверяет значения ограничений и обнуляет значения ограничений

type Config

type Config struct {
	// ограничения для почтовых сервисов, в качестве ключа используется домен
	Limits map[string]*Limit `yaml:"limits"`
}

type Kind

type Kind string

тип ограничения

type Limit

type Limit struct {
	// максимально допустимое количество писем
	Value int32 `json:"value"`

	// тип ограничения
	Kind Kind `json:"type"`
	// contains filtered or unexported fields
}

ограничение

type Limiter

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

ограничитель, проверяет количество отправленных писем почтовому сервису

type Service

type Service struct {
	// количество горутин проверяющих количество отправленных писем
	LimitersCount int `yaml:"workers"`

	Configs map[string]*Config `yaml:"postmans"`
}

сервис ограничений, следит за тем, чтобы почтовым сервисам не отправилось больше писем, чем нужно

func (*Service) Events

func (s *Service) Events() chan *common.SendEvent

канал для приема событий отправки писем

func (*Service) OnFinish

func (s *Service) OnFinish()

завершает работу сервиса соединений

func (*Service) OnInit

func (s *Service) OnInit(event *common.ApplicationEvent)

инициализирует сервис

func (*Service) OnRun

func (s *Service) OnRun()

запускает проверку ограничений и очистку значений лимитов