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
↓ 4 callers
Method
getTaskInfoExternalVolume
(Integer esNodeId)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/util/ProtoTestUtil.java:36
↓ 4 callers
Method
getTasks
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/ESTasks.java:34
↓ 4 callers
Method
hostSocket
(int port)
commons/src/main/java/org/apache/mesos/elasticsearch/common/util/NetworkUtils.java:37
↓ 4 callers
Method
parseHttpAddress
(JSONObject task)
commons/src/main/java/org/apache/mesos/elasticsearch/common/elasticsearch/ElasticsearchParser.java:10
↓ 4 callers
Method
removeTask
(TaskInfo taskInfo)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:116
↓ 4 callers
Method
run
(String[] args)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Main.java:33
↓ 4 callers
Method
run
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/cluster/TaskReaper.java:30
↓ 4 callers
Method
setFrameworkId
(Protos.FrameworkInfo.Builder frameworkBuilder)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/FrameworkInfoFactory.java:43
↓ 4 callers
Method
setStatus
(TaskStatus status)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ESTaskStatus.java:46
↓ 4 callers
Method
singlePortRange
(long port, String frameworkRole)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Resources.java:34
↓ 4 callers
Method
transport
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:88
↓ 4 callers
Function
updateChart
(chart, x, y)
scheduler/src/main/resources/public/app/controllers.js:207
↓ 3 callers
Method
addTask
(ESTaskStatus esTask)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:102
↓ 3 callers
Method
clusterInfo
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/ClusterController.java:34
↓ 3 callers
Method
createTaskInfo
(Protos.TaskID taskId, ByteString data)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactoryTest.java:237
↓ 3 callers
Method
destroy
Deletes all tasks and state.
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:188
↓ 3 callers
Method
esArguments
(ClusterState clusterState, Protos.DiscoveryInfo discoveryInfo, Protos.SlaveID slaveID)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:314
↓ 3 callers
Method
exists
(TaskID taskId)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:126
↓ 3 callers
Method
exists
(String key)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/StatePath.java:35
↓ 3 callers
Method
getCreateContainerCmd
(String heapString)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:55
↓ 3 callers
Method
getElasticsearchBinary
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:218
↓ 3 callers
Method
getElasticsearchMemorySize
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:45
↓ 3 callers
Method
getExecutorForcePullImage
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:210
↓ 3 callers
Method
getExternalVolumeOption
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:297
↓ 3 callers
Method
getFrameworkPrincipal
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:245
↓ 3 callers
Method
getJavaHome
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:273
↓ 3 callers
Method
getJson
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/TasksResponse.java:64
↓ 3 callers
Method
getNumberOfNodes
(String ipAddress)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ScalingSystemTest.java:141
↓ 3 callers
Method
getResourceByName
(List<Protos.Resource> resourceList, String name)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactoryTest.java:112
↓ 3 callers
Method
getScheduler
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/base/SchedulerTestBase.java:35
↓ 3 callers
Method
getWebUiPort
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:178
↓ 3 callers
Method
markRegistered
(Protos.FrameworkID frameworkId, SchedulerDriver driver)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/FrameworkState.java:47
↓ 3 callers
Method
setFrameworkFileServerAddress
(InetSocketAddress addr)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:265
↓ 3 callers
Method
setUser
(String user)
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:51
↓ 3 callers
Method
startContainer
(CreateContainerCmd createCommand)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:68
↓ 3 callers
Method
taskInError
(Protos.TaskStatus status)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:181
↓ 3 callers
Method
taskSpecificHostDir
(Protos.SlaveID slaveID)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:357
↓ 3 callers
Method
validate
(final String ip)
commons/src/test/java/org/apache/mesos/elasticsearch/common/util/NetworkUtilsTest.java:16
↓ 3 callers
Method
waitFor
(Callable<Boolean> callable)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:90
↓ 2 callers
Method
addDefaultDockerGatewayToUnicastHosts
(Integer port)
commons/src/main/java/org/apache/mesos/elasticsearch/common/cli/HostsCLIParameter.java:34
↓ 2 callers
Method
announceStatusUpdate
(Protos.TaskStatus taskStatus)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/FrameworkState.java:95
↓ 2 callers
Method
buildFrameworkResources
(Configuration configuration)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Resources.java:77
↓ 2 callers
Method
clusterHealthUrl
(ESTasks esTasks)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DiscoverySystemTest.java:49
↓ 2 callers
Method
containerLog
(String containerId)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:64
↓ 2 callers
Method
containsTwoPorts
(List<Protos.Resource> resources)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:104
↓ 2 callers
Method
containsUserSpecifiedPorts
(List<Protos.Resource> resourcesList)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:108
↓ 2 callers
Method
createData
(Optional<ZonedDateTime> startedAt)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactoryTest.java:253
↓ 2 callers
Method
createTasksMap
(int nodes)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/controllers/SearchProxyControllerTest.java:50
↓ 2 callers
Method
dataVolumeName
(Long nodeId)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:367
↓ 2 callers
Method
decline
(String reason)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:80
↓ 2 callers
Method
dockerMap
(String image, String tag, String id)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/ClusterController.java:128
↓ 2 callers
Method
getContainerStream
(Boolean showAll)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:94
↓ 2 callers
Method
getDocker0AdapterIPAddress
()
commons/src/main/java/org/apache/mesos/elasticsearch/common/util/NetworkUtils.java:98
↓ 2 callers
Method
getDockerMachineName
(Map<String, String> environment)
commons/src/main/java/org/apache/mesos/elasticsearch/common/util/NetworkUtils.java:49
↓ 2 callers
Method
getElasticsearchJobName
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:49
↓ 2 callers
Method
getExecutorImage
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:206
↓ 2 callers
Method
getJavaHeap
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Environment.java:9
↓ 2 callers
Method
getJsonObjectFrom
(URL url)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DiscoverySystemTest.java:54
↓ 2 callers
Method
getPorts
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:59
↓ 2 callers
Method
getResources
(Configuration configuration, List<Integer> ports)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:131
↓ 2 callers
Method
getStateInfo
(MesosCluster cluster)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/FrameworkRoleSystemTest.java:55
↓ 2 callers
Method
getTransportAddress
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Task.java:55
↓ 2 callers
Method
isAtLeastOneESNodeRunning
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:32
↓ 2 callers
Method
isEnoughCPU
(Configuration configuration, List<Protos.Resource> resourcesList)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:96
↓ 2 callers
Method
isEnoughRAM
(Configuration configuration, List<Protos.Resource> resourcesList)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:100
↓ 2 callers
Method
isHostnameResolveable
(String hostname)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:26
↓ 2 callers
Method
isValid
(List<JSONObject> tasks)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/TasksResponse.java:119
↓ 2 callers
Method
isValidAddress
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/util/SystemTestMatchers.java:14
↓ 2 callers
Method
killOneExecutor
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/util/DockerUtil.java:36
↓ 2 callers
Method
masterConfig
(String imageName, String imageTag)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/containers/MesosMasterTagged.java:35
↓ 2 callers
Method
nativeCommand
(List<String> arguments)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:301
↓ 2 callers
Method
newOffer
(String hostname)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchSchedulerTest.java:131
↓ 2 callers
Method
populateEnvMap
Adds environmental variables to the list. Please add new environmental variables here. @param configuration
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/configuration/ExecutorEnvironmentalVariables.java:65
↓ 2 callers
Method
resolveHostAddress
(Protos.Offer offer, List<Integer> ports)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:114
↓ 2 callers
Method
resourceOffers
(SchedulerDriver driver, List<Protos.Offer> offers)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:85
↓ 2 callers
Method
run
(SchedulerDriver schedulerDriver)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:49
↓ 2 callers
Method
run
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/SimpleFileServer.java:57
↓ 2 callers
Method
schedulerWithId
(String containerId)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:82
↓ 2 callers
Method
search
(@RequestParam("q") String query, @RequestHeader(value = "X-ElasticSearch-Host", required = false) String elas
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/SearchProxyController.java:53
↓ 2 callers
Method
seedData
(String esAddresses)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ScalingSystemTest.java:120
↓ 2 callers
Method
selectTwoPortsFromRange
(List<Protos.Resource> offeredResources)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Resources.java:65
↓ 2 callers
Method
setPort
(String port)
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:84
↓ 2 callers
Method
setTaskInfoList
(List<TaskInfo> taskInfoList)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:233
↓ 2 callers
Method
startScheduler
(String dataDir)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DataVolumesSystemTest.java:55
↓ 2 callers
Method
stopAll
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/util/ContainerLifecycleManagement.java:23
↓ 2 callers
Method
stopContainer
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ElasticsearchAuthSystemTest.java:98
↓ 2 callers
Method
stopScheduler
(ElasticsearchSchedulerContainer schedulerContainer)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DataVolumesSystemTest.java:72
↓ 2 callers
Method
taskId
(Protos.Offer offer, Clock clock)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:269
↓ 2 callers
Method
testMiniMesosReportsFrameworkRole
(String role)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/FrameworkRoleSystemTest.java:37
↓ 2 callers
Method
toData
(String hostname, String ipAddress, ZonedDateTime zonedDateTime)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:254
↓ 2 callers
Method
toFormattedAddress
(InetSocketAddress clientAddress)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/TasksController.java:58
↓ 2 callers
Method
toMap
(Configuration configuration)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/ClusterController.java:42
↓ 2 callers
Method
transportPort
(Integer slaveNumber)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/RunAsJarSystemTest.java:211
↓ 2 callers
Method
validOffer
(String slaveId)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategyTest.java:221
↓ 2 callers
Method
waitForSchedulerStartStop
(String containerId)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:75
↓ 2 callers
Method
webUiAddress
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:261
↓ 1 callers
Method
accepts
(Protos.Offer offer)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:138
↓ 1 callers
Method
addAndStart
(AbstractContainer container, Integer timeout)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/util/ContainerLifecycleManagement.java:13
↓ 1 callers
Method
addIfNotEmpty
(List<String> args, String key, String value)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:361
↓ 1 callers
Method
agentConfig
(String resources, int port, String imageName, String imageTag)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/containers/MesosSlaveTagged.java:22
← previous
next →
101–200 of 630, ranked by callers