manager

Jun 9, 2021

Changes in this version

type Manager

+ func (m *Manager) PushCampaignMessage(msg CampaignMessage) error

May 16, 2021

Changes in this version

+ const BaseTPL

+ const ContentTpl

+ type CampaignMessage struct

+ Campaign *models.Campaign

+ Subscriber models.Subscriber

+ func (m *CampaignMessage) AltBody() []byte

+ func (m *CampaignMessage) Body() []byte

+ func (m *CampaignMessage) Render() error

+ func (m *CampaignMessage) Subject() string

+ type Config struct

+ BatchSize int

+ Concurrency int

+ FromEmail string

+ IndividualTracking bool

+ LinkTrackURL string

+ MaxSendErrors int

+ MessageRate int

+ MessageURL string

+ OptinURL string

+ RequeueOnError bool

+ SlidingWindow bool

+ SlidingWindowDuration time.Duration

+ SlidingWindowRate int

+ UnsubHeader bool

+ UnsubURL string

+ ViewTrackURL string

+ type DataSource interface

+ CreateLink func(url string) (string, error)

+ GetCampaign func(campID int) (*models.Campaign, error)

+ NextCampaigns func(excludeIDs []int64) ([]*models.Campaign, error)

+ NextSubscribers func(campID, limit int) ([]models.Subscriber, error)

+ UpdateCampaignStatus func(campID int, status string) error

+ type Manager struct

+ func New(cfg Config, src DataSource, notifCB models.AdminNotifCallback, i *i18n.I18n, ...) *Manager

+ func (m *Manager) AddMessenger(msg messenger.Messenger) error

+ func (m *Manager) Close()

+ func (m *Manager) HasMessenger(id string) bool

+ func (m *Manager) HasRunningCampaigns() bool

+ func (m *Manager) NewCampaignMessage(c *models.Campaign, s models.Subscriber) CampaignMessage

+ func (m *Manager) PushMessage(msg Message) error

+ func (m *Manager) Run(tick time.Duration)

+ func (m *Manager) TemplateFuncs(c *models.Campaign) template.FuncMap

+ type Message struct

+ Messenger string

+ Subscriber models.Subscriber