alarm

type ActiveList struct {
	Items map[string]Message `json:"items"`
	Id    int                `json:"id"`
	// contains filtered or unexported fields
}

type Alarm struct {
	// contains filtered or unexported fields
}

type Hub interface {
	Pub(header string, body interface{})
}

type MQClient interface {
	Publish(topic string, msg interface{})
	PublishRetained(topic string, msg interface{}) error
	Subscribe(topic string, handler func(topic string, payload []byte)) error
	Unsubscribe(topics ...string) error
	SetConnectHandler(func())
}

type Message struct {
	Id        int         `json:"ID"`
	Value     int         `json:"Value"`
	Message   string      `json:"Message"`
	TimeEvent *TimeStruct `json:"TimeEvent,omitempty"`
	TimeAck   *TimeStruct `json:"TimeAck,omitempty"`

	UId      int    `json:"uid"`
	LineId   string `json:"line_id"`
	ModuleId string `json:"module_id"`
	Resolved bool   `json:"resolved,omitempty"`
}

type Persistent interface {
	Backup(key string, obj interface{}) error  //put
	Restore(key string, obj interface{}) error //get
}

type Storage interface {
	Backup(key string, obj interface{}) error  //put
	Restore(key string, obj interface{}) error //get
	Remove(key string) error
	GetByPrefix(pref string) map[string]string
}

type TimeStruct struct {
	AlmDate string `json:"AlmDate,omitempty"`
	AlmTime string `json:"AlmTime,omitempty"`
}