@@ -70,8 +70,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_Create() {
7070 LatestRequestID : "" ,
7171 Version : 1 ,
7272 }, got )
73-
74- s .log .Logf ("Create passed: created queue %s" , name )
7573}
7674
7775// TestQueueStore_CreateWithFields verifies caller-supplied initial field values are persisted.
@@ -90,8 +88,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_CreateWithFields() {
9088 got , err := s .queueStore .Get (s .ctx , name )
9189 require .NoError (t , err )
9290 assert .Equal (t , toCreate , got )
93-
94- s .log .Logf ("CreateWithFields passed: persisted fields for queue %s" , name )
9591}
9692
9793// TestQueueStore_CreateAlreadyExists verifies a duplicate Create returns ErrAlreadyExists.
@@ -113,8 +109,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_CreateAlreadyExists() {
113109 got , err := s .queueStore .Get (s .ctx , name )
114110 require .NoError (t , err )
115111 assert .Equal (t , first , got )
116-
117- s .log .Logf ("CreateAlreadyExists passed: queue %s" , name )
118112}
119113
120114// TestQueueStore_GetNotFound verifies Get returns ErrNotFound for a missing queue.
@@ -123,8 +117,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_GetNotFound() {
123117
124118 _ , err := s .queueStore .Get (s .ctx , "contract/does-not-exist" )
125119 assert .True (t , storage .IsNotFound (err ))
126-
127- s .log .Logf ("GetNotFound passed" )
128120}
129121
130122// TestQueueStore_UpdateCAS verifies a conditional update persists all mutable fields and rejects stale versions.
@@ -150,8 +142,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_UpdateCAS() {
150142
151143 err = s .queueStore .Update (s .ctx , updated , 1 , 2 )
152144 assert .ErrorIs (t , err , storage .ErrVersionMismatch )
153-
154- s .log .Logf ("UpdateCAS passed: queue %s" , name )
155145}
156146
157147// TestQueueStore_UpdateNotFoundIsVersionMismatch verifies Update on a missing row returns ErrVersionMismatch.
@@ -160,8 +150,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_UpdateNotFoundIsVersionMismatch
160150
161151 err := s .queueStore .Update (s .ctx , entity.Queue {Name : "contract/missing" }, 1 , 2 )
162152 assert .ErrorIs (t , err , storage .ErrVersionMismatch )
163-
164- s .log .Logf ("UpdateNotFoundIsVersionMismatch passed" )
165153}
166154
167155// TestQueueStore_UpdateSequentialCAS verifies successive conditional updates advance version monotonically.
@@ -182,8 +170,6 @@ func (s *QueueStoreContractSuite) TestQueueStore_UpdateSequentialCAS() {
182170 assert .Equal (t , "request/contract/sequential-cas/10" , got .LatestRequestID )
183171 assert .Equal (t , int32 (1 ), got .InFlightCount )
184172 assert .Equal (t , int32 (3 ), got .Version )
185-
186- s .log .Logf ("UpdateSequentialCAS passed: queue %s" , name )
187173}
188174
189175// BuildStoreContractSuite defines contract tests for storage.BuildStore.
@@ -392,6 +378,4 @@ func (s *QueueStoreContractSuite) TestQueueStore_QueueIsolation() {
392378 gotB , err := s .queueStore .Get (s .ctx , nameB )
393379 require .NoError (t , err )
394380 assert .Equal (t , baseline , gotB )
395-
396- s .log .Logf ("QueueIsolation passed: queues %s and %s" , nameA , nameB )
397381}
0 commit comments