File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
postgres-protocol/src/message Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -374,15 +374,15 @@ impl ReplicationMessage<Bytes> {
374
374
}
375
375
INTERPRETED_WAL_RECORD_TAG => {
376
376
let streaming_lsn = buf. read_u64 :: < BigEndian > ( ) ?;
377
- let wal_end = buf. read_u64 :: < BigEndian > ( ) ?;
377
+ let commit_lsn = buf. read_u64 :: < BigEndian > ( ) ?;
378
378
let next_record_lsn = match buf. read_u64 :: < BigEndian > ( ) ? {
379
379
0 => None ,
380
380
lsn => Some ( lsn) ,
381
381
} ;
382
382
383
383
ReplicationMessage :: RawInterpretedWalRecords ( RawInterpretedWalRecordsBody {
384
384
streaming_lsn,
385
- wal_end ,
385
+ commit_lsn ,
386
386
next_record_lsn,
387
387
data : buf. read_all ( ) ,
388
388
} )
@@ -970,7 +970,7 @@ impl<D> XLogDataBody<D> {
970
970
#[ derive( Debug ) ]
971
971
pub struct RawInterpretedWalRecordsBody < D > {
972
972
streaming_lsn : u64 ,
973
- wal_end : u64 ,
973
+ commit_lsn : u64 ,
974
974
next_record_lsn : Option < u64 > ,
975
975
data : D ,
976
976
}
@@ -982,8 +982,8 @@ impl<D> RawInterpretedWalRecordsBody<D> {
982
982
}
983
983
984
984
#[ inline]
985
- pub fn wal_end ( & self ) -> u64 {
986
- self . wal_end
985
+ pub fn commit_lsn ( & self ) -> u64 {
986
+ self . commit_lsn
987
987
}
988
988
989
989
#[ inline]
You can’t perform that action at this time.
0 commit comments