Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Events ¶
type Events struct {
// contains filtered or unexported fields
}
Events is pubsub channel for *jsonmessage.JSONMessage
func (*Events) Log ¶
Log broadcasts event to listeners. Each listener has 100 millisecond for receiving event or it will be skipped.
func (*Events) Subscribe ¶
func (e *Events) Subscribe() ([]*jsonmessage.JSONMessage, chan interface{})
Subscribe adds new listener to events, returns slice of 64 stored last events channel in which you can expect new events in form of interface{}, so you need type assertion.
func (*Events) SubscribersCount ¶
SubscribersCount returns number of event listeners
Source Files
Click to show internal directories.
Click to hide internal directories.