engine

Documentation

Index

• Variables
• func GetDataPoints() ([]types.VolatileDataPoint, error)
• func GetSetting(key string) (types.KeyValuePair, error)
• func InitDataPointMap()
• func InitDispatchers()
• func InitMonitor()
• func InitSetting(key string, value string, description string) types.KeyValuePair
• func NotifySubscribers(topic string, message interface{})
• func PutSetting(key string, value string)
• func RegisterWebsocket(c *websocket.Conn)
• func SendAlerts()
• func SendTestAlerts(recipients string)
• func UpdateDataPointMeta(item *types.DataPointMeta) (err error)
• type WebSocketMessage

Variables

var NewEmitMetaMsg chan types.DataPointMeta = make(chan types.DataPointMeta, 2000)

var NewEmitMsg chan types.DataPoint = make(chan types.DataPoint, 2000)

var NewMeta chan []*types.DataPointMeta = make(chan []*types.DataPointMeta)

var NewMsg chan types.DataMessage = make(chan types.DataMessage, 2000)

Functions

func GetDataPoints

func GetDataPoints() ([]types.VolatileDataPoint, error)

func GetSetting

func GetSetting(key string) (types.KeyValuePair, error)

func InitDataPointMap

func InitDataPointMap()

func InitDispatchers

func InitDispatchers()

func InitMonitor

func InitMonitor()

func InitSetting

func InitSetting(key string, value string, description string) types.KeyValuePair

func NotifySubscribers

func NotifySubscribers(topic string, message interface{})

func PutSetting

func PutSetting(key string, value string)

func RegisterWebsocket

func RegisterWebsocket(c *websocket.Conn)

func SendAlerts

func SendAlerts()

func SendTestAlerts

func SendTestAlerts(recipients string)

func UpdateDataPointMeta

func UpdateDataPointMeta(item *types.DataPointMeta) (err error)

Types

type WebSocketMessage

type WebSocketMessage struct {
	Topic   string      `json:"topic"`
	Message interface{} `json:"message"`
}

websocket connections