@Test(groups="Integration") public void testSshFetch() throws IOException { String fn = Urls.mergePaths(tempDir.getPath(), "f2"); FileUtils.write(new File(fn), "hello fetched world"); SshFetchTaskWrapper t = submit(SshEffectorTasks.fetch(fn)); t.block(); Assert.assertTrue(t.isDone()); Assert.assertEquals(t.get(), "hello fetched world"); }
public static SshFetchEffectorTaskFactory fetch(String remoteFile) { return new SshFetchEffectorTaskFactory(remoteFile); }
SshEffectorTasks { public static SshFetchEffectorTaskFactory fetch(String remoteFile) { return new SshFetchEffectorTaskFactory(remoteFile); } }
SshEffectorTasks { public static SshFetchEffectorTaskFactory fetch(String remoteFile) { return new SshFetchEffectorTaskFactory(remoteFile); }  }
SshEffectorTasks { public static SshFetchEffectorTaskFactory fetch(String remoteFile) { return new SshFetchEffectorTaskFactory(remoteFile); }  static SshEffectorTaskFactory<Integer> ssh(SshMachineLocation machine, String ...commands); static SshEffectorTaskFactory<Integer> ssh(String ...commands); static SshEffectorTaskFactory<Integer> ssh(List<String> commands); static SshPutTaskFactory put(String remoteFile); static SshFetchEffectorTaskFactory fetch(String remoteFile); static SshEffectorTaskFactory<Integer> codePidRunning(Integer pid); static SshEffectorTaskFactory<?> requirePidRunning(Integer pid); static SshEffectorTaskFactory<Boolean> isPidRunning(Integer pid); static SshEffectorTaskFactory<Integer> codePidFromFileRunning(final String pidFile); static SshEffectorTaskFactory<?> requirePidFromFileRunning(String pidFile); static SshEffectorTaskFactory<Boolean> isPidFromFileRunning(String pidFile); @Beta static Map<String, Object> getSshFlags(Entity entity, Location optionalLocation); }
SshEffectorTasks { public static SshFetchEffectorTaskFactory fetch(String remoteFile) { return new SshFetchEffectorTaskFactory(remoteFile); }  static SshEffectorTaskFactory<Integer> ssh(SshMachineLocation machine, String ...commands); static SshEffectorTaskFactory<Integer> ssh(String ...commands); static SshEffectorTaskFactory<Integer> ssh(List<String> commands); static SshPutTaskFactory put(String remoteFile); static SshFetchEffectorTaskFactory fetch(String remoteFile); static SshEffectorTaskFactory<Integer> codePidRunning(Integer pid); static SshEffectorTaskFactory<?> requirePidRunning(Integer pid); static SshEffectorTaskFactory<Boolean> isPidRunning(Integer pid); static SshEffectorTaskFactory<Integer> codePidFromFileRunning(final String pidFile); static SshEffectorTaskFactory<?> requirePidFromFileRunning(String pidFile); static SshEffectorTaskFactory<Boolean> isPidFromFileRunning(String pidFile); @Beta static Map<String, Object> getSshFlags(Entity entity, Location optionalLocation); static final ConfigKey<Boolean> IGNORE_ENTITY_SSH_FLAGS; }