mailroom

Nov 6, 2018

Changes in this version

+ const HandleContactEvent

Oct 31, 2018

Changes in this version

+ const FireCampaignEventType

+ const HandleEvent

+ const SendBroadcastBatchType

+ const SendBroadcastType

Oct 29, 2018

Changes in this version

+ const StartFlowType

Oct 21, 2018

Changes in this version

type MailroomConfig

+ SMTPServer string

Oct 16, 2018

Changes in this version

+ const HandlerQueue

type Mailroom

+ RP *redis.Pool

type MailroomConfig

+ HandlerWorkers int

Oct 10, 2018

Changes in this version

+ type MailroomConfig struct

+ AttachmentDomain string

+ BatchWorkers int

+ DB string

+ DBPoolSize int

+ LibratoToken string

+ LibratoUsername string

+ LogLevel string

+ Redis string

+ SentryDSN string

+ Version string

+ func NewMailroomConfig() *MailroomConfig

Oct 2, 2018

Changes in this version

+ const BatchQueue

Sep 26, 2018

Changes in this version

type Config

+ BatchWorkers int

+ DBPoolSize int

Sep 21, 2018

Changes in this version

type Config

+ LibratoToken string

+ LibratoUsername string

Sep 7, 2018

Changes in this version

+ func AddInitFunction(initFunc InitFunction)

+ func AddTaskFunction(taskType string, taskFunc TaskFunction)

+ type Config struct

+ DB string

+ LogLevel string

+ MaxWorkers int

+ Redis string

+ SentryDSN string

+ Version string

+ func NewConfig() *Config

+ type Foreman struct

+ func NewForeman(mr *Mailroom, queue string, maxWorkers int) *Foreman

+ func (f *Foreman) Assign()

+ func (f *Foreman) Start()

+ func (f *Foreman) Stop()

+ type InitFunction func(mr *Mailroom) error

+ type Mailroom struct

+ CTX context.Context

+ Cancel context.CancelFunc

+ Config *Config

+ DB *sqlx.DB

+ Quit chan bool

+ RedisPool *redis.Pool

+ WaitGroup sync.WaitGroup

+ func NewMailroom(config *Config) *Mailroom

+ func (mr *Mailroom) Start() error

+ func (mr *Mailroom) Stop() error

+ type TaskFunction func(mr *Mailroom, task *queue.Task) error

+ type Worker struct

+ func NewWorker(foreman *Foreman, id int) *Worker

+ func (w *Worker) Start()

+ func (w *Worker) Stop()