Method run

pkg/app/sensor/controlled/controlled.go:83–113

()

}

func (s *Sensor) run() error {
	log.Info("sensor: waiting for commands...")

	for {
		mon, err := s.runWithoutMonitor()
		if err != nil {
			s.exe.HookMonitorFailed()
			s.exe.PubEvent(event.StartMonitorFailed,
				&event.StartMonitorFailedData{
					Component: event.ComMonitorRunner, //TODO: need to get to the real component
					State:     s.exe.State(),
					Errors:    []string{err.Error()},
				})

			return fmt.Errorf("run sensor without monitor failed: %w", err)
		}

		if mon == nil {
			return nil
		}

		s.exe.PubEvent(event.StartMonitorDone)

		if err := s.runWithMonitor(mon); err != nil {
			return fmt.Errorf("run sensor with monitor failed: %w", err)
		}

		s.exe.HookMonitorPostShutdown()
		s.exe.PubEvent(event.StopMonitorDone)
	}
}

func (s *Sensor) runWithoutMonitor() (monitor.CompositeMonitor, error) {
	ticker := time.NewTicker(5 * time.Second)