README
¶
Telegraf Execd Go Shim
The goal of this shim is to make it trivial to extract an internal input plugin out to a stand-alone repo for the purpose of compiling it as a separate app and running it from the inputs.execd plugin.
The execd-shim is still experimental and the interface may change in the future. Especially as the concept expands to processors, aggregators, and outputs.
Steps to externalize a plugin
- Move the project to an external repo, optionally preserving the plugins/inputs/plugin_name folder structure. For an example of what this might look at, take a look at ssoroka/rand or danielnelson/telegraf-plugins
- Copy main.go into your project under the cmd folder. This will be the entrypoint to the plugin when run as a stand-alone program, and it will call the shim code for you to make that happen.
- Edit the main.go file to import your plugin. Within Telegraf this would have been done in an all.go file, but here we don't split the two apart, and the change just goes in the top of main.go. If you skip this step, your plugin will do nothing.
- Optionally add a plugin.conf for configuration specific to your plugin. Note that this config file must be separate from the rest of the config for Telegraf, and must not be in a shared directory where Telegraf is expecting to load all configs. If Telegraf reads this config file it will not know which plugin it relates to.
Steps to build and run your plugin
- Build the cmd/main.go. For my rand project this looks like
go build -o rand cmd/main.go - Test out the binary if you haven't done this yet. eg
./rand -config plugin.confDepending on your polling settings and whether you implemented a service plugin or an input gathering plugin, you may see data right away, or you may have to hit enter first, or wait for your poll duration to elapse, but the metrics will be written to STDOUT. Ctrl-C to end your test. - Configure Telegraf to call your new plugin binary. eg:
[[inputs.execd]]
command = ["/path/to/rand", "-config", "/path/to/plugin.conf"]
signal = "none"
Congratulations!
You've done it! Consider publishing your plugin to github and open a Pull Request back to the Telegraf repo letting us know about the availability of your external plugin.
Documentation
¶
Index ¶
Constants ¶
const ( // PollIntervalDisabled is used to indicate that you want to disable polling, // as opposed to duration 0 meaning poll constantly. PollIntervalDisabled = time.Duration(0) )
Variables ¶
This section is empty.
Functions ¶
func DefaultImportedPlugins ¶
func DefaultImportedPlugins() (i []telegraf.Input, e error)
DefaultImportedPlugins defaults to whatever plugins happen to be loaded and have registered themselves with the registry. This makes loading plugins without having to define a config dead easy.
func LoadConfig ¶
LoadConfig loads the config and returns inputs that later need to be loaded.
Types ¶
type Shim ¶
type Shim struct {
Inputs []telegraf.Input
// contains filtered or unexported fields
}
Shim allows you to wrap your inputs and run them as if they were part of Telegraf, except built externally.
func (*Shim) AddInput ¶
AddInput adds the input to the shim. Later calls to Run() will run this input.
func (*Shim) AddInputs ¶
AddInputs adds multiple inputs to the shim. Later calls to Run() will run these.
func (*Shim) LoadConfig ¶
LoadConfig loads and adds the inputs to the shim
Source Files
Directories