plugins

func AddCompressor ¶ added in v1.8.0

func AddCompressor(key string, p compressorFunc)

compressors

func AddDecompressor ¶ added in v1.8.0

func AddDecompressor(key string, p decompressorFunc)

decompressors

func AddFilter ¶

func AddFilter(key string, f filterFunc)

filters

func AddInput ¶

func AddInput(key string, i inputFunc)

inputs

func AddKeykeeper ¶

func AddKeykeeper(key string, p keykeeperFunc)

keykeepers

func AddLookup ¶ added in v1.14.0

func AddLookup(key string, p lookupFunc)

lookups

func AddOutput ¶

func AddOutput(key string, o outputFunc)

outputs

func AddParser ¶

func AddParser(key string, p parserFunc)

parsers

func AddProcessor ¶

func AddProcessor(key string, p processorFunc)

processors

func AddSerializer ¶

func AddSerializer(key string, p serializerFunc)

serializers

func GetCompressor ¶ added in v1.8.0

func GetCompressor(key string) (compressorFunc, bool)

func GetDecompressor ¶ added in v1.8.0

func GetDecompressor(key string) (decompressorFunc, bool)

func GetFilter ¶

func GetFilter(key string) (filterFunc, bool)

func GetInput ¶

func GetInput(key string) (inputFunc, bool)

func GetKeykeeper ¶

func GetKeykeeper(key string) (keykeeperFunc, bool)

func GetLookup ¶ added in v1.14.0

func GetLookup(key string) (lookupFunc, bool)

func GetOutput ¶

func GetOutput(key string) (outputFunc, bool)

func GetParser ¶

func GetParser(key string) (parserFunc, bool)

func GetProcessor ¶

func GetProcessor(key string) (processorFunc, bool)

func GetSerializer ¶

func GetSerializer(key string) (serializerFunc, bool)