processor

package

v1.0.2 Latest Latest Go to latest Published: Mar 20, 2024 License: CC0-1.0 Imports: 11 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type IProcessor interface {
	ProcessFile(filePath string) error
}

type Processor struct {
	KafkaProducer producer.IProducer
	// contains filtered or unexported fields
}

func NewProcessor(producer producer.IProducer, parsing parser.IParser) *Processor

func (p *Processor) ProcessFile(filePath string) error

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

func NewWorker(kafkaProducer producer.IProducer, errorParsePath string, lock *sync.Mutex, psr parser.IParser,
	processing map[string]bool) *Worker

func (w *Worker) Do(files <-chan string)