event

type EventManager interface {

	// RegisterCollector a collector with the manager
	RegisterCollector(collector.Collector)

	// Collectors returns registered collectors
	Collectors() map[string]collector.Collector

	// Subscribe for event callbacks
	Subscribe(eventTopic string, caller string, callback func(events.Event)) Subscriber

	// Unsubscribe from event callbacks
	Unsubscribe(eventTopic string, caller string)

	// Subscribers will return the subscriber map
	Subscribers() map[string]map[string]Subscriber

	// Subscribed returns subscriber count
	Subscribed() int

	// Publish the event to the subscribers
	Publish(e events.Event)
}

type Manager struct {
	// contains filtered or unexported fields
}

type Subscriber interface {
	// Topic returns the topic this subscriber is subscribed to
	Topic() string
	// Name returns the name of the subscriber
	Name() string

	// Suspend suspends processing events by the subscriber. If
	// queueEvents is true, the events are queued until Resume()
	// is called. If queueEvents is false, events passed into
	// onEvent() after this call are discarded.
	Suspend(queueEvents bool)
	// Resume resumes processing of events by the subscriber.
	// If Suspend() was called with queueEvents as true, any events
	// that were passed to onEvent() after Suspend() returned are
	// processed first.
	Resume()
	// IsSuspended returns true if the subscriber is suspended.
	IsSuspended() bool

	// Discarded returns the number of packets that were discarded by
	// the subscriber as a result of Pause() being called with
	// queueEvents as false.
	Discarded() uint64
	// Dropped returns the number of packets that were dropped when
	// the event queue overflows. This only happens when Pause()
	// is called with queueEvents as true.
	Dropped() uint64
	// contains filtered or unexported methods
}