event

Documentation

Index

• type EventMessage
  • func NewEventMessage(et EventType, areaID uint64) *EventMessage
  • func (e *EventMessage) GetAttr() *entity.Attribute
  • func (e *EventMessage) GetDeviceID() int
  • func (e *EventMessage) SetAttr(attr entity.Attribute)
  • func (e *EventMessage) SetDeviceID(deviceID int)
• type EventType
• type HandleFunc
• type Server
  • func GetServer() *Server
  • func (s *Server) Notify(em *EventMessage)
  • func (s *Server) RegisterHandler(eventType EventType, handlerFunctions ...HandleFunc)

Types

type EventMessage

type EventMessage struct {
	EventType EventType
	AreaID    uint64
	Param     map[string]interface{}
}

func NewEventMessage

func NewEventMessage(et EventType, areaID uint64) *EventMessage

func (*EventMessage) GetAttr

func (e *EventMessage) GetAttr() *entity.Attribute

func (*EventMessage) GetDeviceID

func (e *EventMessage) GetDeviceID() int

func (*EventMessage) SetAttr

func (e *EventMessage) SetAttr(attr entity.Attribute)

func (*EventMessage) SetDeviceID

func (e *EventMessage) SetDeviceID(deviceID int)

type EventType

type EventType string

const (
	AttributeChange EventType = "attribute_change"
	DeviceIncrease  EventType = "device_increase"
	DeviceDecrease  EventType = "device_decrease"
)

type HandleFunc

type HandleFunc func(em EventMessage) error

type Server

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

func GetServer

func GetServer() *Server

func (*Server) Notify

func (s *Server) Notify(em *EventMessage)

func (*Server) RegisterHandler

func (s *Server) RegisterHandler(eventType EventType, handlerFunctions ...HandleFunc)