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 and Description
static class	RestClient.Response
static class	RestClient.WatchResponse

Field Summary

Fields

Modifier and Type	Field and Description
static int	HTTP_NOT_FOUND HTTP status code 404 NOT FOUND
static int	HTTP_OK HTTP status code 200 OK

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RestClient(String url)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

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

Constructor Detail

RestClient

protected RestClient(String url)

Method Detail

create

public static RestClient create(String url)

withHeaders

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

withHeader

public RestClient withHeader(String name,
                             String value)

withBody

public RestClient withBody(String body)

withReadTimeoutSeconds

public RestClient withReadTimeoutSeconds(int readTimeoutSeconds)

withConnectTimeoutSeconds

public RestClient withConnectTimeoutSeconds(int connectTimeoutSeconds)

withRetries

public RestClient withRetries(int retries)

withCaCertificates

public RestClient withCaCertificates(String caCertificate)

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,
                                      ExecutorService readExecutor)

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.