// WatchMachines mocks base method
187429
func (m *MockModelCache) WatchMachines() (cache.StringsWatcher, error) {
	ret := m.ctrl.Call(m, "WatchMachines")
	ret0, _ := ret[0].(cache.StringsWatcher)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}
904210
func (v *ViewModel) Watch(expression string, callback func(newVal *js.Object)) (unwatcher func()) {
	obj := v.Call("$watch", expression, callback)
	return func() {
		obj.Invoke()
	}
}
406511
func NewMockMutaterMachine(ctrl *gomock.Controller) *MockMutaterMachine {
	mock := &MockMutaterMachine{ctrl: ctrl}
	mock.recorder = &MockMutaterMachineMockRecorder{mock}
	return mock
}
1023586
func (sb *storageBackend) WatchBlockDevices(machine names.MachineTag) NotifyWatcher {
	return newBlockDevicesWatcher(sb.mb, machine.Id())
}
783901
func (sb *storageBackend) WatchMachineFilesystemAttachments(m names.MachineTag) StringsWatcher {
	return sb.watchHostStorageAttachments(m, filesystemAttachmentsC)
}
965118
func (st *State) WatchModelLives() StringsWatcher {
	return newLifecycleWatcher(st, modelsC, nil, nil, nil)
}
1359445
func (c *FakeReplicationControllers) Watch(opts v1.ListOptions) (watch.Interface, error) {
	return c.Fake.
		InvokesWatch(testing.NewWatchAction(replicationcontrollersResource, c.ns, opts))

}
163186
func NewMockModelCacheMachine(ctrl *gomock.Controller) *MockModelCacheMachine {
	mock := &MockModelCacheMachine{ctrl: ctrl}
	mock.recorder = &MockModelCacheMachineMockRecorder{mock}
	return mock
}
1299332
func NewMockMachine(ctrl *gomock.Controller) *MockMachine {
	mock := &MockMachine{ctrl: ctrl}
	mock.recorder = &MockMachineMockRecorder{mock}
	return mock
}
411752
func (c *Certs) watchSymlinks() (err error) {
	c.Lock()
	c.cert, err = c.loadCert(c.certFile, c.keyFile)
	c.Unlock()
	if err != nil {
		return err
	}
	go func() {
		for {
			select {
			case <-c.e:
				// Once stopped exits this routine.
				return
			case <-time.After(24 * time.Hour):
				cert, cerr := c.loadCert(c.certFile, c.keyFile)
				if cerr != nil {
					continue
				}
				c.Lock()
				c.cert = cert
				c.Unlock()
			}
		}
	}()
	return nil
}
792594
func (m *MockBaseWatcher) Watch(arg0 string, arg1 interface{}, arg2 chan<- watcher.Change) {
	m.ctrl.Call(m, "Watch", arg0, arg1, arg2)
}
62194
func (m *MockIngressInterface) Watch(arg0 v1.ListOptions) (watch.Interface, error) {
	ret := m.ctrl.Call(m, "Watch", arg0)
	ret0, _ := ret[0].(watch.Interface)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}
68537
func (fw Watchers) WatchMachineManagedFilesystemAttachments(m names.MachineTag) state.StringsWatcher {
	w := &hostFilesystemAttachmentsWatcher{
		stringsWatcherBase:               stringsWatcherBase{out: make(chan []string)},
		backend:                          fw.Backend,
		changes:                          set.NewStrings(),
		hostFilesystemAttachments:        fw.Backend.WatchMachineFilesystemAttachments(m),
		modelFilesystemAttachments:       fw.Backend.WatchModelFilesystemAttachments(),
		modelVolumeAttachments:           fw.Backend.WatchModelVolumeAttachments(),
		modelVolumesAttached:             names.NewSet(),
		modelVolumeFilesystemAttachments: make(map[names.VolumeTag]string),
		hostMatch: func(tag names.Tag) (bool, error) {
			return tag == m, nil
		},
	}

	w.tomb.Go(func() error {
		defer watcher.Stop(w.hostFilesystemAttachments, &w.tomb)
		defer watcher.Stop(w.modelFilesystemAttachments, &w.tomb)
		defer watcher.Stop(w.modelVolumeAttachments, &w.tomb)
		return w.loop()
	})
	return w
}
452620
func (sb *storageBackend) WatchMachineVolumes(m names.MachineTag) StringsWatcher {
	return sb.watchHostStorage(m, volumesC)
}
164968
func (a *AAgent) ManageMachines(ctx context.Context, wg *sync.WaitGroup) error {
	wg.Add(1)
	go a.watchSource(ctx, wg)

	return nil
}
686189
func NewMockNotifyWatcher(ctrl *gomock.Controller) *MockNotifyWatcher {
	mock := &MockNotifyWatcher{ctrl: ctrl}
	mock.recorder = &MockNotifyWatcherMockRecorder{mock}
	return mock
}
736245
func (m *MockModelCacheMachine) WatchContainers() (cache.StringsWatcher, error) {
	ret := m.ctrl.Call(m, "WatchContainers")
	ret0, _ := ret[0].(cache.StringsWatcher)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}