Modifier and Type | Method and Description |
---|---|
protected Transport |
AbstractKeyOperation.getTransport(int retryCount) |
protected Transport |
ClearOperation.getTransport(int retryCount) |
protected Transport |
BulkGetKeysOperation.getTransport(int retryCount) |
protected Transport |
QueryOperation.getTransport(int retryCount) |
protected abstract Transport |
RetryOnFailureOperation.getTransport(int retryCount) |
protected Transport |
BulkGetOperation.getTransport(int retryCount) |
protected Transport |
StatsOperation.getTransport(int retryCount) |
protected Transport |
FaultTolerantPingOperation.getTransport(int retryCount) |
Modifier and Type | Method and Description |
---|---|
protected Boolean |
ContainsKeyOperation.executeOperation(Transport transport) |
protected byte[] |
PutIfAbsentOperation.executeOperation(Transport transport) |
byte[] |
RemoveOperation.executeOperation(Transport transport) |
protected Void |
ClearOperation.executeOperation(Transport transport) |
protected byte[] |
ReplaceOperation.executeOperation(Transport transport) |
protected VersionedValue<byte[]> |
GetWithVersionOperation.executeOperation(Transport transport)
Deprecated.
|
protected Set<byte[]> |
BulkGetKeysOperation.executeOperation(Transport transport) |
protected QueryResponse |
QueryOperation.executeOperation(Transport transport) |
protected byte[] |
PutOperation.executeOperation(Transport transport) |
byte[] |
GetOperation.executeOperation(Transport transport) |
protected MetadataValue<byte[]> |
GetWithMetadataOperation.executeOperation(Transport transport) |
protected abstract T |
RetryOnFailureOperation.executeOperation(Transport transport) |
protected Map<byte[],byte[]> |
BulkGetOperation.executeOperation(Transport transport) |
protected VersionedOperationResponse |
RemoveIfUnmodifiedOperation.executeOperation(Transport transport) |
protected VersionedOperationResponse |
ReplaceIfUnmodifiedOperation.executeOperation(Transport transport) |
protected Map<String,String> |
StatsOperation.executeOperation(Transport transport) |
protected PingOperation.PingResult |
FaultTolerantPingOperation.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) |
Constructor and Description |
---|
PingOperation(Codec codec,
AtomicInteger topologyId,
Transport transport) |
PingOperation(Codec codec,
AtomicInteger topologyId,
Transport transport,
byte[] cacheName) |
Modifier and Type | Method and Description |
---|---|
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) |
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 |
Codec12.writeHeader(Transport transport,
HeaderParams params) |
HeaderParams |
Codec10.writeHeader(Transport transport,
HeaderParams params) |
HeaderParams |
Codec11.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) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractTransport
Support class for transport implementations.
|
Modifier and Type | Method and Description |
---|---|
Transport |
TransportFactory.getTransport() |
Transport |
TransportFactory.getTransport(byte[] key) |
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.getTransport() |
Transport |
TcpTransportFactory.getTransport(byte[] key) |
Modifier and Type | Method and Description |
---|---|
void |
TcpTransportFactory.invalidateTransport(SocketAddress serverAddress,
Transport transport) |
void |
TcpTransportFactory.releaseTransport(Transport transport) |
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.