providers

Documentation

Index

• func RegisterInputProvider(configType string, p InputProvider)
• func RegisterPipelineFactory(configType string, provider PipelineProvider)
• func StandardizeType(t string) string
• type InputProvider
  • func GetInputProvider(configType string) (InputProvider, bool)
• type PipelineProvider
  • func GetPipelineProvider(configType string) (PipelineProvider, bool)

Functions

func RegisterInputProvider

func RegisterInputProvider(configType string, p InputProvider)

func RegisterPipelineFactory

func RegisterPipelineFactory(configType string, provider PipelineProvider)

func StandardizeType

func StandardizeType(t string) string

Types

type InputProvider

type InputProvider func(task *collecttask.CollectTask) (api.Input, error)

func GetInputProvider

func GetInputProvider(configType string) (InputProvider, bool)

type PipelineProvider

type PipelineProvider func(task *collecttask.CollectTask) (api.Pipeline, error)

func GetPipelineProvider

func GetPipelineProvider(configType string) (PipelineProvider, bool)