processor

Documentation

Index

• Constants
• Variables
• func AddToScoreboard(section int, msgID string)
• func IsInScoreboard(section int, msgID string) bool
• func MoveToRetryQueue(msgID string)
• func ProcessMessage(msgID string)
• func ProcessRetryQueue(forceRetry bool)
• func ProcessStuckIncomingMessages()
• func ProcessStuckProcessingMessages()
• func QueueIncomingMessage(msgID string)
• func RemoveFromScoreboard(section int, msgID string)

Constants

const (
	// MaxRetries defines how many retries we can do for sending a message
	MaxRetries int = 30
)

Variables

var (
	// IncomingChannel Message with given msgID is incoming from a client
	IncomingChannel chan string
)

Functions

func AddToScoreboard

func AddToScoreboard(section int, msgID string)

AddToScoreboard will set the message ID in the section in the scoreboard

func IsInScoreboard

func IsInScoreboard(section int, msgID string) bool

IsInScoreboard will check if the given message ID in the section is present

func MoveToRetryQueue

func MoveToRetryQueue(msgID string)

MoveToRetryQueue moves a message (back) to retry queue and update retry info

func ProcessMessage

func ProcessMessage(msgID string)

ProcessMessage will process a message found in the processing queue.

• If it's a local address, it will be moved to the local mailbox
• If it's a remote address, it will be send to the remote mail server
• If things fail, it will be moved to the retry queue, where it will be moved to processed queue later

func ProcessRetryQueue

func ProcessRetryQueue(forceRetry bool)

ProcessRetryQueue will process all mails found in the retry queue or removes them when they are expired

func ProcessStuckIncomingMessages

func ProcessStuckIncomingMessages()

ProcessStuckIncomingMessages will process stuck message found in the incoming queue.

func ProcessStuckProcessingMessages

func ProcessStuckProcessingMessages()

ProcessStuckProcessingMessages will process stuck message found in the processing queue.

func QueueIncomingMessage

func QueueIncomingMessage(msgID string)

QueueIncomingMessage queues message on the uploaded channel so it can be picked up for processing by the main loop

func RemoveFromScoreboard

func RemoveFromScoreboard(section int, msgID string)

RemoveFromScoreboard will remove the message ID from the section in the scoreboard