recognition

type Worker ¶

type Worker struct {
	*worker.Worker
	// contains filtered or unexported fields
}

Worker reads from the face recognition kafka queue, calls the face_recognition grpc service and writes the found faces into another queue

func New(jobQReader *kafka.Reader, resultQWriter *kafka.Writer, faceRecognizerAddress string, pictureBucketName string, imgProxyAddress, imgProxyKey, imgProxySalt string) *Worker