dht

package

v0.0.0-...-2ec1701 Latest Latest Go to latest Published: Jul 24, 2014 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var NotAvailable = errors.New("Not Available")

View Source

var NotFound = errors.New("Not Found")

View Source

var TimeoutExceeded = errors.New("Timeout Exceeded")

This section is empty.

type DHT struct {
	//Network
	Network net.Conn

	// DHT Configuration Settings
	Config DHTConfig

	//Republish
	Republish *DHTRepublish
}

func (dht *DHT) FindNode(id *peer.ID) error

Looks for a particular node

func (dht *DHT) GetSloppyValues(key string, count int) ([]*DHTValue, error)

GetSloppyValues finds (at least) a number of values for given key

func (dht *DHT) GetValue(key string) *DHTValue

Retrieves a value for a given key

func (dht *DHT) PingNode(id *peer.ID, timeout time.Duration) error

func (dht *DHT) SetSloppyValue(key string, value *DHTValue) error

func (dht *DHT) SetValue(key string, value *DHTValue) error

Stores a value for a given key

type DHTConfig struct {
	// Time to wait between republishing intervals
	RepublishInterval time.Duration

	// Multihash hash function
	HashType int
}

type DHTObject struct {
	Key           string
	Value         *DHTValue
	LastPublished *time.Time
}

func (o *DHTObject) ShouldRepublish(interval time.Duration) bool

type DHTRepublish struct {
	Strict []*DHTObject
	Sloppy []*DHTObject
}

TODO: not call this republish

type DHTValue struct{}

A struct representing a value in the DHT