Re: Time delayed LR (WAS Re: logical replication restrictions)

>
> On Tue, 27 Dec 2022 at 14:59, Hayato Kuroda (Fujitsu)
> <kuroda.hayato@fujitsu.com> wrote:
> > Note that more than half of the modifications are done by Osumi-san.
>

Please find a few minor comments.
1.
+      diffms = TimestampDifferenceMilliseconds(GetCurrentTimestamp(),
+

   TimestampTzPlusMilliseconds(ts, MySubscription->minapplydelay));
 on unix, above code looks unaligned (copied from unix)

2. same with:
+      interval = DatumGetIntervalP(DirectFunctionCall3(interval_in,
+

   CStringGetDatum(val),
+

   ObjectIdGetDatum(InvalidOid),
+

   Int32GetDatum(-1)));
perhaps due to tabs?

2. comment not clear:
+      * During the time delayed replication, avoid reporting the suspended
+      * latest LSN are already flushed and written, to the publisher.

3.
+      * Call send_feedback() to prevent the publisher from exiting by
+      * timeout during the delay, when wal_receiver_status_interval is
+      * available. The WALs for this delayed transaction is neither
+      * written nor flushed yet, Thus, we don't make the latest LSN
+      * overwrite those positions of the update message for this delay.

 yet, Thus, we -->  yet, thus, we/   yet. Thus, we


4.
+      /* Adds portion time (in ms) to the previous result. */
+      ms = interval->time / INT64CONST(1000);
Is interval->time always in micro-seconds here?



Thanks
Shveta