Functions — github.com/mesos/elasticsearch

hub / github.com/mesos/elasticsearch / functions

Functions630 in github.com/mesos/elasticsearch

⨍ Functions 630◇ Types & classes 137

↓ 151 callersMethodget

(String key)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/SerializableState.java:9

↓ 62 callersMethodgetValue

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/ClusterController.java:96

↓ 53 callersMethodtoString

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ESTaskStatus.java:76

↓ 46 callersMethodgetFrameworkRole

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:202

↓ 31 callersMethodgetTaskId

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Task.java:35

↓ 31 callersMethodgetTaskList

Get a list of all tasks with state @return a list of TaskInfo

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:42

↓ 25 callersMethodcreateTask

(String hostname)

scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategyTest.java:213

↓ 24 callersMethodgetClusterTimeout

()

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:70

↓ 23 callersMethodgetElasticsearchNodesCount

()

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:41

↓ 22 callersMethodset

(String key, T object)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/SerializableState.java:10

↓ 22 callersMethodvalidateZkUrl

(final String zkUrl)

commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/parser/ZKAddressParser.java:28

↓ 20 callersMethodgetElasticsearchNodes

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:162

↓ 18 callersMethoderror

(SchedulerDriver driver, String message)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ElasticsearchScheduler.java:163

↓ 18 callersMethodportRange

(long beginPort, long endPort, String frameworkRole)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Resources.java:24

↓ 18 callersMethodtoString

()

system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/callbacks/LogContainerTestCallback.java:24

↓ 17 callersMethodgetStatus

Get the status of a specific task @param taskID the taskID to retreive the task status for @return a POJO representing TaskInfo, TaskStatus and Framew

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:94

↓ 16 callersMethodgetDefaultTaskInfo

()

scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/util/ProtoTestUtil.java:16

↓ 16 callersMethodgetFrameworkID

Return empty if no frameworkId found.

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/FrameworkState.java:37

↓ 15 callersMethodevaluate

(Protos.Offer offer)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:54

↓ 15 callersMethodgetMem

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:146

↓ 14 callersMethodgetExternalVolumeDriver

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:293

↓ 14 callersMethodgetPorts

(Protos.Offer offer, Configuration configuration)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:121

↓ 13 callersMethodcpus

(double cpus, String frameworkRole)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Resources.java:38

↓ 13 callersMethodgetPortRanges

()

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:63

↓ 13 callersMethodgetSlaveId

()

scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/util/ProtoTestUtil.java:60

↓ 12 callersMethodgetEsHttpAddressList

()

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/ESTasks.java:55

↓ 12 callersMethodkillAllExecutors

()

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/util/DockerUtil.java:41

↓ 11 callersMethodbaseOfferBuilder

(String slaveId)

scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategyTest.java:226

↓ 11 callersMethodgetElasticsearchPorts

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:281

↓ 11 callersMethodgetState

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Task.java:39

↓ 10 callersMethodassertZKEquals

(ZKAddress zk, String user, String pass, String addr, String port, String zkNode)

commons/src/test/java/org/apache/mesos/elasticsearch/common/zookeeper/parser/ZKAddressParserTest.java:104

↓ 10 callersMethodgetContainer

(Configuration configuration, Protos.TaskID taskID, Long elasticSearchNodeId, Protos.SlaveID slaveID)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:149

↓ 10 callersMethodgetSchedulerGuiPort

()

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:37

↓ 10 callersMethodnow

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/util/Clock.java:12

↓ 9 callersMethoddelete

(String key)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/SerializableState.java:11

↓ 9 callersMethodgetCpus

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:142

↓ 9 callersMethodgetDisk

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:150

↓ 9 callersMethodgetHostname

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Task.java:31

↓ 9 callersMethodgetPort

()

commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:80

↓ 9 callersMethodgetSchedulerImageName

()

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:29

↓ 9 callersMethodkillAllSchedulers

()

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/util/DockerUtil.java:45

↓ 9 callersMethodmem

(double mem, String frameworkRole)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Resources.java:47

↓ 9 callersMethodscaleNumNodesTo

(String ipAddress, Integer newNumNodes)

system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ScalingSystemTest.java:132

↓ 9 callersMethodwaitForGreen

(Integer numNodes)

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/ESTasks.java:59

↓ 8 callersMethoddisk

(double disk, String frameworkRole)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Resources.java:56

↓ 8 callersMethodformat

(String zkURL)

commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/formatter/ZKFormatter.java:7

↓ 8 callersMethodgetAddress

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/SimpleFileServer.java:49

↓ 8 callersMethodgetDiscovery

(List<Integer> ports, Configuration configuration)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:138

↓ 8 callersMethodgetExecutorId

()

scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/util/ProtoTestUtil.java:64

↓ 8 callersMethodgetSchedulerName

()

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:33

↓ 8 callersMethodgetTaskName

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:190

↓ 8 callersMethodisDiscoverySuccessful

()

system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/callbacks/ElasticsearchNodesResponse.java:77

↓ 8 callersMethodisEnough

Check to see if the required amount of resources is contained within the resources list. @param resourcesList a list of resources @param requiredValue

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/ResourceCheck.java:26

↓ 8 callersMethodnowUTC

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/util/Clock.java:20

↓ 7 callersMethodaddToList

(String key, String value)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/configuration/ExecutorEnvironmentalVariables.java:95

