events

Feb 4, 2016

Changes in this version

type Events

+ func (e *Events) SubscribeTopic(since, sinceNano int64, ef *Filter) ([]eventtypes.Message, chan interface{})

Nov 3, 2015

Changes in this version

+ type Filter struct

+ func NewFilter(filter filters.Args, getLabels func(id string) map[string]string) *Filter

+ func (ef *Filter) Include(ev *jsonmessage.JSONMessage) bool

Jun 18, 2015

Changes in this version

+ type Events struct

+ func New() *Events

+ func (e *Events) Evict(l chan interface{})

+ func (e *Events) Log(action, id, from string)

+ func (e *Events) Subscribe() ([]*jsonmessage.JSONMessage, chan interface{})

+ func (e *Events) SubscribersCount() int