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
Constants ¶
This section is empty.
Variables ¶
View Source
var NewEmitMetaMsg chan types.DataPointMeta = make(chan types.DataPointMeta, 2000)
View Source
var NewMeta chan []*types.DataPointMeta = make(chan []*types.DataPointMeta)
View Source
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 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
Source Files
Click to show internal directories.
Click to hide internal directories.