Package org.jgroups.protocols.kubernetes

Class Utils

java.lang.Object

org.jgroups.protocols.kubernetes.Utils

public final class Utils
extends Object

Author:

Ales Justin

Method Summary

Modifier and Type	Method	Description
static <V> V	execute(Callable<V> callable, int attempts, long sleep)
static <V> V	execute(Callable<V> callable, int attempts, long sleep, boolean throwOnFail)
static String	getSystemEnv(String key)
static String	getSystemEnv(String key, String def)
static String	getSystemEnv(String key, String def, boolean trimToNull)
static String	getSystemProperty(String key, String def)
static String	getSystemProperty(String key, String def, boolean trimToNull)
static InputStream	openFile(String name)
static InputStream	openStream(String url, Map<String,String> headers, int connectTimeout, int readTimeout, int attempts, long sleep, StreamProvider streamProvider)
static String	readFileToString(File file)
static String	readFileToString(String name)
static Map<String,String>	sanitizeHttpHeaders(Map<String,String> headers)	Sanitizes a map of HTTP headers - all entries where the key equals "Authorization" (case-insensitive) are overridden to mask the original authorization data.
static String	trimToNull(String s)
static String	urlencode(String s)

Methods inherited from class java.lang.Object

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

Method Details

openStream

public static InputStream openStream(String url,
 Map<String,String> headers,
 int connectTimeout,
 int readTimeout,
 int attempts,
 long sleep,
 StreamProvider streamProvider)
                              throws Exception

Throws:

Exception

openFile

public static InputStream openFile(String name)
                            throws FileNotFoundException

Throws:

FileNotFoundException

readFileToString

public static String readFileToString(String name)
                               throws IOException

Throws:

IOException

readFileToString

public static String readFileToString(File file)
                               throws IOException

Throws:

IOException

getSystemProperty

public static String getSystemProperty(String key,
 String def)

getSystemProperty

public static String getSystemProperty(String key,
 String def,
 boolean trimToNull)

getSystemEnv

public static String getSystemEnv(String key)

getSystemEnv

public static String getSystemEnv(String key,
 String def)

getSystemEnv

public static String getSystemEnv(String key,
 String def,
 boolean trimToNull)

trimToNull

public static String trimToNull(String s)

urlencode

public static String urlencode(String s)

execute

public static <V> V execute(Callable<V> callable,
 int attempts,
 long sleep)

execute

public static <V> V execute(Callable<V> callable,
 int attempts,
 long sleep,
 boolean throwOnFail)
                     throws Exception

Throws:

Exception

sanitizeHttpHeaders

public static Map<String,String> sanitizeHttpHeaders(Map<String,String> headers)

Sanitizes a map of HTTP headers - all entries where the key equals "Authorization" (case-insensitive) are overridden to mask the original authorization data.

Parameters:

headers - HTTP header map

Returns:

map where all "Authorization" entries are masked