connector

Documentation

Index

• 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 ConnectionEvent

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

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

type Connector

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

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

type MailServer

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

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

type MailServerStatus

type MailServerStatus int

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

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

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

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

type MxServer

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

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

type Preparer

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

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

type Seeker

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

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

type Service

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

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

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

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

	Domain string `yaml:"domain"`
	// contains filtered or unexported fields
}

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

func Inst

func Inst() *Service

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

func (*Service) Events

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

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

func (*Service) OnFinish

func (s *Service) OnFinish()

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

func (*Service) OnInit

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

OnInit инициализирует сервис соединений

func (*Service) OnRun

func (s *Service) OnRun()

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