-
Notifications
You must be signed in to change notification settings - Fork 5k
Cherry-pick #21444 to 7.x: Add implementation of FSWatcher and FSScanner for filestream #21468
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
…#21444) ## What does this PR do? This PR adds the implementation for `FSWatcher` and `FSScanner` for the `filestream` input. The implementation of `FSScanner` is called `fileScanner`. It is responsible for * resolves recursive globs on creation * normalizes glob patterns on creation * finds files which match the configured paths and returns `FileInfo` for those This is the refactored version of the `log` input's scanner, globber functions. The implementation of `FSWatcher` is called `fileWatcher`. It checks the file list returned by `fileScanner` and creates events based on the result. ## Why is it important? It is required for the `filestream` input. ## Related issues Related elastic#20243 (cherry picked from commit a119083)
|
Pinging @elastic/integrations-services (Team:Services) |
💔 Tests FailedExpand to view the summary
Build stats
Test stats 🧪
Test errorsExpand to view the tests failures
Steps errorsExpand to view the steps failures
Log outputExpand to view the last 100 lines of log output
|
Cherry-pick of PR #21444 to 7.x branch. Original message:
What does this PR do?
This PR adds the implementation for
FSWatcherandFSScannerfor thefilestreaminput.The implementation of
FSScanneris calledfileScanner. It is responsible forFileInfofor thoseThis is the refactored version of the
loginput's scanner, globber functions.The implementation of
FSWatcheris calledfileWatcher. It checks the file list returned byfileScannerand creates events based on the result.Why is it important?
It is required for the
filestreaminput.Checklist
- [ ] I have made corresponding changes to the documentation- [ ] I have made corresponding change to the default configuration files- [ ] I have added an entry inCHANGELOG.next.asciidocorCHANGELOG-developer.next.asciidoc.Related issues
Related #20243