processor

package

v1.0.0 Latest Latest Go to latest Published: Dec 24, 2023 License: MIT Imports: 9 Imported by: 0

Details

Package processor handles the processing of resources.

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	BatchSize int
}

Config holds configuration values for the Processor.

type Processor struct {
	Config  Config
	Storage storage.Storage
	// contains filtered or unexported fields
}

Processor manages the processing of resources from various sources.

func NewProcessor(config Config, storage storage.Storage, scanners []scanner.Scanner, logger *logrus.Logger, metrics *metrics.Collector) Processor

NewProcessor initializes a new Processor instance.

func (p *Processor) Process(resourceChan chan resource.Resource, sch scheduler.Scheduler) error

Process initiates resource processing. It starts scanners for all sources and processes resources in batches.