-
Notifications
You must be signed in to change notification settings - Fork 5.6k
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
Expand shim for processor and outputs. #7677
Conversation
plugins/common/shim/config.go
Outdated
return fmt.Errorf("Failed to add Processor: %w", err) | ||
} | ||
} else if conf.Output != nil { | ||
if err = s.AddOutput(conf.Output); err != nil { |
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.
Does this let people have multiple inputs, processors, and outputs in the same shim? I guess I expected one plugin of any type per shim process.
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.
yeah, you can only have one.
rebased master to resolve conflicts... and that might have screwed up this branch... |
Merging this PR will fix some data races reported in #7729 too. |
Expands execd shim support for processors and outputs.
Execd lets you write custom input, processor, and output plugins in any language. The execd shim lets you run plugins written in Go without changing the structure, regardless of whether they're run as internal plugins compiled into Telegraf, or external plugins compiled as a separate binary and run through execd.