mnl/VM-Operator
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 4 Wiki Activity Actions

Prevent unindented reboots.

Browse source
This commit is contained in:
Michael Lipp 2023-08-11 12:49:48 +02:00
parent 3c5b7334a8
commit 6972225e26
1 changed files with 13 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

15
org.jdrupes.vmoperator.manager/src/org/jdrupes/vmoperator/manager/StsReconciler.java
View file

@ -29,6 +29,7 @@ import io.kubernetes.client.util.generic.options.PatchOptions;
import java.io.IOException; import java.io.IOException;
import java.io.StringWriter; import java.io.StringWriter;
import java.util.Map; import java.util.Map;
import java.util.logging.Logger;
import org.jdrupes.vmoperator.manager.VmDefChanged.Type; import org.jdrupes.vmoperator.manager.VmDefChanged.Type;
/** /**
@ -37,6 +38,7 @@ import org.jdrupes.vmoperator.manager.VmDefChanged.Type;
@SuppressWarnings("PMD.DataflowAnomalyAnalysis") @SuppressWarnings("PMD.DataflowAnomalyAnalysis")
/* default */ class StsReconciler { /* default */ class StsReconciler {
protected final Logger logger = Logger.getLogger(getClass().getName());
private final Configuration fmConfig; private final Configuration fmConfig;
/** /**
@ -61,11 +63,10 @@ import org.jdrupes.vmoperator.manager.VmDefChanged.Type;
public void reconcile(VmDefChanged event, Map<String, Object> model, public void reconcile(VmDefChanged event, Map<String, Object> model,
VmChannel channel) VmChannel channel)
throws IOException, TemplateException, ApiException { throws IOException, TemplateException, ApiException {
// Check if exists
DynamicKubernetesApi stsApi = new DynamicKubernetesApi("apps", "v1", DynamicKubernetesApi stsApi = new DynamicKubernetesApi("apps", "v1",
"statefulsets", channel.client()); "statefulsets", channel.client());
// var existing = K8s.get(stsApi, event.object().getMetadata());
// Maybe delete
if (event.type() == Type.DELETED) { if (event.type() == Type.DELETED) {
var meta = GsonPtr.to((JsonObject) model.get("cr")).to("metadata"); var meta = GsonPtr.to((JsonObject) model.get("cr")).to("metadata");
PatchOptions opts = new PatchOptions(); PatchOptions opts = new PatchOptions();
@ -80,6 +81,16 @@ import org.jdrupes.vmoperator.manager.VmDefChanged.Type;
return; return;
} }
// Never change existing if replicas is greater 0 (would cause
// update and thus VM restart). Apply will happen when replicas
// changes from 0 to 1, i.e. on next powerdown/powerup.
var metadata = event.object().getMetadata();
var existing = K8s.get(stsApi, metadata);
if (existing.isPresent() && GsonPtr.to(existing.get().getRaw())
.to("spec").getAsInt("replicas").orElse(1) > 0) {
return;
}
// Combine template and data and parse result // Combine template and data and parse result
var fmTemplate = fmConfig.getTemplate("runnerSts.ftl.yaml"); var fmTemplate = fmConfig.getTemplate("runnerSts.ftl.yaml");
StringWriter out = new StringWriter(); StringWriter out = new StringWriter();