diff --git a/libs/pageserver_api/src/models.rs b/libs/pageserver_api/src/models.rs index 76f0e8c0e0..80026e13f0 100644 --- a/libs/pageserver_api/src/models.rs +++ b/libs/pageserver_api/src/models.rs @@ -923,7 +923,7 @@ impl PagestreamFeMessage { match self { Self::Exists(req) => { - bytes.put_u8(0); + bytes.put_u8(10); bytes.put_u64(req.horizon.0); bytes.put_u64(req.lsn.0); bytes.put_u32(req.rel.spcnode); @@ -933,7 +933,7 @@ impl PagestreamFeMessage { } Self::Nblocks(req) => { - bytes.put_u8(1); + bytes.put_u8(11); bytes.put_u64(req.horizon.0); bytes.put_u64(req.lsn.0); bytes.put_u32(req.rel.spcnode); @@ -943,7 +943,7 @@ impl PagestreamFeMessage { } Self::GetPage(req) => { - bytes.put_u8(2); + bytes.put_u8(12); bytes.put_u64(req.horizon.0); bytes.put_u64(req.lsn.0); bytes.put_u32(req.rel.spcnode); @@ -954,14 +954,14 @@ impl PagestreamFeMessage { } Self::DbSize(req) => { - bytes.put_u8(3); + bytes.put_u8(13); bytes.put_u64(req.horizon.0); bytes.put_u64(req.lsn.0); bytes.put_u32(req.dbnode); } Self::GetSlruSegment(req) => { - bytes.put_u8(4); + bytes.put_u8(14); bytes.put_u64(req.horizon.0); bytes.put_u64(req.lsn.0); bytes.put_u8(req.kind);