本文整理了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
暂无
代码示例来源: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());
内容来源于网络,如有侵权,请联系作者删除!