Package com.hazelcast.spi.utils

Class RestClient

java.lang.Object

com.hazelcast.spi.utils.RestClient

public final class RestClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RestClient.Response
static class	RestClient.WatchResponse

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_CONNECT_TIMEOUT_SECONDS	Default value of -1 results in connection timeout not being explicitly defined
static final int	HTTP_NOT_FOUND	HTTP status code 404 NOT FOUND
static final int	HTTP_OK	HTTP status code 200 OK

Method Summary

Modifier and Type	Method	Description
static RestClient	create(String url)
static RestClient	create(String url, int connectTimeoutSeconds)
static RestClient	createWithSSL(String url, String caCertificate)
static RestClient	createWithSSL(String url, String caCertificate, int connectTimeoutSeconds)
RestClient	expectResponseCodes(Integer... codes)
RestClient.Response	get()
RestClient.Response	post()
RestClient.Response	put()
RestClient.WatchResponse	watch(String resourceVersion)	Issues a watch request to a Kubernetes resource, starting with the given resourceVersion.
RestClient	withBody(String body)
RestClient	withHeader(String name, String value)
RestClient	withHeaders(Map<String,String> headers)
RestClient	withRequestTimeoutSeconds(int timeoutSeconds)
RestClient	withRetries(int retries)

Methods inherited from class java.lang.Object

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

Field Details

HTTP_OK

public static final int HTTP_OK

HTTP status code 200 OK

See Also:

• Constant Field Values

HTTP_NOT_FOUND

public static final int HTTP_NOT_FOUND

HTTP status code 404 NOT FOUND

See Also:

• Constant Field Values

DEFAULT_CONNECT_TIMEOUT_SECONDS

public static final int DEFAULT_CONNECT_TIMEOUT_SECONDS

Default value of -1 results in connection timeout not being explicitly defined

See Also:

• Constant Field Values

Method Details

create

public static RestClient create(String url)

create

public static RestClient create(String url,
 int connectTimeoutSeconds)

createWithSSL

public static RestClient createWithSSL(String url,
 String caCertificate)

createWithSSL

public static RestClient createWithSSL(String url,
 String caCertificate,
 int connectTimeoutSeconds)

withHeaders

public RestClient withHeaders(Map<String,String> headers)

withHeader

public RestClient withHeader(String name,
 String value)

withBody

public RestClient withBody(String body)

withRequestTimeoutSeconds

public RestClient withRequestTimeoutSeconds(int timeoutSeconds)

withRetries

public RestClient withRetries(int retries)

expectResponseCodes

public RestClient expectResponseCodes(Integer... codes)

get

public RestClient.Response get()

post

public RestClient.Response post()

put

public RestClient.Response put()

watch

public RestClient.WatchResponse watch(String resourceVersion)
                               throws RestClientException

Issues a watch request to a Kubernetes resource, starting with the given resourceVersion. Since a watch implies a stream of updates from the server will be consumed, unlike other methods in this class, it is the responsibility of the consumer to disconnect the connection (by invoking RestClient.WatchResponse.disconnect()) once the watch is no longer required.

Throws:

RestClientException