MCPcopy Create free account

hub / github.com/mesos/elasticsearch / functions

Functions630 in github.com/mesos/elasticsearch

⨍ Functions 630◇ Types & classes 137
↓ 1 callersMethodannounceNewTask
(ESTaskStatus esTask)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/FrameworkState.java:91
↓ 1 callersMethodbuildDockerTask
(Protos.Offer offer, Configuration configuration, Clock clock, Long elasticSearchNodeId)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:89
↓ 1 callersMethodbuildNativeTask
(Protos.Offer offer, Configuration configuration, Clock clock, Long elasticSearchNodeId)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:67
↓ 1 callersMethodcheckEnv
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Main.java:93
↓ 1 callersMethodcheckHeap
(String s)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Main.java:97
↓ 1 callersMethodclusterIsGreen
(ESTasks esTasks)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DiscoverySystemTest.java:27
↓ 1 callersMethoddockerCommand
(Configuration configuration, List<String> args, Long elasticSearchNodeId)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:216
↓ 1 callersMethoddockerCommand
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ElasticsearchAuthSystemTest.java:139
↓ 1 callersMethoddockerCommand
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/RunAsJarSystemTest.java:168
↓ 1 callersMethodendpointIsOk
(JSONObject task)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/callbacks/ElasticsearchNodesResponse.java:57
↓ 1 callersMethodenvVars
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ElasticsearchAuthSystemTest.java:131
↓ 1 callersMethoderrorState
(TaskState state)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ESTaskStatus.java:96
↓ 1 callersMethodexecutorLost
(SchedulerDriver driver, Protos.ExecutorID executorId, Protos.SlaveID slaveId, int status)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:147
↓ 1 callersFunctionfetchClusterConfiguration
()
scheduler/src/main/resources/public/app/controllers.js:29
↓ 1 callersFunctionfetchStats
()
scheduler/src/main/resources/public/app/controllers.js:215
↓ 1 callersFunctionfetchTasks
()
scheduler/src/main/resources/public/app/controllers.js:96
↓ 1 callersMethodflattenProtobufString
(String s)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:110
↓ 1 callersMethodformat
Validates the ZooKeeper address and returns it @param zkUrl The raw ZK address string in the format "zk://host:port/zkNode,..." @throws ZKAddressExc
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/formatter/MesosZKFormatter.java:28
↓ 1 callersMethodgetDocumentCount
(String httpAddress)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/ESTasks.java:79
↓ 1 callersMethodgetElasticNodeIdList
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:62
↓ 1 callersMethodgetElasticsearchCLI
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:237
↓ 1 callersMethodgetElasticsearchNodes
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/ClusterController.java:80
↓ 1 callersMethodgetEnvProto
(String key, String value)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/configuration/ExecutorEnvironmentalVariables.java:99
↓ 1 callersMethodgetFailoverTimeout
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:198
↓ 1 callersMethodgetFrameworkSecretPath
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:241
↓ 1 callersMethodgetHeapSpaceString
Gets the heap space settings. Will set heap space to (available - 256MB) or available/4, whichever is smaller. @param configuration The mesos cluster
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/configuration/ExecutorEnvironmentalVariables.java:110
↓ 1 callersMethodgetLastExecutorId
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/util/DockerUtil.java:32
↓ 1 callersMethodgetLocalAddress
(String adaptorName)
commons/src/main/java/org/apache/mesos/elasticsearch/common/util/NetworkUtils.java:108
↓ 1 callersMethodgetMesosStateZKURL
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:223
↓ 1 callersMethodgetPassword
()
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:58
↓ 1 callersMethodgetResource
(List<Protos.Resource> resourcesList)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ResourceCheck.java:31
↓ 1 callersMethodgetResourceListByName
(List<Protos.Resource> resourceList, String name)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactoryTest.java:116
↓ 1 callersMethodgetResponse
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/ESTasks.java:30
↓ 1 callersMethodgetResult
(JSONObject task)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/TasksResponse.java:115
↓ 1 callersMethodgetRole
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/SeedDataContainer.java:35
↓ 1 callersMethodgetRole
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/containers/AlpineContainer.java:44
↓ 1 callersMethodgetSchedulerContainers
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/util/DockerUtil.java:28
↓ 1 callersMethodgetTaskInfo
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ESTaskStatus.java:72
↓ 1 callersMethodgetUser
()
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:47
↓ 1 callersMethodgetVersion
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:182
↓ 1 callersMethodgetZkNode
()
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:91
↓ 1 callersMethodgetZookeeperCLI
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:233
↓ 1 callersMethodgetZookeeperMesosTimeout
()
commons/src/main/java/org/apache/mesos/elasticsearch/common/cli/ZookeeperCLIParameter.java:22
↓ 1 callersMethodgetZookeeperMesosUrl
()
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/containers/ElasticsearchSchedulerContainer.java:72
↓ 1 callersMethodgetZookeeperMesosUrl
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/CustomSettingsDockerSystemTest.java:190
↓ 1 callersMethodhostAddress
()
commons/src/main/java/org/apache/mesos/elasticsearch/common/util/NetworkUtils.java:28
↓ 1 callersMethodisEnoughDisk
(Configuration configuration, List<Protos.Resource> resourcesList)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategyNormal.java:31
↓ 1 callersMethodisPortAvailable
(List<Protos.Resource> resourcesList, Integer port)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Resources.java:90
↓ 1 callersMethodisValidDateTime
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/util/SystemTestMatchers.java:28
↓ 1 callersMethodlogTaskList
(List<TaskInfo> taskInfoList)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:225
↓ 1 callersMethodmain
(String[] args)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Main.java:28
↓ 1 callersMethodnativeCommand
(Configuration configuration, List<String> args, Long elasticSearchNodeId)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:229
↓ 1 callersMethodnewMasterInfo
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchSchedulerTest.java:135
↓ 1 callersMethodnewOfferBuilder
(String offerId, String hostname, String slave, Protos.FrameworkID frameworkID)
commons/src/main/java/org/apache/mesos/elasticsearch/common/Offers.java:14
↓ 1 callersMethodnoSchedulers
()
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/SchedulerMainSystemTest.java:86
↓ 1 callersMethodnotValid
(T value)
commons/src/main/java/org/apache/mesos/elasticsearch/common/cli/validators/CLIValidators.java:24
↓ 1 callersMethodonStatusUpdate
(Consumer<Protos.TaskStatus> listener)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/FrameworkState.java:99
↓ 1 callersMethodpopulateEnvMapForMesos
(Configuration configuration, Long nodeId)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/configuration/ExecutorEnvironmentalVariables.java:72
↓ 1 callersMethodreapTasks
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:59
↓ 1 callersMethodregistered
(SchedulerDriver driver, Protos.FrameworkID frameworkId, Protos.MasterInfo masterInfo)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:64
↓ 1 callersMethodrm
Remove a zNode or zFolder. @param key the path to remove. @throws IOException If unable to remove
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/StatePath.java:50
↓ 1 callersMethodrunCommand
(CommandLine commandline)
commons/src/main/java/org/apache/mesos/elasticsearch/common/util/NetworkUtils.java:89
↓ 1 callersMethodseedData
(MesosCluster cluster, ElasticsearchSchedulerContainer schedulerContainer)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Main.java:68
↓ 1 callersMethodserve
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/SimpleFileServer.java:41
↓ 1 callersMethodsetAddress
(String address)
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:73
↓ 1 callersMethodsetElasticsearchNodes
(int numberOfNodes)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:166
↓ 1 callersMethodsetFrameworkPrincipal
(Protos.FrameworkInfo.Builder frameworkBuilder)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/FrameworkInfoFactory.java:35
↓ 1 callersMethodsetPassword
(String password)
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:62
↓ 1 callersMethodsetWebuiUrl
(Protos.FrameworkInfo.Builder frameworkBuilder)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/FrameworkInfoFactory.java:51
↓ 1 callersMethodsetZkNode
(String zkNode)
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:95
↓ 1 callersMethodshutdown
(SchedulerDriver driver)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:168
↓ 1 callersMethodstatusUpdate
(SchedulerDriver driver, Protos.TaskStatus status)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:119
↓ 1 callersMethodtaskStatus
()
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategyTest.java:234
↓ 1 callersMethodthereAreThreeNodes
(ESTasks esTasks)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DiscoverySystemTest.java:38
↓ 1 callersMethodtoHttpHost
(InetSocketAddress address)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/SearchProxyController.java:76
↓ 1 callersMethodupdate
(Protos.TaskStatus status)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:174
↓ 1 callersFunctionupdateStatesPercentage
(states, tasksData)
scheduler/src/main/resources/public/app/controllers.js:68
↓ 1 callersFunctionupdateTasks
(data)
scheduler/src/main/resources/public/app/controllers.js:84
↓ 1 callersMethodwriteClassPathResource
(HttpExchange t, String classPathResource)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/SimpleFileServer.java:28
↓ 1 callersMethodwritePasswordFileToVM
Use an alpine image to write files to the VM/docker host. Then all the containers can mount that DIR and get access to the passwd files.
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ElasticsearchAuthSystemTest.java:76
↓ 1 callersMethodwriteVariable
(Object object)
scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/state/SerializableZookeeperStateTest.java:130
MethodAbstractZKFormatter
(ZKAddressParser parser)
commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/formatter/AbstractZKFormatter.java:11
MethodAlpineContainer
(DockerClient dockerClient, String hostVolume, String containerVolume, String... cmd)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/containers/AlpineContainer.java:21
MethodClusterState
(@NotNull SerializableState zooKeeperStateDriver, @NotNull FrameworkState frameworkState)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:29
MethodConfiguration
(String... args)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:127
MethodCredentialFactory
(Configuration configuration)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/CredentialFactory.java:17
MethodCustomSettingsScheduler
(DockerClient dockerClient, ZooKeeper zooKeeperContainer, String clusterId, String configPath)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/CustomSettingsDockerSystemTest.java:161
MethodDataInDirectory
(String containerId, String dataDirectory)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DataVolumesSystemTest.java:83
MethodDockerESVersionScheduler
(DockerClient dockerClient, String zkIp, MesosCluster cluster, String image)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/DifferentESVersionSystemTest.java:129
MethodDockerUtil
(DockerClient dockerClient)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/util/DockerUtil.java:16
MethodESPorts
(final Integer client, final Integer transport)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:80
MethodESTaskStatus
(SerializableState state, FrameworkID frameworkID, TaskInfo taskInfo, StatePath statePath)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ESTaskStatus.java:27
MethodESTasks
(Configuration config, String schedulerIpAddress)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/ESTasks.java:26
MethodElasticsearchNodesResponse
(ESTasks esTasks, int nodesCount)
system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/callbacks/ElasticsearchNodesResponse.java:24
MethodElasticsearchNodesWrapper
()
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/ClusterController.java:99
MethodElasticsearchScheduler
(Configuration configuration, FrameworkState frameworkState, ClusterState clusterState, TaskInfoFactory taskIn
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:32
MethodElasticsearchSchedulerContainer
(DockerClient dockerClient, String zkIp, MesosCluster cluster)
system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/containers/ElasticsearchSchedulerContainer.java:29
MethodExecutorEnvironmentalVariables
@param configuration The mesos cluster configuration
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/configuration/ExecutorEnvironmentalVariables.java:35
MethodFrameworkInfoFactory
(Configuration configuration, FrameworkState frameworkState)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/FrameworkInfoFactory.java:17
MethodFrameworkState
(SerializableState zookeeperStateDriver)
scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/FrameworkState.java:29
← previousnext →201–300 of 630, ranked by callers