()
| 216 | } |
| 217 | |
| 218 | func (u *S3) Stats() baker.UploadStats { |
| 219 | bag := make(baker.MetricsBag) |
| 220 | bag.AddGauge("s3upload.queuedn", float64(atomic.LoadInt64(&u.queuedn))) |
| 221 | |
| 222 | return baker.UploadStats{ |
| 223 | NumProcessedFiles: atomic.LoadInt64(&u.totaln), |
| 224 | NumErrorFiles: atomic.LoadInt64(&u.totalerr), |
| 225 | Metrics: bag, |
| 226 | } |
| 227 | } |
| 228 | |
| 229 | type sem chan struct{} |
| 230 |