MCPcopy Create free account

hub / github.com/mesos/elasticsearch / functions

Functions630 in github.com/mesos/elasticsearch

↓ 4 callersMethodgetTaskInfoExternalVolume
(Integer esNodeId)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/util/ProtoTestUtil.java:36
↓ 4 callersMethodgetTasks
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/ESTasks.java:34
↓ 4 callersMethodhostSocket
(int port)
commons/src/main/java/org/apache/mesos/elasticsearch/common/util/NetworkUtils.java:37
↓ 4 callersMethodparseHttpAddress
(JSONObject task)
commons/src/main/java/org/apache/mesos/elasticsearch/common/elasticsearch/ElasticsearchParser.java:10
↓ 4 callersMethodremoveTask
(TaskInfo taskInfo)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:116
↓ 4 callersMethodrun
(String[] args)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Main.java:33
↓ 4 callersMethodrun
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/cluster/TaskReaper.java:30
↓ 4 callersMethodsetFrameworkId
(Protos.FrameworkInfo.Builder frameworkBuilder)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/FrameworkInfoFactory.java:43
↓ 4 callersMethodsetStatus
(TaskStatus status)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ESTaskStatus.java:46
↓ 4 callersMethodsinglePortRange
(long port, String frameworkRole)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Resources.java:34
↓ 4 callersMethodtransport
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:88
↓ 4 callersFunctionupdateChart
(chart, x, y)
scheduler/src/main/resources/public/app/controllers.js:207
↓ 3 callersMethodaddTask
(ESTaskStatus esTask)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:102
↓ 3 callersMethodclusterInfo
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/ClusterController.java:34
↓ 3 callersMethodcreateTaskInfo
(Protos.TaskID taskId, ByteString data)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactoryTest.java:237
↓ 3 callersMethoddestroy
Deletes all tasks and state.
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:188
↓ 3 callersMethodesArguments
(ClusterState clusterState, Protos.DiscoveryInfo discoveryInfo, Protos.SlaveID slaveID)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:314
↓ 3 callersMethodexists
(TaskID taskId)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:126
↓ 3 callersMethodexists
(String key)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/StatePath.java:35
↓ 3 callersMethodgetCreateContainerCmd
(String heapString)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:55
↓ 3 callersMethodgetElasticsearchBinary
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:218
↓ 3 callersMethodgetElasticsearchMemorySize
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:45
↓ 3 callersMethodgetExecutorForcePullImage
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:210
↓ 3 callersMethodgetExternalVolumeOption
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:297
↓ 3 callersMethodgetFrameworkPrincipal
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:245
↓ 3 callersMethodgetJavaHome
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:273
↓ 3 callersMethodgetJson
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/TasksResponse.java:64
↓ 3 callersMethodgetNumberOfNodes
(String ipAddress)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ScalingSystemTest.java:141
↓ 3 callersMethodgetResourceByName
(List<Protos.Resource> resourceList, String name)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactoryTest.java:112
↓ 3 callersMethodgetScheduler
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/base/SchedulerTestBase.java:35
↓ 3 callersMethodgetWebUiPort
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:178
↓ 3 callersMethodmarkRegistered
(Protos.FrameworkID frameworkId, SchedulerDriver driver)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/FrameworkState.java:47
↓ 3 callersMethodsetFrameworkFileServerAddress
(InetSocketAddress addr)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:265
↓ 3 callersMethodsetUser
(String user)
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:51
↓ 3 callersMethodstartContainer
(CreateContainerCmd createCommand)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:68
↓ 3 callersMethodtaskInError
(Protos.TaskStatus status)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:181
↓ 3 callersMethodtaskSpecificHostDir
(Protos.SlaveID slaveID)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:357
↓ 3 callersMethodvalidate
(final String ip)
commons/src/test/java/org/apache/mesos/elasticsearch/common/util/NetworkUtilsTest.java:16
↓ 3 callersMethodwaitFor
(Callable<Boolean> callable)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:90
↓ 2 callersMethodaddDefaultDockerGatewayToUnicastHosts
(Integer port)
commons/src/main/java/org/apache/mesos/elasticsearch/common/cli/HostsCLIParameter.java:34
↓ 2 callersMethodannounceStatusUpdate
(Protos.TaskStatus taskStatus)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/FrameworkState.java:95
↓ 2 callersMethodbuildFrameworkResources
(Configuration configuration)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Resources.java:77
↓ 2 callersMethodclusterHealthUrl
(ESTasks esTasks)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DiscoverySystemTest.java:49
↓ 2 callersMethodcontainerLog
(String containerId)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:64
↓ 2 callersMethodcontainsTwoPorts
(List<Protos.Resource> resources)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:104
↓ 2 callersMethodcontainsUserSpecifiedPorts
(List<Protos.Resource> resourcesList)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:108
↓ 2 callersMethodcreateData
(Optional<ZonedDateTime> startedAt)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactoryTest.java:253
↓ 2 callersMethodcreateTasksMap
(int nodes)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/controllers/SearchProxyControllerTest.java:50
↓ 2 callersMethoddataVolumeName
(Long nodeId)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:367
↓ 2 callersMethoddecline
(String reason)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:80
↓ 2 callersMethoddockerMap
(String image, String tag, String id)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/ClusterController.java:128
↓ 2 callersMethodgetContainerStream
(Boolean showAll)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:94
↓ 2 callersMethodgetDocker0AdapterIPAddress
()
commons/src/main/java/org/apache/mesos/elasticsearch/common/util/NetworkUtils.java:98
↓ 2 callersMethodgetDockerMachineName
(Map<String, String> environment)
commons/src/main/java/org/apache/mesos/elasticsearch/common/util/NetworkUtils.java:49
↓ 2 callersMethodgetElasticsearchJobName
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:49
↓ 2 callersMethodgetExecutorImage
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:206
↓ 2 callersMethodgetJavaHeap
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Environment.java:9
↓ 2 callersMethodgetJsonObjectFrom
(URL url)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DiscoverySystemTest.java:54
↓ 2 callersMethodgetPorts
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:59
↓ 2 callersMethodgetResources
(Configuration configuration, List<Integer> ports)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:131
↓ 2 callersMethodgetStateInfo
(MesosCluster cluster)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/FrameworkRoleSystemTest.java:55
↓ 2 callersMethodgetTransportAddress
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Task.java:55
↓ 2 callersMethodisAtLeastOneESNodeRunning
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:32
↓ 2 callersMethodisEnoughCPU
(Configuration configuration, List<Protos.Resource> resourcesList)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:96
↓ 2 callersMethodisEnoughRAM
(Configuration configuration, List<Protos.Resource> resourcesList)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:100
↓ 2 callersMethodisHostnameResolveable
(String hostname)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:26
↓ 2 callersMethodisValid
(List<JSONObject> tasks)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/TasksResponse.java:119
↓ 2 callersMethodisValidAddress
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/util/SystemTestMatchers.java:14
↓ 2 callersMethodkillOneExecutor
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/util/DockerUtil.java:36
↓ 2 callersMethodmasterConfig
(String imageName, String imageTag)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/containers/MesosMasterTagged.java:35
↓ 2 callersMethodnativeCommand
(List<String> arguments)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:301
↓ 2 callersMethodnewOffer
(String hostname)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchSchedulerTest.java:131
↓ 2 callersMethodpopulateEnvMap
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 callersMethodresolveHostAddress
(Protos.Offer offer, List<Integer> ports)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:114
↓ 2 callersMethodresourceOffers
(SchedulerDriver driver, List<Protos.Offer> offers)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:85
↓ 2 callersMethodrun
(SchedulerDriver schedulerDriver)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:49
↓ 2 callersMethodrun
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/SimpleFileServer.java:57
↓ 2 callersMethodschedulerWithId
(String containerId)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:82
↓ 2 callersMethodsearch
(@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 callersMethodseedData
(String esAddresses)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ScalingSystemTest.java:120
↓ 2 callersMethodselectTwoPortsFromRange
(List<Protos.Resource> offeredResources)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Resources.java:65
↓ 2 callersMethodsetPort
(String port)
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:84
↓ 2 callersMethodsetTaskInfoList
(List<TaskInfo> taskInfoList)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:233
↓ 2 callersMethodstartScheduler
(String dataDir)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DataVolumesSystemTest.java:55
↓ 2 callersMethodstopAll
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/util/ContainerLifecycleManagement.java:23
↓ 2 callersMethodstopContainer
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ElasticsearchAuthSystemTest.java:98
↓ 2 callersMethodstopScheduler
(ElasticsearchSchedulerContainer schedulerContainer)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DataVolumesSystemTest.java:72
↓ 2 callersMethodtaskId
(Protos.Offer offer, Clock clock)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:269
↓ 2 callersMethodtestMiniMesosReportsFrameworkRole
(String role)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/FrameworkRoleSystemTest.java:37
↓ 2 callersMethodtoData
(String hostname, String ipAddress, ZonedDateTime zonedDateTime)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:254
↓ 2 callersMethodtoFormattedAddress
(InetSocketAddress clientAddress)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/TasksController.java:58
↓ 2 callersMethodtoMap
(Configuration configuration)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/ClusterController.java:42
↓ 2 callersMethodtransportPort
(Integer slaveNumber)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/RunAsJarSystemTest.java:211
↓ 2 callersMethodvalidOffer
(String slaveId)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategyTest.java:221
↓ 2 callersMethodwaitForSchedulerStartStop
(String containerId)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:75
↓ 2 callersMethodwebUiAddress
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:261
↓ 1 callersMethodaccepts
(Protos.Offer offer)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:138
↓ 1 callersMethodaddAndStart
(AbstractContainer container, Integer timeout)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/util/ContainerLifecycleManagement.java:13
↓ 1 callersMethodaddIfNotEmpty
(List<String> args, String key, String value)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:361
↓ 1 callersMethodagentConfig
(String resources, int port, String imageName, String imageTag)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/containers/MesosSlaveTagged.java:22
← previousnext →101–200 of 630, ranked by callers