Class BackupWriteCommand

java.lang.Object

org.infinispan.commands.remote.BaseRpcCommand

org.infinispan.commands.triangle.BackupWriteCommand

All Implemented Interfaces:

CacheRpcCommand, ReplicableCommand, TracedCommand, VersionAware

Direct Known Subclasses:

BackupNoopCommand, MultiEntriesFunctionalBackupWriteCommand, MultiKeyFunctionalBackupWriteCommand, PutMapBackupWriteCommand, SingleKeyBackupWriteCommand, SingleKeyFunctionalBackupWriteCommand

public abstract class BackupWriteCommand
extends BaseRpcCommand

A write operation sent from the primary owner to the backup owners.

This is a base command with the CommandInvocationId, topology and flags.

Since the primary → backup operations are ordered by segment, it contains the segment to be updated and its sequence number.

Since:

9.2

Author:

Pedro Ruivo

Field Summary

Fields inherited from class BaseRpcCommand

cacheName, origin

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BackupWriteCommand(ByteString cacheName, CommandInvocationId commandInvocationId, int topologyId, long flags, long sequence, int segmentId)
protected	BackupWriteCommand(ByteString cacheName, WriteCommand command, long sequence, int segmentId)

Method Summary

Modifier and Type	Method	Description
final CommandInvocationId	getCommandInvocationId()
final long	getFlags()
final int	getSegmentId()
final long	getSequence()
final int	getTopologyId()
final CompletionStage<?>	invokeAsync(ComponentRegistry componentRegistry)	Invoke the command asynchronously.
final boolean	isReturnValueExpected()	If true, a return value will be provided when performed remotely.

Methods inherited from class BaseRpcCommand

getCacheName, getOrigin, setOrigin, toString

Methods inherited from class Object

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

Methods inherited from interface ReplicableCommand

getCommandId, isSuccessful, logThrowable, readFrom, supportedSince, writeTo

Methods inherited from interface TracedCommand

getOperationName, getSpanAttributes, setSpanAttributes

Constructor Details

BackupWriteCommand

protected BackupWriteCommand(ByteString cacheName,
 WriteCommand command,
 long sequence,
 int segmentId)

BackupWriteCommand

protected BackupWriteCommand(ByteString cacheName,
 CommandInvocationId commandInvocationId,
 int topologyId,
 long flags,
 long sequence,
 int segmentId)

Method Details

invokeAsync

public final CompletionStage<?> invokeAsync(ComponentRegistry componentRegistry)

Description copied from interface: CacheRpcCommand

Invoke the command asynchronously.

isReturnValueExpected

public final boolean isReturnValueExpected()

Description copied from interface: ReplicableCommand

If true, a return value will be provided when performed remotely. Otherwise, a remote ResponseGenerator may choose to simply return null to save on marshalling costs.

Returns:

true or false

getSequence

public final long getSequence()

getCommandInvocationId

public final CommandInvocationId getCommandInvocationId()

getTopologyId

public final int getTopologyId()

getFlags

public final long getFlags()

getSegmentId

public final int getSegmentId()