Class RemoteSchemasAdminImpl

java.lang.Object

org.infinispan.client.hotrod.impl.RemoteSchemasAdminImpl

All Implemented Interfaces:

RemoteSchemasAdmin

public class RemoteSchemasAdminImpl
extends Object
implements RemoteSchemasAdmin

Nested Class Summary

Nested classes/interfaces inherited from interface RemoteSchemasAdmin

RemoteSchemasAdmin.SchemaError, RemoteSchemasAdmin.SchemaErrors, RemoteSchemasAdmin.SchemaOpResult, RemoteSchemasAdmin.SchemaOpResultType

Field Summary

Fields

Modifier and Type	Field	Description
static final Log	log

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RemoteSchemasAdminImpl(org.infinispan.client.hotrod.impl.operations.ManagerOperationsFactory operationsFactory, org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher operationDispatcher, RemoteCacheManager cacheManager)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Map<String, RemoteSchemasAdmin.SchemaOpResult>>	createAsync(org.infinispan.protostream.FileDescriptorSource fileDescriptorSource)	Non-blocking version of RemoteSchemasAdmin.create(FileDescriptorSource)
CompletionStage<RemoteSchemasAdmin.SchemaOpResult>	createAsync(org.infinispan.protostream.schema.Schema schema)	Non-blocking version of RemoteSchemasAdmin.create(Schema)
CompletionStage<Map<String, RemoteSchemasAdmin.SchemaOpResult>>	createOrUpdateAsync(org.infinispan.protostream.FileDescriptorSource fileDescriptorSource)	Creates or updates schemas from descriptor source.
CompletionStage<RemoteSchemasAdmin.SchemaOpResult>	createOrUpdateAsync(org.infinispan.protostream.schema.Schema schema, boolean force)	Non-blocking version of RemoteSchemasAdmin.createOrUpdate(Schema, boolean)
CompletionStage<Boolean>	existsAsync(String schemaName)	Non-blocking version of RemoteSchemasAdmin.exists(String)
CompletionStage<Optional<org.infinispan.protostream.schema.Schema>>	getAsync(String schemaName)	Non-blocking version of RemoteSchemasAdmin.get(String)
CompletionStage<RemoteSchemasAdmin.SchemaOpResult>	removeAsync(String name, boolean force)	Non-blocking version of RemoteSchemasAdmin.remove(String, boolean)
CompletionStage<RemoteSchemasAdmin.SchemaErrors>	retrieveAllSchemaErrorsAsync()	Non-blocking version of RemoteSchemasAdmin.retrieveAllSchemaErrors()
CompletionStage<Optional<String>>	retrieveErrorAsync(String schemaName)	Non-blocking version of RemoteSchemasAdmin.retrieveError(String)
CompletionStage<Map<String, RemoteSchemasAdmin.SchemaOpResult>>	updateAsync(org.infinispan.protostream.FileDescriptorSource fileDescriptorSource)	Non-blocking version of RemoteSchemasAdmin.update(FileDescriptorSource)
CompletionStage<RemoteSchemasAdmin.SchemaOpResult>	updateAsync(org.infinispan.protostream.schema.Schema schema, boolean force)	Non-blocking version of RemoteSchemasAdmin.update(Schema, boolean)

Methods inherited from class Object

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

Methods inherited from interface RemoteSchemasAdmin

create, create, createOrUpdate, createOrUpdate, createOrUpdate, createOrUpdateAsync, exists, get, remove, remove, removeAsync, retrieveAllSchemaErrors, retrieveError, update, update, update, updateAsync

Field Details

log

public static final Log log

Constructor Details

RemoteSchemasAdminImpl

protected RemoteSchemasAdminImpl(org.infinispan.client.hotrod.impl.operations.ManagerOperationsFactory operationsFactory,
 org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher operationDispatcher,
 RemoteCacheManager cacheManager)

Method Details

existsAsync

public CompletionStage<Boolean> existsAsync(String schemaName)

Description copied from interface: RemoteSchemasAdmin

