Function UpdateSubscriptionLsn

pgserver/logrepl/subscription.go:126–129

(ctx *sql.Context, lsn, name string)

}

func UpdateSubscriptionLsn(ctx *sql.Context, lsn, name string) error {
	_, tx, release, err := adapter.GetCatalogTxnExecutionSnapshotWithLease(ctx, nil)
	if err != nil {
		return err
	}
	defer release()
	return UpdateSubscriptionLsnInTxn(ctx, tx, lsn, name)