Package org.apache.storm.container.oci
Class OciUtils
java.lang.Object
org.apache.storm.container.oci.OciUtils
-
Constructor Summary
-
Method Summary
-
Constructor Details
-
OciUtils
public OciUtils()
-
-
Method Details
-
adjustImageConfigForTopo
public static void adjustImageConfigForTopo(Map<String, Object> conf, Map<String, throws InvalidTopologyExceptionObject> topoConf, String topoId) Adjust the image config for the topology. If OCI container is not supported, remove the oci image setting from the topoConf; otherwise, set it to the default image if it's null.- Parameters:
conf
- the daemon conftopoConf
- the topology conftopoId
- the topology Id- Throws:
InvalidTopologyException
- if image config is invalid
-
validateImageInDaemonConf
Validates the image setting in the daemon conf. This will be skipped ifDaemonConfig.STORM_OCI_ALLOWED_IMAGES
not configured.- Parameters:
conf
- the daemon conf
-