Versions in this module Expand all Collapse all v1 v1.0.1 Apr 1, 2020 v1.0.0 Mar 18, 2020 Changes in this version + type AlarmAreaInfo struct + type AlarmStreamBroker struct + func NewAlarmStreamBroker() *AlarmStreamBroker + func (asb *AlarmStreamBroker) HandleAlarm(msg json.RawMessage) error + func (asb *AlarmStreamBroker) HandleAllClear(msg json.RawMessage) error + func (asb *AlarmStreamBroker) HandleHeartbeat(json.RawMessage) error + func (asb *AlarmStreamBroker) HandleTestAlarm(msg json.RawMessage) error + func (asb *AlarmStreamBroker) HandleTestAllClear(msg json.RawMessage) error + func (asb *AlarmStreamBroker) RegisterClient(ctx context.Context, key string, id int64, queue *Queue) + func (asb *AlarmStreamBroker) Run() + func (asb *AlarmStreamBroker) SessionDied(key string) + func (asb *AlarmStreamBroker) UnregisterClient(key string, queue *Queue) + type MessageHandler func(json.RawMessage) error + type Queue struct + func NewQueue() *Queue + func (q *Queue) Append(v []byte) + func (q *Queue) Close() + func (q *Queue) Remove() ([]byte, bool) + type Receiver struct + func NewReceiver(dsn string) *Receiver + func (rcv *Receiver) AddHandler(msgType string, handler MessageHandler) + func (rcv *Receiver) Run() + type StrokeStreamBroker struct + func NewStrokeStreamBroker() *StrokeStreamBroker + func (ssb *StrokeStreamBroker) Handle(msg json.RawMessage) error + func (ssb *StrokeStreamBroker) HandleHeartbeat(json.RawMessage) error + func (ssb *StrokeStreamBroker) RegisterClient(key string, geom wkt.Geom, out *Queue) + func (ssb *StrokeStreamBroker) Run() + func (ssb *StrokeStreamBroker) SessionDied(key string) + func (ssb *StrokeStreamBroker) UnregisterClient(key string, out *Queue)