Versions in this module Expand all Collapse all v0 v0.6.0 Oct 6, 2016 v0.5.0 Sep 15, 2016 v0.4.0 Aug 4, 2016 Changes in this version + const Namespace + type AlertServer struct + AlertManager *AlertManager + WSServer *shttp.WSServer + func (a *AlertServer) OnRegisterClient(c *shttp.WSClient) + func (a *AlertServer) OnUnregisterClient(c *shttp.WSClient) v0.3.0 Apr 26, 2016 Changes in this version + const FIXED + const THRESHOLD + type AlertEventListener interface + OnAlert func(n *AlertMessage) + type AlertManager struct + AlertHandler api.ApiHandler + Graph *graph.Graph + func NewAlertManager(g *graph.Graph, ah api.ApiHandler) *AlertManager + func (a *AlertManager) AddEventListener(l AlertEventListener) + func (a *AlertManager) DelEventListener(l AlertEventListener) + func (a *AlertManager) DeleteAlert(id string) + func (a *AlertManager) EvalNodes() + func (a *AlertManager) OnNodeAdded(n *graph.Node) + func (a *AlertManager) OnNodeUpdated(n *graph.Node) + func (a *AlertManager) SetAlert(at *api.Alert) + func (a *AlertManager) Start() + func (a *AlertManager) Stop() + type AlertMessage struct + Count int + Reason string + ReasonData interface{} + Timestamp time.Time + Type int + UUID string + func (am *AlertMessage) Marshal() []byte + func (am *AlertMessage) String() string + type Server struct + AlertManager *AlertManager + Host string + func NewServer(a *AlertManager, server *shttp.Server, pongWait time.Duration) *Server + func NewServerFromConfig(a *AlertManager, server *shttp.Server) (*Server, error) + func (s *Server) ListenAndServe() + func (s *Server) Stop() + type WSClient struct + func (c *WSClient) OnAlert(amsg *AlertMessage) + type WSServer struct + AlertManager *AlertManager + func (s *WSServer) ListenAndServe()