connector

Documentation

Index

• type Config
• type ConnectionEvent
• type Connector
• type MailServer
• type MailServerStatus
• type MxServer
• type Preparer
• type Seeker
• type Service
  • func Inst() *Service
  • func (s *Service) Events() chan *common.SendEvent
  • func (s *Service) OnFinish()
  • func (s *Service) OnInit(event *common.ApplicationEvent)
  • func (s *Service) OnRun()

Types

type Config

type Config struct {
	// путь до файла с закрытым ключом
	PrivateKeyFilename string `yaml:"privateKey"`

	// путь до файла с сертификатом
	CertFilename string `yaml:"certificate"`

	// ip с которых будем рассылать письма
	Addresses []string `yaml:"ips"`
	// contains filtered or unexported fields
}

type ConnectionEvent

type ConnectionEvent struct {
	*common.SendEvent
	// contains filtered or unexported fields
}

событие создания соединения

type Connector

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

соединитель, устанавливает соединение к почтовому сервису

type MailServer

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

почтовый сервис

type MailServerStatus

type MailServerStatus int

статус почтового сервис

const (
	// по сервису ведется поиск информации
	LookupMailServerStatus MailServerStatus = iota

	// по сервису успешно собрана информация
	SuccessMailServerStatus

	// по сервису не удалось собрать информацию
	ErrorMailServerStatus
)

type MxServer

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

почтовый сервер

type Preparer

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

заготовщик, подготавливает событие соединения

type Seeker

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

искатель, ищет информацию о сервере

type Service

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

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

сервис, управляющий соединениями к почтовым сервисам письма могут отсылаться в несколько потоков, почтовый сервис может разрешить несколько подключений с одного IP количество подключений может быть не равно количеству отсылающих потоков если доверить управление подключениями отправляющим потокам, тогда это затруднит общее управление подключениями поэтому создание подключений и предоставление имеющихся подключений отправляющим потокам вынесено в отдельный сервис

func Inst

func Inst() *Service

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

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()

запускает горутины