Method parameters in net.tomp2p.p2p with type arguments of type Data |
FutureDHT |
Peer.add(Number160 locationKey,
Collection<Data> dataCollection,
ConfigurationStore config)
|
FutureDHT |
Peer.add(Number160 locationKey,
Collection<Data> dataCollection,
ConfigurationStore config,
FutureChannelCreator channelCreator)
|
FutureDHT |
DistributedHashTable.add(Number160 locationKey,
Number160 domainKey,
Collection<Data> dataSet,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
boolean protectDomain,
boolean signMessage,
boolean isAutomaticCleanup,
FutureCreate<FutureDHT> futureCreate,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
Map<Number160,Data> |
VotingSchemeDHT.evaluate2(Map<PeerAddress,Map<Number160,Data>> rawData)
|
Map<Number160,Data> |
CumulativeScheme.evaluate2(Map<PeerAddress,Map<Number160,Data>> rawKeys)
|
Map<Number160,Data> |
EvaluatingSchemeDHT.evaluate2(Map<PeerAddress,Map<Number160,Data>> rawData)
|
FutureDHT |
Peer.put(Number160 locationKey,
Map<Number160,Data> dataMap,
ConfigurationStore config)
|
FutureDHT |
Peer.put(Number160 locationKey,
Map<Number160,Data> dataMap,
ConfigurationStore config,
FutureChannelCreator channelCreator)
Stores values in the DHT. |
FutureDHT |
DistributedHashTable.put(Number160 locationKey,
Number160 domainKey,
Map<Number160,Data> dataMap,
RoutingConfiguration routingConfiguration,
RequestP2PConfiguration p2pConfiguration,
boolean putIfAbsent,
boolean protectDomain,
boolean signMessage,
boolean isAutomaticCleanup,
FutureCreate<FutureDHT> futureCreate,
FutureChannelCreator futureChannelCreator,
ConnectionReservation connectionReservation)
|
FutureTask |
DistributedTask.submit(Number160 locationKey,
Map<Number160,Data> dataMap,
Worker worker,
RoutingConfiguration routingConfiguration,
TaskConfiguration taskConfiguration,
FutureChannelCreator futureChannelCreator,
boolean signMessage,
boolean isAutomaticCleanup,
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,
ChannelCreator channelCreator,
boolean forceUDP)
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)
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)
Stores data on a remote peer. |
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 |
StorageDisk.get(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
Storage.get(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
DataSet.getData()
|
Data |
StorageMemory.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
StorageDisk.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
Storage.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey)
|
Data |
StorageGeneric.remove(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
PublicKey publicKey)
|
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)
|
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> |
StorageDisk.subMap(Number160 locationKey)
|
Map<Number480,Data> |
Storage.subMap(Number160 locationKey)
|
SortedMap<Number480,Data> |
StorageMemory.subMap(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey)
|
SortedMap<Number480,Data> |
StorageDisk.subMap(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey)
|
SortedMap<Number480,Data> |
Storage.subMap(Number160 locationKey,
Number160 domainKey,
Number160 fromContentKey,
Number160 toContentKey)
|
Methods in net.tomp2p.storage with parameters of type Data |
void |
StorageRunner.call(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
Data data)
|
boolean |
StorageMemory.put(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
Data value)
|
boolean |
StorageDisk.put(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
Data value)
|
boolean |
Storage.put(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
Data value)
|
boolean |
StorageGeneric.put(Number160 locationKey,
Number160 domainKey,
Number160 contentKey,
Data newData,
PublicKey publicKey,
boolean putIfAbsent,
boolean domainProtection)
|
Method parameters in net.tomp2p.task with type arguments of type Data |
Map<Number160,Data> |
Worker.execute(Map<Number160,Data> inputData,
Storage storage)
|
void |
TaskManager.notifyListeners(Number160 taskId,
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(Number160 taskId,
Worker mapper,
Map<Number160,Data> data,
PeerAddress senderAddress,
boolean sign)
|
void |
AsyncTask.taskReceived(Number160 taskId,
Map<Number160,Data> dataMap)
|
void |
TaskResultListener.taskReceived(Number160 taskId,
Map<Number160,Data> dataMap)
|