-
Notifications
You must be signed in to change notification settings - Fork 4.9k
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
Move winlogbeat to new publisher pipeline #4690
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM. Thanks for refactoring the tests.
winlogbeat/beater/metrics.go
Outdated
// enable through configuration in order for the web service to be started. | ||
var ( | ||
publishedEvents = expvar.NewMap("published_events") | ||
ignoredEvents = expvar.NewMap("ignored_events") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I don't think this one is used anymore.
return beat.Event{ | ||
Timestamp: e.TimeCreated.SystemTime, | ||
Fields: m, | ||
Private: checkpoint.EventLogState{ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Nice
@@ -58,5 +59,5 @@ def test_invalid_api(self): | |||
] | |||
) | |||
self.start_beat(extra_args=["-configtest"]).check_wait(exit_code=1) | |||
assert self.log_contains(("Failed to create new event log. file API is " | |||
"not available")) | |||
assert self.log_contains("Failed to create new event log." |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Is this missing a space after the period? nosetest output / log output
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yup. Thanks.
- Move winlogbeat to publisher pipeline - move fields + tags processing to pipeline client - introduce local `processors` setting for each configured event log. - minor cleanups in tests
731ed74
to
701eda7
Compare
@andrewkroh I rebased and squashed commits to most recent master. |
(beat.Client).Close()
from being called multiple timesprocessors
setting for each configured event log.