Skip to content

Instantly share code, notes, and snippets.

@dustin
Last active December 19, 2015 16:18
Show Gist options
  • Star 5 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save dustin/5982452 to your computer and use it in GitHub Desktop.
Save dustin/5982452 to your computer and use it in GitHub Desktop.
Uploading a ton of stuff to S3, I decided I wanted something that would take this boring *os.File and give me a progress indicator. Here's the thing I threw together. Sends this sort of thing to stdout ('\r'ing over itself every second): 10MB/72MB (14.6%)
package main
import (
"fmt"
"io"
"os"
"time"
"github.com/dustin/go-humanize"
)
type progressReader struct {
orig io.Reader
total int64
width int
clearBuf []byte
read chan int
}
func newProgressReader(r io.Reader, n int64) io.ReadCloser {
width := 80
rv := &progressReader{
orig: r,
total: n,
width: width,
clearBuf: make([]byte, width),
read: make(chan int),
}
for i := range rv.clearBuf {
rv.clearBuf[i] = ' '
}
rv.clearBuf[0] = '\r'
rv.clearBuf[width-1] = '\r'
go rv.update()
return rv
}
func (p *progressReader) showPercent(read int64) {
p.clear()
perc := float64(read*100) / float64(p.total)
fmt.Fprintf(os.Stdout, "%v/%v (%.1f%%)",
humanize.Bytes(uint64(read)),
humanize.Bytes(uint64(p.total)), perc)
os.Stdout.Sync()
}
func (p *progressReader) Close() error {
p.clear()
close(p.read)
return nil
}
func (p *progressReader) clear() {
os.Stdout.Write(p.clearBuf)
}
func (p *progressReader) update() {
t := time.NewTicker(time.Second)
defer t.Stop()
var read int64
for {
select {
case <-t.C:
p.showPercent(read)
case n, ok := <-p.read:
if !ok {
return
}
read += int64(n)
}
}
}
func (p *progressReader) Read(b []byte) (int, error) {
n, err := p.orig.Read(b)
p.read <- n
return n, err
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment