io.github.retz.mesosc

Class MesosHTTPFetcher

java.lang.Object

io.github.retz.mesosc.MesosHTTPFetcher

public class MesosHTTPFetcher
extends java.lang.Object

A fetcher class that fetches various information from Mesos masters and slaves

Constructor Summary

Constructors

Constructor and Description
MesosHTTPFetcher()

Method Summary

Modifier and Type	Method and Description
static Pair<java.lang.Integer,byte[]>	downloadHTTPFile(java.lang.String url, java.lang.String name)
static java.util.Optional<java.lang.String>	extractContainerId(java.io.InputStream stream, java.lang.String frameworkId, java.lang.String executorId)
static java.util.Optional<java.lang.String>	extractDirectory(java.io.InputStream stream, java.lang.String frameworkId, java.lang.String executorId)
static java.util.Optional<java.lang.String>	extractSlaveAddr(java.io.InputStream stream, java.lang.String slaveId)
static java.util.Optional<java.lang.String>	extractSlaveBasePath(java.io.InputStream stream)
static Pair<java.lang.Integer,java.lang.String>	fetchHTTPDir(java.lang.String url, java.lang.String path)
static Pair<java.lang.Integer,java.lang.String>	fetchHTTPFile(java.lang.String url, java.lang.String name, long offset, long length)
static java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	fetchTasks(java.lang.String master, java.lang.String frameworkId, int offset, int limit)
static java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	parseTasks(java.io.InputStream in, java.lang.String frameworkId)
static java.util.Optional<java.lang.String>	sandboxBaseUri(java.lang.String master, java.lang.String slaveId, java.lang.String frameworkId, java.lang.String executorId)
static java.util.Optional<java.lang.String>	sandboxDownloadUri(java.lang.String master, java.lang.String slaveId, java.lang.String frameworkId, java.lang.String executorId, java.lang.String path)
static java.util.Optional<java.lang.String>	sandboxUri(java.lang.String t, java.lang.String master, java.lang.String slaveId, java.lang.String frameworkId, java.lang.String executorId)
static boolean	statHTTPFile(java.lang.String url, java.lang.String name)

Methods inherited from class java.lang.Object

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

Constructor Detail

MesosHTTPFetcher

public MesosHTTPFetcher()

Method Detail

sandboxBaseUri

public static java.util.Optional<java.lang.String> sandboxBaseUri(java.lang.String master,
                                                                  java.lang.String slaveId,
                                                                  java.lang.String frameworkId,
                                                                  java.lang.String executorId)

sandboxDownloadUri

public static java.util.Optional<java.lang.String> sandboxDownloadUri(java.lang.String master,
                                                                      java.lang.String slaveId,
                                                                      java.lang.String frameworkId,
                                                                      java.lang.String executorId,
                                                                      java.lang.String path)

sandboxUri

public static java.util.Optional<java.lang.String> sandboxUri(java.lang.String t,
                                                              java.lang.String master,
                                                              java.lang.String slaveId,
                                                              java.lang.String frameworkId,
                                                              java.lang.String executorId)

extractSlaveAddr

public static java.util.Optional<java.lang.String> extractSlaveAddr(java.io.InputStream stream,
                                                                    java.lang.String slaveId)
                                                             throws java.io.IOException

Throws:

java.io.IOException

extractSlaveBasePath

public static java.util.Optional<java.lang.String> extractSlaveBasePath(java.io.InputStream stream)
                                                                 throws java.io.IOException

Throws:

java.io.IOException

extractDirectory

public static java.util.Optional<java.lang.String> extractDirectory(java.io.InputStream stream,
                                                                    java.lang.String frameworkId,
                                                                    java.lang.String executorId)
                                                             throws java.io.IOException

Throws:

java.io.IOException

extractContainerId

public static java.util.Optional<java.lang.String> extractContainerId(java.io.InputStream stream,
                                                                      java.lang.String frameworkId,
                                                                      java.lang.String executorId)
                                                               throws java.io.IOException

Throws:

java.io.IOException

fetchTasks

public static java.util.List<java.util.Map<java.lang.String,java.lang.Object>> fetchTasks(java.lang.String master,
                                                                                          java.lang.String frameworkId,
                                                                                          int offset,
                                                                                          int limit)
                                                                                   throws java.net.MalformedURLException

Throws:

java.net.MalformedURLException

parseTasks

public static java.util.List<java.util.Map<java.lang.String,java.lang.Object>> parseTasks(java.io.InputStream in,
                                                                                          java.lang.String frameworkId)
                                                                                   throws java.io.IOException

Throws:

java.io.IOException

downloadHTTPFile

public static Pair<java.lang.Integer,byte[]> downloadHTTPFile(java.lang.String url,
                                                              java.lang.String name)
                                                       throws java.io.IOException

Throws:

java.io.IOException

statHTTPFile

public static boolean statHTTPFile(java.lang.String url,
                                   java.lang.String name)

fetchHTTPFile

public static Pair<java.lang.Integer,java.lang.String> fetchHTTPFile(java.lang.String url,
                                                                     java.lang.String name,
                                                                     long offset,
                                                                     long length)
                                                              throws java.net.MalformedURLException,
                                                                     java.io.IOException

Throws:

java.net.MalformedURLException

java.io.IOException

fetchHTTPDir

public static Pair<java.lang.Integer,java.lang.String> fetchHTTPDir(java.lang.String url,
                                                                    java.lang.String path)
                                                             throws java.net.MalformedURLException,
                                                                    java.io.IOException

Throws:

java.net.MalformedURLException

java.io.IOException