Skip to content
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.

Sign up for GitHub

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

Add better handling for Kubernetes Update and Delete watcher events #18882

Merged
merged 13 commits into from
Jun 17, 2020
Merged

Add better handling for Kubernetes Update and Delete watcher events #18882

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
43bc4f8
Fix race conditions and config errors
ChrsMark Jun 1, 2020
188e970
log level
ChrsMark Jun 1, 2020
638f96d
Add delete-anyway logic as well as retry on stop/start
ChrsMark Jun 2, 2020
078c279
Add specific check for InputNotFinished errors
ChrsMark Jun 3, 2020
bf14d18
Add License
ChrsMark Jun 3, 2020
ad14e50
Fix state
ChrsMark Jun 3, 2020
5aaba62
Merge remote-tracking branch 'upstream/master' into k8s_autodiscover_…
ChrsMark Jun 3, 2020
d8c70f9
Remove input related stuff
ChrsMark Jun 15, 2020
b6681ee
changelog
ChrsMark Jun 15, 2020
23a1242
Merge remote-tracking branch 'upstream/master' into k8s_autodiscover_…
ChrsMark Jun 15, 2020
2c56f4b
Review changes
ChrsMark Jun 16, 2020
943825f
Bring back removed line
ChrsMark Jun 16, 2020
9c46945
replace if/else with switch
ChrsMark Jun 16, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Fix state 
Signed-off-by: chrismark <chrismarkou92@gmail.com>
  • Loading branch information
@ChrsMark
ChrsMark committed Jun 3, 2020
commit ad14e501aa1f36c7a7f263cb08aa02f28a6d6b2a
4 changes: 2 additions & 2 deletions libbeat/common/errors.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,10 +23,10 @@ import (

// ErrInputNotFinished struct for reporting errors related to not finished inputs
type ErrInputNotFinished struct {
state string
State string
}

// Error method of ErrInputNotFinished
func (e *ErrInputNotFinished) Error() string {
return fmt.Sprintf("Can only start an input when all related states are finished: %+v", e.state)
return fmt.Sprintf("Can only start an input when all related states are finished: %+v", e.State)
}