Versions in this module Expand all Collapse all v0 v0.10.1 Apr 21, 2021 v0.10.0 Apr 21, 2021 v0.9.1 Nov 20, 2020 v0.9.0 Oct 12, 2020 v0.8.0 Sep 28, 2020 v0.7.0 Sep 22, 2020 v0.6.0 Sep 20, 2020 v0.5.0 Sep 16, 2020 v0.4.0 Sep 14, 2020 v0.3.0 Sep 9, 2020 v0.2.0 Nov 11, 2019 Changes in this version + type DataBus struct + func NewDataBus() *DataBus + func (self *DataBus) All(fn func(DataBusContext)) (id int32) + func (self *DataBus) Get(key string) (nson.Value, bool) + func (self *DataBus) InitDataBus() + func (self *DataBus) Insert(key string, value nson.Value) (nson.Value, bool) + func (self *DataBus) InsertSkipAll(key string, value nson.Value) (nson.Value, bool) + func (self *DataBus) Off(id int32) (ok bool) + func (self *DataBus) On(key string, fn func(DataBusContext)) (id int32) + func (self *DataBus) Remove(key string) (nson.Value, bool) + func (self *DataBus) Run(eventBus *EventBus, event string) + func (self *DataBus) Set(key string, value nson.Value) (nson.Value, bool) + type DataBusContext struct + DataBus *DataBus + Id int32 + Key string + OldValue nson.Value + Value nson.Value + type DataBusHandler struct + type EventBus struct + func NewEventBus() *EventBus + func (self *EventBus) Emit(event string, message nson.Message) + func (self *EventBus) InitEventBus() + func (self *EventBus) Off(id int32) (ok bool) + func (self *EventBus) On(event string, fn func(EventBusContext)) (id int32) + func (self *EventBus) Push(event string, message nson.Message) + type EventBusContext struct + Event string + EventBus *EventBus + Id int32 + Message nson.Message + type EventBusHandler struct v0.1.1 Jun 21, 2019 Changes in this version + func MqttRun(topic string, mqttClient mqtt.Client, queen *Queen) type Center + func (self *Center) InsertSkipAll(key string, value nson.Value) (nson.Value, bool) + func (self *Center) Run(queen *Queen, event string) type Queen + func (self *Queen) Push(event string, message nson.Message) + type Task struct + type Tasks []Task + func (h *Tasks) Pop() interface{} + func (h *Tasks) Push(x interface{}) + func (h Tasks) Len() int + func (h Tasks) Less(i, j int) bool + func (h Tasks) Swap(i, j int) + type Timer struct + func NewTimer() *Timer + func (t *Timer) Pop() interface{} + func (t *Timer) Push(task Task) + func (t *Timer) Run(queen *Queen) v0.1.0 Feb 21, 2019 Changes in this version + const ATTACH + const DETACH + const HAND + const HANDED + const LINK + const RECV + const REMOVE + const SEND + const UNLINK + func GetI32(b []byte, pos int) int32 + func InitConnect(queen *Queen) + type CContext struct + Center *Center + Id int32 + Key string + OldValue nson.Value + Value nson.Value + type CHandler struct + type Center struct + func NewCenter() Center + func (self *Center) All(fn func(CContext)) (id int32) + func (self *Center) Get(key string) (nson.Value, bool) + func (self *Center) InitCenter() + func (self *Center) Insert(key string, value nson.Value) (nson.Value, bool) + func (self *Center) Off(id int32) (ok bool) + func (self *Center) On(key string, fn func(CContext)) (id int32) + func (self *Center) Remove(key string) (nson.Value, bool) + func (self *Center) Set(key string, value nson.Value) (nson.Value, bool) + type Context struct + Event string + Id int32 + Message interface{} + Queen *Queen + type Handler struct + type Queen struct + func NewQueen() Queen + func (self *Queen) Emit(event string, message interface{}) + func (self *Queen) InitQueen() + func (self *Queen) Off(id int32) (ok bool) + func (self *Queen) On(event string, fn func(Context)) (id int32)
Go to main page