watch

Documentation

Index

• type MockWatcher
  • func NewMockWatcher(t mockConstructorTestingTNewMockWatcher) *MockWatcher
  • func (_m *MockWatcher) StopWatching(id cron.EntryID)
  • func (_m *MockWatcher) Watch(config WatchConfig) cron.EntryID
• type WatchConfig
• type WatchResult
• type WatchResultPublisher
• type WatchResultSubscriber
• type Watcher
  • func New(resultNotifier WatchResultPublisher, queryRepo query.QueryRepo) Watcher
• type WatcherId

Types

type MockWatcher

type MockWatcher struct {
	mock.Mock
}

MockWatcher is an autogenerated mock type for the Watcher type

func NewMockWatcher

func NewMockWatcher(t mockConstructorTestingTNewMockWatcher) *MockWatcher

NewMockWatcher creates a new instance of MockWatcher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockWatcher) StopWatching

func (_m *MockWatcher) StopWatching(id cron.EntryID)

StopWatching provides a mock function with given fields: id

func (*MockWatcher) Watch

func (_m *MockWatcher) Watch(config WatchConfig) cron.EntryID

Watch provides a mock function with given fields: config

type WatchConfig

type WatchConfig struct {
	LookoutId int
	Name      string
	Query     string
	Cron      string
}

type WatchResult

type WatchResult struct {
	LookoutId int
	Result    query.QueryResult
	Error     error
}

type WatchResultPublisher

type WatchResultPublisher = observer.Publisher[WatchResult]

type WatchResultSubscriber

type WatchResultSubscriber = observer.Subscriber[WatchResult]

type Watcher

type Watcher interface {
	Watch(config WatchConfig) WatcherId
	StopWatching(id WatcherId)
}

func New

func New(resultNotifier WatchResultPublisher, queryRepo query.QueryRepo) Watcher

type WatcherId

type WatcherId = cron.EntryID