EntityUserOperator extends AbstractModel { @Override protected List<EnvVar> getEnvVars() { List<EnvVar> varList = new ArrayList<>(); varList.add(buildEnvVar(ENV_VAR_ZOOKEEPER_CONNECT, zookeeperConnect)); varList.add(buildEnvVar(ENV_VAR_KAFKA_BOOTSTRAP_SERVERS, kafkaBootstrapServers)); varList.add(buildEnvVar(ENV_VAR_WATCHED_NAMESPACE, watchedNamespace)); varList.add(buildEnvVar(ENV_VAR_RESOURCE_LABELS, resourceLabels)); varList.add(buildEnvVar(ENV_VAR_FULL_RECONCILIATION_INTERVAL_MS, Long.toString(reconciliationIntervalMs))); varList.add(buildEnvVar(ENV_VAR_ZOOKEEPER_SESSION_TIMEOUT_MS, Long.toString(zookeeperSessionTimeoutMs))); varList.add(buildEnvVar(ENV_VAR_CLIENTS_CA_KEY_SECRET_NAME, KafkaCluster.clientsCaKeySecretName(cluster))); varList.add(buildEnvVar(ENV_VAR_CLIENTS_CA_CERT_SECRET_NAME, KafkaCluster.clientsCaCertSecretName(cluster))); varList.add(buildEnvVar(ENV_VAR_CLIENTS_CA_NAMESPACE, namespace)); varList.add(buildEnvVar(ENV_VAR_CLIENTS_CA_VALIDITY, Integer.toString(clientsCaValidityDays))); varList.add(buildEnvVar(ENV_VAR_CLIENTS_CA_RENEWAL, Integer.toString(clientsCaRenewalDays))); varList.add(buildEnvVar(ENV_VAR_CLUSTER_CA_CERT_SECRET_NAME, KafkaCluster.clusterCaCertSecretName(cluster))); varList.add(buildEnvVar(ENV_VAR_EO_KEY_SECRET_NAME, EntityOperator.secretName(cluster))); varList.add(buildEnvVar(ENV_VAR_STRIMZI_GC_LOG_ENABLED, String.valueOf(gcLoggingEnabled))); EntityOperator.javaOptions(varList, getJvmOptions(), javaSystemProperties); varList.addAll(getRequiredEnvVars()); addContainerEnvsToExistingEnvs(varList, templateContainerEnvVars); return varList; } protected  EntityUserOperator(HasMetadata resource); void setWatchedNamespace(String watchedNamespace); String getWatchedNamespace(); void setReconciliationIntervalMs(long reconciliationIntervalMs); long getReconciliationIntervalMs(); void setClientsCaValidityDays(int clientsCaValidityDays); long getClientsCaValidityDays(); void setClientsCaRenewalDays(int clientsCaRenewalDays); long getClientsCaRenewalDays(); void setZookeeperSessionTimeoutMs(long zookeeperSessionTimeoutMs); long getZookeeperSessionTimeoutMs(); void setZookeeperConnect(String zookeeperConnect); String getZookeeperConnect(); void setKafkaBootstrapServers(String kafkaBootstrapServers); String getKafkaBootstrapServers(); static String userOperatorName(String cluster); static String metricAndLogConfigsName(String cluster); static String roleBindingName(String cluster); @Override String getAncillaryConfigMapKeyLogConfig(); static EntityUserOperator fromCrd(Kafka kafkaAssembly); List<Volume> getVolumes(); RoleBinding generateRoleBinding(String namespace, String watchedNamespace); void setContainerEnvVars(List<ContainerEnvVar> envVars); void setContainerSecurityContext(SecurityContext securityContext); @Override String createLog4jProperties(OrderedProperties properties); static final String ENV_VAR_RESOURCE_LABELS; static final String ENV_VAR_KAFKA_BOOTSTRAP_SERVERS; static final String ENV_VAR_ZOOKEEPER_CONNECT; static final String ENV_VAR_WATCHED_NAMESPACE; static final String ENV_VAR_FULL_RECONCILIATION_INTERVAL_MS; static final String ENV_VAR_ZOOKEEPER_SESSION_TIMEOUT_MS; static final String ENV_VAR_CLIENTS_CA_CERT_SECRET_NAME; static final String ENV_VAR_CLIENTS_CA_KEY_SECRET_NAME; static final String ENV_VAR_CLIENTS_CA_NAMESPACE; static final String ENV_VAR_CLIENTS_CA_VALIDITY; static final String ENV_VAR_CLIENTS_CA_RENEWAL; static final String ENV_VAR_CLUSTER_CA_CERT_SECRET_NAME; static final String ENV_VAR_EO_KEY_SECRET_NAME; static final Probe DEFAULT_HEALTHCHECK_OPTIONS; }
@Test public void testEnvVars() { checkEnvVars(getExpectedEnvVars(), entityUserOperator.getEnvVars()); }