worker

Documentation

Index

• type EmailGateway
• type EmailGatewayError
  • func (this *EmailGatewayError) Error() string
• type EmailSender
  • func (this *EmailSender) Start()
  • func (this *EmailSender) Stop()
• type LeaseExtender
  • func (this *LeaseExtender) Start()
  • func (this *LeaseExtender) Stop()
• type MandrillGateway
  • func (this *MandrillGateway) Description() string
  • func (this *MandrillGateway) Send(message RenderedTemplates) *EmailGatewayError
• type RenderedTemplates
  • func RenderTemplates(templates recipientsRepository.Templates, recipient map[string]interface{}) (result RenderedTemplates, err error)
• type SmtpEmailGateway
  • func (this *SmtpEmailGateway) Description() string
  • func (this *SmtpEmailGateway) Send(message RenderedTemplates) *EmailGatewayError
• type WorkerError
  • func (this *WorkerError) Error() string

Types

type EmailGateway

type EmailGateway interface {
	Send(message RenderedTemplates) *EmailGatewayError
	Description() string
}

type EmailGatewayError

type EmailGatewayError struct {
	Cause             error
	IsConnectionError bool
}

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

type SmtpEmailGateway struct {
	SmtpUrl  string
	SmtpAuth smtp.Auth
}

func (*SmtpEmailGateway) Description

func (this *SmtpEmailGateway) Description() string

func (*SmtpEmailGateway) Send

func (this *SmtpEmailGateway) Send(message RenderedTemplates) *EmailGatewayError

type WorkerError

type WorkerError struct {
	Message string
	Cause   error
}

func (*WorkerError) Error

func (this *WorkerError) Error() string