We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b3373c1 commit a5dded8Copy full SHA for a5dded8
internal/sms-gateway/modules/messages/tasks.go
@@ -53,6 +53,7 @@ func (t *HashingTask) Run(ctx context.Context) {
53
}
54
55
56
+// Enqueue adds a message ID to the processing queue to be hashed in the next batch
57
func (t *HashingTask) Enqueue(id uint64) {
58
t.mux.Lock()
59
t.queue[id] = struct{}{}
0 commit comments