Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EmailGateway ¶
type EmailGateway interface { Send(message RenderedTemplates) *EmailGatewayError Description() string }
type EmailGatewayError ¶
func (*EmailGatewayError) Error ¶
func (this *EmailGatewayError) Error() string
type EmailSender ¶
type EmailSender struct { Gateway EmailGateway Repository recipientsRepository.Repository // contains filtered or unexported fields }
func (*EmailSender) Start ¶
func (this *EmailSender) Start()
func (*EmailSender) Stop ¶
func (this *EmailSender) Stop()
type LeaseExtender ¶
type LeaseExtender struct { Repository recipientsRepository.LeaseExtensionRepository JobId string Receiver string ExtensionInterval time.Duration // contains filtered or unexported fields }
func (*LeaseExtender) Start ¶
func (this *LeaseExtender) Start()
func (*LeaseExtender) Stop ¶
func (this *LeaseExtender) Stop()
TODO: rename to StopAndRevoke and if stopped revoke lease (?)
type MandrillGateway ¶
type MandrillGateway struct {
ApiKey string
}
func (*MandrillGateway) Description ¶
func (this *MandrillGateway) Description() string
func (*MandrillGateway) Send ¶
func (this *MandrillGateway) Send(message RenderedTemplates) *EmailGatewayError
type RenderedTemplates ¶
type RenderedTemplates struct { Subject string Body string ReceiverEmail string ReceiverName string SenderEmail string SenderName string ReplyToEmail string }
func RenderTemplates ¶
func RenderTemplates(templates recipientsRepository.Templates, recipient map[string]interface{}) (result RenderedTemplates, err error)
type SmtpEmailGateway ¶
func (*SmtpEmailGateway) Description ¶
func (this *SmtpEmailGateway) Description() string
func (*SmtpEmailGateway) Send ¶
func (this *SmtpEmailGateway) Send(message RenderedTemplates) *EmailGatewayError
type WorkerError ¶
func (*WorkerError) Error ¶
func (this *WorkerError) Error() string
Click to show internal directories.
Click to hide internal directories.