Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
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
Source Files
Click to show internal directories.
Click to hide internal directories.