Class RemoteSchemasAdminImpl
java.lang.Object
org.infinispan.client.hotrod.impl.RemoteSchemasAdminImpl
- All Implemented Interfaces:
RemoteSchemasAdmin
-
Nested Class Summary
Nested classes/interfaces inherited from interface RemoteSchemasAdmin
RemoteSchemasAdmin.SchemaError, RemoteSchemasAdmin.SchemaErrors, RemoteSchemasAdmin.SchemaOpResult, RemoteSchemasAdmin.SchemaOpResultType -
Field Summary
Fields -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedRemoteSchemasAdminImpl(org.infinispan.client.hotrod.impl.operations.ManagerOperationsFactory operationsFactory, org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher operationDispatcher, RemoteCacheManager cacheManager) -
Method Summary
Modifier and TypeMethodDescriptioncreateAsync(org.infinispan.protostream.FileDescriptorSource fileDescriptorSource) Non-blocking version ofRemoteSchemasAdmin.create(FileDescriptorSource)createAsync(org.infinispan.protostream.schema.Schema schema) Non-blocking version ofRemoteSchemasAdmin.create(Schema)createOrUpdateAsync(org.infinispan.protostream.FileDescriptorSource fileDescriptorSource) Creates or updates schemas from descriptor source.createOrUpdateAsync(org.infinispan.protostream.schema.Schema schema, boolean force) Non-blocking version ofRemoteSchemasAdmin.createOrUpdate(Schema, boolean)existsAsync(String schemaName) Non-blocking version ofRemoteSchemasAdmin.exists(String)CompletionStage<Optional<org.infinispan.protostream.schema.Schema>> Non-blocking version ofRemoteSchemasAdmin.get(String)removeAsync(String name, boolean force) Non-blocking version ofRemoteSchemasAdmin.remove(String, boolean)Non-blocking version ofRemoteSchemasAdmin.retrieveAllSchemaErrors()retrieveErrorAsync(String schemaName) Non-blocking version ofRemoteSchemasAdmin.retrieveError(String)updateAsync(org.infinispan.protostream.FileDescriptorSource fileDescriptorSource) Non-blocking version ofRemoteSchemasAdmin.update(FileDescriptorSource)updateAsync(org.infinispan.protostream.schema.Schema schema, boolean force) Non-blocking version ofRemoteSchemasAdmin.update(Schema, boolean)Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface RemoteSchemasAdmin
create, create, createOrUpdate, createOrUpdate, createOrUpdate, createOrUpdateAsync, exists, get, remove, remove, removeAsync, retrieveAllSchemaErrors, retrieveError, update, update, update, updateAsync
-
Field Details
-
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
Description copied from interface:RemoteSchemasAdminNon-blocking version ofRemoteSchemasAdmin.exists(String)- Specified by:
existsAsyncin interfaceRemoteSchemasAdmin
-
getAsync
public CompletionStage<Optional<org.infinispan.protostream.schema.Schema>> getAsync(String schemaName) Description copied from interface:RemoteSchemasAdminNon-blocking version ofRemoteSchemasAdmin.get(String)- Specified by:
getAsyncin interfaceRemoteSchemasAdmin
-
createAsync
public CompletionStage<RemoteSchemasAdmin.SchemaOpResult> createAsync(org.infinispan.protostream.schema.Schema schema) Description copied from interface:RemoteSchemasAdminNon-blocking version ofRemoteSchemasAdmin.create(Schema)- Specified by:
createAsyncin interfaceRemoteSchemasAdmin
-
createAsync
public CompletionStage<Map<String, RemoteSchemasAdmin.SchemaOpResult>> createAsync(org.infinispan.protostream.FileDescriptorSource fileDescriptorSource) Description copied from interface:RemoteSchemasAdminNon-blocking version ofRemoteSchemasAdmin.create(FileDescriptorSource)- Specified by:
createAsyncin interfaceRemoteSchemasAdmin
-
updateAsync
public CompletionStage<RemoteSchemasAdmin.SchemaOpResult> updateAsync(org.infinispan.protostream.schema.Schema schema, boolean force) Description copied from interface:RemoteSchemasAdminNon-blocking version ofRemoteSchemasAdmin.update(Schema, boolean)- Specified by:
updateAsyncin interfaceRemoteSchemasAdmin
-
updateAsync
public CompletionStage<Map<String, RemoteSchemasAdmin.SchemaOpResult>> updateAsync(org.infinispan.protostream.FileDescriptorSource fileDescriptorSource) Description copied from interface:RemoteSchemasAdminNon-blocking version ofRemoteSchemasAdmin.update(FileDescriptorSource)- Specified by:
updateAsyncin interfaceRemoteSchemasAdmin
-
createOrUpdateAsync
public CompletionStage<RemoteSchemasAdmin.SchemaOpResult> createOrUpdateAsync(org.infinispan.protostream.schema.Schema schema, boolean force) Description copied from interface:RemoteSchemasAdminNon-blocking version ofRemoteSchemasAdmin.createOrUpdate(Schema, boolean)- Specified by:
createOrUpdateAsyncin interfaceRemoteSchemasAdmin
-
createOrUpdateAsync
public CompletionStage<Map<String, RemoteSchemasAdmin.SchemaOpResult>> createOrUpdateAsync(org.infinispan.protostream.FileDescriptorSource fileDescriptorSource) Description copied from interface:RemoteSchemasAdminCreates or updates schemas from descriptor source.- Specified by:
createOrUpdateAsyncin interfaceRemoteSchemasAdmin- Parameters:
fileDescriptorSource- source of schema descriptors- Returns:
- map of schema names to results
-
removeAsync
Description copied from interface:RemoteSchemasAdminNon-blocking version ofRemoteSchemasAdmin.remove(String, boolean)- Specified by:
removeAsyncin interfaceRemoteSchemasAdmin
-
retrieveAllSchemaErrorsAsync
Description copied from interface:RemoteSchemasAdminNon-blocking version ofRemoteSchemasAdmin.retrieveAllSchemaErrors()- Specified by:
retrieveAllSchemaErrorsAsyncin interfaceRemoteSchemasAdmin
-
retrieveErrorAsync
Description copied from interface:RemoteSchemasAdminNon-blocking version ofRemoteSchemasAdmin.retrieveError(String)- Specified by:
retrieveErrorAsyncin interfaceRemoteSchemasAdmin
-