kademlia

type DHT struct {

	// Seconds after which an otherwise unaccessed bucket must be refreshed,
	// also used to reap dead nodes from the DHT. if a node hasnt been seen in 4x
	// the refresh period then its dead.
	TRefresh time.Duration

	// The maximum time to wait for a response from a node before discarding
	// it from the bucket
	TPingMax time.Duration

	// The maximum time to wait to locate a key before timing out.
	TLocateTimeout time.Duration
	// contains filtered or unexported fields
}

type MemoryStore struct {
	// contains filtered or unexported fields
}

type Message struct {
	Sender     *NetworkNode
	Receiver   *NetworkNode
	ID         int64
	Type       int
	IsResponse bool
	Data       interface{}
}

type MessageOption func(*Message)

type NetworkNode struct {
	// ID is a 20 byte unique identifier
	ID []byte

	// IP is the public address of the node
	IP net.IP

	// Port is the public port of the node
	Port int

	// LastSeen when was this node last considered seen by the DHT
	LastSeen time.Time
}

type Option func(*DHT)

type Socket struct {
	Gateway net.IP
	Port    int
	// contains filtered or unexported fields
}

type SocketOption func(*Socket)