AddFileValidator - add a new FileValidator for source.

WithClientID set clientID for KafkaSource.

WithFileProcessorFactory - set ProcessorFactory for source.

WithFnameParser - set the filename parser for FileSource.

WithRawChan set rawChan for KafkaSource.

WithRawChanNATs set rawChan for NATsSource.

WithShred - active shredder of FileSource.

WithSnapMS - set the snapMS for FileSource, which indicate how long to wait for next scan if no files after the scanned.

WithWorkers - set the number of parallel Queue processing.

DefaultProcessor - is a default LogProcessor read out contents directly from file to rawChan channel.

LogProcessor - help to Process the LogFile.

FileValidator validate the LogFile whether is suitable for processing.

ProcessorFactory - is used by FileSource to create LogProcessor.