| 90 | } |
| 91 | |
| 92 | type S3 struct { |
| 93 | Cfg *S3Config |
| 94 | |
| 95 | uploader *s3manager.Uploader |
| 96 | wgUpload sync.WaitGroup |
| 97 | quit chan struct{} |
| 98 | stopOnce sync.Once |
| 99 | |
| 100 | totaln int64 |
| 101 | totalerr int64 |
| 102 | queuedn int64 |
| 103 | } |
| 104 | |
| 105 | func NewS3(cfg baker.UploadParams) (baker.Upload, error) { |
| 106 | dcfg := cfg.DecodedConfig.(*S3Config) |
nothing calls this directly
no outgoing calls
no test coverage detected