Non-blocking version of RemoteSchemasAdmin.exists(String)

Specified by:

existsAsync in interface RemoteSchemasAdmin

getAsync

public CompletionStage<Optional<org.infinispan.protostream.schema.Schema>> getAsync(String schemaName)

Description copied from interface: RemoteSchemasAdmin

Non-blocking version of RemoteSchemasAdmin.get(String)

Specified by:

getAsync in interface RemoteSchemasAdmin

createAsync

public CompletionStage<RemoteSchemasAdmin.SchemaOpResult> createAsync(org.infinispan.protostream.schema.Schema schema)

Description copied from interface: RemoteSchemasAdmin

Non-blocking version of RemoteSchemasAdmin.create(Schema)

Specified by:

createAsync in interface RemoteSchemasAdmin

createAsync

public CompletionStage<Map<String, RemoteSchemasAdmin.SchemaOpResult>> createAsync(org.infinispan.protostream.FileDescriptorSource fileDescriptorSource)

Description copied from interface: RemoteSchemasAdmin

Non-blocking version of RemoteSchemasAdmin.create(FileDescriptorSource)

Specified by:

createAsync in interface RemoteSchemasAdmin

updateAsync

public CompletionStage<RemoteSchemasAdmin.SchemaOpResult> updateAsync(org.infinispan.protostream.schema.Schema schema,
 boolean force)

Description copied from interface: RemoteSchemasAdmin

Non-blocking version of RemoteSchemasAdmin.update(Schema, boolean)

Specified by:

updateAsync in interface RemoteSchemasAdmin

updateAsync

public CompletionStage<Map<String, RemoteSchemasAdmin.SchemaOpResult>> updateAsync(org.infinispan.protostream.FileDescriptorSource fileDescriptorSource)

Description copied from interface: RemoteSchemasAdmin

Non-blocking version of RemoteSchemasAdmin.update(FileDescriptorSource)

Specified by:

updateAsync in interface RemoteSchemasAdmin

createOrUpdateAsync

public CompletionStage<RemoteSchemasAdmin.SchemaOpResult> createOrUpdateAsync(org.infinispan.protostream.schema.Schema schema,
 boolean force)

Description copied from interface: RemoteSchemasAdmin

Non-blocking version of RemoteSchemasAdmin.createOrUpdate(Schema, boolean)

Specified by:

createOrUpdateAsync in interface RemoteSchemasAdmin

createOrUpdateAsync

public CompletionStage<Map<String, RemoteSchemasAdmin.SchemaOpResult>> createOrUpdateAsync(org.infinispan.protostream.FileDescriptorSource fileDescriptorSource)

Description copied from interface: RemoteSchemasAdmin

Creates or updates schemas from descriptor source.

Specified by:

createOrUpdateAsync in interface RemoteSchemasAdmin

Parameters:

fileDescriptorSource - source of schema descriptors

Returns:

map of schema names to results

removeAsync

public CompletionStage<RemoteSchemasAdmin.SchemaOpResult> removeAsync(String name,
 boolean force)

Description copied from interface: RemoteSchemasAdmin

Non-blocking version of RemoteSchemasAdmin.remove(String, boolean)

Specified by:

removeAsync in interface RemoteSchemasAdmin

retrieveAllSchemaErrorsAsync

public CompletionStage<RemoteSchemasAdmin.SchemaErrors> retrieveAllSchemaErrorsAsync()

Description copied from interface: RemoteSchemasAdmin

Non-blocking version of RemoteSchemasAdmin.retrieveAllSchemaErrors()

Specified by:

retrieveAllSchemaErrorsAsync in interface RemoteSchemasAdmin

retrieveErrorAsync

public CompletionStage<Optional<String>> retrieveErrorAsync(String schemaName)

Description copied from interface: RemoteSchemasAdmin

Non-blocking version of RemoteSchemasAdmin.retrieveError(String)

Specified by:

retrieveErrorAsync in interface RemoteSchemasAdmin