Documentation
¶
Index ¶
- Constants
- type AlertMessage
- type AlertServer
- func (a *AlertServer) EvaluateAlerts(alerts map[string]*GremlinAlert)
- func (a *AlertServer) OnEdgeAdded(e *graph.Edge)
- func (a *AlertServer) OnEdgeDeleted(e *graph.Edge)
- func (a *AlertServer) OnEdgeUpdated(e *graph.Edge)
- func (a *AlertServer) OnNodeAdded(n *graph.Node)
- func (a *AlertServer) OnNodeDeleted(n *graph.Node)
- func (a *AlertServer) OnNodeUpdated(n *graph.Node)
- func (a *AlertServer) RegisterAlert(apiAlert *api.Alert) error
- func (a *AlertServer) Start()
- func (a *AlertServer) Stop()
- func (a *AlertServer) TriggerAlert(al *GremlinAlert, data interface{}) error
- func (a *AlertServer) UnregisterAlert(id string)
- type GremlinAlert
Constants ¶
View Source
const ( WEBHOOK = 1 + iota SCRIPT )
View Source
const (
Namespace = "Alert"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AlertMessage ¶
type AlertServer ¶
type AlertServer struct {
sync.RWMutex
shttp.DefaultWSServerEventHandler
Graph *graph.Graph
WSServer *shttp.WSServer
AlertHandler api.ApiHandler
// contains filtered or unexported fields
}
func NewAlertServer ¶
func NewAlertServer(g *graph.Graph, ah api.ApiHandler, wsServer *shttp.WSServer, tc *flow.TableClient, s storage.Storage) *AlertServer
func (*AlertServer) EvaluateAlerts ¶
func (a *AlertServer) EvaluateAlerts(alerts map[string]*GremlinAlert)
func (*AlertServer) OnEdgeAdded ¶
func (a *AlertServer) OnEdgeAdded(e *graph.Edge)
func (*AlertServer) OnEdgeDeleted ¶
func (a *AlertServer) OnEdgeDeleted(e *graph.Edge)
func (*AlertServer) OnEdgeUpdated ¶
func (a *AlertServer) OnEdgeUpdated(e *graph.Edge)
func (*AlertServer) OnNodeAdded ¶
func (a *AlertServer) OnNodeAdded(n *graph.Node)
func (*AlertServer) OnNodeDeleted ¶
func (a *AlertServer) OnNodeDeleted(n *graph.Node)
func (*AlertServer) OnNodeUpdated ¶
func (a *AlertServer) OnNodeUpdated(n *graph.Node)
func (*AlertServer) RegisterAlert ¶
func (a *AlertServer) RegisterAlert(apiAlert *api.Alert) error
func (*AlertServer) Start ¶
func (a *AlertServer) Start()
func (*AlertServer) Stop ¶
func (a *AlertServer) Stop()
func (*AlertServer) TriggerAlert ¶
func (a *AlertServer) TriggerAlert(al *GremlinAlert, data interface{}) error
func (*AlertServer) UnregisterAlert ¶
func (a *AlertServer) UnregisterAlert(id string)
type GremlinAlert ¶
func NewGremlinAlert ¶
func NewGremlinAlert(alert *api.Alert, g *graph.Graph, p *traversal.GremlinTraversalParser) (*GremlinAlert, error)
func (*GremlinAlert) Evaluate ¶
func (ga *GremlinAlert) Evaluate() (interface{}, error)
func (*GremlinAlert) Trigger ¶
func (ga *GremlinAlert) Trigger(payload []byte) error
Source Files
¶
- server.go
Click to show internal directories.
Click to hide internal directories.