s3

type Archive struct {
	// contains filtered or unexported fields
}

type ArchiveConfig struct {
	// The S3 bucket that contains the archive
	Bucket string `validate:"required"`
	// A configured s3 client
	Client s3iface.S3API `validate:"required"`
	// Number of objects to download in parallel
	Concurrency int `validate:"required,min=1"`
	// A configured s3 download manager
	Downloader Downloader `validate:"required"`
	// An optional archive scoped logger
	Log logrus.FieldLogger `valdiate:"required"`
	// An optional prefix that contains the relevant archive portion
	Prefix string `validate:"-"`
	// An optional s3 key to begin replay after
	StartAfter string `validate:"-"`
	// An optional s3 key to stop replay at
	StopAt string `validate:"-"`
}

type Downloader interface {
	Download(io.WriterAt, *s3.GetObjectInput, ...func(*s3manager.Downloader)) (int64, error)
}