Skip to content

Commit

Permalink
add ignore_init_fail_input option for ignore initialization failed In…
Browse files Browse the repository at this point in the history
  • Loading branch information
observeralone committed Jun 14, 2022
1 parent 72e91ba commit a2d309a
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 1 deletion.
8 changes: 7 additions & 1 deletion agent/agent.go
Original file line number Diff line number Diff line change
Expand Up @@ -186,17 +186,23 @@ func (a *Agent) Run(ctx context.Context) error {

// initPlugins runs the Init function on plugins.
func (a *Agent) initPlugins() error {
inputs := make([]*models.RunningInput, 0)
for _, input := range a.Config.Inputs {
// Share the snmp translator setting with plugins that need it.
if tp, ok := input.Input.(snmp.TranslatorPlugin); ok {
tp.SetTranslator(a.Config.Agent.SnmpTranslator)
}
err := input.Init()
if err != nil {
if err != nil && a.Config.Agent.IgnoreInitFailInput {
log.Printf("W! [agent] Ignore initialize fail input %s: %v", input.LogName(), err)
continue
} else if err != nil {
return fmt.Errorf("could not initialize input %s: %v",
input.LogName(), err)
}
inputs = append(inputs, input)
}
a.Config.Inputs = inputs
for _, parser := range a.Config.Parsers {
err := parser.Init()
if err != nil {
Expand Down
3 changes: 3 additions & 0 deletions config/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -223,6 +223,9 @@ type AgentConfig struct {
// Pick a timezone to use when logging or type 'local' for local time.
LogWithTimezone string `toml:"log_with_timezone"`

// Ignore Inputs that failed to initialize
IgnoreInitFailInput bool `toml:"ignore_init_fail_input"`

Hostname string
OmitHostname bool

Expand Down

0 comments on commit a2d309a

Please sign in to comment.