processor

package

v0.0.0-...-db3c348 Latest Latest Go to latest Published: May 6, 2024 License: Apache-2.0 Imports: 10 Imported by: 2

Details

This section is empty.

This section is empty.

func NewProcessorProvider(cfg Config, deps Dependencies) (providers.ProcessorProvider, error)

NewProcessorProvider creates a new processor provider with an active grpc connection.

type Config struct {
	GrpcAddress string
}

Config needed for the processor.

type Dependencies struct {
	Logger         zerolog.Logger
	CircuitBreaker circuitbreaker.CircuitBreaker
	Storer         providers.ImageStorer
}

Dependencies of the processor provider.

type Processor struct {
	Dependencies
	Config
	IdentifyClient    facerecog.IdentifyClient
	HealthCheckClient facerecog.HealthCheckClient
}

Processor defines a processor which uses a real database to store and process data.

func (p *Processor) ProcessImages(ctx context.Context, in chan int)

ProcessImages takes a channel for input and waits on that channel for processable items. This channel must never be closed.