socket

Mar 25, 2025

Changes in this version

+ func Factory() (pipeline.AnyPlugin, pipeline.AnyConfig)

+ type Config struct

+ Address string

+ CACert string

+ Network string

+ PrivateKey string

+ type Plugin struct

+ func (p *Plugin) Commit(_ *pipeline.Event)

+ func (p *Plugin) PassEvent(_ *pipeline.Event) bool

+ func (p *Plugin) Start(config pipeline.AnyConfig, params *pipeline.InputPluginParams)

+ func (p *Plugin) Stop()