Package org.apache.storm.container.oci

# Class OciUtils

java.lang.Object
org.apache.storm.container.oci.OciUtils

public class OciUtils extends Object

- ## Constructor Summary

  Constructors
  Constructor
  Description
  `OciUtils()`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `static void`
  `adjustImageConfigForTopo(Map<String,Object> conf, Map<String,Object> topoConf, String topoId)`
  Adjust the image config for the topology.
  `static void`
  `validateImageInDaemonConf(Map<String,Object> conf)`
  Validates the image setting in the daemon conf.

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- ## Constructor Details

  - ### OciUtils

    public OciUtils()

- ## Method Details

  - ### adjustImageConfigForTopo

    public static void adjustImageConfigForTopo(Map<String,Object> conf, Map<String,Object> topoConf, String topoId) throws InvalidTopologyException
    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 conf
      `topoConf` - the topology conf
      `topoId` - the topology Id
    Throws:
      `InvalidTopologyException` - if image config is invalid

  - ### validateImageInDaemonConf

    public static void validateImageInDaemonConf(Map<String,Object> conf)
    Validates the image setting in the daemon conf. This will be skipped if `DaemonConfig.STORM_OCI_ALLOWED_IMAGES` not configured.
    Parameters:
      `conf` - the daemon conf