Package com.couchbase.client.java.manager.analytics

Class ReactiveAnalyticsIndexManager

java.lang.Object

com.couchbase.client.java.manager.analytics.ReactiveAnalyticsIndexManager

public class ReactiveAnalyticsIndexManager
extends Object

Constructor Summary

Constructors

Constructor	Description
ReactiveAnalyticsIndexManager(AsyncCluster cluster)

Method Summary

Modifier and Type	Method	Description
Mono<Void>	connectLink()
Mono<Void>	connectLink(ConnectLinkAnalyticsOptions options)
Mono<Void>	createDataset(String datasetName, String bucketName)
Mono<Void>	createDataset(String datasetName, String bucketName, CreateDatasetAnalyticsOptions options)
Mono<Void>	createDataverse(String dataverseName)
Mono<Void>	createDataverse(String dataverseName, CreateDataverseAnalyticsOptions options)
Mono<Void>	createIndex(String indexName, String datasetName, Map<String,AnalyticsDataType> fields)
Mono<Void>	createIndex(String indexName, String datasetName, Map<String,AnalyticsDataType> fields, CreateIndexAnalyticsOptions options)
Mono<Void>	createLink(AnalyticsLink link)
Mono<Void>	createLink(AnalyticsLink link, CreateLinkAnalyticsOptions options)
Mono<Void>	disconnectLink()
Mono<Void>	disconnectLink(DisconnectLinkAnalyticsOptions options)
Mono<Void>	dropDataset(String datasetName)
Mono<Void>	dropDataset(String datasetName, DropDatasetAnalyticsOptions options)
Mono<Void>	dropDataverse(String dataverseName)
Mono<Void>	dropDataverse(String dataverseName, DropDataverseAnalyticsOptions options)
Mono<Void>	dropIndex(String indexName, String datasetName)
Mono<Void>	dropIndex(String indexName, String datasetName, DropIndexAnalyticsOptions options)
Mono<Void>	dropLink(String linkName, String dataverse)
Mono<Void>	dropLink(String linkName, String dataverse, DropLinkAnalyticsOptions options)
Flux<AnalyticsDataset>	getAllDatasets()
Flux<AnalyticsDataset>	getAllDatasets(GetAllDatasetsAnalyticsOptions options)
Flux<AnalyticsDataverse>	getAllDataverses()
Flux<AnalyticsDataverse>	getAllDataverses(GetAllDataversesAnalyticsOptions options)
Flux<AnalyticsIndex>	getAllIndexes()
Flux<AnalyticsIndex>	getAllIndexes(GetAllIndexesAnalyticsOptions options)
Flux<AnalyticsLink>	getLinks()
Flux<AnalyticsLink>	getLinks(GetLinksAnalyticsOptions options)
Mono<Map<String,Map<String,Long>>>	getPendingMutations()
Mono<Map<String,Map<String,Long>>>	getPendingMutations(GetPendingMutationsAnalyticsOptions options)
Mono<Void>	replaceLink(AnalyticsLink link)
Mono<Void>	replaceLink(AnalyticsLink link, ReplaceLinkAnalyticsOptions options)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveAnalyticsIndexManager

public ReactiveAnalyticsIndexManager(AsyncCluster cluster)

Method Detail

createDataverse

public Mono<Void> createDataverse(String dataverseName)

Throws:

DataverseExistsException - if a dataverse with the given name already exists

createDataverse

public Mono<Void> createDataverse(String dataverseName,
                                  CreateDataverseAnalyticsOptions options)

Throws:

DataverseExistsException - if a dataverse with the given name already exist and the options do not specify to ignore this condition.

dropDataverse

public Mono<Void> dropDataverse(String dataverseName)

Throws:

DataverseNotFoundException - if no dataverse with the given name exists

dropDataverse

public Mono<Void> dropDataverse(String dataverseName,
                                DropDataverseAnalyticsOptions options)

Throws:

DataverseNotFoundException - if no dataverse with the given name exists and the options do not specify to ignore this condition.

getAllDataverses

@Uncommitted
public Flux<AnalyticsDataverse> getAllDataverses()

getAllDataverses

@Uncommitted
public Flux<AnalyticsDataverse> getAllDataverses(GetAllDataversesAnalyticsOptions options)

createDataset

public Mono<Void> createDataset(String datasetName,
                                String bucketName)

createDataset

public Mono<Void> createDataset(String datasetName,
                                String bucketName,
                                CreateDatasetAnalyticsOptions options)

dropDataset

public Mono<Void> dropDataset(String datasetName)

dropDataset

public Mono<Void> dropDataset(String datasetName,
                              DropDatasetAnalyticsOptions options)

getAllDatasets

public Flux<AnalyticsDataset> getAllDatasets()

getAllDatasets

public Flux<AnalyticsDataset> getAllDatasets(GetAllDatasetsAnalyticsOptions options)

createIndex

public Mono<Void> createIndex(String indexName,
                              String datasetName,
                              Map<String,AnalyticsDataType> fields)

createIndex

public Mono<Void> createIndex(String indexName,
                              String datasetName,
                              Map<String,AnalyticsDataType> fields,
                              CreateIndexAnalyticsOptions options)

dropIndex

public Mono<Void> dropIndex(String indexName,
                            String datasetName)

dropIndex

public Mono<Void> dropIndex(String indexName,
                            String datasetName,
                            DropIndexAnalyticsOptions options)

getAllIndexes

public Flux<AnalyticsIndex> getAllIndexes()

getAllIndexes

public Flux<AnalyticsIndex> getAllIndexes(GetAllIndexesAnalyticsOptions options)

connectLink

public Mono<Void> connectLink()

connectLink

public Mono<Void> connectLink(ConnectLinkAnalyticsOptions options)

disconnectLink

public Mono<Void> disconnectLink()

disconnectLink

public Mono<Void> disconnectLink(DisconnectLinkAnalyticsOptions options)

getPendingMutations

public Mono<Map<String,Map<String,Long>>> getPendingMutations()

getPendingMutations

public Mono<Map<String,Map<String,Long>>> getPendingMutations(GetPendingMutationsAnalyticsOptions options)

createLink

public Mono<Void> createLink(AnalyticsLink link)

createLink

public Mono<Void> createLink(AnalyticsLink link,
                             CreateLinkAnalyticsOptions options)

replaceLink

public Mono<Void> replaceLink(AnalyticsLink link)

replaceLink

public Mono<Void> replaceLink(AnalyticsLink link,
                              ReplaceLinkAnalyticsOptions options)

dropLink

public Mono<Void> dropLink(String linkName,
                           String dataverse)

dropLink

public Mono<Void> dropLink(String linkName,
                           String dataverse,
                           DropLinkAnalyticsOptions options)

getLinks

public Flux<AnalyticsLink> getLinks()

getLinks

public Flux<AnalyticsLink> getLinks(GetLinksAnalyticsOptions options)