Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/mesos/elasticsearch
/ functions
Functions
630 in github.com/mesos/elasticsearch
⨍
Functions
630
◇
Types & classes
137
Method
GetTasksResponse
(String id, String state, String name, String version, String startedAt, String httpAddress, String transportA
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/TasksController.java:72
Method
IpPortsListZKFormatter
(ZKAddressParser parser)
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/formatter/IpPortsListZKFormatter.java:18
Method
IpTables
(DockerClient client, Configuration config, String containerId)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/util/IpTables.java:37
Method
JarESVersionScheduler
(DockerClient dockerClient, String zkIp, MesosCluster cluster, String binaryUrl)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DifferentESVersionSystemTest.java:163
Method
JarScheduler
(DockerClient dockerClient, ZooKeeper zooKeeperContainer, String clusterId)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/RunAsJarSystemTest.java:156
Method
Main
(Environment env)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Main.java:24
Method
MesosMasterTagged
(ZooKeeper zooKeeperContainer)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/containers/MesosMasterTagged.java:24
Method
MesosSlaveTagged
(ZooKeeper zooKeeperContainer, String resources)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/containers/MesosSlaveTagged.java:17
Method
MesosSlaveWithSchedulerLink
(ZooKeeper zooKeeperContainer, JarScheduler scheduler, Integer slaveNumber)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/RunAsJarSystemTest.java:201
Method
MesosSlaveWithVolume
(ZooKeeper zooKeeperContainer, String resources)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/CustomSettingsDockerSystemTest.java:206
Method
MesosZKFormatter
(ZKAddressParser parser)
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/formatter/MesosZKFormatter.java:15
Method
OfferIDMatcher
(String value)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/matcher/OfferIDMatcher.java:14
Method
OfferResult
(boolean acceptable, Optional<String> reason)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:71
Method
OfferRule
(String declineReason, Rule rule)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:127
Method
OfferStrategy
(Configuration configuration, ClusterState clusterState)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:49
Method
OfferStrategyExternalStorage
(Configuration configuration, ClusterState clusterState)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategyExternalStorage.java:14
Method
OfferStrategyNormal
(Configuration configuration, ClusterState clusterState)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategyNormal.java:15
Method
Offers
()
commons/src/main/java/org/apache/mesos/elasticsearch/common/Offers.java:10
Method
RequestMatcher
(double cpus, double mem, double disk, String frameworkRole)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/matcher/RequestMatcher.java:60
Method
ResourceCheck
@param resourceName the name of the resource you want to check
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ResourceCheck.java:16
Method
Resources
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Resources.java:20
Method
SeedDataContainer
(DockerClient dockerClient, String elasticSearchUrl)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/SeedDataContainer.java:17
Method
SerializableZookeeperState
(org.apache.mesos.state.State zkState)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/SerializableZookeeperState.java:15
Method
SimpleAuthMaster
(ZooKeeper zooKeeperContainer)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ElasticsearchAuthSystemTest.java:127
Method
SimpleAuthSlave
(ZooKeeper zooKeeperContainer, String resources)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ElasticsearchAuthSystemTest.java:149
Method
SimpleFileServer
(String file)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/SimpleFileServer.java:24
Method
SmallerCPUScheduler
(DockerClient dockerClient, String zkIp, String frameworkRole, MesosCluster cluster)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ElasticsearchAuthSystemTest.java:156
Method
StatePath
(SerializableState zkState)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/StatePath.java:11
Method
Task
(String hostname, String taskId, Protos.TaskState state, ZonedDateTime startedAt, InetSocketAddress clientInte
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Task.java:22
Method
TaskInfoFactory
(ClusterState clusterState)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:36
Method
TaskReaper
(SchedulerDriver schedulerDriver, Configuration configuration, ClusterState clusterState)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/cluster/TaskReaper.java:21
Method
TasksResponse
(ESTasks esTasks, int nodesCount)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/TasksResponse.java:31
Method
ZKAddress
Represents a single zookeeper address. @param address Must be in the format [user:password@]host[:port] where [] are optional.
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:32
Method
ZKAddressException
(String zkUrl)
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/exception/ZKAddressException.java:9
Method
ZookeeperContainer
(DockerClient dockerClient)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/containers/ZookeeperContainer.java:16
Method
after
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DifferentESVersionSystemTest.java:61
Method
after
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/CustomSettingsDockerSystemTest.java:88
Method
before
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/FrameworkInfoFactoryTest.java:25
Method
before
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactoryTest.java:50
Method
before
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/CLITest.java:22
Method
before
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchSchedulerTest.java:49
Method
before
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/state/SerializableZookeeperStateTest.java:32
Method
before
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterStateTest.java:30
Method
before
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/state/ESTaskStatusTest.java:28
Method
before
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/state/StatePathTest.java:17
Method
before
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/cluster/TaskReaperTest.java:25
Method
before
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ElasticsearchAuthSystemTest.java:57
Method
before
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ScalingSystemTest.java:37
Method
before
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DifferentESVersionSystemTest.java:45
Method
before
()
commons/src/test/java/org/apache/mesos/elasticsearch/common/zookeeper/formatter/MesosZKFormatterTest.java:24
Method
call
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/TasksResponse.java:49
Method
call
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/util/IpTables.java:43
Method
call
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DataVolumesSystemTest.java:88
Method
call
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/callbacks/ElasticsearchNodesResponse.java:37
Method
canParseTask
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactoryTest.java:154
Method
canParseTaskCappedTimestamp
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactoryTest.java:191
Method
canParseTaskWithoutTimestamp
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactoryTest.java:173
Method
containsElasticNodeId
(TaskInfo taskInfo)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:74
Method
createMesosLocalEnvironment
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/containers/MesosMasterTagged.java:42
Method
delete
(String key)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/state/TestSerializableStateImpl.java:29
Method
delete
Delete a path in zk @param key the key to delete @throws InvalidParameterException if cannot read path @throws IOException
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/SerializableZookeeperState.java:90
Method
describeTo
(Description description)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/matcher/RequestMatcher.java:55
Method
describeTo
(Description description)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/matcher/OfferIDMatcher.java:24
Method
describeTo
(Description description)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/util/SystemTestMatchers.java:21
Method
destroy
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ESTaskStatus.java:102
Method
destroy
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/FrameworkState.java:64
Method
disconnected
(SchedulerDriver driver)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:137
Method
dockerCommand
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/SeedDataContainer.java:27
Method
dockerCommand
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/containers/ElasticsearchSchedulerContainer.java:52
Method
dockerCommand
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ElasticsearchAuthSystemTest.java:160
Method
dockerCommand
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/RunAsJarSystemTest.java:215
Method
dockerCommand
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DifferentESVersionSystemTest.java:140
Method
dockerCommand
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DifferentESVersionSystemTest.java:168
Method
dockerCommand
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/CustomSettingsDockerSystemTest.java:173
Method
dockerCommand
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/CustomSettingsDockerSystemTest.java:210
Method
dockerCommand
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/containers/AlpineContainer.java:33
Method
dockerCommand
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/containers/ZookeeperContainer.java:25
Method
doesNotAcceptBlank
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/CLITest.java:97
Method
ensureMainFailsIfInvalidHeap
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:38
Method
ensureMainFailsIfNoHeap
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:27
Method
ensureMainWorksIfValidHeap
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:48
Method
ensureOver1GBHeapIs256MB
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/configuration/ExecutorEnvironmentalVariablesTest.java:20
Method
ensureUnder1GBIsLessThan256MB
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/configuration/ExecutorEnvironmentalVariablesTest.java:37
Function
error
(data)
scheduler/src/main/resources/public/app/controllers.js:260
Method
executionException
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/state/SerializableZookeeperStateTest.java:56
Method
executorsInfo
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/ClusterController.java:114
Method
failed
(Throwable e, Description description)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ElasticsearchAuthSystemTest.java:51
Method
failed
(Throwable e, Description description)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ReconciliationSystemTest.java:36
Method
failed
(Throwable e, Description description)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/RunAsJarSystemTest.java:82
Method
failed
(Throwable e, Description description)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/CustomSettingsDockerSystemTest.java:59
Method
failed
(Throwable e, Description description)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/base/TestBase.java:34
Method
format
(String zkURL)
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/formatter/AbstractZKFormatter.java:15
Method
frameworkMessage
(SchedulerDriver driver, Protos.ExecutorID executorId, Protos.SlaveID slaveId, byte[] data)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:132
Method
from
(Map.Entry<String, Task> task)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/TasksController.java:45
Method
get
(String key)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/state/TestSerializableStateImpl.java:16
Method
get
Get serializable object from store null if none @return Object @throws IOException
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/SerializableZookeeperState.java:26
Method
getBuilder
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/CredentialFactory.java:21
Method
getClusterController
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/controllers/TestConfiguration.java:22
Method
getConfig
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/controllers/TestConfiguration.java:32
Method
getDriver
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/FrameworkState.java:72
← previous
next →
301–400 of 630, ranked by callers