chore: decrease send stand by status update ticker time

Trendyol · Sep 11, 2024 · 4becbb1 · 4becbb1
1 parent 115f690
commit 4becbb1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pq/replication/stream.go b/pq/replication/stream.go
@@ -113,7 +113,7 @@ func (s *stream) sink(ctx context.Context) {
 	logger.Info("postgres message sink started")
 
 	for {
-		msgCtx, cancel := context.WithDeadline(context.Background(), time.Now().Add(time.Second*5))
+		msgCtx, cancel := context.WithDeadline(context.Background(), time.Now().Add(time.Millisecond*500))
 		rawMsg, err := s.conn.ReceiveMessage(msgCtx)
 		cancel()
 		if err != nil {