alert

package
v0.21.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 3, 2018 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Namespace is the alerting WebSocket namespace
	Namespace = "Alert"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type GremlinAlert 

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

GremlinAlert represents an alert that will be triggered if its associated Gremlin expression returns a non empty result.

func NewGremlinAlert 

func NewGremlinAlert(alert *types.Alert, g *graph.Graph, p *traversal.GremlinTraversalParser) (*GremlinAlert, error)

NewGremlinAlert returns a new gremlin based alert

type Message added in v0.19.1 

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

Message describes a websocket message that is sent by the alerting server when an alert was triggered

type Server added in v0.19.1 

type Server struct {
	common.RWMutex
	*etcd.MasterElector
	Graph        *graph.Graph
	Pool         ws.StructSpeakerPool
	AlertHandler api.Handler
	// contains filtered or unexported fields
}

Server describes an alerting alerts that evaluates registered alerts on graph events or periodically and trigger them if their condition evaluates to true

func NewServer added in v0.19.1 

func NewServer(apiServer *api.Server, pool ws.StructSpeakerPool, graph *graph.Graph, parser *traversal.GremlinTraversalParser, etcdClient *etcd.Client) (*Server, error)

NewServer creates a new alerting server

func (*Server) OnEdgeAdded added in v0.19.1 

func (a *Server) OnEdgeAdded(e *graph.Edge)

OnEdgeAdded event

func (*Server) OnEdgeDeleted added in v0.19.1 

func (a *Server) OnEdgeDeleted(e *graph.Edge)

OnEdgeDeleted event

func (*Server) OnEdgeUpdated added in v0.19.1 

func (a *Server) OnEdgeUpdated(e *graph.Edge)

OnEdgeUpdated event

func (*Server) OnNodeAdded added in v0.19.1 

func (a *Server) OnNodeAdded(n *graph.Node)

OnNodeAdded event

func (*Server) OnNodeDeleted added in v0.19.1 

func (a *Server) OnNodeDeleted(n *graph.Node)

OnNodeDeleted event

func (*Server) OnNodeUpdated added in v0.19.1 

func (a *Server) OnNodeUpdated(n *graph.Node)

OnNodeUpdated event

func (*Server) Start added in v0.19.1 

func (a *Server) Start()

Start the alerting server

func (*Server) Stop added in v0.19.1 

func (a *Server) Stop()

Stop the alerting server

Source Files

  • server.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.