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

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

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

Execution.getPipelineConfigId介绍

暂无

代码示例

代码示例来源: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-redis

try {
 map.put("name", execution.getName());
 map.put("pipelineConfigId", execution.getPipelineConfigId());
 map.put("notifications", mapper.writeValueAsString(execution.getNotifications()));
 map.put("initialConfig", mapper.writeValueAsString(execution.getInitialConfig()));

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

} else if (execution.getType() == PIPELINE) {
 value.put("description", execution.getName());
 value.put("pipelineConfigId", execution.getPipelineConfigId());

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

@Override
public void store(@Nonnull Execution execution) {
 RedisClientDelegate delegate = getRedisDelegate(execution);
 storeExecutionInternal(delegate, execution);
 if (execution.getType() == PIPELINE) {
  delegate.withCommandsClient(c -> {
   c.zadd(executionsByPipelineKey(execution.getPipelineConfigId()),
    execution.getBuildTime() != null ? execution.getBuildTime() : currentTimeMillis(),
    execution.getId()
   );
  });
 }
}

相关文章