org.springframework.data.elasticsearch.client.reactive

Interface ReactiveElasticsearchClient.Indices

All Known Implementing Classes:

DefaultReactiveElasticsearchClient

Enclosing interface:

ReactiveElasticsearchClient

public static interface ReactiveElasticsearchClient.Indices

Encapsulation of methods for accessing the Indices API.

Author:

Christoph Strobl

See Also:

Indices API.

Method Summary

Modifier and Type	Method and Description
default reactor.core.publisher.Mono<Void>	closeIndex(org.elasticsearch.action.admin.indices.close.CloseIndexRequest closeIndexRequest) Execute the given CloseIndexRequest against the indices API.
default reactor.core.publisher.Mono<Void>	closeIndex(Consumer<org.elasticsearch.action.admin.indices.close.CloseIndexRequest> consumer) Execute the given CloseIndexRequest against the indices API.
reactor.core.publisher.Mono<Void>	closeIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.close.CloseIndexRequest closeIndexRequest) Execute the given CloseIndexRequest against the indices API.
default reactor.core.publisher.Mono<Void>	createIndex(Consumer<org.elasticsearch.action.admin.indices.create.CreateIndexRequest> consumer) Execute the given CreateIndexRequest against the indices API.
default reactor.core.publisher.Mono<Void>	createIndex(org.elasticsearch.action.admin.indices.create.CreateIndexRequest createIndexRequest) Execute the given CreateIndexRequest against the indices API.
reactor.core.publisher.Mono<Void>	createIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.create.CreateIndexRequest createIndexRequest) Execute the given CreateIndexRequest against the indices API.
default reactor.core.publisher.Mono<Void>	deleteIndex(Consumer<org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest> consumer) Execute the given DeleteIndexRequest against the indices API.
default reactor.core.publisher.Mono<Void>	deleteIndex(org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest deleteIndexRequest) Execute the given DeleteIndexRequest against the indices API.
reactor.core.publisher.Mono<Void>	deleteIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest deleteIndexRequest) Execute the given DeleteIndexRequest against the indices API.
default reactor.core.publisher.Mono<Boolean>	existsIndex(Consumer<org.elasticsearch.action.admin.indices.get.GetIndexRequest> consumer) Execute the given GetIndexRequest against the indices API.
default reactor.core.publisher.Mono<Boolean>	existsIndex(org.elasticsearch.action.admin.indices.get.GetIndexRequest getIndexRequest) Execute the given GetIndexRequest against the indices API.
reactor.core.publisher.Mono<Boolean>	existsIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.get.GetIndexRequest getIndexRequest) Execute the given GetIndexRequest against the indices API.
default reactor.core.publisher.Mono<Void>	flushIndex(Consumer<org.elasticsearch.action.admin.indices.flush.FlushRequest> consumer) Execute the given FlushRequest against the indices API.
default reactor.core.publisher.Mono<Void>	flushIndex(org.elasticsearch.action.admin.indices.flush.FlushRequest flushRequest) Execute the given RefreshRequest against the indices API.
reactor.core.publisher.Mono<Void>	flushIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.flush.FlushRequest flushRequest) Execute the given RefreshRequest against the indices API.
default reactor.core.publisher.Mono<Void>	openIndex(Consumer<org.elasticsearch.action.admin.indices.open.OpenIndexRequest> consumer) Execute the given OpenIndexRequest against the indices API.
reactor.core.publisher.Mono<Void>	openIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.open.OpenIndexRequest openIndexRequest) Execute the given OpenIndexRequest against the indices API.
default reactor.core.publisher.Mono<Void>	openIndex(org.elasticsearch.action.admin.indices.open.OpenIndexRequest openIndexRequest) Execute the given OpenIndexRequest against the indices API.
default reactor.core.publisher.Mono<Void>	refreshIndex(Consumer<org.elasticsearch.action.admin.indices.refresh.RefreshRequest> consumer) Execute the given RefreshRequest against the indices API.
reactor.core.publisher.Mono<Void>	refreshIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.refresh.RefreshRequest refreshRequest) Execute the given RefreshRequest against the indices API.
default reactor.core.publisher.Mono<Void>	refreshIndex(org.elasticsearch.action.admin.indices.refresh.RefreshRequest refreshRequest) Execute the given RefreshRequest against the indices API.
default reactor.core.publisher.Mono<Void>	updateMapping(Consumer<org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest> consumer) Execute the given PutMappingRequest against the indices API.
reactor.core.publisher.Mono<Void>	updateMapping(HttpHeaders headers, org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest putMappingRequest) Execute the given PutMappingRequest against the indices API.
default reactor.core.publisher.Mono<Void>	updateMapping(org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest putMappingRequest) Execute the given PutMappingRequest against the indices API.

