Versions in this module Expand all Collapse all v0 v0.1.0 May 15, 2020 Changes in this version + var ErrNoSubscribers = errors.New("no subscribers") + func MillisecondEpoch(now time.Time) int64 + func SetLogger(l logr.Logger) + type Event struct + Data json.RawMessage + type Manager struct + func NewManager(opts ...ManagerOption) *Manager + func (this *Manager) Publish(data interface{}) error + func (this *Manager) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (this *Manager) Start(ctx context.Context) error + type ManagerOption func(*managerOptions) + func LVC(l bool) ManagerOption + func MaxTimeout(m int) ManagerOption + type Message struct + Error string + Events []Event + Timestamp int64 + type Watcher struct + func NewWatcher(opts ...WatcherOption) *Watcher + func (this *Watcher) Watch(ctx context.Context, path string, events chan Event) error + type WatcherOption func(*watcherOptions) + func Endpoint(e string) WatcherOption + func Since(s time.Time) WatcherOption + func Transport(t *http.Transport) WatcherOption