Method serfEventHandler

onecache/onecache.go:158–181

serfEventHandler is a dispatch method on Serf Events. Should be started in a goroutine.

()

// serfEventHandler is a dispatch method on Serf Events. Should be started in a
// goroutine.
func (n *Node) serfEventHandler() {
	for {
		select {
		case <-n.quitCh:
			return
		case e := <-n.eventCh:
			switch t := e.(type) {
			case serf.MemberEvent:
				switch t.EventType() {
				case serf.EventMemberJoin:
					go n.handleNodeJoins(t.Members)
				case serf.EventMemberLeave, serf.EventMemberFailed:
					go n.handleNodeLeaves(t.Members)
				default:
					// Don't handle any other event type.
					continue
				}
			default:
				n.logger.Printf("[ERROR] onecache: unexpected Serf event type %v\n", t)
				continue
			}
		}
	}
}

// Exit removes this Node from the ring, kills background tasks and frees any
// used resources. Once this is called the Node will no longer accept