Skip to content

Instantly share code, notes, and snippets.

View yaronp68's full-sized avatar

Yaron Parasol yaronp68

  • Redis
  • London
View GitHub Profile
@yaronp68
yaronp68 / es-local-remote-cluster.md
Created December 4, 2018 14:14 — forked from sebelga/es-local-remote-cluster.md
Configure and launch a local Elasticsearch Remote Cluster (for development)

Setup

You'll need to build from source. For that we will use gradle (https://gradle.org/).

Prerequisite

Make sure that your JAVA_HOME environment variable is set by running:

$ echo $JAVA_HOME
service {
name "groovy"
type "WEB_SERVER"
elastic true
numInstances 2
maxAllowedInstances 2
// define SLA requirements for each service instance with regards to isolation from other services
// if this is not defined - defaults to dedicated mode. which means each service instance is insalled on a dedicated VM.
isolationSLA {
templates ([
SMALL_LINUX_32 : template{
machineMemoryMB 1600
custom ([
"nodesList" : ([
([
"id" : "byon-pc-lab",
"ip" : "192.168.9.59"
]),
templates ([
SMALL_LINUX_32 : template {
imageId "221"
machineMemoryMB 1600
hardwareId "100"
}
])
cloud {
name = "openstack"
configuration {
className "org.cloudifysource.clouds.openstack.OpenstackProvisioningDriver"
managementMachineTemplate "SMALL_LINUX_32"
connectToPrivateIp true
}
<repository>
<id>org.cloudifysource</id>
<url>http://maven-repository.cloudifysource.org</url>
</repository>
<dependency>
<groupId>org.cloudifysource</groupId>
<artifactId>esc</artifactId>
<version>${cloudifyVersion}</version>
</dependency>
<properties>
< cloudifyVersion >2.0.1</cloudifyVersion >
</properties>
@Override
public void stopManagementMachines()
throws TimeoutException, CloudProvisioningException {
final String token = createAuthenticationToken();
final long endTime = calcEndTimeInMillis(
DEFAULT_SHUTDOWN_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS);
List<Node> nodes;
try {
nodes = listServers(token);
try {
service.path(
this.pathPrefix + "servers/" + serverId).header(
"X-Auth-Token", token).accept(
MediaType.APPLICATION_XML).delete();
} catch (final UniformInterfaceException e) {
throw new IllegalArgumentException(e);
}