mailer

Documentation

Index

• Constants
• func IsAlpha(r rune) bool
• func ProcessTheQueue(mailer *Mailer)
• type EscapeMode
• type GotStat
• type Mailer
  • func NewMailer(r *registry.Container) *Mailer
  • func (self *Mailer) AddOutbound(path queue.FileEntry)
  • func (self *Mailer) GetAddr() string
  • func (self *Mailer) GetLocation() string
  • func (self *Mailer) GetReport() *MailerReport
  • func (self *Mailer) GetSystemName() string
  • func (self *Mailer) GetUserName() string
  • func (self *Mailer) GetWork() string
  • func (self *Mailer) GetWorkOutbound() string
  • func (self *Mailer) IsReceiveName(name string) bool
  • func (self *Mailer) IsReceiving() bool
  • func (self *Mailer) IsTransmitName(name string) bool
  • func (self *Mailer) IsTransmitting() bool
  • func (self *Mailer) SetAddr(addr string)
  • func (self *Mailer) SetInboundDirectory(inb string)
  • func (self *Mailer) SetLocation(location string)
  • func (self *Mailer) SetOutboundDirectory(outb string)
  • func (self *Mailer) SetSecret(secret string)
  • func (self *Mailer) SetServerAddr(addr string)
  • func (self *Mailer) SetStationName(name string)
  • func (self *Mailer) SetTemp(work string)
  • func (self *Mailer) SetTempInbound(workInbound string)
  • func (self *Mailer) SetTempOutbound(workOutbound string)
  • func (self *Mailer) SetUserName(name string)
  • func (self *Mailer) Start() (error, *MailerReport)
  • func (self *Mailer) Wait() *MailerReport
• type MailerManager
  • func NewMailerManager(r *registry.Container) *MailerManager
  • func RestoreMailerManager(r *registry.Container) *MailerManager
  • func (self *MailerManager) GetMailerInterval() int
  • func (self *MailerManager) HandleEvent(event string)
  • func (self *MailerManager) IsAutoMailer() bool
  • func (self *MailerManager) Start()
  • func (self *MailerManager) Stop()
• type MailerReport
  • func NewMailerReport() *MailerReport
  • func (self MailerReport) Dump()
  • func (self MailerReport) GetDuration() time.Duration
  • func (self *MailerReport) GetSessionID() int64
  • func (self *MailerReport) GetSessionStart() time.Time
  • func (self *MailerReport) GetSessionStop() time.Time
  • func (self *MailerReport) GetStatus() string
  • func (self *MailerReport) SetRemoteIdent(remoteIdent string)
  • func (self *MailerReport) SetSessionID(sessionId int64)
  • func (self *MailerReport) SetSessionStart(now time.Time)
  • func (self *MailerReport) SetSessionStop(now time.Time)
  • func (self *MailerReport) SetStatus(s string)
• type ReceiveRoutineResult
  • func ReceiveRoutine(mailer *Mailer) ReceiveRoutineResult
  • func ReceiveRoutineRxAccF(mailer *Mailer) ReceiveRoutineResult
  • func ReceiveRoutineRxEOB(mailer *Mailer) ReceiveRoutineResult
  • func ReceiveRoutineRxRaceD(mailer *Mailer) ReceiveRoutineResult
  • func ReceiveRoutineRxWaitF(mailer *Mailer) ReceiveRoutineResult
  • func ReceiveRoutineRxWriteD(mailer *Mailer) ReceiveRoutineResult
• type RxState
• type TransmitRoutineResult
  • func TransmitRoutine(mailer *Mailer) TransmitRoutineResult
  • func TransmitRoutineTxGNF(mailer *Mailer) TransmitRoutineResult
  • func TransmitRoutineTxReadS(mailer *Mailer) TransmitRoutineResult
  • func TransmitRoutineTxTryR(mailer *Mailer) TransmitRoutineResult
  • func TransmitRoutineTxWLA(mailer *Mailer) TransmitRoutineResult
• type TxState

Constants

const (
	AcceptFromBegin  = 1
	AcceptFromOffset = 2
	AcceptLater      = 3
)

const MAILER_MANAGER_ID = "MailerManager"

Functions

func IsAlpha

func IsAlpha(r rune) bool

func ProcessTheQueue

func ProcessTheQueue(mailer *Mailer)

Types

type EscapeMode

type EscapeMode int

const (
	LEGACY EscapeMode = 0
	MODERN EscapeMode = 1
)

type GotStat

type GotStat struct {
	Name     string
	Size     int64
	UnixTime int64
}

type Mailer

type Mailer struct {
	ServerAddr string /* Server IPv4 or FQDN address */

	InFileCount  int
	OutFileCount int
	// contains filtered or unexported fields
}

func NewMailer

func NewMailer(r *registry.Container) *Mailer

func (*Mailer) AddOutbound

func (self *Mailer) AddOutbound(path queue.FileEntry)

func (*Mailer) GetAddr

func (self *Mailer) GetAddr() string

func (*Mailer) GetLocation

func (self *Mailer) GetLocation() string

func (*Mailer) GetReport

func (self *Mailer) GetReport() *MailerReport

func (*Mailer) GetSystemName

func (self *Mailer) GetSystemName() string

func (*Mailer) GetUserName

func (self *Mailer) GetUserName() string

func (*Mailer) GetWork

func (self *Mailer) GetWork() string

func (*Mailer) GetWorkOutbound

func (self *Mailer) GetWorkOutbound() string

func (*Mailer) IsReceiveName

func (self *Mailer) IsReceiveName(name string) bool

func (*Mailer) IsReceiving

func (self *Mailer) IsReceiving() bool

