| Method parameters in net.tomp2p.p2p with type arguments of type Data |
FutureDHT |
DistributedHashTable.add(Number160 locationKey,
Number160 domainKey,
Collection<Data> dataSet,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
boolean protectDomain,
boolean signMessage,
boolean isManualCleanup,
boolean list,
FutureCreate<FutureDHT> futureCreate,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
Map<Number160,Data> |
CumulativeScheme.evaluate2(Map<PeerAddress,Map<Number160,Data>> rawKeys)
|
Map<Number160,Data> |
EvaluatingSchemeDHT.evaluate2(Map<PeerAddress,Map<Number160,Data>> rawData)
|
Map<Number160,Data> |
VotingSchemeDHT.evaluate2(Map<PeerAddress,Map<Number160,Data>> rawData)
|
FutureDHT |
DistributedHashTable.put(Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMap,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
boolean putIfAbsent,
boolean protectDomain,
boolean signMessage,
boolean isManualCleanup,
FutureCreate<FutureDHT> futureCreate,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
void |
BroadcastHandler.receive(Number160 messageKey,
Map<Number160,Data> dataMap,
int hopCounter,
boolean isUDP)
|
void |
DefaultBroadcastHandler.receive(Number160 messageKey,
Map<Number160,Data> dataMap,
int hopCounter,
boolean isUDP)
|
FutureTask |
DistributedTask.submit(Number160 locationKey,
Map<Number160,Data> dataMap,
Worker worker,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration requestP2PConfiguration,
FutureChannelCreator futureChannelCreator,
boolean signMessage,
boolean isManualCleanup,
ConnectionReservation connectionReservation)
Submit a task to the DHT. |
| Method parameters in net.tomp2p.rpc with type arguments of type Data |
FutureResponse |
StorageRPC.add(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Collection<Data> dataSet,
boolean protectDomain,
boolean signMessage,
boolean list,
ChannelCreator channelCreator,
boolean forceUDP,
SenderCacheStrategy senderCacheStrategy)
Adds data on a remote peer. |
FutureResponse |
StorageRPC.put(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMap,
boolean protectDomain,
boolean protectEntry,
boolean signMessage,
ChannelCreator channelCreator,
boolean forceUDP,
SenderCacheStrategy senderCacheStrategy)
Stores data on a remote peer. |
FutureResponse |
StorageRPC.putIfAbsent(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMap,
boolean protectDomain,
boolean protectEntry,
boolean signMessage,
ChannelCreator channelCreator,
boolean forceUDP,
SenderCacheStrategy senderCacheStrategy)
Stores data on a remote peer. |
FutureResponse |
BroadcastRPC.send(PeerAddress remotePeer,
Number160 messageKey,
Map<Number160,Data> dataMap,
ChannelCreator channelCreator,
int idleTCPMillis,
boolean forceUDP)
|
FutureResponse |
BroadcastRPC.send(PeerAddress remotePeer,
Number160 messageKey,
Map<Number160,Data> dataMap,
int hopCounter,
ChannelCreator channelCreator,
int idleTCPMillis,
boolean forceUDP)
|
FutureResponse |
TaskRPC.sendResult(PeerAddress remotePeer,
ChannelCreator channelCreator,
Number160 taskID,
Map<Number160,Data> dataMap,
KeyPair keyPair,
boolean forceUDP,
boolean sign)
|
FutureResponse |
TaskRPC.sendTask(PeerAddress remotePeer,
ChannelCreator channelCreator,
Number160 taskID,
Map<Number160,Data> dataMap,
Worker mapper,
KeyPair keyPair,
boolean forceUDP,
boolean sign)
Sends a task to a remote peer. |
| Methods in net.tomp2p.storage that return Data |
Data |
StorageMemory.get(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
Storage.get(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
StorageDisk.get(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
StorageMemory.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
Storage.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
StorageDisk.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
StorageGeneric.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
PublicKey publicKey)
|
Data |
Data.setDirectReplication()
|
Data |
Data.setDirectReplication(boolean directReplication)
|
Data |
Data.setFileReference()
|
Data |
Data.setFileReference(boolean fileReference)
|
Data |
Data.setProtectedEntry()
|
Data |
Data.setProtectedEntry(boolean protectedEntry)
|
Data |
Data.setPublicKey(PublicKey publicKey)
|
Data |
Data.setTTLSeconds(int ttlSeconds)
|
| Methods in net.tomp2p.storage that return types with arguments of type Data |
SortedMap<Number480,Data> |
StorageGeneric.get(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey)
|
NavigableMap<Number480,Data> |
StorageMemory.map()
|
NavigableMap<Number480,Data> |
Storage.map()
The storage is typically backed by multiple Java collections (HashMap, TreeMap, etc.). |
NavigableMap<Number480,Data> |
StorageDisk.map()
|
SortedMap<Number480,Data> |
StorageGeneric.remove(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey,
PublicKey publicKey)
|
Map<Number480,Data> |
StorageMemory.subMap(Number160 locationKey)
|
Map<Number480,Data> |
Storage.subMap(Number160 locationKey)
|
Map<Number480,Data> |
StorageDisk.subMap(Number160 locationKey)
|
SortedMap<Number480,Data> |
StorageMemory.subMap(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey)
|
SortedMap<Number480,Data> |
Storage.subMap(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey)
|
SortedMap<Number480,Data> |
StorageDisk.subMap(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey)
|
| Method parameters in net.tomp2p.task with type arguments of type Data |
Map<Number160,Data> |
Worker.execute(Peer peer,
Number160 taskId,
Map<Number160,Data> inputData)
|
void |
TaskManager.notifyListeners(Number320 taskKey,
Map<Number160,Data> dataMap)
|
FutureAsyncTask |
AsyncTask.submit(PeerAddress remotePeer,
ChannelCreator channelCreator,
Number160 taskId,
Map<Number160,Data> dataMap,
Worker mapper,
boolean forceUDP,
boolean sign)
|
int |
TaskManager.submitTask(Peer peer,
Number160 taskId,
Worker mapper,
Map<Number160,Data> data,
PeerAddress senderAddress,
boolean sign)
|
void |
TaskResultListener.taskReceived(Number320 taskId,
Map<Number160,Data> dataMap)
|
void |
AsyncTask.taskReceived(Number320 taskKey,
Map<Number160,Data> dataMap)
|