Basic start/stop functionality.
This commit is contained in:
parent
d5e4d87b1c
commit
f3e6384db6
1 changed files with 8 additions and 2 deletions
|
|
@ -57,6 +57,8 @@ import org.jgrapes.core.annotation.Handler;
|
||||||
"PMD.AvoidDuplicateLiterals" })
|
"PMD.AvoidDuplicateLiterals" })
|
||||||
public class Reconciler extends Component {
|
public class Reconciler extends Component {
|
||||||
|
|
||||||
|
private static final String STATE_RUNNING = "Running";
|
||||||
|
private static final String STATE_STOPPED = "Stopped";
|
||||||
private final Configuration fmConfig;
|
private final Configuration fmConfig;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
@ -267,8 +269,12 @@ public class Reconciler extends Component {
|
||||||
"pods", channel.client());
|
"pods", channel.client());
|
||||||
var existing = K8s.get(podApi, event.metadata());
|
var existing = K8s.get(podApi, event.metadata());
|
||||||
|
|
||||||
// If deleted, delete
|
// Get state
|
||||||
if (event.type() == Type.DELETED) {
|
var state = GsonPtr.to((JsonObject) model.get("cr")).to("spec", "vm")
|
||||||
|
.getAsString("state").get();
|
||||||
|
|
||||||
|
// If deleted or stopped, delete
|
||||||
|
if (event.type() == Type.DELETED || STATE_STOPPED.equals(state)) {
|
||||||
if (existing.isPresent()) {
|
if (existing.isPresent()) {
|
||||||
K8s.delete(podApi, existing.get());
|
K8s.delete(podApi, existing.get());
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue