input

Documentation

Index

• type InputPlugin
  • func NewInputPlugin(nodeInfo config.NodeInfo, configInfo config.InputPluginInfo, bufferSize int) *InputPlugin
  • func (inputPlugin *InputPlugin) Init() error
  • func (inputPlugin *InputPlugin) Run()
• type InputPluginManager
  • func NewInputPluginManager(nodeInfo config.NodeInfo, configInfos []config.InputPluginInfo, ...) *InputPluginManager
  • func (manager *InputPluginManager) Init() error
  • func (manager *InputPluginManager) Run()

Types

type InputPlugin

type InputPlugin struct {
	// contains filtered or unexported fields
}

Input plugin

func NewInputPlugin

func NewInputPlugin(nodeInfo config.NodeInfo, configInfo config.InputPluginInfo, bufferSize int) *InputPlugin

func (*InputPlugin) Init

func (inputPlugin *InputPlugin) Init() error

Init plugin

func (*InputPlugin) Run

func (inputPlugin *InputPlugin) Run()

Run to collect data

type InputPluginManager

type InputPluginManager struct {
	// contains filtered or unexported fields
}

Input plugin manager

func NewInputPluginManager

func NewInputPluginManager(nodeInfo config.NodeInfo, configInfos []config.InputPluginInfo, transferQueue *queue.TransferQueue) *InputPluginManager

func (*InputPluginManager) Init

func (manager *InputPluginManager) Init() error

Init plugin manager

func (*InputPluginManager) Run

func (manager *InputPluginManager) Run()

Run all plugin to collect data