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 void	close(AutoCloseable cl)
static final <V> V	execute(Callable<V> callable, int attempts, long sleep)
static final <V> V	execute(Callable<V> callable, int attempts, long sleep, boolean throwOnFail)
static final String	getSystemEnv(String key)
static final String	getSystemEnv(String key, String def)
static final String	getSystemEnv(String key, String def, boolean trimToNull)
static final String	getSystemProperty(String key, String def)
static final String	getSystemProperty(String key, String def, boolean trimToNull)
static final InputStream	openFile(String name)
static final InputStream	openStream(String url, Map<String,String> headers, int connectTimeout, int readTimeout, int attempts, long sleep, StreamProvider streamProvider)
static final String	readFileToString(File file)
static final 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 final String	trimToNull(String s)
static final 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 final 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 final InputStream openFile(String name)
                                  throws FileNotFoundException

Throws:

FileNotFoundException

readFileToString

public static final String readFileToString(String name)
                                     throws IOException

Throws:

IOException

readFileToString

public static final String readFileToString(File file)
                                     throws IOException

Throws:

IOException

getSystemProperty

public static final String getSystemProperty(String key,
 String def)

getSystemProperty

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

getSystemEnv

public static final String getSystemEnv(String key)

getSystemEnv

public static final String getSystemEnv(String key,
 String def)

getSystemEnv

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

trimToNull

public static final String trimToNull(String s)

urlencode

public static final String urlencode(String s)

execute

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

execute

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

Throws:

Exception

close

public static void close(AutoCloseable cl)

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