Documentation ¶ Index ¶ func Start(ctx context.Context, config *config.Config) (chan<- string, error) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func Start ¶ func Start(ctx context.Context, config *config.Config) (chan<- string, error) Start uses the provided config to start the execution of any plugin outputs that have been defined. Packets that are written to the returned channel will be fanned out to N configured plugins. Types ¶ This section is empty. Source Files ¶ View all Source files plugins.go Directories ¶ Show internal Expand all Path Synopsis kafka s3 Click to show internal directories. Click to hide internal directories.