backend

Documentation

Index

• Constants
• type BackendCommandProcessor
  • func (s *BackendCommandProcessor) IsValidCommand(command string) bool
• type DbStoreStorageBackend
  • func (backend *DbStoreStorageBackend) IsStarted() bool
  • func (backend *DbStoreStorageBackend) OnSubmitQueue(message *smtp.SmtpServerChannelMessage)
  • func (backend *DbStoreStorageBackend) Start() error
• type FsStoreStorageBackend
  • func (backend *FsStoreStorageBackend) IsStarted() bool
  • func (backend *FsStoreStorageBackend) OnSubmitQueue(message *smtp.SmtpServerChannelMessage)
  • func (backend *FsStoreStorageBackend) Start() error
• type InMemoryStorageConnector
  • func (m *InMemoryStorageConnector) PerformSendReceive(message common.StorageMessage) (common.StorageMessage, error)
• type MailStoreBackend
  • func NewMailStoreBackend(config *common.ApplicationConfig) *MailStoreBackend
  • func (backend *MailStoreBackend) GetStorageConnector() common.StorageConnector
  • func (backend *MailStoreBackend) InitSmtpMessageChannelListener(channel chan smtp.SmtpServerChannelMessage)
  • func (backend *MailStoreBackend) Start() error
• type MailStoreStorageProvider
• type Mailbox
• type MemStoreStorageBackend
  • func (s *MemStoreStorageBackend) IsStarted() bool
  • func (s *MemStoreStorageBackend) Mailboxes() []Mailbox
  • func (s *MemStoreStorageBackend) Start() error
  • func (s *MemStoreStorageBackend) Store(message *common.MailMessage) error
• type QueueWorker
  • func NewQueueWorker(backend *MailStoreBackend) *QueueWorker
  • func (w *QueueWorker) Start()
  • func (w *QueueWorker) StopWorker()

Constants

const (
	MEMSTORE = iota
	FILESTORE
	DBSTORE
)

Types

type BackendCommandProcessor

type BackendCommandProcessor struct{}

func (*BackendCommandProcessor) IsValidCommand

func (s *BackendCommandProcessor) IsValidCommand(command string) bool

type DbStoreStorageBackend

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

func (*DbStoreStorageBackend) IsStarted

func (backend *DbStoreStorageBackend) IsStarted() bool

func (*DbStoreStorageBackend) OnSubmitQueue

func (backend *DbStoreStorageBackend) OnSubmitQueue(message *smtp.SmtpServerChannelMessage)

func (*DbStoreStorageBackend) Start

func (backend *DbStoreStorageBackend) Start() error

type FsStoreStorageBackend

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

func (*FsStoreStorageBackend) IsStarted

func (backend *FsStoreStorageBackend) IsStarted() bool

func (*FsStoreStorageBackend) OnSubmitQueue

func (backend *FsStoreStorageBackend) OnSubmitQueue(message *smtp.SmtpServerChannelMessage)

func (*FsStoreStorageBackend) Start

func (backend *FsStoreStorageBackend) Start() error

type InMemoryStorageConnector

type InMemoryStorageConnector struct {
	MailStoreBackend
}

func (*InMemoryStorageConnector) PerformSendReceive

func (m *InMemoryStorageConnector) PerformSendReceive(message common.StorageMessage) (common.StorageMessage, error)

type MailStoreBackend

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

func NewMailStoreBackend

func NewMailStoreBackend(config *common.ApplicationConfig) *MailStoreBackend

func (*MailStoreBackend) GetStorageConnector

func (backend *MailStoreBackend) GetStorageConnector() common.StorageConnector

func (*MailStoreBackend) InitSmtpMessageChannelListener

func (backend *MailStoreBackend) InitSmtpMessageChannelListener(channel chan smtp.SmtpServerChannelMessage)

func (*MailStoreBackend) Start

func (backend *MailStoreBackend) Start() error

type MailStoreStorageProvider

type MailStoreStorageProvider interface {
	Start() error
	IsStarted() bool
	Store(message *common.MailMessage) error
	Mailboxes() []Mailbox
}

type Mailbox

type Mailbox interface {
	Name() string
}

type MemStoreStorageBackend

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

func (*MemStoreStorageBackend) IsStarted

func (s *MemStoreStorageBackend) IsStarted() bool

func (*MemStoreStorageBackend) Mailboxes

func (s *MemStoreStorageBackend) Mailboxes() []Mailbox

func (*MemStoreStorageBackend) Start

func (s *MemStoreStorageBackend) Start() error

func (*MemStoreStorageBackend) Store

func (s *MemStoreStorageBackend) Store(message *common.MailMessage) error

type QueueWorker

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

func NewQueueWorker

func NewQueueWorker(backend *MailStoreBackend) *QueueWorker

func (*QueueWorker) Start

func (w *QueueWorker) Start()

func (*QueueWorker) StopWorker

func (w *QueueWorker) StopWorker()

Stop signals the worker to stop listening for work requests.