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
type Filter ¶
type Filter struct {
// contains filtered or unexported fields
}
Filter can filter out docker events from a stream
func (*Filter) Include ¶
func (ef *Filter) Include(ev *jsonmessage.JSONMessage) bool
Include returns true when the event ev is included by the filters
Click to show internal directories.
Click to hide internal directories.