alert

Documentation

Index

• Constants
• type AlertMessage
• type AlertServer
  • func NewAlertServer(g *graph.Graph, ah api.ApiHandler, wsServer *shttp.WSServer, ...) *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
  • func NewGremlinAlert(alert *api.Alert, g *graph.Graph, p *traversal.GremlinTraversalParser) (*GremlinAlert, error)
  • func (ga *GremlinAlert) Evaluate() (interface{}, error)
  • func (ga *GremlinAlert) Trigger(payload []byte) error

Constants

const (
	WEBHOOK = 1 + iota
	SCRIPT
)

const (
	Namespace = "Alert"
)

Types

type AlertMessage

type AlertMessage struct {
	UUID       string
	Timestamp  time.Time
	ReasonData interface{}
}

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

type GremlinAlert struct {
	*api.Alert
	// contains filtered or unexported fields
}

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