This is a helper function to validate the image. @param allowedImages the allowed image list @param imageToValidate the image to be validated @param i

Determines if a scheduling is valid and all constraints are satisfied (for use in testing). This is done in three steps. <li>Check if nodeCoLocationC

Validate topology conf. @param topoConf The topology conf.

The user should be able to see the metadata if and only if they have any of READ, WRITE, or ADMIN.

Verify the ZK ACLs are correct and optionally fix them if needed. @param conf the cluster config. @param fixUp true if we want to fix the ACLs else fa

Asserting that method is called with expected first argument. @param verifyConsumer Consumer implementation that takes ArgumentCaptor and call 'Mocki

{@inheritDoc}

Remove any object from the counter whose total count is zero (to free up memory).

Sets expire (time to live) if needed. @param expireIntervalSec time to live in seconds @return RedisStateUpdater itself

Overrides the default field delimiter.

Only output the specified fields.

Override the INimbus instance that nimbus will use.

Run with a local cluster. @deprecated use ``` try (LocalCluster cluster = new LocalCluster()) { ... } ``` @param code what to run

support parameters:<br/> $TIME - current time. use <code>withTimeFormat</code> to format.<br/> $NUM - rotation number<br/> $HOST - local host name<br/

Before nimbus is created/used call nimbusWrapper on it first and use the result instead. This is intended for internal testing only, and it here to a

Overrides the default prefix.

Run with a local cluster. @deprecated use ``` try (LocalCluster cluster = new LocalCluster.Builder().withSimulatedTime().build()) { ...

When assigning ports to worker slots start at minPort.

Set the messages to be published to a single topic. @param topic the topic to publish to @return this

Get the key used to store a WorkerToken in the credentials map. @param type the type of service to get. @return the key as a String.