gpt4 book ai didi

org.apache.brooklyn.util.yaml.Yamls类的使用及代码示例

转载 作者:知者 更新时间:2024-03-15 14:28:40 26 4
gpt4 key购买 nike

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

Yamls介绍

暂无

代码示例

代码示例来源:origin: org.apache.brooklyn/brooklyn-core

public static Map<?,?> getCatalogMetadata(String yaml) {
  Map<?,?> itemDef = Yamls.getAs(Yamls.parseAll(yaml), Map.class);
  return getFirstAsMap(itemDef, "brooklyn.catalog").orNull();        
}

代码示例来源:origin: io.cloudsoft.brooklyn.tosca/brooklyn-tosca-transformer

@SuppressWarnings("unchecked")
public static Iterable<String> getDefaultTypes() {
  String input = new ResourceUtils(null).getResourceAsString(CONFIG_URL);
  return (List) Yamls.getAt(input, ImmutableList.of("defaultTypes"));
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

@SuppressWarnings("rawtypes")
public static void dump(int depth, Object r) {
  if (r instanceof Iterable) {
    for (Object ri : ((Iterable)r))
      dump(depth+1, ri);
  } else if (r instanceof Map) {
    for (Object re: ((Map)r).entrySet()) {
      for (int i=0; i<depth; i++) System.out.print(" ");
      System.out.println(((Entry)re).getKey()+":");
      dump(depth+1, ((Entry)re).getValue());
    }
  } else {
    for (int i=0; i<depth; i++) System.out.print(" ");
    if (r==null) System.out.println("<null>");
    else System.out.println("<"+r.getClass().getSimpleName()+">"+" "+r);
  }
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

/** simplifies new Yaml().loadAll, and converts to list to prevent single-use iterable bug in yaml */
@SuppressWarnings("unchecked")
public static Iterable<Object> parseAll(String yaml) {
  Iterable<Object> result = newYaml().loadAll(yaml);
  return getAs(result, List.class);
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-core

public static CompoundTransformer load(String contents) {
  CompoundTransformer.Builder builder = CompoundTransformer.builder();
  Iterable<Object> toplevel = Yamls.parseAll(contents);
  Collection<?> rules = (Collection<?>)Iterables.getOnlyElement(toplevel);
  for (Object obj : rules) {
    Map<?, ?> map = (Map<?, ?>)obj;
    Entry<?, ?> entry = Iterables.getOnlyElement(map.entrySet());
    addRule(builder, (String)entry.getKey(), (Map<?, ?>)entry.getValue());
  }
  LOG.info("Loaded " + rules.size() + " transforms");
  return builder.build();
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-core

List<CatalogItemDtoAbstract<?, ?>> resultLegacyFormat, Map<RegisteredType, RegisteredType> resultNewFormat, 
  boolean requireValidation, Map<?, ?> parentMeta, int depth, boolean force) {
Map<?,?> itemDef = Yamls.getAs(Yamls.parseAll(yaml), Map.class);
Map<?,?> catalogMetadata = getFirstAsMap(itemDef, "brooklyn.catalog").orNull();
if (catalogMetadata==null)
catalogMetadata = MutableMap.copyOf(catalogMetadata);
collectCatalogItemsFromItemMetadataBlock(Yamls.getTextOfYamlAtPath(yaml, "brooklyn.catalog").getMatchedYamlTextOrWarn(), 
  containingBundle, catalogMetadata, resultLegacyFormat, resultNewFormat, requireValidation, parentMeta, 0, force);
  Map<String,?> rootItem = MutableMap.of("item", itemDef);
  String rootItemYaml = yaml;
  YamlExtract yamlExtract = Yamls.getTextOfYamlAtPath(rootItemYaml, "brooklyn.catalog");
  String match = yamlExtract.withOriginalIndentation(true).withKeyIncluded(true).getMatchedYamlTextOrWarn();
  if (match!=null) {

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

@Test
public void testGetAs() throws Exception {
  MutableList<String> list = MutableList.of("x");
  assertEquals(Yamls.getAs(list.iterator(), List.class), list);
  assertEquals(Yamls.getAs(list.iterator(), Iterable.class), list);
  assertEquals(Yamls.getAs(list.iterator(), Iterator.class), list.iterator());
  assertEquals(Yamls.getAs(list.iterator(), String.class), "x");
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

@Test
public void testReplace() {
  Assert.assertEquals(Yamls.getTextOfYamlAtPath("x: a\n bc", "x").getFullYamlTextWithExtractReplaced("\nc: 1\nd: 2"),
    "x: \n   c: 1\n   d: 2");
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

Object input = Iterables.getOnlyElement( Yamls.parseAll(range) );
if (input instanceof Iterable) return LinearRangeQuorumCheck.of(name, (Iterable)input);
throw new IllegalArgumentException("Invalid input to linear range quorum check; should be a list of points (not '"+range+"')");

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

/** as {@link #parseAll(String)} */
@SuppressWarnings("unchecked")
public static Iterable<Object> parseAll(Reader yaml) {
  Iterable<Object> result = newYaml().loadAll(yaml);
  return getAs(result, List.class);
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

@Test
public void testExtractMapWithOddWhitespace() {
  Assert.assertEquals(Yamls.getTextOfYamlAtPath("x: a\n bc", "x").getMatchedYamlText(),
    "a\n bc");
}

代码示例来源:origin: org.apache.brooklyn.camp/camp-base

@SuppressWarnings("unchecked")
public DeploymentPlan parseDeploymentPlan(String yaml) {
  Iterable<Object> template = Yamls.parseAll(yaml);
  
  Map<String, Object> dpRootUninterpreted = null;
  try {
    dpRootUninterpreted = Yamls.getAs(template, Map.class);
  } catch (Exception e) {
    Exceptions.propagateIfFatal(e);
    throw new YAMLException("Plan not in acceptable format: "+(e.getMessage()!=null ? e.getMessage() : ""+e), e);
  }
  Map<String, Object> dpRootInterpreted = applyInterpreters(dpRootUninterpreted);
  
  return DeploymentPlan.of(dpRootInterpreted, yaml);
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-core

raw = Yamls.parseAll((String)raw).iterator().next();

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

@Test
public void testExtractMapIgnoringPreviousComments() {
  String sample = "a: 1 # one\n"
    + "b: 2 # two";
  Assert.assertEquals(Yamls.getTextOfYamlAtPath(sample, "b").getMatchedYamlText(),
    "2 # two");
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

@Test
public void testGetAt() throws Exception {
  // leaf of map
  assertEquals(Yamls.getAt("k1: v", ImmutableList.of("k1")), "v");
  assertEquals(Yamls.getAt("k1: {k2: v}", ImmutableList.of("k1", "k2")), "v");
  
  // get list
  assertEquals(Yamls.getAt("k1: [v1, v2]", ImmutableList.<String>of("k1")), ImmutableList.of("v1", "v2"));
  // get map
  assertEquals(Yamls.getAt("k1: v", ImmutableList.<String>of()), ImmutableMap.of("k1", "v"));
  assertEquals(Yamls.getAt("k1: {k2: v}", ImmutableList.of("k1")), ImmutableMap.of("k2", "v"));
  
  // get array index
  assertEquals(Yamls.getAt("k1: [v1, v2]", ImmutableList.<String>of("k1", "[0]")), "v1");
  assertEquals(Yamls.getAt("k1: [v1, v2]", ImmutableList.<String>of("k1", "[1]")), "v2");
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

return Yamls.getAs( Yamls.parseAll(input), Map.class );
} catch (Exception e) {
  Exceptions.propagateIfFatal(e);

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

public static QuorumCheck of(String nameOrRange) {
  if (nameOrRange==null) return null;
  for (QuorumCheck qc: NAMED_CHECKS) {
    if (qc instanceof NumericQuorumCheck) {
      if (Objects.equal(nameOrRange, ((NumericQuorumCheck)qc).getName()))
        return qc;
    }
  }
  // parse YAML
  Object input = Iterables.getOnlyElement( Yamls.parseAll(nameOrRange) );
  if (input instanceof Collection) return of((Collection<?>)input);
  if (input instanceof Integer || input instanceof Long) return of((int)((Number)input));
  // TODO also accept "50%", and "50%,1"
  throw new IllegalArgumentException("Unknown quorum check format '"+input+"'");
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-utils-common

@Test
public void testExtractNoOOBE() {
  // this might log a warning, as item not found, but won't throw
  YamlExtract r1 = Yamls.getTextOfYamlAtPath(
    "items:\n- id: sample2\n  itemType: location\n  item:\n    type: jclouds:aws-ec2\n    brooklyn.config:\n      key2: value2\n\n",
    "item");
  
  // won't throw
  r1.getMatchedYamlTextOrWarn();
  // will throw
  try {
    r1.getMatchedYamlText();
    Assert.fail();
  } catch (UserFacingException e) {
    // expected, it should give a vaguely explanatory exception and no trace
  }
}

代码示例来源:origin: org.apache.brooklyn.camp/camp-base

@SuppressWarnings("unchecked")
public void testToyInterpreter() {
  @SuppressWarnings("rawtypes")
  Map y1 = Yamls.getAs( Yamls.parseAll( Streams.reader(getClass().getResourceAsStream("yaml-sample-toy-interpreter.yaml"))), Map.class );
  log.info("pre-interpreter have: "+y1);
  
  BasicCampPlatform p = new BasicCampPlatform();
  p.pdp().addInterpreter(new ToyInterpreter());
  Map<String, Object> y2 = p.pdp().applyInterpreters(y1);
  log.info("interpreter gives: "+y2);
  
  Map<String, Object> y3 = Yamls.getAs( Yamls.parseAll( Streams.reader(getClass().getResourceAsStream("yaml-sample-toy-interpreter-result.yaml"))), Map.class );
  Assert.assertEquals(y2, y3);
}

代码示例来源:origin: org.apache.brooklyn/brooklyn-rest-resources

@Override
@Beta
public Response createFromUpload(byte[] item, boolean forceUpdate) {
  Throwable yamlException = null;
  try {
    MutableList.copyOf( Yamls.parseAll(new InputStreamReader(new ByteArrayInputStream(item))) );
  } catch (Exception e) {
    Exceptions.propagateIfFatal(e);
    yamlException = e;
  }
  
  if (yamlException==null) {
    // treat as yaml if it parsed
    return createFromYaml(new String(item), forceUpdate);
  }
  
  return createFromArchive(item, false, forceUpdate);
}

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com