Implement kubernetes-additional-manifests

Allows to add extra manifests which should be created when the proxy
is started. The created resources are deleted when the proxy is deleted.

Author: LEDfan

src/main/java/eu/openanalytics/containerproxy/backend/kubernetes/KubernetesBackend.java

@@ -20,6 +20,9 @@
  */
 package eu.openanalytics.containerproxy.backend.kubernetes;
 
+import java.io.ByteArrayInputStream;
+import java.io.File;
+import java.io.FileWriter;
 import java.io.IOException;
 import java.io.OutputStream;
 import java.net.URI;
@@ -36,6 +39,7 @@
 import java.util.stream.Collectors;
 
 import javax.inject.Inject;
+import javax.json.JsonValue;
 
 import org.apache.commons.io.IOUtils;
 
@@ -52,6 +56,7 @@
 import io.fabric8.kubernetes.api.model.ContainerPortBuilder;
 import io.fabric8.kubernetes.api.model.EnvVar;
 import io.fabric8.kubernetes.api.model.EnvVarSourceBuilder;
+import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.fabric8.kubernetes.api.model.LocalObjectReference;
 import io.fabric8.kubernetes.api.model.Pod;
 import io.fabric8.kubernetes.api.model.PodBuilder;
@@ -134,6 +139,16 @@ protected Container startContainer(ContainerSpec spec, Proxy proxy) throws Excep
 
 		String kubeNamespace = getProperty(PROPERTY_NAMESPACE, DEFAULT_NAMESPACE);
 		String apiVersion = getProperty(PROPERTY_API_VERSION, DEFAULT_API_VERSION);
+
+		// create additional manifests
+		for (String manifest : proxy.getSpec().getKubernetesAdditionalManifests()) {
+			List<HasMetadata> objects = kubeClient.load(new ByteArrayInputStream(manifest.getBytes())).get();
+			for (HasMetadata object : objects) {
+				if (kubeClient.resource(object).fromServer().get() == null) {
+					kubeClient.resource(object).createOrReplace();
+				}
+			}
+		}
 
 		String[] volumeStrings = Optional.ofNullable(spec.getVolumes()).orElse(new String[] {});
 		List<Volume> volumes = new ArrayList<>();
@@ -287,6 +302,7 @@ protected Container startContainer(ContainerSpec spec, Proxy proxy) throws Excep
 			proxy.getTargets().put(mapping, target);
 		}
 
+		
 		return container;
 	}
 
@@ -334,6 +350,14 @@ protected void doStopProxy(Proxy proxy) throws Exception {
 			if (pod != null) kubeClient.pods().inNamespace(kubeNamespace).delete(pod);
 			Service service = Service.class.cast(container.getParameters().get(PARAM_SERVICE));
 			if (service != null) kubeClient.services().inNamespace(kubeNamespace).delete(service);
+
+			// delete additional manifests
+			for (String manifest : proxy.getSpec().getKubernetesAdditionalManifests()) {
+				List<HasMetadata> objects = kubeClient.load(new ByteArrayInputStream(manifest.getBytes())).get();
+				for (HasMetadata object : objects) {
+					kubeClient.resource(object).delete();
+				}
+			}
 		}
 	}
 

src/main/java/eu/openanalytics/containerproxy/model/spec/ProxySpec.java

@@ -25,6 +25,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 import javax.json.JsonPatch;
 import javax.json.JsonValue;
@@ -50,6 +51,7 @@ public class ProxySpec {
 	private Map<String, String> settings = new HashMap<>();
 
 	private JsonPatch kubernetesPodPatches;
+	private List<String> kubernetesAdditionalManifests = new ArrayList<>();
 
 	public ProxySpec() {
 		settings = new HashMap<>();
@@ -154,6 +156,14 @@ public void setKubernetesPodPatches(String kubernetesPodPatches) throws JsonPars
 	private void setKubernetesPodPatches(JsonPatch kubernetesPodPatches) {
 		this.kubernetesPodPatches = kubernetesPodPatches;
 	}
+
+	public void setKubernetesAdditionalManifests(List<String> manifests) {
+		this.kubernetesAdditionalManifests = manifests;
+	}
+
+	public List<String> getKubernetesAdditionalManifests() {
+		return kubernetesAdditionalManifests;
+	}
 
 	public void copy(ProxySpec target) {
 		target.setId(id);
@@ -195,6 +205,10 @@ public void copy(ProxySpec target) {
 			target.setKubernetesPodPatches(kubernetesPodPatches);
 		}
 
+		if (kubernetesAdditionalManifests != null) {
+			target.setKubernetesAdditionalManifests(kubernetesAdditionalManifests.stream().collect(Collectors.toList()));
+		}
+		
 	}
 
 }