postal

type Config struct {
	UAAClientID          string
	UAAClientSecret      string
	UAATokenValidator    *uaa.TokenValidator
	UAAHost              string
	VerifySSL            bool
	InstanceIndex        int
	WorkerCount          int
	EncryptionKey        []byte
	DBLoggingEnabled     bool
	RootPath             string
	Sender               string
	Domain               string
	QueueWaitMaxDuration int
	MaxQueueLength       int
	MaxRetries           int
	CCHost               string
}

type DeliveryJobProcessor interface {
	Process(job *gobble.Job, logger lager.Logger) error
}

type DeliveryWorker struct {
	gobble.Worker

	DeliveryJobProcessor   DeliveryJobProcessor
	V2DeliveryJobProcessor v2DeliveryJobProcessor
	// contains filtered or unexported fields
}

type DeliveryWorkerConfig struct {
	ID                     int
	UAAHost                string
	Logger                 lager.Logger
	Queue                  gobble.QueueInterface
	DBTrace                bool
	Database               db.DatabaseInterface
	CampaignJobProcessor   campaignJobProcessor
	DeliveryFailureHandler deliveryFailureHandler
	MessageStatusUpdater   messageStatusUpdater
}

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

type Worker interface {
	Work()
}

type WorkerGenerator struct {
	InstanceIndex int
	Count         int
}