From 461ca1744bfe84aac16f9c1e67090639aed06e2d Mon Sep 17 00:00:00 2001 From: Andrew Sisley Date: Fri, 15 Nov 2024 15:17:06 -0500 Subject: [PATCH] PR FIXUP - Fix capitalisation --- internal/db/messages.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/db/messages.go b/internal/db/messages.go index 2dcc175cfe..e980eb7d84 100644 --- a/internal/db/messages.go +++ b/internal/db/messages.go @@ -22,7 +22,7 @@ import ( ) func (db *db) handleMessages(ctx context.Context, sub *event.Subscription) { - docIdQueue := newMergeQueue() + docIDQueue := newMergeQueue() schemaRootQueue := newMergeQueue() // This is used to ensure we only trigger loadAndPublishP2PCollections and loadAndPublishReplicators @@ -57,8 +57,8 @@ func (db *db) handleMessages(ctx context.Context, sub *event.Subscription) { defer schemaRootQueue.done(evt.SchemaRoot) } else { // ensure only one merge per docID - docIdQueue.add(evt.DocID) - defer docIdQueue.done(evt.DocID) + docIDQueue.add(evt.DocID) + defer docIDQueue.done(evt.DocID) } // retry the merge process if a conflict occurs