watch

Documentation

Index

• type Watcher
  • func (w *Watcher) GetName() string
  • func (w *Watcher) Start() error
  • func (w *Watcher) Stop(_ context.Context) error
  • func (w *Watcher) Subscribe(c chan<- *domain.Event, q *repository.LogQuery) error
  • func (w *Watcher) Unsubscribe(c chan<- *domain.Event)

Types

type Watcher

type Watcher struct {
	// LogDAO provides access to the log events
	LogRepository *repository.LogRepository
	// contains filtered or unexported fields
}

Watcher notifies subscribers of new events whenever the log file is written to

func (*Watcher) GetName

func (w *Watcher) GetName() string

GetName returns the name "watcher"

func (*Watcher) Start

func (w *Watcher) Start() error

Start begins watching for log file changes and notifies subscribers accordingly

func (*Watcher) Stop

func (w *Watcher) Stop(_ context.Context) error

Stop stops watching for log file changes

func (*Watcher) Subscribe

func (w *Watcher) Subscribe(c chan<- *domain.Event, q *repository.LogQuery) error

Subscribe starts sending all events that match the query over the given channel. The query will be updated with the a new SinceUUID value whenever events are published to the channel.

func (*Watcher) Unsubscribe

func (w *Watcher) Unsubscribe(c chan<- *domain.Event)

Unsubscribe stops publishing events to the channel but does not close the channel