@@ -286,7 +286,7 @@ func (sb *shardBuffer) startBufferingLocked(ctx context.Context, kev *discovery.
286
286
msg = "Dry-run: Would have started buffering"
287
287
}
288
288
starts .Add (sb .statsKey , 1 )
289
- log .V ( 2 ). Infof ("%v for shard: %s (window: %v, size: %v, max failover duration: %v) (A failover was detected by this seen error: %v.)" ,
289
+ log .Infof ("%v for shard: %s (window: %v, size: %v, max failover duration: %v) (A failover was detected by this seen error: %v.)" ,
290
290
msg ,
291
291
topoproto .KeyspaceShardString (sb .keyspace , sb .shard ),
292
292
sb .buf .config .Window ,
@@ -562,7 +562,7 @@ func (sb *shardBuffer) stopBufferingLocked(reason stopReason, details string) {
562
562
if sb .mode == bufferModeDryRun {
563
563
msg = "Dry-run: Would have stopped buffering"
564
564
}
565
- log .V ( 2 ). Infof ("%v for shard: %s after: %.1f seconds due to: %v. Draining %d buffered requests now." ,
565
+ log .Infof ("%v for shard: %s after: %.1f seconds due to: %v. Draining %d buffered requests now." ,
566
566
msg , topoproto .KeyspaceShardString (sb .keyspace , sb .shard ), d .Seconds (), details , len (q ))
567
567
568
568
var clientEntryError error
@@ -622,7 +622,7 @@ func (sb *shardBuffer) drain(q []*entry, err error) {
622
622
wg .Wait ()
623
623
624
624
d := sb .timeNow ().Sub (start )
625
- log .V ( 2 ). Infof ("Draining finished for shard: %s Took: %v for: %d requests." , topoproto .KeyspaceShardString (sb .keyspace , sb .shard ), d , len (q ))
625
+ log .Infof ("Draining finished for shard: %s Took: %v for: %d requests." , topoproto .KeyspaceShardString (sb .keyspace , sb .shard ), d , len (q ))
626
626
requestsDrained .Add (sb .statsKey , int64 (len (q )))
627
627
628
628
// Draining is done. Change state from "draining" to "idle".
0 commit comments