Documentation
¶
Index ¶
- Constants
- type AlertMessage
- type AlertServer
- func (a *AlertServer) EvaluateAlerts(alerts map[string]*GremlinAlert, lockGraph bool)
- 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 *types.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 (
// Namespace Alert
Namespace = "Alert"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AlertMessage ¶
type AlertServer ¶
type AlertServer struct {
sync.RWMutex
*etcd.EtcdMasterElector
Graph *graph.Graph
Pool shttp.WSJSONSpeakerPool
AlertHandler api.Handler
// contains filtered or unexported fields
}
func NewAlertServer ¶
func NewAlertServer(ah api.Handler, pool shttp.WSJSONSpeakerPool, graph *graph.Graph, parser *traversal.GremlinTraversalParser, etcdClient *etcd.EtcdClient) *AlertServer
func (*AlertServer) EvaluateAlerts ¶
func (a *AlertServer) EvaluateAlerts(alerts map[string]*GremlinAlert, lockGraph bool)
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 *types.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 *types.Alert, g *graph.Graph, p *traversal.GremlinTraversalParser) (*GremlinAlert, error)
func (*GremlinAlert) Evaluate ¶
func (ga *GremlinAlert) Evaluate(lockGraph bool) (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.