|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Transport in org.infinispan.client.hotrod.impl.operations |
---|
Methods in org.infinispan.client.hotrod.impl.operations that return Transport | |
---|---|
protected abstract Transport |
RetryOnFailureOperation.getTransport(int retryCount)
|
protected Transport |
BulkGetOperation.getTransport(int retryCount)
|
protected Transport |
BulkGetKeysOperation.getTransport(int retryCount)
|
protected Transport |
StatsOperation.getTransport(int retryCount)
|
protected Transport |
AbstractKeyOperation.getTransport(int retryCount)
|
protected Transport |
ClearOperation.getTransport(int retryCount)
|
protected Transport |
FaultTolerantPingOperation.getTransport(int retryCount)
|
Methods in org.infinispan.client.hotrod.impl.operations with parameters of type Transport | |
---|---|
protected byte[] |
PutIfAbsentOperation.executeOperation(Transport transport)
|
protected VersionedValue<byte[]> |
GetWithVersionOperation.executeOperation(Transport transport)
Deprecated. |
protected abstract T |
RetryOnFailureOperation.executeOperation(Transport transport)
|
protected Map<byte[],byte[]> |
BulkGetOperation.executeOperation(Transport transport)
|
protected Set<byte[]> |
BulkGetKeysOperation.executeOperation(Transport transport)
|
protected byte[] |
PutOperation.executeOperation(Transport transport)
|
protected VersionedOperationResponse |
ReplaceIfUnmodifiedOperation.executeOperation(Transport transport)
|
protected MetadataValue<byte[]> |
GetWithMetadataOperation.executeOperation(Transport transport)
|
protected byte[] |
ReplaceOperation.executeOperation(Transport transport)
|
protected Boolean |
ContainsKeyOperation.executeOperation(Transport transport)
|
protected Map<String,String> |
StatsOperation.executeOperation(Transport transport)
|
byte[] |
GetOperation.executeOperation(Transport transport)
|
protected Void |
ClearOperation.executeOperation(Transport transport)
|
protected VersionedOperationResponse |
RemoveIfUnmodifiedOperation.executeOperation(Transport transport)
|
protected PingOperation.PingResult |
FaultTolerantPingOperation.executeOperation(Transport transport)
|
byte[] |
RemoveOperation.executeOperation(Transport transport)
|
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 |
RetryOnFailureOperation.releaseTransport(Transport transport)
|
protected byte[] |
AbstractKeyOperation.returnPossiblePrevValue(Transport transport)
|
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)
|
Constructors in org.infinispan.client.hotrod.impl.operations with parameters of type Transport | |
---|---|
PingOperation(Codec codec,
AtomicInteger topologyId,
Transport transport)
|
|
PingOperation(Codec codec,
AtomicInteger topologyId,
Transport transport,
byte[] cacheName)
|
Uses of Transport in org.infinispan.client.hotrod.impl.protocol |
---|
Methods in org.infinispan.client.hotrod.impl.protocol with parameters of type Transport | |
---|---|
protected void |
Codec10.checkForErrorsInResponseStatus(Transport transport,
HeaderParams params,
short status)
|
protected Map<SocketAddress,Set<Integer>> |
Codec11.computeNewHashes(Transport transport,
Log localLog,
int newTopologyId,
int numKeyOwners,
short hashFunctionVersion,
int hashSpace,
int clusterSize)
|
protected Map<SocketAddress,Set<Integer>> |
Codec10.computeNewHashes(Transport transport,
Log localLog,
int newTopologyId,
int numKeyOwners,
short hashFunctionVersion,
int hashSpace,
int clusterSize)
|
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. |
protected void |
Codec10.readNewTopologyAndHash(Transport transport,
AtomicInteger topologyId)
|
protected void |
Codec10.readNewTopologyIfPresent(Transport transport,
HeaderParams params)
|
HeaderParams |
Codec11.writeHeader(Transport transport,
HeaderParams params)
|
HeaderParams |
Codec12.writeHeader(Transport transport,
HeaderParams params)
|
HeaderParams |
Codec10.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 |
Codec12.writeHeader(Transport transport,
HeaderParams params,
byte version)
|
protected HeaderParams |
Codec10.writeHeader(Transport transport,
HeaderParams params,
byte version)
|
Uses of Transport in org.infinispan.client.hotrod.impl.transport |
---|
Classes in org.infinispan.client.hotrod.impl.transport that implement Transport | |
---|---|
class |
AbstractTransport
Support class for transport implementations. |
Methods in org.infinispan.client.hotrod.impl.transport that return Transport | |
---|---|
Transport |
TransportFactory.getTransport()
|
Transport |
TransportFactory.getTransport(byte[] key)
|
Methods in org.infinispan.client.hotrod.impl.transport with parameters of type Transport | |
---|---|
void |
TransportFactory.invalidateTransport(SocketAddress serverAddress,
Transport transport)
|
void |
TransportFactory.releaseTransport(Transport transport)
|
Uses of Transport in org.infinispan.client.hotrod.impl.transport.tcp |
---|
Classes in org.infinispan.client.hotrod.impl.transport.tcp that implement Transport | |
---|---|
class |
TcpTransport
Transport implementation based on TCP. |
Methods in org.infinispan.client.hotrod.impl.transport.tcp that return Transport | |
---|---|
Transport |
TcpTransportFactory.getTransport()
|
Transport |
TcpTransportFactory.getTransport(byte[] key)
|
Methods in org.infinispan.client.hotrod.impl.transport.tcp with parameters of type Transport | |
---|---|
void |
TcpTransportFactory.invalidateTransport(SocketAddress serverAddress,
Transport transport)
|
void |
TcpTransportFactory.releaseTransport(Transport transport)
|
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV NEXT | FRAMES NO FRAMES |