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 ¶
AddToScoreboard will set the message ID in the section in the scoreboard
func IsInScoreboard ¶
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 ¶
RemoveFromScoreboard will remove the message ID from the section in the scoreboard
Types ¶
This section is empty.