↓ 7 callersMethodaddressToString

(InetSocketAddress address, Boolean useIpAddress)

commons/src/main/java/org/apache/mesos/elasticsearch/common/util/NetworkUtils.java:41

↓ 7 callersMethodgetElasticsearchSettingsLocation

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:170

↓ 7 callersMethodisFrameworkUseDocker

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:249

↓ 7 callersMethodparse

(Protos.TaskInfo taskInfo, Protos.TaskStatus taskStatus, Clock clock)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:274

↓ 7 callersMethodsetState

(Protos.TaskState state)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Task.java:43

↓ 6 callersMethodassertCorrectNumberOfExecutors

()

system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ReconciliationSystemTest.java:86

↓ 6 callersMethodgetAddress

()

commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/model/ZKAddress.java:69

↓ 6 callersMethodgetFrameworkName

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:186

↓ 6 callersMethodgetKey

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ESTaskStatus.java:87

↓ 6 callersMethodgetStatus

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ESTaskStatus.java:56

↓ 6 callersMethodgetTasks

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/controllers/TasksController.java:36

↓ 6 callersMethodgetTestConfig

()

system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/base/TestBase.java:73

↓ 6 callersMethodgetZookeeperMesosUrl

()

system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/RunAsJarSystemTest.java:186

↓ 6 callersMethodmkdir

Creates the zNode if it does not exist. Will create parent directories. @param key the zNode path

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/StatePath.java:19

↓ 6 callersMethodwaitForCorrectDocumentCount

(Integer docCount)

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/ESTasks.java:85

↓ 5 callersMethodaccept

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/OfferStrategy.java:76

↓ 5 callersMethodapply

(DockerClient client, MesosCluster cluster, Configuration config)

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/util/IpTables.java:29

↓ 5 callersMethodcreateTask

Creates TaskInfo for Elasticsearch execcutor running in a Docker container @param configuration configuation of the framework @param offer with resou

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactory.java:48

↓ 5 callersMethodgetContainers

(Boolean showAll)

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/util/DockerUtil.java:20

↓ 5 callersMethodgetDataDir

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:194

↓ 5 callersMethodgetDefaultTaskStatus

(Protos.TaskState state)

scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/util/ProtoTestUtil.java:48

↓ 5 callersMethodgetDockerHostIpAddress

(Map<String, String> environment)

commons/src/main/java/org/apache/mesos/elasticsearch/common/util/NetworkUtils.java:58

↓ 5 callersMethodgetElasticNodeId

When using external volumes, retrieve the next available elasticsearch node id @return Integer (node id)

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:57

↓ 5 callersMethodgetElasticsearchClusterName

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:174

↓ 5 callersMethodgetGuiTaskList

Get a list of all tasks in a format specific to the web GUI. @return

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:82

↓ 5 callersMethodgetKey

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:243

↓ 5 callersMethodgetList

Get a list of environmental variables @return

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/configuration/ExecutorEnvironmentalVariables.java:57

↓ 5 callersMethodgetMesosZKURL

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:228

↓ 5 callersMethodgetTask

Get the TaskInfo packet for a specific task. @param taskID the taskID to retreive the TaskInfo for @return a TaskInfo packet @throws IllegalArgumentEx

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ClusterState.java:141

↓ 5 callersMethodhttpPort

(Integer slaveNumber)

system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/RunAsJarSystemTest.java:207

↓ 5 callersMethodisRegistered

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/FrameworkState.java:87

↓ 5 callersMethodmatches

(Object o)

scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/matcher/RequestMatcher.java:20

↓ 5 callersMethodstartSchedulerContainer

()

system-test/src/systemTest/java/org/apache/mesos/elasticsearch/systemtest/ReconciliationSystemTest.java:28

↓ 4 callersMethodclient

()

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:84

↓ 4 callersMethodformat

Get the ZooKeeper address, correctly formatted. @param zkUrl The raw ZK address string in the format "zk://host:port/zkNode,..." @throws ZKAddressExce

commons/src/main/java/org/apache/mesos/elasticsearch/common/zookeeper/formatter/IpPortsListZKFormatter.java:28

↓ 4 callersMethodgetBuilder

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/FrameworkInfoFactory.java:22

↓ 4 callersMethodgetClientAddress

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Task.java:51

↓ 4 callersMethodgetDefaultStatus

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/state/ESTaskStatus.java:64

↓ 4 callersMethodgetDocker0AdaptorIpAddress

()

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/Configuration.java:25

↓ 4 callersMethodgetEnvironment

()

commons/src/main/java/org/apache/mesos/elasticsearch/common/util/NetworkUtils.java:79

↓ 4 callersMethodgetExecutorContainers

()

system-test/src/main/java/org/apache/mesos/elasticsearch/systemtest/util/DockerUtil.java:24

↓ 4 callersMethodgetFrameworkFileServerAddress

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:253

↓ 4 callersMethodgetIsUseIpAddress

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Configuration.java:214

↓ 4 callersMethodgetOffer

(Protos.FrameworkID frameworkId)

scheduler/src/test/java/org/apache/mesos/elasticsearch/scheduler/TaskInfoFactoryTest.java:120

↓ 4 callersMethodgetStartedAt

()

scheduler/src/main/java/org/apache/mesos/elasticsearch/scheduler/Task.java:47

next →1–100 of 630, ranked by callers