plugin

Documentation

Index

• Variables
• func New(name string, f PluginFactory) *plugin
• type Env
• type FilterPlugin
• type OutputPlugin
• type Plugin
• type PluginFactory

Variables

var (
	EmbeddedPlugins = make(map[string]PluginFactory)
)

Functions

func New

func New(name string, f PluginFactory) *plugin

Types

type Env

type Env struct {
	ReadConfig func(interface{}) error
	Emit       func(*message.Event)
	Log        *log.Logger
}

type FilterPlugin

type FilterPlugin interface {
	Plugin
	Filter(*message.Event) (*message.Event, error)
}

type OutputPlugin

type OutputPlugin interface {
	Plugin
	Encode(*message.Event) (buffer.Sizer, error)
	Write([]buffer.Sizer) (int, error)
}

type Plugin

type Plugin interface {
	Init(*Env) error
	Start() error
	Close() error
}

type PluginFactory

type PluginFactory func() Plugin