queue

Documentation

Index

• Constants
• type FileEntry
  • func NewFileEntry() *FileEntry
  • func (self *FileEntry) SetAbsolutePath(absolutePath string)
  • func (self *FileEntry) SetName(name string)
  • func (self *FileEntry) SetType(nodeType FileEntryType)
• type FileEntryType
• type MailerInbound
  • func (self *MailerInbound) Scan() ([]FileEntry, error)
• type MailerOutbound
  • func NewMailerOutbound(r *registry.Container) *MailerOutbound
  • func (self *MailerOutbound) GetItems() ([]FileEntry, error)
  • func (self *MailerOutbound) TransmitFile(filename string)
• type QueueManager
  • func NewQueueManager(r *registry.Container) *QueueManager
  • func RestoreQueueManager(r *registry.Container) *QueueManager
  • func (self *QueueManager) GetMailerInbound() *MailerInbound
  • func (self *QueueManager) GetMailerOutbound() *MailerOutbound

Constants

const QUEUE_MANAGER_ID = "QueueManager"

Types

type FileEntry

type FileEntry struct {
	Type         FileEntryType
	AbsolutePath string
	Name         string
}

func NewFileEntry

func NewFileEntry() *FileEntry

func (*FileEntry) SetAbsolutePath

func (self *FileEntry) SetAbsolutePath(absolutePath string)

func (*FileEntry) SetName

func (self *FileEntry) SetName(name string)

func (*FileEntry) SetType

func (self *FileEntry) SetType(nodeType FileEntryType)

type FileEntryType

type FileEntryType int

const (
	TypeUnknown FileEntryType = 0
	TypeNetmail FileEntryType = 1
	TypeARCmail FileEntryType = 2
	TypeTICmail FileEntryType = 3
)

type MailerInbound

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

func (*MailerInbound) Scan

func (self *MailerInbound) Scan() ([]FileEntry, error)

type MailerOutbound

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

func NewMailerOutbound

func NewMailerOutbound(r *registry.Container) *MailerOutbound

func (*MailerOutbound) GetItems

func (self *MailerOutbound) GetItems() ([]FileEntry, error)

func (*MailerOutbound) TransmitFile

func (self *MailerOutbound) TransmitFile(filename string)

type QueueManager

type QueueManager struct {
	registry.Service
	// contains filtered or unexported fields
}

func NewQueueManager

func NewQueueManager(r *registry.Container) *QueueManager

func RestoreQueueManager

func RestoreQueueManager(r *registry.Container) *QueueManager

func (*QueueManager) GetMailerInbound

func (self *QueueManager) GetMailerInbound() *MailerInbound

func (*QueueManager) GetMailerOutbound

func (self *QueueManager) GetMailerOutbound() *MailerOutbound