2016-03-28 17:28:57 -07:00
|
|
|
package networkdb
|
|
|
|
|
|
|
|
import "github.com/hashicorp/memberlist"
|
|
|
|
|
|
|
|
type eventDelegate struct {
|
|
|
|
nDB *NetworkDB
|
|
|
|
}
|
|
|
|
|
|
|
|
func (e *eventDelegate) NotifyJoin(n *memberlist.Node) {
|
|
|
|
e.nDB.Lock()
|
|
|
|
e.nDB.nodes[n.Name] = n
|
|
|
|
e.nDB.Unlock()
|
|
|
|
}
|
|
|
|
|
|
|
|
func (e *eventDelegate) NotifyLeave(n *memberlist.Node) {
|
|
|
|
e.nDB.deleteNodeTableEntries(n.Name)
|
2016-06-14 12:39:38 -07:00
|
|
|
e.nDB.deleteNetworkNodeEntries(n.Name)
|
2016-03-28 17:28:57 -07:00
|
|
|
e.nDB.Lock()
|
|
|
|
delete(e.nDB.nodes, n.Name)
|
|
|
|
e.nDB.Unlock()
|
|
|
|
}
|
|
|
|
|
|
|
|
func (e *eventDelegate) NotifyUpdate(n *memberlist.Node) {
|
|
|
|
}
|