agent: remove unnecessary EventFire function
This commit is contained in:
parent
d893a60534
commit
d2eac37579
|
@ -72,7 +72,7 @@ func (m *Internal) EventFire(args *structs.EventFireRequest,
|
|||
m.srv.setQueryMeta(&reply.QueryMeta)
|
||||
|
||||
// Fire the event
|
||||
return m.srv.UserEvent(args.Name, args.Payload)
|
||||
return m.srv.serfLAN.UserEvent(args.Name, args.Payload, false)
|
||||
}
|
||||
|
||||
// KeyringOperation will query the WAN and LAN gossip keyrings of all nodes.
|
||||
|
|
|
@ -616,11 +616,6 @@ func (s *Server) RemoveFailedNode(node string) error {
|
|||
return nil
|
||||
}
|
||||
|
||||
// UserEvent is used to fire an event via the Serf layer on the LAN
|
||||
func (s *Server) UserEvent(name string, payload []byte) error {
|
||||
return s.serfLAN.UserEvent(userEventName(name), payload, false)
|
||||
}
|
||||
|
||||
// IsLeader checks if this server is the cluster leader
|
||||
func (s *Server) IsLeader() bool {
|
||||
return s.raft.State() == raft.Leader
|
||||
|
|
Loading…
Reference in New Issue