Package com.elastisys.scale.cloudadapers.api.types

Examples of com.elastisys.scale.cloudadapers.api.types.Machine

47
48
49
50
51
52
53
54
    if (privateIp != null) {
      privateIps.add(privateIp);
    }

    JsonObject metadata = JsonUtils.toJson(instance).getAsJsonObject();
    return new Machine(id, state, launchtime, publicIps, privateIps,
        metadata);
  }
View Full Code Here
81
82
83
84
85
86
87
88
      } else {
        publicIps.add(ip);
      }
    }
    JsonElement metadata = JsonUtils.toJson(server);
    return new Machine(server.getId(), state, launchTime, publicIps,
        privateIps, metadata);
  }
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
    checkArgument(terminationCandidates.size() >= numVictims,
        "more victims (%s) than eligble termination candidates (%s)",
        numVictims, terminationCandidates.size());
    for (int i = 0; i < numVictims; i++) {
      // use victim selection strategy to pick a victim
      Machine victim = this.victimSelectionStrategy
          .selectVictim(terminationCandidates);
      victims.add(victim);
      terminationCandidates.remove(victim);
    }
View Full Code Here
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
   *
   * @param livenessTestResult
   */
  private void updateStateAndAlertOnChange(
      LivenessTestResult livenessTestResult) {
    Machine machine = livenessTestResult.getMachine();
    LivenessState newState = livenessTestResult.getState();

    String id = machine.getId();
    LivenessState previousState = this.livenessObservations.get(id);
    this.livenessObservations.put(machine.getId(), newState);

    if ((previousState == null) || (previousState != newState)) {
      LivenessStateChange livenessChange = new LivenessStateChange(
          machine, previousState, newState);
      LOG.info("liveness state change: " + livenessChange);
View Full Code Here
214
215
216
217
218
219
220
221
222
223
224
      this.livenessCheckTask = livenessTestTask;
    }

    @Override
    public LivenessTestResult call() throws Exception {
      Machine machine = this.livenessCheckTask.getMachine();

      LivenessTestResult result = null;
      try {
        SshCommandResult commandResult = this.livenessCheckTask.call();
        LivenessState state = (commandResult.getExitStatus() == 0) ? LivenessState.LIVE
View Full Code Here
57
58
59
60
61
62
63
64
    if (privateIp != null) {
      privateIps.add(privateIp);
    }

    JsonObject metadata = JsonUtils.toJson(instance).getAsJsonObject();
    return new Machine(id, state, launchtime, publicIps, privateIps,
        metadata);
  }
View Full Code Here
130
131
132
133
134
135
136
137
138
139
140
      List<Machine> requestedInstances = Lists.newArrayList();
      int missingInstances = desiredCapacity - actualCapacity;
      if (missingInstances > 0) {
        for (int i = 1; i <= missingInstances; i++) {
          String pseudoId = String.format("i-requested%d", i);
          requestedInstances.add(new Machine(pseudoId,
              MachineState.REQUESTED, null, null, null, null));
        }
      }

      // retrieve all scaling group members
View Full Code Here
TOP

Related Classes of com.elastisys.scale.cloudadapers.api.types.Machine

  • com.elastisys.scale.cloudadapters.aws.autoscaling.scalinggroup.AwsAsScalingGroup
  • com.elastisys.scale.cloudadapters.aws.commons.functions.InstanceToMachine
  • com.elastisys.scale.cloudadapters.aws.ec2.functions.InstanceToMachine
  • com.elastisys.scale.cloudadapters.commons.adapter.liveness.impl.NotifyingLivenessTracker
  • com.elastisys.scale.cloudadapters.commons.adapter.liveness.impl.NotifyingLivenessTracker$LivenessCheckRunner
  • com.elastisys.scale.cloudadapters.commons.scaledown.VictimSelector
  • com.elastisys.scale.cloudadapters.openstack.functions.ServerToMachine
  • com.google.gson.JsonObject
  • org.joda.time.DateTime
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.