bus

Sep 9, 2020

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

+ 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 *EventBus)