Method Detail

existsIndex

default reactor.core.publisher.Mono<Boolean> existsIndex(Consumer<org.elasticsearch.action.admin.indices.get.GetIndexRequest> consumer)

Execute the given GetIndexRequest against the indices API.

Parameters:

consumer - never null.

Returns:

the Mono emitting true if the index exists, false otherwise.

See Also:

Indices Exists API on elastic.co

existsIndex

default reactor.core.publisher.Mono<Boolean> existsIndex(org.elasticsearch.action.admin.indices.get.GetIndexRequest getIndexRequest)

Execute the given GetIndexRequest against the indices API.

Parameters:

getIndexRequest - must not be null.

Returns:

the Mono emitting true if the index exists, false otherwise.

See Also:

Indices Exists API on elastic.co

existsIndex

reactor.core.publisher.Mono<Boolean> existsIndex(HttpHeaders headers,
                                                 org.elasticsearch.action.admin.indices.get.GetIndexRequest getIndexRequest)

Execute the given GetIndexRequest against the indices API.

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

getIndexRequest - must not be null.

Returns:

the Mono emitting true if the index exists, false otherwise.

See Also:

Indices Exists API on elastic.co

deleteIndex

default reactor.core.publisher.Mono<Void> deleteIndex(Consumer<org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest> consumer)

Execute the given DeleteIndexRequest against the indices API.

Parameters:

consumer - never null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Delete API on elastic.co

deleteIndex

default reactor.core.publisher.Mono<Void> deleteIndex(org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest deleteIndexRequest)

Execute the given DeleteIndexRequest against the indices API.

Parameters:

deleteIndexRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Delete API on elastic.co

deleteIndex

reactor.core.publisher.Mono<Void> deleteIndex(HttpHeaders headers,
                                              org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest deleteIndexRequest)

Execute the given DeleteIndexRequest against the indices API.

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

deleteIndexRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Delete API on elastic.co

createIndex

default reactor.core.publisher.Mono<Void> createIndex(Consumer<org.elasticsearch.action.admin.indices.create.CreateIndexRequest> consumer)

Execute the given CreateIndexRequest against the indices API.

Parameters:

consumer - never null.

Returns:

a Mono signalling operation completion or an error if eg. the index already exist.

See Also:

Indices Create API on elastic.co

createIndex

default reactor.core.publisher.Mono<Void> createIndex(org.elasticsearch.action.admin.indices.create.CreateIndexRequest createIndexRequest)

Execute the given CreateIndexRequest against the indices API.

Parameters:

createIndexRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index already exist.

See Also:

Indices Create API on elastic.co

createIndex

reactor.core.publisher.Mono<Void> createIndex(HttpHeaders headers,
                                              org.elasticsearch.action.admin.indices.create.CreateIndexRequest createIndexRequest)

Execute the given CreateIndexRequest against the indices API.

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

createIndexRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index already exist.

See Also:

Indices Create API on elastic.co

openIndex

default reactor.core.publisher.Mono<Void> openIndex(Consumer<org.elasticsearch.action.admin.indices.open.OpenIndexRequest> consumer)

