output

Documentation

Index

• type OutputPlugin
  • func NewOutputPlugin(nodeInfo config.NodeInfo, configInfo config.OutputPluginInfo, bufferSize int) *OutputPlugin
  • func (outputPlugin *OutputPlugin) Init() error
  • func (outputPlugin *OutputPlugin) Run()
• type OutputPluginManager
  • func NewOutputPluginManager(nodeInfo config.NodeInfo, configInfos []config.OutputPluginInfo, ...) *OutputPluginManager
  • func (manager *OutputPluginManager) Init() error
  • func (manager *OutputPluginManager) Run()

Types

type OutputPlugin

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

Output plugin

func NewOutputPlugin

func NewOutputPlugin(nodeInfo config.NodeInfo, configInfo config.OutputPluginInfo, bufferSize int) *OutputPlugin

func (*OutputPlugin) Init

func (outputPlugin *OutputPlugin) Init() error

Init plugin

func (*OutputPlugin) Run

func (outputPlugin *OutputPlugin) Run()

Run to send data

type OutputPluginManager

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

Output plugin manager

func NewOutputPluginManager

func NewOutputPluginManager(nodeInfo config.NodeInfo, configInfos []config.OutputPluginInfo, transferQueue *queue.TransferQueue) *OutputPluginManager

func (*OutputPluginManager) Init

func (manager *OutputPluginManager) Init() error

Init output plugin manager

func (*OutputPluginManager) Run

func (manager *OutputPluginManager) Run()

Run to dispatch data to output plugin