func NewLauncher(sources *config.LogSources, frameSize int, pipelineProvider pipeline.Provider) *Launcher {
	return &Launcher{
		pipelineProvider: pipelineProvider,
		frameSize:        frameSize,
		tcpSources:       sources.GetAddedForType(config.TCPType),
		udpSources:       sources.GetAddedForType(config.UDPType),
		stop:             make(chan struct{}),
	}
}
// NewLauncher returns an initialized Launcher
NewLauncher returns an initialized Launcher
// NewLauncher returns an initialized Launcher
func NewLauncher(sources *config.LogSources, frameSize int, pipelineProvider pipeline.Provider) *Launcher {
	return &Launcher{
		pipelineProvider: pipelineProvider,
		frameSize:        frameSize,
		tcpSources:       sources.GetAddedForType(config.TCPType),
		udpSources:       sources.GetAddedForType(config.UDPType),
		stop:             make(chan struct{}),
	}
}
func NewLauncher ( sources * config . LogSources , frameSize int , pipelineProvider pipeline . Provider ) * Launcher { return & Launcher { pipelineProvider : pipelineProvider , frameSize : frameSize , tcpSources : sources . GetAddedForType ( config . TCPType ) , udpSources : sources . GetAddedForType ( config . UDPType ) , stop : make ( chan struct { } ) , } }
NewLauncher returns an initialized Launcher
NewLauncher returns an initialized Launcher