Package co.elastic.clients.elasticsearch.streams

Class ElasticsearchStreamsAsyncClient

java.lang.Object

co.elastic.clients.ApiClient<ElasticsearchTransport,ElasticsearchStreamsAsyncClient>

co.elastic.clients.elasticsearch.streams.ElasticsearchStreamsAsyncClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class ElasticsearchStreamsAsyncClient
extends ApiClient<ElasticsearchTransport,ElasticsearchStreamsAsyncClient>

Client for the streams namespace.

Field Summary

Fields inherited from class co.elastic.clients.ApiClient

transport, transportOptions

Constructor Summary

Constructors

Constructor	Description
ElasticsearchStreamsAsyncClient(ElasticsearchTransport transport)
ElasticsearchStreamsAsyncClient(ElasticsearchTransport transport, TransportOptions transportOptions)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<LogsDisableResponse>	logsDisable(LogsDisableRequest request)	Disable a named stream.
final CompletableFuture<LogsDisableResponse>	logsDisable(Function<LogsDisableRequest.Builder,ObjectBuilder<LogsDisableRequest>> fn)	Disable a named stream.
CompletableFuture<LogsEnableResponse>	logsEnable(LogsEnableRequest request)	Enable a named stream.
final CompletableFuture<LogsEnableResponse>	logsEnable(Function<LogsEnableRequest.Builder,ObjectBuilder<LogsEnableRequest>> fn)	Enable a named stream.
CompletableFuture<StreamsStatusResponse>	status()	Get the status of streams.
CompletableFuture<StreamsStatusResponse>	status(StreamsStatusRequest request)	Get the status of streams.
final CompletableFuture<StreamsStatusResponse>	status(Function<StreamsStatusRequest.Builder,ObjectBuilder<StreamsStatusRequest>> fn)	Get the status of streams.
ElasticsearchStreamsAsyncClient	withTransportOptions(TransportOptions transportOptions)	Creates a new client with some request options

Methods inherited from class co.elastic.clients.ApiClient

_jsonpMapper, _transport, _transportOptions, close, getDeserializer, withTransportOptions

Methods inherited from class java.lang.Object

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

Constructor Details

ElasticsearchStreamsAsyncClient

public ElasticsearchStreamsAsyncClient(ElasticsearchTransport transport)

ElasticsearchStreamsAsyncClient

public ElasticsearchStreamsAsyncClient(ElasticsearchTransport transport,
 @Nullable
 TransportOptions transportOptions)

Method Details

withTransportOptions

public ElasticsearchStreamsAsyncClient withTransportOptions(@Nullable
 TransportOptions transportOptions)

Description copied from class: ApiClient

Creates a new client with some request options

Specified by:

withTransportOptions in class ApiClient<ElasticsearchTransport,ElasticsearchStreamsAsyncClient>

logsDisable

public CompletableFuture<LogsDisableResponse> logsDisable(LogsDisableRequest request)

Disable a named stream.

Turn off the named stream feature for this cluster.

See Also:

• Documentation on elastic.co

logsDisable

public final CompletableFuture<LogsDisableResponse> logsDisable(Function<LogsDisableRequest.Builder,ObjectBuilder<LogsDisableRequest>> fn)

Disable a named stream.

Turn off the named stream feature for this cluster.

Parameters:

fn - a function that initializes a builder to create the LogsDisableRequest

See Also:

• Documentation on elastic.co

logsEnable

public CompletableFuture<LogsEnableResponse> logsEnable(LogsEnableRequest request)

Enable a named stream.

Turn on the named stream feature for this cluster.

NOTE: To protect existing data, this feature can be turned on only if the cluster does not have existing indices or data streams that match the pattern <name>|<name>.* for the enabled stream type name. If those indices or data streams exist, a 409 - Conflict response and error is returned.

See Also:

• Documentation on elastic.co

logsEnable

public final CompletableFuture<LogsEnableResponse> logsEnable(Function<LogsEnableRequest.Builder,ObjectBuilder<LogsEnableRequest>> fn)

Enable a named stream.

Turn on the named stream feature for this cluster.

NOTE: To protect existing data, this feature can be turned on only if the cluster does not have existing indices or data streams that match the pattern <name>|<name>.* for the enabled stream type name. If those indices or data streams exist, a 409 - Conflict response and error is returned.

Parameters:

fn - a function that initializes a builder to create the LogsEnableRequest

See Also:

• Documentation on elastic.co

status

public CompletableFuture<StreamsStatusResponse> status(StreamsStatusRequest request)

Get the status of streams.

Get the current status for all types of streams.

See Also:

• Documentation on elastic.co

status

public final CompletableFuture<StreamsStatusResponse> status(Function<StreamsStatusRequest.Builder,ObjectBuilder<StreamsStatusRequest>> fn)

Get the status of streams.

Get the current status for all types of streams.

Parameters:

fn - a function that initializes a builder to create the StreamsStatusRequest

See Also:

• Documentation on elastic.co

status

public CompletableFuture<StreamsStatusResponse> status()

Get the status of streams.

Get the current status for all types of streams.

See Also:

• Documentation on elastic.co