Method SetS3API

input/inpututils/s3.go:40–42

SetS3API allows to replace the S3API, for tests.

(s3API s3iface.S3API)

// SetS3API allows to replace the S3API, for tests.
func (s3 *S3Input) SetS3API(s3API s3iface.S3API) {
	s3.svc = s3API
}

// ProcessDirectory enqueues all files matching a specific prefix for
// processing by s3Input. If prefix is actually a s3 url use the bucket