connector

Documentation

Index

• type Config
• type ConnectionEvent
• type Connector
• type MailServer
• type MailServerStatus
• type MailServers
  • func NewMailServers() *MailServers
  • func (ms *MailServers) Get(hostname string) (*MailServer, bool)
  • func (ms *MailServers) Set(hostname string, s *MailServer)
• type MxServer
• type Preparer
• type Seeker
• type Service
  • func Inst() *Service
  • func (s *Service) Event(ev *common.SendEvent) bool
  • func (s *Service) OnFinish()
  • func (s *Service) OnInit(event *common.ApplicationEvent)
  • func (s *Service) OnRun()
  • func (s *Service) Reconfigure(event *common.ApplicationEvent)

Types

type Config

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

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

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

	// MXHostname hostname, на котором будет слушаться 25 порт
	MXHostname string `yaml:"mxHostname"`
	// contains filtered or unexported fields
}

type ConnectionEvent

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

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

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 MailServers

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

func NewMailServers

func NewMailServers() *MailServers

func (*MailServers) Get

func (ms *MailServers) Get(hostname string) (*MailServer, bool)

func (*MailServers) Set

func (ms *MailServers) Set(hostname string, s *MailServer)

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"`
	// contains filtered or unexported fields
}

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

func Inst

func Inst() *Service

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

func (*Service) Event

func (s *Service) Event(ev *common.SendEvent) bool

Event send event

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 запускает горутины

func (*Service) Reconfigure

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