Execute the given OpenIndexRequest against the indices API.

Parameters:

consumer - never null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Open API on elastic.co

openIndex

default reactor.core.publisher.Mono<Void> openIndex(org.elasticsearch.action.admin.indices.open.OpenIndexRequest openIndexRequest)

Execute the given OpenIndexRequest against the indices API.

Parameters:

openIndexRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Open API on elastic.co

openIndex

reactor.core.publisher.Mono<Void> openIndex(HttpHeaders headers,
                                            org.elasticsearch.action.admin.indices.open.OpenIndexRequest openIndexRequest)

Execute the given OpenIndexRequest against the indices API.

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

openIndexRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Open API on elastic.co

closeIndex

default reactor.core.publisher.Mono<Void> closeIndex(Consumer<org.elasticsearch.action.admin.indices.close.CloseIndexRequest> consumer)

Execute the given CloseIndexRequest against the indices API.

Parameters:

consumer - never null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Close API on elastic.co

closeIndex

default reactor.core.publisher.Mono<Void> closeIndex(org.elasticsearch.action.admin.indices.close.CloseIndexRequest closeIndexRequest)

Execute the given CloseIndexRequest against the indices API.

Parameters:

closeIndexRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Close API on elastic.co

closeIndex

reactor.core.publisher.Mono<Void> closeIndex(HttpHeaders headers,
                                             org.elasticsearch.action.admin.indices.close.CloseIndexRequest closeIndexRequest)

Execute the given CloseIndexRequest against the indices API.

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

closeIndexRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices CLose API on elastic.co

refreshIndex

default reactor.core.publisher.Mono<Void> refreshIndex(Consumer<org.elasticsearch.action.admin.indices.refresh.RefreshRequest> consumer)

Execute the given RefreshRequest against the indices API.

Parameters:

consumer - never null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Refresh API on elastic.co

refreshIndex

default reactor.core.publisher.Mono<Void> refreshIndex(org.elasticsearch.action.admin.indices.refresh.RefreshRequest refreshRequest)

Execute the given RefreshRequest against the indices API.

Parameters:

refreshRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Refresh API on elastic.co

refreshIndex

reactor.core.publisher.Mono<Void> refreshIndex(HttpHeaders headers,
                                               org.elasticsearch.action.admin.indices.refresh.RefreshRequest refreshRequest)

Execute the given RefreshRequest against the indices API.

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

refreshRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Refresh API on elastic.co

updateMapping

default reactor.core.publisher.Mono<Void> updateMapping(Consumer<org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest> consumer)

Execute the given PutMappingRequest against the indices API.

Parameters:

consumer - never null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Put Mapping API on elastic.co

updateMapping

default reactor.core.publisher.Mono<Void> updateMapping(org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest putMappingRequest)

Execute the given PutMappingRequest against the indices API.

Parameters:

putMappingRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Put Mapping API on elastic.co

updateMapping

reactor.core.publisher.Mono<Void> updateMapping(HttpHeaders headers,
                                                org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest putMappingRequest)

Execute the given PutMappingRequest against the indices API.

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

putMappingRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Put Mapping API on elastic.co

flushIndex

default reactor.core.publisher.Mono<Void> flushIndex(Consumer<org.elasticsearch.action.admin.indices.flush.FlushRequest> consumer)

Execute the given FlushRequest against the indices API.

Parameters:

consumer - never null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Flush API on elastic.co

flushIndex

default reactor.core.publisher.Mono<Void> flushIndex(org.elasticsearch.action.admin.indices.flush.FlushRequest flushRequest)

Execute the given RefreshRequest against the indices API.

Parameters:

flushRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Flush API on elastic.co

flushIndex

reactor.core.publisher.Mono<Void> flushIndex(HttpHeaders headers,
                                             org.elasticsearch.action.admin.indices.flush.FlushRequest flushRequest)

Execute the given RefreshRequest against the indices API.

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

flushRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Flush API on elastic.co