Configuration { public String dataVolumeName(Long nodeId) { return getFrameworkName() + nodeId + "data"; } Configuration(String... args); double getCpus(); double getMem(); double getDisk(); int getElasticsearchNodes(); void setElasticsearchNodes(int numberOfNodes); String getElasticsearchSettingsLocation(); String getElasticsearchClusterName(); int getWebUiPort(); String getVersion(); String getFrameworkName(); String getTaskName(); Map<String, String> getTaskLabels(); String getDataDir(); double getFailoverTimeout(); String getFrameworkRole(); String getExecutorImage(); Boolean getExecutorForcePullImage(); Boolean getIsUseIpAddress(); String getElasticsearchBinary(); String getMesosStateZKURL(); String getMesosZKURL(); ZookeeperCLIParameter getZookeeperCLI(); ElasticsearchCLIParameter getElasticsearchCLI(); String getFrameworkSecretPath(); String getFrameworkPrincipal(); Boolean isFrameworkUseDocker(); String getFrameworkFileServerAddress(); String webUiAddress(); void setFrameworkFileServerAddress(InetSocketAddress addr); String getJavaHome(); List<Integer> getElasticsearchPorts(); String getExternalVolumeDriver(); String getExternalVolumeOption(); String nativeCommand(List<String> arguments); List<String> esArguments(ClusterState clusterState, Protos.DiscoveryInfo discoveryInfo, Protos.SlaveID slaveID); String taskSpecificHostDir(Protos.SlaveID slaveID); String dataVolumeName(Long nodeId); static final String ELASTICSEARCH_CPU; static final String ELASTICSEARCH_RAM; static final String ELASTICSEARCH_DISK; static final String WEB_UI_PORT; static final String FRAMEWORK_NAME; static final String EXECUTOR_NAME; static final String EXECUTOR_LABELS; static final String DATA_DIR; static final String DEFAULT_HOST_DATA_DIR; static final String FRAMEWORK_FAILOVER_TIMEOUT; static final String FRAMEWORK_ROLE; static final String EXECUTOR_IMAGE; static final String EXECUTOR_BINARY; static final String DEFAULT_EXECUTOR_IMAGE; static final String EXECUTOR_FORCE_PULL_IMAGE; static final String FRAMEWORK_PRINCIPAL; static final String FRAMEWORK_SECRET_PATH; static final String ES_TAR; static final String ES_BINARY; static final String FRAMEWORK_USE_DOCKER; static final String JAVA_HOME; static final String USE_IP_ADDRESS; static final String ELASTICSEARCH_PORTS; static final String CONTAINER_PATH_DATA; static final String CONTAINER_PATH_CONF; static final String CONTAINER_PATH_CONF_YML; static final String HOST_SANDBOX; static final String HOST_PATH_HOME; static final String HOST_PATH_CONF; static final String EXTERNAL_VOLUME_DRIVER; static final String EXTERNAL_VOLUME_OPTIONS; }
@Test public void shouldCreateVolumeName() { Configuration configuration = new Configuration(ZookeeperCLIParameter.ZOOKEEPER_MESOS_URL, "aa", Configuration.FRAMEWORK_NAME, "test"); assertEquals("test0data", configuration.dataVolumeName(0L)); }