com.netflix.spinnaker.orca.pipeline.model.Execution.getApplication()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(4.9k)|赞(0)|评价(0)|浏览(135)

本文整理了Java中com.netflix.spinnaker.orca.pipeline.model.Execution.getApplication()方法的一些代码示例,展示了Execution.getApplication()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Execution.getApplication()方法的具体详情如下:
包路径:com.netflix.spinnaker.orca.pipeline.model.Execution
类名称:Execution
方法名:getApplication

Execution.getApplication介绍

暂无

代码示例

代码示例来源:origin: spinnaker/kayenta

CanaryAnalysisExecutionStatusResponse.CanaryAnalysisExecutionStatusResponseBuilder responseBuilder =
  CanaryAnalysisExecutionStatusResponse.builder()
  .application(pipeline.getApplication())
  .pipelineId(pipeline.getId())
  .stageStatus(pipeline.getStages()

代码示例来源:origin: com.netflix.spinnaker.orca/orca-front50

@Override public void checkRunnable(Execution pipeline) {
 if (front50Service == null) {
  throw new UnsupportedOperationException("Front50 not enabled, no way to validate pipeline. Fix this by setting front50.enabled: true");
 }
 List<Map<String, Object>> pipelines = isStrategy(pipeline) ? front50Service.getStrategies(pipeline.getApplication()) : front50Service.getPipelines(pipeline.getApplication(), false);
 pipelines
  .stream()
  .filter(it -> it.get("id").equals(pipeline.getPipelineConfigId()))
  .findFirst()
  .ifPresent(it -> {
   if ((boolean) it.getOrDefault("disabled", false)) {
    throw new PipelineIsDisabled(it.get("id").toString(), it.get("application").toString(), it.get("name").toString());
   }
  });
}

代码示例来源:origin: com.netflix.spinnaker.orca/orca-core

@Override
public void beforeExecution(Persister persister, Execution execution) {
 if (execution.getApplication() == null) {
  return;
 }
 Id id = registry
  .createId("executions.started")
  .withTag("executionType", execution.getClass().getSimpleName().toLowerCase())
  .withTag("application", execution.getApplication().toLowerCase());
 registry.counter(id).increment();
}

代码示例来源:origin: com.netflix.spinnaker.orca/orca-pipelinetemplate

private String render(String templateString, Execution pipeline) {
 DefaultRenderContext rc = new DefaultRenderContext(pipeline.getApplication(), null, mapper.convertValue(pipeline.getTrigger(), Map.class));
 return renderer.render(templateString, rc);
}

代码示例来源:origin: com.netflix.spinnaker.orca/orca-core

@Override public Object get(@Nullable Object key) {
  Object value = super.get(key);
  if (value != null) {
   log.warn(
    "Global context key \"{}\" accessed by {} {}[{}] \"{}\"",
    key,
    execution.getApplication(),
    execution.getType(),
    execution.getId(),
    Optional.ofNullable(execution.getName()).orElseGet(execution::getDescription)
   );
   Id counterId = registry
    .createId("global.context.access")
    .withTag("application", execution.getApplication())
    .withTag("key", String.valueOf(key));
   registry
    .counter(counterId)
    .increment();
  }
  return value;
 }
}

代码示例来源:origin: com.netflix.spinnaker.orca/orca-clouddriver

value.put("executionId", execution.getId());
value.put("executionType", execution.getType().toString());
value.put("application", execution.getApplication());
  execution.getApplication(),
  account,
  cluster,

代码示例来源:origin: com.netflix.spinnaker.orca/orca-redis

protected Map<String, String> serializeExecution(@Nonnull Execution execution) {
 Map<String, String> map = new HashMap<>();
 try {
  map.put("application", execution.getApplication());
  map.put("canceled", String.valueOf(execution.isCanceled()));
  map.put("limitConcurrent", String.valueOf(execution.isLimitConcurrent()));

代码示例来源:origin: com.netflix.spinnaker.orca/orca-core

@Override
 public void afterExecution(Persister persister,
               Execution execution,
               ExecutionStatus executionStatus,
               boolean wasSuccessful) {
  if (execution.getType() != ORCHESTRATION) {
   // not concerned with pipelines right now (pipelines can have wait stages / manual judgments which skew execution time)
   return;
  }

  if (execution.getApplication() == null || execution.getStartTime() == null || execution.getEndTime() == null) {
   // should normally have all attributes but a guard just in case
   return;
  }

  Id id = registry
   .createId("executions.totalTime")
   .withTag("executionType", "orchestration")
   .withTag("successful", Boolean.valueOf(wasSuccessful).toString())
   .withTag("application", execution.getApplication().toLowerCase());

  registry.timer(id).record(execution.getEndTime() - execution.getStartTime(), TimeUnit.MILLISECONDS);
 }
}

代码示例来源:origin: com.netflix.spinnaker.orca/orca-redis

.createId("executions.deserialization.error")
.withTag("executionType", execution.getType().toString())
.withTag("application", execution.getApplication());

代码示例来源:origin: com.netflix.kayenta/kayenta-standalone-canary-analysis

CanaryAnalysisExecutionStatusResponse.CanaryAnalysisExecutionStatusResponseBuilder responseBuilder =
  CanaryAnalysisExecutionStatusResponse.builder()
  .application(pipeline.getApplication())
  .pipelineId(pipeline.getId())
  .stageStatus(pipeline.getStages()

代码示例来源:origin: com.netflix.spinnaker.orca/orca-redis

c.sadd(appKey(execution.getType(), execution.getApplication()), execution.getId());

相关文章