(ctx context.Context, out chan pipeline.Event)
| 18 | const journalctlCmd = "journalctl" |
| 19 | |
| 20 | func (s *Source) OneShot(ctx context.Context, out chan pipeline.Event) error { |
| 21 | err := s.runJournalCtl(ctx, out) |
| 22 | s.logger.Debug("Oneshot acquisition is done") |
| 23 | |
| 24 | return err |
| 25 | } |
| 26 | |
| 27 | func (s *Source) Stream(ctx context.Context, out chan pipeline.Event) error { |
| 28 | return s.runJournalCtl(ctx, out) |