func (*Mailer) IsTransmitName

func (self *Mailer) IsTransmitName(name string) bool

func (*Mailer) IsTransmitting

func (self *Mailer) IsTransmitting() bool

func (*Mailer) SetAddr

func (self *Mailer) SetAddr(addr string)

func (*Mailer) SetInboundDirectory

func (self *Mailer) SetInboundDirectory(inb string)

func (*Mailer) SetLocation

func (self *Mailer) SetLocation(location string)

func (*Mailer) SetOutboundDirectory

func (self *Mailer) SetOutboundDirectory(outb string)

func (*Mailer) SetSecret

func (self *Mailer) SetSecret(secret string)

func (*Mailer) SetServerAddr

func (self *Mailer) SetServerAddr(addr string)

func (*Mailer) SetStationName

func (self *Mailer) SetStationName(name string)

func (*Mailer) SetTemp

func (self *Mailer) SetTemp(work string)

func (*Mailer) SetTempInbound

func (self *Mailer) SetTempInbound(workInbound string)

func (*Mailer) SetTempOutbound

func (self *Mailer) SetTempOutbound(workOutbound string)

func (*Mailer) SetUserName

func (self *Mailer) SetUserName(name string)

func (*Mailer) Start

func (self *Mailer) Start() (error, *MailerReport)

func (*Mailer) Wait

func (self *Mailer) Wait() *MailerReport

type MailerManager

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

func NewMailerManager

func NewMailerManager(r *registry.Container) *MailerManager

func RestoreMailerManager

func RestoreMailerManager(r *registry.Container) *MailerManager

func (*MailerManager) GetMailerInterval

func (self *MailerManager) GetMailerInterval() int

func (*MailerManager) HandleEvent

func (self *MailerManager) HandleEvent(event string)

func (*MailerManager) IsAutoMailer

func (self *MailerManager) IsAutoMailer() bool

func (*MailerManager) Start

func (self *MailerManager) Start()

func (*MailerManager) Stop

func (self *MailerManager) Stop()

type MailerReport

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

func NewMailerReport

func NewMailerReport() *MailerReport

func (MailerReport) Dump

func (self MailerReport) Dump()

func (MailerReport) GetDuration

func (self MailerReport) GetDuration() time.Duration

func (*MailerReport) GetSessionID

func (self *MailerReport) GetSessionID() int64

func (*MailerReport) GetSessionStart

func (self *MailerReport) GetSessionStart() time.Time

func (*MailerReport) GetSessionStop

func (self *MailerReport) GetSessionStop() time.Time

func (*MailerReport) GetStatus

func (self *MailerReport) GetStatus() string

func (*MailerReport) SetRemoteIdent

func (self *MailerReport) SetRemoteIdent(remoteIdent string)

func (*MailerReport) SetSessionID

func (self *MailerReport) SetSessionID(sessionId int64)

func (*MailerReport) SetSessionStart

func (self *MailerReport) SetSessionStart(now time.Time)

func (*MailerReport) SetSessionStop

func (self *MailerReport) SetSessionStop(now time.Time)

func (*MailerReport) SetStatus

func (self *MailerReport) SetStatus(s string)

type ReceiveRoutineResult

type ReceiveRoutineResult string

const (
	RxOk       ReceiveRoutineResult = "RxOk"
	RxFailure  ReceiveRoutineResult = "RxFailure"
	RxContinue ReceiveRoutineResult = "RxContinue"
)

func ReceiveRoutine

func ReceiveRoutine(mailer *Mailer) ReceiveRoutineResult

func ReceiveRoutineRxAccF

func ReceiveRoutineRxAccF(mailer *Mailer) ReceiveRoutineResult

func ReceiveRoutineRxEOB

func ReceiveRoutineRxEOB(mailer *Mailer) ReceiveRoutineResult

func ReceiveRoutineRxRaceD

func ReceiveRoutineRxRaceD(mailer *Mailer) ReceiveRoutineResult

func ReceiveRoutineRxWaitF

func ReceiveRoutineRxWaitF(mailer *Mailer) ReceiveRoutineResult

func ReceiveRoutineRxWriteD

func ReceiveRoutineRxWriteD(mailer *Mailer) ReceiveRoutineResult

type RxState

type RxState string

const (
	RxWaitF  RxState = "RxWaitF"
	RxAccF   RxState = "RxAccF"
	RxRaceD  RxState = "RxRaceD"
	RxWriteD RxState = "RxWriteD"
	RxEOB    RxState = "RxEOB"
	RxDone   RxState = "RxDone"
)

type TransmitRoutineResult

type TransmitRoutineResult string

const (
	TxOk       TransmitRoutineResult = "TxOk"
	TxFailure  TransmitRoutineResult = "TxFailure"
	TxContinue TransmitRoutineResult = "TxContinue"
)

func TransmitRoutine

func TransmitRoutine(mailer *Mailer) TransmitRoutineResult

func TransmitRoutineTxGNF

func TransmitRoutineTxGNF(mailer *Mailer) TransmitRoutineResult

func TransmitRoutineTxReadS

func TransmitRoutineTxReadS(mailer *Mailer) TransmitRoutineResult

func TransmitRoutineTxTryR

func TransmitRoutineTxTryR(mailer *Mailer) TransmitRoutineResult

func TransmitRoutineTxWLA

func TransmitRoutineTxWLA(mailer *Mailer) TransmitRoutineResult

type TxState

type TxState string

const (
	TxGNF   TxState = "TxGNF"
	TxTryR  TxState = "TxTryR"
	TxReadS TxState = "TxReadS"
	TxWLA   TxState = "TxWLA"
	TxDone  TxState = "TxDone"
)