Struct Source

pkg/acquisition/modules/s3/source.go:24–35

}

type Source struct {
	metricsLevel metrics.AcquisitionMetricsLevel
	Config       Configuration
	logger       *log.Entry
	s3Client     S3API
	sqsClient    SQSAPI
	readerChan   chan S3Object
	t            *tomb.Tomb
	out          chan pipeline.Event
	ctx          context.Context
	cancel       context.CancelFunc
}

type S3Object struct {
	Key    string