processor

package

v0.0.0-...-c23655e Latest Latest Go to latest Published: May 15, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

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 {
	FaceRecognitionAddress 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) error

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