plugin

Oct 21, 2021

Changes in this version

+ const CloseFuncName

+ const StartFuncName

+ type CloseFunc func() error

type PluginProgram

+ func (pp *PluginProgram) Start() (err error)

+ type StartFunc func() error

+ type TestTagger struct

+ func NewTestTagger() *TestTagger

+ func (tt *TestTagger) KnownTags() (r []string)

+ func (tt *TestTagger) LookupTag(tag entry.EntryTag) (r string, ok bool)

+ func (tt *TestTagger) NegotiateTag(name string) (tag entry.EntryTag, err error)

Oct 7, 2021

Changes in this version

+ const BuiltinPackageName

+ const ConfigFuncName

+ const ConfigMapName

+ const ExecuteFuncName

+ const FlushFuncName

+ const ProcessFuncName

+ const TaggerName

+ var ErrInvalidScript = errors.New("invalid plugin program")

+ var ErrNotReady = errors.New("not ready")

+ type ConfigFunc func(ConfigMap, Tagger) error

+ type ConfigMap interface

+ GetBool func(string) (bool, error)

+ GetFloat func(string) (float64, error)

+ GetInt func(string) (int64, error)

+ GetString func(string) (string, error)

+ GetStringSlice func(string) ([]string, error)

+ GetUint func(string) (uint64, error)

+ Names func() []string

+ type FlushFunc func() []*entry.Entry

+ type PluginProgram struct

+ func NewPlugin(fsys fs.FS) (pp *PluginProgram, err error)

+ func NewPluginProgram(content []byte) (pp *PluginProgram, err error)

+ func (pp *PluginProgram) Close() (err error)

+ func (pp *PluginProgram) Config(vc *config.VariableConfig, tg Tagger) error

+ func (pp *PluginProgram) Flush() []*entry.Entry

+ func (pp *PluginProgram) Process(ents []*entry.Entry) ([]*entry.Entry, error)

+ func (pp *PluginProgram) Ready() (r bool)

+ func (pp *PluginProgram) Run(to time.Duration) (err error)

+ type ProcessFunc func([]*entry.Entry) ([]*entry.Entry, error)

+ type Tagger interface

+ KnownTags func() []string

+ LookupTag func(entry.EntryTag) (string, bool)

+ NegotiateTag func(name string) (entry.EntryTag, error)