postmanq: github.com/actionpay/postmanq/connector Index | Files

package connector

import "github.com/actionpay/postmanq/connector"

Index

Package Files

connector.go preparer.go seeker.go server.go service.go

type Config Uses

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

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

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

type ConnectionEvent Uses

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

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

type Connector Uses

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

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

type MailServer Uses

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

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

type MailServerStatus Uses

type MailServerStatus int

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

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

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

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

type MxServer Uses

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

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

type Preparer Uses

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

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

type Seeker Uses

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

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

type Service Uses

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

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

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

func Inst Uses

func Inst() *Service

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

func (*Service) Events Uses

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

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

func (*Service) OnFinish Uses

func (s *Service) OnFinish()

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

func (*Service) OnInit Uses

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

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

func (*Service) OnRun Uses

func (s *Service) OnRun()

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

Package connector imports 14 packages (graph). Updated 2017-10-21. Refresh now. Tools for package owners.