Class IracPutManyRequest

java.lang.Object

org.infinispan.xsite.commands.remote.XSiteCacheRequest<IntSet>

org.infinispan.xsite.commands.remote.IracUpdateKeyRequest<IntSet>

org.infinispan.xsite.commands.remote.IracPutManyRequest

All Implemented Interfaces:

TracedCommand, XSiteRequest<IntSet>

@ProtoTypeId(1098)
public class IracPutManyRequest
extends IracUpdateKeyRequest<IntSet>

A multi-key cross-site requests.

This command is used by asynchronous cross-site replication to send multiple keys batched to remote sites. The keys in this command can include updates, removal or expirations.

The element order in updateList is important because the reply will be a IntSet with the position of the failed keys.

Since:

15.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	IracPutManyRequest.Expire
static class	IracPutManyRequest.Remove
static final class	IracPutManyRequest.Write

Field Summary

Fields inherited from class org.infinispan.xsite.commands.remote.XSiteCacheRequest

cacheName

Constructor Summary

Constructors

Constructor	Description
IracPutManyRequest(ByteString cacheName, int maxCapacity)

Method Summary

Modifier and Type	Method	Description
void	addExpire(Object key, IracMetadata tombstone)
void	addRemove(Object key, IracMetadata tombstone)
void	addUpdate(Object key, Object value, Metadata metadata, IracMetadata iracMetadata)
CompletionStage<IntSet>	executeOperation(org.infinispan.xsite.BackupReceiver receiver)
boolean	isEmpty()
String	toString()

Methods inherited from class org.infinispan.xsite.commands.remote.IracUpdateKeyRequest

invokeInLocalCache

Methods inherited from class org.infinispan.xsite.commands.remote.XSiteCacheRequest

getCacheName, invokeInLocalSite

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commands.TracedCommand

getOperationName, getSpanAttributes, setSpanAttributes

Constructor Details

IracPutManyRequest

public IracPutManyRequest(ByteString cacheName,
 int maxCapacity)

Method Details

executeOperation

public CompletionStage<IntSet> executeOperation(org.infinispan.xsite.BackupReceiver receiver)

Specified by:

executeOperation in class IracUpdateKeyRequest<IntSet>

toString

public String toString()

Overrides:

toString in class Object

addUpdate

public void addUpdate(Object key,
 Object value,
 Metadata metadata,
 IracMetadata iracMetadata)

addRemove

public void addRemove(Object key,
 IracMetadata tombstone)

addExpire

public void addExpire(Object key,
 IracMetadata tombstone)

isEmpty

public boolean isEmpty()