Only providing applied LSN (processed and pushed) to PG

noctarius · Jul 9, 2023 · b2a7eff · b2a7eff
1 parent b4bf054
commit b2a7eff
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/internal/replication/context/replicationconnection.go b/internal/replication/context/replicationconnection.go
@@ -83,11 +83,11 @@ func (rc *ReplicationConnection) ReceiveMessage(deadline time.Time) (pgproto3.Ba
 }
 
 func (rc *ReplicationConnection) SendStatusUpdate() error {
-	receivedLSN, processedLSN := rc.replicationContext.positionLSNs()
+	/*receivedLSN*/ _, processedLSN := rc.replicationContext.positionLSNs()
 	if err := pglogrepl.SendStandbyStatusUpdate(context.Background(), rc.conn,
 		pglogrepl.StandbyStatusUpdate{
-			WALWritePosition: pglogrepl.LSN(receivedLSN),
-			WALFlushPosition: pglogrepl.LSN(processedLSN),
+			WALWritePosition: pglogrepl.LSN(processedLSN),
+			WALApplyPosition: pglogrepl.LSN(processedLSN),
 		},
 	); err != nil {
 		rc.logger.Fatalln("SendStandbyStatusUpdate failed:", err)