org.gudy.azureus2.plugins.ddb
Interface DistributedDatabase

All Known Implementing Classes:
DDBaseImpl

public interface DistributedDatabase

Author:
parg

Field Summary
static int DHT_CVS
           
static int DHT_MAIN
           
static byte DT_FREQUENCY
           
static byte DT_NONE
           
static byte DT_SIZE
           
static int OP_EXHAUSTIVE_READ
           
static int OP_NONE
           
static int OP_PRIORITY_HIGH
           
 
Method Summary
 void addListener(DistributedDatabaseListener l)
           
 void addTransferHandler(DistributedDatabaseTransferType type, DistributedDatabaseTransferHandler handler)
           
 DistributedDatabaseKey createKey(Object key)
           
 DistributedDatabaseKey createKey(Object key, String description)
           
 DistributedDatabaseValue createValue(Object value)
           
 void delete(DistributedDatabaseListener listener, DistributedDatabaseKey key)
           
 void delete(DistributedDatabaseListener listener, DistributedDatabaseKey key, DistributedDatabaseContact[] targets)
           
 DHTPluginInterface getDHTPlugin()
           
 DistributedDatabaseContact getLocalContact()
           
 String getNetwork()
           
 DistributedDatabaseTransferType getStandardTransferType(int standard_type)
           
 List<DistributedDatabaseValue> getValues(DistributedDatabaseKey key)
          Get all locally held (direct+indirect) values for a key
 DistributedDatabaseContact importContact(InetSocketAddress address)
           
 DistributedDatabaseContact importContact(InetSocketAddress address, byte protocol_version)
           
 DistributedDatabaseContact importContact(InetSocketAddress address, byte protocol_version, int preferred_dht)
           
 DistributedDatabaseContact importContact(Map<String,Object> map)
           
 boolean isAvailable()
           
 boolean isExtendedUseAllowed()
           
 boolean isInitialized()
           
 void read(DistributedDatabaseListener listener, DistributedDatabaseKey key, long timeout)
           
 void read(DistributedDatabaseListener listener, DistributedDatabaseKey key, long timeout, int options)
           
 void readKeyStats(DistributedDatabaseListener listener, DistributedDatabaseKey key, long timeout)
           
 void removeListener(DistributedDatabaseListener l)
           
 void write(DistributedDatabaseListener listener, DistributedDatabaseKey key, DistributedDatabaseValue value)
           
 void write(DistributedDatabaseListener listener, DistributedDatabaseKey key, DistributedDatabaseValue[] values)
           
 

Field Detail

OP_NONE

static final int OP_NONE
See Also:
Constant Field Values

OP_EXHAUSTIVE_READ

static final int OP_EXHAUSTIVE_READ
See Also:
Constant Field Values

OP_PRIORITY_HIGH

static final int OP_PRIORITY_HIGH
See Also:
Constant Field Values

DT_NONE

static final byte DT_NONE
See Also:
Constant Field Values

DT_FREQUENCY

static final byte DT_FREQUENCY
See Also:
Constant Field Values

DT_SIZE

static final byte DT_SIZE
See Also:
Constant Field Values

DHT_MAIN

static final int DHT_MAIN
See Also:
Constant Field Values

DHT_CVS

static final int DHT_CVS
See Also:
Constant Field Values
Method Detail

isAvailable

boolean isAvailable()

isInitialized

boolean isInitialized()

isExtendedUseAllowed

boolean isExtendedUseAllowed()

getNetwork

String getNetwork()

getDHTPlugin

DHTPluginInterface getDHTPlugin()

getLocalContact

DistributedDatabaseContact getLocalContact()

createKey

DistributedDatabaseKey createKey(Object key)
                                 throws DistributedDatabaseException
Throws:
DistributedDatabaseException

createKey

DistributedDatabaseKey createKey(Object key,
                                 String description)
                                 throws DistributedDatabaseException
Throws:
DistributedDatabaseException

createValue

DistributedDatabaseValue createValue(Object value)
                                     throws DistributedDatabaseException
Throws:
DistributedDatabaseException

importContact

DistributedDatabaseContact importContact(InetSocketAddress address)
                                         throws DistributedDatabaseException
Throws:
DistributedDatabaseException

importContact

DistributedDatabaseContact importContact(InetSocketAddress address,
                                         byte protocol_version)
                                         throws DistributedDatabaseException
Throws:
DistributedDatabaseException

importContact

DistributedDatabaseContact importContact(InetSocketAddress address,
                                         byte protocol_version,
                                         int preferred_dht)
                                         throws DistributedDatabaseException
Throws:
DistributedDatabaseException

importContact

DistributedDatabaseContact importContact(Map<String,Object> map)
                                         throws DistributedDatabaseException
Throws:
DistributedDatabaseException

write

void write(DistributedDatabaseListener listener,
           DistributedDatabaseKey key,
           DistributedDatabaseValue value)
           throws DistributedDatabaseException
Throws:
DistributedDatabaseException

write

void write(DistributedDatabaseListener listener,
           DistributedDatabaseKey key,
           DistributedDatabaseValue[] values)
           throws DistributedDatabaseException
Throws:
DistributedDatabaseException

read

void read(DistributedDatabaseListener listener,
          DistributedDatabaseKey key,
          long timeout)
          throws DistributedDatabaseException
Throws:
DistributedDatabaseException

read

void read(DistributedDatabaseListener listener,
          DistributedDatabaseKey key,
          long timeout,
          int options)
          throws DistributedDatabaseException
Throws:
DistributedDatabaseException

readKeyStats

void readKeyStats(DistributedDatabaseListener listener,
                  DistributedDatabaseKey key,
                  long timeout)
                  throws DistributedDatabaseException
Throws:
DistributedDatabaseException

getValues

List<DistributedDatabaseValue> getValues(DistributedDatabaseKey key)
                                         throws DistributedDatabaseException
Get all locally held (direct+indirect) values for a key

Parameters:
key -
Returns:
Throws:
DistributedDatabaseException

delete

void delete(DistributedDatabaseListener listener,
            DistributedDatabaseKey key)
            throws DistributedDatabaseException
Throws:
DistributedDatabaseException

delete

void delete(DistributedDatabaseListener listener,
            DistributedDatabaseKey key,
            DistributedDatabaseContact[] targets)
            throws DistributedDatabaseException
Throws:
DistributedDatabaseException

addTransferHandler

void addTransferHandler(DistributedDatabaseTransferType type,
                        DistributedDatabaseTransferHandler handler)
                        throws DistributedDatabaseException
Throws:
DistributedDatabaseException

getStandardTransferType

DistributedDatabaseTransferType getStandardTransferType(int standard_type)
                                                        throws DistributedDatabaseException
Throws:
DistributedDatabaseException

addListener

void addListener(DistributedDatabaseListener l)

removeListener

void removeListener(DistributedDatabaseListener l)