Package | Description |
---|---|
org.infinispan.client.hotrod.event |
Hot Rod client remote event API.
|
org.infinispan.client.hotrod.impl.operations | |
org.infinispan.client.hotrod.impl.protocol | |
org.infinispan.client.hotrod.impl.transport | |
org.infinispan.client.hotrod.impl.transport.tcp | |
org.infinispan.client.hotrod.logging |
Modifier and Type | Method and Description |
---|---|
Transport |
ClientListenerNotifier.findTransport(byte[] listenerId) |
Modifier and Type | Method and Description |
---|---|
Transport |
AddClientListenerOperation.getDedicatedTransport() |
Transport |
IterationStartResponse.getTransport() |
protected Transport |
IterationStartOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected Transport |
ExecuteOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected Transport |
SizeOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected Transport |
QueryOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected Transport |
FaultTolerantPingOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected Transport |
BulkGetKeysOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected Transport |
BulkGetOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected Transport |
ClearOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected Transport |
PutAllOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected Transport |
StatsOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected Transport |
GetAllOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected Transport |
AbstractKeyOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected abstract Transport |
RetryOnFailureOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
protected Transport |
AddClientListenerOperation.getTransport(int retryCount,
Set<SocketAddress> failedServers) |
Modifier and Type | Method and Description |
---|---|
protected IterationStartResponse |
IterationStartOperation.executeOperation(Transport transport) |
protected T |
ExecuteOperation.executeOperation(Transport transport) |
protected Integer |
SizeOperation.executeOperation(Transport transport) |
protected QueryResponse |
QueryOperation.executeOperation(Transport transport) |
protected PingOperation.PingResult |
FaultTolerantPingOperation.executeOperation(Transport transport) |
protected Set<K> |
BulkGetKeysOperation.executeOperation(Transport transport) |
protected Map<K,V> |
BulkGetOperation.executeOperation(Transport transport) |
protected Void |
ClearOperation.executeOperation(Transport transport) |
protected Boolean |
ContainsKeyOperation.executeOperation(Transport transport) |
protected V |
ReplaceOperation.executeOperation(Transport transport) |
protected V |
PutIfAbsentOperation.executeOperation(Transport transport) |
protected Void |
PutAllOperation.executeOperation(Transport transport) |
protected V |
PutOperation.executeOperation(Transport transport) |
protected Map<String,String> |
StatsOperation.executeOperation(Transport transport) |
protected MetadataValue<V> |
GetWithMetadataOperation.executeOperation(Transport transport) |
protected VersionedValue<V> |
GetWithVersionOperation.executeOperation(Transport transport)
Deprecated.
|
protected VersionedOperationResponse |
ReplaceIfUnmodifiedOperation.executeOperation(Transport transport) |
protected VersionedOperationResponse<V> |
RemoveIfUnmodifiedOperation.executeOperation(Transport transport) |
V |
RemoveOperation.executeOperation(Transport transport) |
protected Map<K,V> |
GetAllOperation.executeOperation(Transport transport) |
V |
GetOperation.executeOperation(Transport transport) |
protected abstract T |
RetryOnFailureOperation.executeOperation(Transport transport) |
protected Short |
AddClientListenerOperation.executeOperation(Transport transport) |
IterationEndOperation |
OperationsFactory.newIterationEndOperation(String iterationId,
Transport transport) |
<K,V> IterationNextOperation |
OperationsFactory.newIterationNextOperation(String iterationId,
Transport transport,
KeyTracker segmentKeyTracker) |
PingOperation |
OperationsFactory.newPingOperation(Transport transport)
Construct a ping request directed to a particular node.
|
protected short |
HotRodOperation.readHeaderAndValidate(Transport transport,
HeaderParams params)
Magic | Message Id | Op code | Status | Topology Change Marker
|
protected void |
IterationStartOperation.releaseTransport(Transport transport) |
protected void |
RetryOnFailureOperation.releaseTransport(Transport transport) |
protected void |
AddClientListenerOperation.releaseTransport(Transport transport) |
protected T |
AbstractKeyOperation.returnPossiblePrevValue(Transport transport,
short status) |
protected VersionedOperationResponse |
AbstractKeyOperation.returnVersionedOperationResponse(Transport transport,
HeaderParams params) |
protected short |
AbstractKeyOperation.sendKeyOperation(byte[] key,
Transport transport,
byte opCode,
byte opRespCode) |
protected short |
AbstractKeyValueOperation.sendPutOperation(Transport transport,
short opCode,
byte opRespCode) |
protected HeaderParams |
HotRodOperation.writeHeader(Transport transport,
short operationCode) |
Constructor and Description |
---|
AuthMechListOperation(Codec codec,
AtomicInteger topologyId,
Transport transport) |
AuthOperation(Codec codec,
AtomicInteger topologyId,
Transport transport,
String saslMechanism,
byte[] response) |
IterationEndOperation(Codec codec,
int flags,
byte[] cacheName,
AtomicInteger topologyId,
String iterationId,
TransportFactory transportFactory,
Transport transport) |
IterationNextOperation(Codec codec,
int flags,
byte[] cacheName,
AtomicInteger topologyId,
String iterationId,
Transport transport,
KeyTracker segmentKeyTracker) |
PingOperation(Codec codec,
AtomicInteger topologyId,
Transport transport) |
PingOperation(Codec codec,
AtomicInteger topologyId,
Transport transport,
byte[] cacheName) |
Modifier and Type | Method and Description |
---|---|
protected void |
Codec20.checkForErrorsInResponseStatus(Transport transport,
HeaderParams params,
short status) |
protected void |
Codec10.checkForErrorsInResponseStatus(Transport transport,
HeaderParams params,
short status) |
protected Map<SocketAddress,Set<Integer>> |
Codec10.computeNewHashes(Transport transport,
Log localLog,
int newTopologyId,
int numKeyOwners,
short hashFunctionVersion,
int hashSpace,
int clusterSize) |
protected Map<SocketAddress,Set<Integer>> |
Codec11.computeNewHashes(Transport transport,
Log localLog,
int newTopologyId,
int numKeyOwners,
short hashFunctionVersion,
int hashSpace,
int clusterSize) |
ClientEvent |
Codec20.readEvent(Transport transport,
byte[] expectedListenerId,
Marshaller marshaller) |
ClientEvent |
Codec10.readEvent(Transport transport,
byte[] expectedListenerId,
Marshaller marshaller) |
ClientEvent |
Codec.readEvent(Transport transport,
byte[] expectedListenerId,
Marshaller marshaller) |
short |
Codec20.readHeader(Transport transport,
HeaderParams params) |
short |
Codec10.readHeader(Transport transport,
HeaderParams params) |
short |
Codec.readHeader(Transport transport,
HeaderParams params)
Reads a response header from the transport and returns the status
of the response.
|
Either<Short,ClientEvent> |
Codec20.readHeaderOrEvent(Transport transport,
HeaderParams params,
byte[] expectedListenerId,
Marshaller marshaller) |
Either<Short,ClientEvent> |
Codec10.readHeaderOrEvent(Transport transport,
HeaderParams params,
byte[] expectedListenerId,
Marshaller marshaller) |
Either<Short,ClientEvent> |
Codec.readHeaderOrEvent(Transport transport,
HeaderParams params,
byte[] expectedListenerId,
Marshaller marshaller) |
protected void |
Codec10.readNewTopologyAndHash(Transport transport,
AtomicInteger topologyId,
byte[] cacheName) |
protected void |
Codec20.readNewTopologyAndHash(Transport transport,
HeaderParams params) |
protected void |
Codec20.readNewTopologyIfPresent(Transport transport,
HeaderParams params) |
protected void |
Codec10.readNewTopologyIfPresent(Transport transport,
HeaderParams params) |
protected ClientEvent |
Codec20.readPartialEvent(Transport transport,
byte[] expectedListenerId,
Marshaller marshaller,
short eventTypeId) |
protected ClientEvent |
Codec21.readPartialEvent(Transport transport,
byte[] expectedListenerId,
Marshaller marshaller,
short eventTypeId) |
<T> T |
Codec20.readUnmarshallByteArray(Transport transport,
short status) |
<T> T |
Codec10.readUnmarshallByteArray(Transport transport,
short status) |
<T> T |
Codec.readUnmarshallByteArray(Transport transport,
short status)
Read and unmarshall byte array.
|
Object |
Codec20.returnPossiblePrevValue(Transport transport,
short status,
int flags) |
Object |
Codec10.returnPossiblePrevValue(Transport transport,
short status,
int flags) |
Object |
Codec.returnPossiblePrevValue(Transport transport,
short status,
int flags) |
void |
Codec20.writeClientListenerParams(Transport transport,
ClientListener clientListener,
byte[][] filterFactoryParams,
byte[][] converterFactoryParams) |
void |
Codec21.writeClientListenerParams(Transport transport,
ClientListener clientListener,
byte[][] filterFactoryParams,
byte[][] converterFactoryParams) |
void |
Codec10.writeClientListenerParams(Transport transport,
ClientListener clientListener,
byte[][] filterFactoryParams,
byte[][] converterFactoryParams) |
void |
Codec.writeClientListenerParams(Transport transport,
ClientListener clientListener,
byte[][] filterFactoryParams,
byte[][] converterFactoryParams)
Writes client listener parameters
|
void |
Codec20.writeExpirationParams(Transport transport,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit) |
void |
Codec22.writeExpirationParams(Transport transport,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit) |
void |
Codec10.writeExpirationParams(Transport transport,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit) |
void |
Codec.writeExpirationParams(Transport transport,
long lifespan,
TimeUnit lifespanTimeUnit,
long maxIdle,
TimeUnit maxIdleTimeUnit)
Write lifespan/maxidle parameters.
|
HeaderParams |
Codec24.writeHeader(Transport transport,
HeaderParams params) |
HeaderParams |
Codec25.writeHeader(Transport transport,
HeaderParams params) |
HeaderParams |
Codec20.writeHeader(Transport transport,
HeaderParams params) |
HeaderParams |
Codec21.writeHeader(Transport transport,
HeaderParams params) |
HeaderParams |
Codec22.writeHeader(Transport transport,
HeaderParams params) |
HeaderParams |
Codec23.writeHeader(Transport transport,
HeaderParams params) |
HeaderParams |
Codec10.writeHeader(Transport transport,
HeaderParams params) |
HeaderParams |
Codec11.writeHeader(Transport transport,
HeaderParams params) |
HeaderParams |
Codec12.writeHeader(Transport transport,
HeaderParams params) |
HeaderParams |
Codec13.writeHeader(Transport transport,
HeaderParams params) |
HeaderParams |
Codec.writeHeader(Transport transport,
HeaderParams params)
Writes a request header with the given parameters to the transport and
returns an updated header parameters.
|
protected HeaderParams |
Codec20.writeHeader(Transport transport,
HeaderParams params,
byte version) |
protected HeaderParams |
Codec10.writeHeader(Transport transport,
HeaderParams params,
byte version) |
protected HeaderParams |
Codec12.writeHeader(Transport transport,
HeaderParams params,
byte version) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractTransport
Support class for transport implementations.
|
Modifier and Type | Method and Description |
---|---|
Transport |
TransportFactory.getAddressTransport(SocketAddress server) |
Transport |
TransportFactory.getTransport(Object key,
Set<SocketAddress> failedServers,
byte[] cacheName) |
Transport |
TransportFactory.getTransport(Set<SocketAddress> failedServers,
byte[] cacheName) |
Modifier and Type | Method and Description |
---|---|
void |
TransportFactory.invalidateTransport(SocketAddress serverAddress,
Transport transport) |
void |
TransportFactory.releaseTransport(Transport transport) |
Modifier and Type | Class and Description |
---|---|
class |
TcpTransport
Transport implementation based on TCP.
|
Modifier and Type | Method and Description |
---|---|
Transport |
TcpTransportFactory.getAddressTransport(SocketAddress server) |
Transport |
TcpTransportFactory.getTransport(Object key,
Set<SocketAddress> failedServers,
byte[] cacheName) |
Transport |
TcpTransportFactory.getTransport(Set<SocketAddress> failedServers,
byte[] cacheName) |
Modifier and Type | Method and Description |
---|---|
void |
TcpTransportFactory.invalidateTransport(SocketAddress serverAddress,
Transport transport) |
void |
TcpTransportFactory.releaseTransport(Transport transport) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.iterationTransportObtained(Transport transport,
String iterationId) |
void |
Log.iterationTransportObtained(Transport transport,
String iterationId) |
Copyright © 2022 JBoss, a division of Red Hat. All rights reserved.