Package org.jgroups.protocols.kubernetes.stream

Class TokenStreamProvider

java.lang.Object

org.jgroups.protocols.kubernetes.stream.BaseStreamProvider

org.jgroups.protocols.kubernetes.stream.TokenStreamProvider

All Implemented Interfaces:

StreamProvider

public class TokenStreamProvider
extends BaseStreamProvider

Copied and adapted version from openshift-ping repository. A warning message is issued if ca cert file is undefined or not found rather than always using insecure stream or being mandatory and eventually failing. Token refresh is modeled after approach in io.fabric8.kubernetes.client.utils.TokenRefreshInterceptor.

Author:

Ricardo Martinelli, Radoslav Husar

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AUTHORIZATION

Constructor Summary

Constructors

Constructor	Description
TokenStreamProvider(String saTokenFile, String caCertFile)

Method Summary

Modifier and Type	Method	Description
InputStream	openStream(String url, Map<String,String> headers, int connectTimeout, int readTimeout)

Methods inherited from class org.jgroups.protocols.kubernetes.stream.BaseStreamProvider

openConnection

Methods inherited from class java.lang.Object

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

Field Details

AUTHORIZATION

public static final String AUTHORIZATION

See Also:

• Constant Field Values

Constructor Details

TokenStreamProvider

public TokenStreamProvider(String saTokenFile,
 String caCertFile)

Method Details

openStream

public InputStream openStream(String url,
 Map<String,String> headers,
 int connectTimeout,
 int readTimeout)
                       throws IOException

Throws:

IOException