org.apache.brooklyn.util.text.Strings.getFirstWordAfter()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(6.6k)|赞(0)|评价(0)|浏览(113)

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

Strings.getFirstWordAfter介绍

[英]returns the first word after the given phrase, or null if no such phrase; if the character immediately after the phrase is not whitespace, the non-whitespace sequence starting with that character will be returned
[中]返回给定短语后的第一个单词,如果没有此类短语,则返回null;如果短语后面的字符不是空格,则返回以该字符开头的非空格序列

代码示例

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

@Override
  public Double apply(SshPollValue input) {
    String q = Strings.getFirstWordAfter(input.getStdout(), "Queries per second avg:");
    return (q == null) ? null : Double.parseDouble(q);
  }})
.setOnFailureOrException(null) )

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

@Override
  public Double apply(SshPollValue input) {
    String loadAverage = Strings.getFirstWordAfter(input.getStdout(), "load average:").replace(",", "");
    return Double.valueOf(loadAverage);
  }
}))

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

@Override
  public Double apply(SshPollValue input) {
    String q = Strings.getFirstWordAfter(input.getStdout(), "Queries per second avg:");
    if (q==null) return null;
    return Double.parseDouble(q);
  }})
.setOnFailureOrException(null)

代码示例来源:origin: io.brooklyn.clocker/brooklyn-clocker-docker

@Override
public Optional<String> getImageNamed(String name, String tag) {
  String imageList = runDockerCommand("images --no-trunc " + name);
  return Optional.fromNullable(Strings.getFirstWordAfter(imageList, tag));
}

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

@Test
public void testFirstWordAfter() {
  Assert.assertEquals(Strings.getFirstWordAfter("hello world", "hello"), "world");
  Assert.assertEquals(Strings.getFirstWordAfter("   hello world", "hello"), "world");
  Assert.assertEquals(Strings.getFirstWordAfter("   hello world: is not enough", "world:"), "is");
  Assert.assertEquals(Strings.getFirstWordAfter("   hello world: is not enough", "world"), ":");
  Assert.assertEquals(Strings.getFirstWordAfter("   hello   ", "hello"), null);
  Assert.assertEquals(Strings.getFirstWordAfter("hello", "hello"), null);
  Assert.assertEquals(Strings.getFirstWordAfter("  ", "x"), null);
  Assert.assertEquals(Strings.getFirstWordAfter("", "x"), null);
  Assert.assertEquals(Strings.getFirstWordAfter(null, "x"), null);
}

代码示例来源:origin: io.brooklyn.clocker/brooklyn-clocker-docker

private String buildDockerfile(String dockerfile, String name) {
  String build = format("build --rm -t %s - < %s",
      name, Os.mergePaths(getRunDir(), name, dockerfile));
  String stdout = ((DockerHost) getEntity()).runDockerCommandTimeout(build, Duration.minutes(20));
  String prefix = Strings.getFirstWordAfter(stdout, "Successfully built");
  return getImageId(prefix, name);
}

代码示例来源:origin: io.brooklyn.clocker/brooklyn-clocker-docker

private String buildDockerfileDirectory(String name) {
  String build = format("build --rm -t %s %s",
      name, Os.mergePaths(getRunDir(), name));
  String stdout = ((DockerHost) getEntity()).runDockerCommandTimeout(build, Duration.minutes(20));
  String prefix = Strings.getFirstWordAfter(stdout, "Successfully built");
  return getImageId(prefix, name);
}

代码示例来源:origin: io.brooklyn.clocker/brooklyn-clocker-mesos

String dockerIp = Strings.getFirstWordAfter(dockerIpOutput.replace('/', ' '), "inet");
String inspect = Strings.trimEnd(slave.execCommand(sudo("docker inspect -f '{{.State.Pid}}' " + containerId)));
String dockerPid = Iterables.find(Splitter.on(CharMatcher.anyOf("\r\n")).omitEmptyStrings().split(inspect),
Cidr subnetCidr = getSubnetCidr(subnetId);
String slaveAddressOutput = slave.execCommand(sudo("ip addr show dev eth0 scope global label eth0"));
String slaveAddress = Strings.getFirstWordAfter(slaveAddressOutput.replace('/', ' '), "inet");

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

private Long getRunTimeUtc(VanillaSoftwareProcess p) {
  Assert.assertNotNull(p.getAttribute(SoftwareProcess.RUN_DIR));
  return Long.parseLong( Strings.getFirstWordAfter(new ResourceUtils(this).getResourceAsString(Os.mergePaths(p.getAttribute(SoftwareProcess.RUN_DIR), "DATE")), "utc") );
}

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

@Override public boolean apply(Application app) {
    VanillaWindowsProcess entity = Iterables.getOnlyElement(Entities.descendantsAndSelf(app, VanillaWindowsProcess.class));
    String winRMAddress = entity.getAttribute(AdvertiseWinrmLoginPolicy.VM_USER_CREDENTIALS); 
    String ipPort = Strings.getFirstWordAfter(winRMAddress, "@");
    String user = Strings.getFirstWord(winRMAddress);
    String password = Strings.getFirstWordAfter(winRMAddress, ":");
    
    WinRmTool winRmTool = WinRmTool.Builder.builder(ipPort, user, password).build();
    WinRmToolResponse winRmResponse = winRmTool.executePs(ImmutableList.of("(Get-Item \"C:\\\\Program Files\\\\7-Zip\\\\7z.exe\").name"));
    
    LOG.info("winRmResponse: code="+winRmResponse.getStatusCode()+"; out="+winRmResponse.getStdOut()+"; err="+winRmResponse.getStdErr());
    return "7z.exe\r\n".equals(winRmResponse.getStdOut());
  }
};

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

/** yaml variant of VanillaSoftwareProcessAndChildrenIntegrationTest */
@Test(groups="Integration")
public void testVanillaSoftwareYamlWithChildStartedAfter() {
  SimpleYamlLauncher l = new SimpleYamlLauncherForTests();
  try {
    Application app = l.launchAppYaml("vanilla-software-with-child-blueprint.yaml");
    log.info("started "+app);
    Entity p1 = Iterables.getOnlyElement( app.getChildren() );
    Long d1 = Long.parseLong( Strings.getFirstWordAfter(new ResourceUtils(this).getResourceAsString(Os.mergePaths(p1.getAttribute(SoftwareProcess.RUN_DIR), "DATE")), "utc") );
    
    Entity p2 = Iterables.getOnlyElement( p1.getChildren() );
    Long d2 = Long.parseLong( Strings.getFirstWordAfter(new ResourceUtils(this).getResourceAsString(Os.mergePaths(p2.getAttribute(SoftwareProcess.RUN_DIR), "DATE")), "utc") );
    Assert.assertTrue( d2-d1 > 2 && d2-d1 < 10, "p2 should have started 3s after parent, but it did not ("+(d2-d1)+"s difference" );
  } finally {
    l.destroyAll();
  }
  log.info("DONE");
}

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

Long d1 = Long.parseLong( Strings.getFirstWordAfter(fileContents, "utc") );
Assert.assertTrue( Math.abs(d1*1000-System.currentTimeMillis())<15000, "Time UTC does not match system; "+d1+" v "+System.currentTimeMillis() );

相关文章