本文整理了Java中org.apache.brooklyn.util.text.Strings.getFirstWordAfter()
方法的一些代码示例,展示了Strings.getFirstWordAfter()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Strings.getFirstWordAfter()
方法的具体详情如下:
包路径:org.apache.brooklyn.util.text.Strings
类名称: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() );
内容来源于网络,如有侵权,请联系作者删除!