v1

Documentation

Index

• type DeliveryJobProcessor
  • func NewDeliveryJobProcessor(config DeliveryJobProcessorConfig) DeliveryJobProcessor
  • func (p DeliveryJobProcessor) Process(job *gobble.Job, logger lager.Logger) error
• type DeliveryJobProcessorConfig
• type MessageStatusUpdater
  • func NewMessageStatusUpdater(messagesRepo MessageUpserter) MessageStatusUpdater
  • func (mu MessageStatusUpdater) Update(conn db.ConnectionInterface, messageID, messageStatus, campaignID string, ...)
• type MessageUpserter
• type TemplatesLoader
  • func NewTemplatesLoader(database db.DatabaseInterface, clientsRepo clientFinder, kindsRepo kindFinder, ...) TemplatesLoader
  • func (loader TemplatesLoader) LoadTemplates(clientID, kindID, templateID string) (common.Templates, error)

Types

type DeliveryJobProcessor

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

func NewDeliveryJobProcessor

func NewDeliveryJobProcessor(config DeliveryJobProcessorConfig) DeliveryJobProcessor

func (DeliveryJobProcessor) Process

func (p DeliveryJobProcessor) Process(job *gobble.Job, logger lager.Logger) error

type DeliveryJobProcessorConfig

type DeliveryJobProcessorConfig struct {
	DBTrace bool
	UAAHost string
	Sender  string
	Domain  string

	Packager    common.Packager
	MailClient  mailSender
	Database    db.DatabaseInterface
	TokenLoader tokenLoader
	UserLoader  userLoader

	KindsRepo              kindsFinder
	ReceiptsRepo           receiptsCreator
	UnsubscribesRepo       unsubscribesGetter
	GlobalUnsubscribesRepo globalUnsubscribesGetter
	MessageStatusUpdater   messageStatusUpdater
	DeliveryFailureHandler deliveryFailureHandler
}

type MessageStatusUpdater

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

func NewMessageStatusUpdater

func NewMessageStatusUpdater(messagesRepo MessageUpserter) MessageStatusUpdater

func (MessageStatusUpdater) Update

func (mu MessageStatusUpdater) Update(conn db.ConnectionInterface, messageID, messageStatus, campaignID string, logger lager.Logger)

type MessageUpserter

type MessageUpserter interface {
	Upsert(conn models.ConnectionInterface, message models.Message) (models.Message, error)
}

type TemplatesLoader

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

func NewTemplatesLoader

func NewTemplatesLoader(database db.DatabaseInterface, clientsRepo clientFinder, kindsRepo kindFinder, templatesRepo templateFinder) TemplatesLoader

func (TemplatesLoader) LoadTemplates

func (loader TemplatesLoader) LoadTemplates(clientID, kindID, templateID string) (common.Templates, error)