io.github.retz.web

Class ClientHelper

java.lang.Object

io.github.retz.web.ClientHelper

public class ClientHelper
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ClientHelper()

Method Summary

Modifier and Type	Method and Description
static boolean	fileExists(Client c, int id, java.lang.String filename)
static java.util.List<Job>	finished(Client c)
static void	getWholeBinaryFile(Client c, int id, java.lang.String path, java.io.OutputStream out)
static void	getWholeBinaryFile(Client c, int id, java.lang.String path, java.lang.String output)
static java.util.Optional<Job>	getWholeFile(Client c, int id, java.lang.String filename, boolean poll, java.io.OutputStream out)
static void	getWholeFile(Client c, int id, java.lang.String filename, java.lang.String resultDir)
static java.util.Optional<Job>	getWholeFileWithTerminator(Client c, int id, java.lang.String filename, boolean poll, java.io.OutputStream out, java.util.concurrent.Callable<java.lang.Boolean> terminate)
static java.util.Optional<Job>	getWholeFileWithTerminator(Client c, int id, java.lang.String filename, boolean poll, java.io.OutputStream out, long offset, java.util.concurrent.Callable<java.lang.Boolean> terminator)
static void	getWholeFileWithTerminator(Client c, int id, java.lang.String filename, java.lang.String resultDir, java.util.concurrent.Callable<java.lang.Boolean> terminator)
static void	maybeSleep(int millis)
static java.util.List<Job>	queue(Client c)
static java.util.List<Job>	running(Client c)
static Job	waitForStart(Job job, Client c, java.util.concurrent.Callable<java.lang.Boolean> terminate)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClientHelper

public ClientHelper()

Method Detail

queue

public static java.util.List<Job> queue(Client c)
                                 throws java.io.IOException

Throws:

java.io.IOException

running

public static java.util.List<Job> running(Client c)
                                   throws java.io.IOException

Throws:

java.io.IOException

finished

public static java.util.List<Job> finished(Client c)
                                    throws java.io.IOException

Throws:

java.io.IOException

fileExists

public static boolean fileExists(Client c,
                                 int id,
                                 java.lang.String filename)
                          throws java.io.IOException

Throws:

java.io.IOException

getWholeFile

public static void getWholeFile(Client c,
                                int id,
                                java.lang.String filename,
                                java.lang.String resultDir)
                         throws java.io.IOException

Throws:

java.io.IOException

getWholeFileWithTerminator

public static void getWholeFileWithTerminator(Client c,
                                              int id,
                                              java.lang.String filename,
                                              java.lang.String resultDir,
                                              java.util.concurrent.Callable<java.lang.Boolean> terminator)
                                       throws java.io.IOException,
                                              java.util.concurrent.TimeoutException

Throws:

java.io.IOException

java.util.concurrent.TimeoutException

getWholeFile

public static java.util.Optional<Job> getWholeFile(Client c,
                                                   int id,
                                                   java.lang.String filename,
                                                   boolean poll,
                                                   java.io.OutputStream out)
                                            throws JobNotFoundException,
                                                   java.io.IOException

Throws:

JobNotFoundException

java.io.IOException

getWholeFileWithTerminator

public static java.util.Optional<Job> getWholeFileWithTerminator(Client c,
                                                                 int id,
                                                                 java.lang.String filename,
                                                                 boolean poll,
                                                                 java.io.OutputStream out,
                                                                 java.util.concurrent.Callable<java.lang.Boolean> terminate)
                                                          throws java.io.IOException,
                                                                 JobNotFoundException,
                                                                 java.util.concurrent.TimeoutException

Throws:

java.io.IOException

JobNotFoundException

java.util.concurrent.TimeoutException

getWholeFileWithTerminator

public static java.util.Optional<Job> getWholeFileWithTerminator(Client c,
                                                                 int id,
                                                                 java.lang.String filename,
                                                                 boolean poll,
                                                                 java.io.OutputStream out,
                                                                 long offset,
                                                                 java.util.concurrent.Callable<java.lang.Boolean> terminator)
                                                          throws java.io.IOException,
                                                                 JobNotFoundException,
                                                                 java.util.concurrent.TimeoutException

Throws:

java.io.IOException

JobNotFoundException

java.util.concurrent.TimeoutException

getWholeBinaryFile

public static void getWholeBinaryFile(Client c,
                                      int id,
                                      java.lang.String path,
                                      java.lang.String output)
                               throws java.io.IOException

Throws:

java.io.IOException

getWholeBinaryFile

public static void getWholeBinaryFile(Client c,
                                      int id,
                                      java.lang.String path,
                                      java.io.OutputStream out)
                               throws java.io.IOException

Throws:

java.io.IOException

waitForStart

public static Job waitForStart(Job job,
                               Client c,
                               java.util.concurrent.Callable<java.lang.Boolean> terminate)
                        throws java.io.IOException,
                               java.util.concurrent.TimeoutException

Throws:

java.io.IOException

java.util.concurrent.TimeoutException

maybeSleep

public static void maybeSleep(int millis)