Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ErrQueueing = errors.New("problem with persistent queue")
Functions ¶
func FetchFailedMsgs ¶
FetchFailedMsgs fetches failed messages from a persistent queue identified by key so they can be resent. The function returns the list of failed messages.
The function assumes the database and the key are valid. If the key doesn't exist, it will be created.
If any of the operations fail, the function will log an error and return an empty list.
func StoreFailedMsgs ¶
StoreFailedMsgs stores a message in a persistent queue identified by key. The message is appended to any existing messages in the queue, and the queue is stored in the database using the given key.
The function assumes the database and the key are valid. If the key doesn't exist, it will be created.
If any of the operations fail, the function returns an error.
Types ¶
This section is empty.
Source Files