package serf import ( "serfNode/ipc" "basic.com/valib/logger.git" "basic.com/valib/serf.git/serf" ) const ( PLCDATA = "plcData" ) func HandleSerfEvent(event serf.Event) { switch ev := event.(type) { case serf.UserEvent: case *serf.Query: if ev.Name == PLCDATA { if IsMaster() { ipc.Produce(ev.Payload) } } case serf.MemberEvent: default: logger.Debug("unknown event name:", ev.String()) } }