Commit 2d1b96cfa9a37c3246c5d4f227a5da60c44ca819 - golang-github-vbauerster-mpb

+6

-8

.travis.yml less more

0	0	language: go
1		sudo: false
	1
2	2	go:
3	3	- 1.10.x
4		- tip
	4	- 1.11.x
5	5
6		before_install:
7		- go get -t -v ./...
	6	env:
	7	- GO111MODULE=on
8	8
9	9	script:
10		- go test -race -coverprofile=coverage.txt -covermode=atomic
11
12		after_success:
13		- bash <(curl -s https://codecov.io/bash)
	10	- go test -race -timeout 10s ./...
	11	- for i in _examples//; do go build $i/.go \|\| exit 1; done

+26

-25

README.md less more

15	15	* __Predefined Decorators__: Elapsed time, [ewma](https://github.com/VividCortex/ewma) based ETA, Percentage, Bytes counter
16	16	* __Decorator's width sync__: Synchronized decorator's width among multiple bars
17	17
18		## Installation
19
20		```sh
21		go get github.com/vbauerster/mpb
22		```
23
24		_Note:_ it is preferable to go get from github.com, rather than gopkg.in. See issue [#11](https://github.com/vbauerster/mpb/issues/11).
25
26	18	## Usage
27	19
28		#### [Rendering single bar](examples/singleBar/main.go)
	20	#### [Rendering single bar](_examples/singleBar/main.go)
29	21	```go
30		p := mpb.New(
31		// override default (80) width
32		mpb.WithWidth(64),
33		// override default 120ms refresh rate
34		mpb.WithRefreshRate(180*time.Millisecond),
35		)
	22	package main
	23
	24	import (
	25	"math/rand"
	26	"time"
	27
	28	"github.com/vbauerster/mpb/v4"
	29	"github.com/vbauerster/mpb/v4/decor"
	30	)
	31
	32	func main() {
	33	// initialize progress container, with custom width
	34	p := mpb.New(mpb.WithWidth(64))
36	35
37	36	total := 100
38	37	name := "Single Bar:"
39		// adding a single bar
	38	// adding a single bar, which will inherit container's width
40	39	bar := p.AddBar(int64(total),
41		// override default "[=>-]" style
	40	// set custom bar style, default one is "[=>-]"
42	41	mpb.BarStyle("╢▌▌░╟"),
43	42	mpb.PrependDecorators(
44	43	// display our name with one space on the right

61	60	}
62	61	// wait for our bar to complete and flush
63	62	p.Wait()
	63	}
64	64	```
65	65
66		#### [Rendering multiple bars](examples/simple/main.go)
	66	#### [Rendering multiple bars](_examples/simple/main.go)
67	67	```go
68	68	var wg sync.WaitGroup
	69	// pass &wg (optional), so p will wait for it eventually
69	70	p := mpb.New(mpb.WithWaitGroup(&wg))
70	71	total, numBars := 100, 3
71	72	wg.Add(numBars)

99	100	}
100	101	}()
101	102	}
102		// wait for all bars to complete and flush
	103	// Waiting for passed &wg and for all bars to complete and flush
103	104	p.Wait()
104	105	```
105	106
106		#### [Dynamic total](examples/dynTotal/main.go)
	107	#### [Dynamic total](_examples/dynTotal/main.go)
107	108
108		![dynamic total](examples/gifs/godEMrCZmJkHYH1X9dN4Nm0U7.svg)
	109	![dynamic total](_svg/godEMrCZmJkHYH1X9dN4Nm0U7.svg)
109	110
110		#### [Complex example](examples/complex/main.go)
	111	#### [Complex example](_examples/complex/main.go)
111	112
112		![complex](examples/gifs/wHzf1M7sd7B3zVa2scBMnjqRf.svg)
	113	![complex](_svg/wHzf1M7sd7B3zVa2scBMnjqRf.svg)
113	114
114		#### [Bytes counters](examples/io/single/main.go)
	115	#### [Bytes counters](_examples/io/single/main.go)
115	116
116		![byte counters](examples/gifs/hIpTa3A5rQz65ssiVuRJu87X6.svg)
	117	![byte counters](_svg/hIpTa3A5rQz65ssiVuRJu87X6.svg)

+60

-0

_examples/barNewLineExtend/main.go less more

	0	package main
	1
	2	import (
	3	"fmt"
	4	"io"
	5	"math/rand"
	6	"sync"
	7	"time"
	8
	9	"github.com/vbauerster/mpb/v4"
	10	"github.com/vbauerster/mpb/v4/decor"
	11	)
	12
	13	func init() {
	14	rand.Seed(time.Now().UnixNano())
	15	}
	16
	17	func main() {
	18	var wg sync.WaitGroup
	19	p := mpb.New(mpb.WithWaitGroup(&wg))
	20	total, numBars := 100, 3
	21	wg.Add(numBars)
	22
	23	for i := 0; i < numBars; i++ {
	24	name := fmt.Sprintf("Bar#%d:", i)
	25	efn := func(w io.Writer, s *decor.Statistics) {
	26	if s.Completed {
	27	fmt.Fprintf(w, "Bar id: %d has been completed\n", s.ID)
	28	}
	29	}
	30	bar := p.AddBar(int64(total), mpb.BarNewLineExtend(efn),
	31	mpb.PrependDecorators(
	32	// simple name decorator
	33	decor.Name(name),
	34	// decor.DSyncWidth bit enables column width synchronization
	35	decor.Percentage(decor.WCSyncSpace),
	36	),
	37	mpb.AppendDecorators(
	38	// replace ETA decorator with "done" message, OnComplete event
	39	decor.OnComplete(
	40	// ETA decorator with ewma age of 60
	41	decor.EwmaETA(decor.ET_STYLE_GO, 60), "done",
	42	),
	43	),
	44	)
	45	// simulating some work
	46	go func() {
	47	defer wg.Done()
	48	max := 100 * time.Millisecond
	49	for i := 0; i < total; i++ {
	50	start := time.Now()
	51	time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
	52	// ewma based decorators require work duration measurement
	53	bar.IncrBy(1, time.Since(start))
	54	}
	55	}()
	56	}
	57	// wait for all bars to complete and flush
	58	p.Wait()
	59	}

+56

-0

_examples/cancel/main.go less more

	0	package main
	1
	2	import (
	3	"context"
	4	"fmt"
	5	"math/rand"
	6	"sync"
	7	"time"
	8
	9	"github.com/vbauerster/mpb"
	10	"github.com/vbauerster/mpb/decor"
	11	)
	12
	13	func init() {
	14	rand.Seed(time.Now().UnixNano())
	15	}
	16
	17	func main() {
	18	ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
	19	defer cancel()
	20
	21	var wg sync.WaitGroup
	22	p := mpb.New(
	23	mpb.WithWaitGroup(&wg),
	24	mpb.WithContext(ctx),
	25	)
	26	total := 300
	27	numBars := 3
	28	wg.Add(numBars)
	29
	30	for i := 0; i < numBars; i++ {
	31	name := fmt.Sprintf("Bar#%d:", i)
	32	bar := p.AddBar(int64(total),
	33	mpb.PrependDecorators(
	34	decor.Name(name),
	35	decor.EwmaETA(decor.ET_STYLE_GO, 60, decor.WCSyncSpace),
	36	),
	37	mpb.AppendDecorators(
	38	decor.Percentage(decor.WC{W: 5}),
	39	),
	40	)
	41
	42	go func() {
	43	defer wg.Done()
	44	max := 100 * time.Millisecond
	45	for !bar.Completed() {
	46	start := time.Now()
	47	time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
	48	// ewma based decorators require work duration measurement
	49	bar.IncrBy(1, time.Since(start))
	50	}
	51	}()
	52	}
	53
	54	p.Wait()
	55	}

+79

-0

_examples/complex/main.go less more

	0	package main
	1
	2	import (
	3	"fmt"
	4	"math/rand"
	5	"sync"
	6	"time"
	7
	8	"github.com/vbauerster/mpb/v4"
	9	"github.com/vbauerster/mpb/v4/decor"
	10	)
	11
	12	func init() {
	13	rand.Seed(time.Now().UnixNano())
	14	}
	15
	16	func main() {
	17	doneWg := new(sync.WaitGroup)
	18	p := mpb.New(mpb.WithWidth(64), mpb.WithWaitGroup(doneWg))
	19	numBars := 4
	20
	21	var bars []*mpb.Bar
	22	var downloadWgg []*sync.WaitGroup
	23	for i := 0; i < numBars; i++ {
	24	wg := new(sync.WaitGroup)
	25	wg.Add(1)
	26	downloadWgg = append(downloadWgg, wg)
	27	task := fmt.Sprintf("Task#%02d:", i)
	28	job := "downloading"
	29	b := p.AddBar(rand.Int63n(201)+100,
	30	mpb.BarRemoveOnComplete(),
	31	mpb.PrependDecorators(
	32	decor.Name(task, decor.WC{W: len(task) + 1, C: decor.DidentRight}),
	33	decor.Name(job, decor.WCSyncSpaceR),
	34	decor.CountersNoUnit("%d / %d", decor.WCSyncWidth),
	35	),
	36	mpb.AppendDecorators(decor.Percentage(decor.WC{W: 5})),
	37	)
	38	go newTask(wg, b, i+1)
	39	bars = append(bars, b)
	40	}
	41
	42	for i := 0; i < numBars; i++ {
	43	doneWg.Add(1)
	44	i := i
	45	go func() {
	46	task := fmt.Sprintf("Task#%02d:", i)
	47	job := "installing"
	48	// preparing delayed bars
	49	b := p.AddBar(rand.Int63n(101)+100,
	50	mpb.BarReplaceOnComplete(bars[i]),
	51	mpb.BarClearOnComplete(),
	52	mpb.PrependDecorators(
	53	decor.Name(task, decor.WC{W: len(task) + 1, C: decor.DidentRight}),
	54	decor.OnComplete(decor.Name(job, decor.WCSyncSpaceR), "done!"),
	55	decor.OnComplete(decor.EwmaETA(decor.ET_STYLE_MMSS, 60, decor.WCSyncWidth), "")),
	56	mpb.AppendDecorators(
	57	decor.OnComplete(decor.Percentage(decor.WC{W: 5}), ""),
	58	),
	59	)
	60	// waiting for download to complete, before starting install job
	61	downloadWgg[i].Wait()
	62	go newTask(doneWg, b, numBars-i)
	63	}()
	64	}
	65
	66	p.Wait()
	67	}
	68
	69	func newTask(wg sync.WaitGroup, b mpb.Bar, incrBy int) {
	70	defer wg.Done()
	71	max := 100 * time.Millisecond
	72	for !b.Completed() {
	73	start := time.Now()
	74	time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
	75	// ewma based decorators require work duration measurement
	76	b.IncrBy(incrBy, time.Since(start))
	77	}
	78	}

+60

-0

_examples/differentWidth/main.go less more

	0	package main
	1
	2	import (
	3	"fmt"
	4	"math/rand"
	5	"sync"
	6	"time"
	7
	8	"github.com/vbauerster/mpb/v4"
	9	"github.com/vbauerster/mpb/v4/decor"
	10	)
	11
	12	func init() {
	13	rand.Seed(time.Now().UnixNano())
	14	}
	15
	16	func main() {
	17	var wg sync.WaitGroup
	18	p := mpb.New(
	19	mpb.WithWaitGroup(&wg),
	20	// container's width.
	21	mpb.WithWidth(60),
	22	)
	23	total, numBars := 100, 3
	24	wg.Add(numBars)
	25
	26	for i := 0; i < numBars; i++ {
	27	name := fmt.Sprintf("Bar#%d:", i)
	28	bar := p.AddBar(int64(total),
	29	// set BarWidth 40 for bar 1 and 2
	30	mpb.OptionOnCondition(mpb.BarWidth(40), func() bool { return i > 0 }),
	31	mpb.PrependDecorators(
	32	// simple name decorator
	33	decor.Name(name),
	34	// decor.DSyncWidth bit enables column width synchronization
	35	decor.Percentage(decor.WCSyncSpace),
	36	),
	37	mpb.AppendDecorators(
	38	// replace ETA decorator with "done" message, OnComplete event
	39	decor.OnComplete(
	40	// ETA decorator with ewma age of 60
	41	decor.EwmaETA(decor.ET_STYLE_GO, 60), "done",
	42	),
	43	),
	44	)
	45	// simulating some work
	46	go func() {
	47	defer wg.Done()
	48	max := 100 * time.Millisecond
	49	for i := 0; i < total; i++ {
	50	start := time.Now()
	51	time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
	52	// ewma based decorators require work duration measurement
	53	bar.IncrBy(1, time.Since(start))
	54	}
	55	}()
	56	}
	57	// wait for all bars to complete and flush
	58	p.Wait()
	59	}

+52

-0

_examples/dynTotal/main.go less more

	0	package main
	1
	2	import (
	3	"io"
	4	"math/rand"
	5	"time"
	6
	7	"github.com/vbauerster/mpb/v4"
	8	"github.com/vbauerster/mpb/v4/decor"
	9	)
	10
	11	func init() {
	12	rand.Seed(time.Now().UnixNano())
	13	}
	14
	15	func main() {
	16	p := mpb.New(mpb.WithWidth(64))
	17
	18	var total int64
	19	bar := p.AddBar(total,
	20	mpb.PrependDecorators(decor.Counters(decor.UnitKiB, "% .1f / % .1f")),
	21	mpb.AppendDecorators(decor.Percentage()),
	22	)
	23
	24	maxSleep := 100 * time.Millisecond
	25	read := makeStream(200)
	26	for {
	27	n, err := read()
	28	total += int64(n)
	29	time.Sleep(time.Duration(rand.Intn(10)+1) * maxSleep / 10)
	30	bar.IncrBy(n)
	31	if err == io.EOF {
	32	// total is known, final=true
	33	bar.SetTotal(total, true)
	34	break
	35	}
	36	// total is unknown, final=false
	37	bar.SetTotal(total+2048, false)
	38	}
	39
	40	p.Wait()
	41	}
	42
	43	func makeStream(limit int) func() (int, error) {
	44	return func() (int, error) {
	45	if limit <= 0 {
	46	return 0, io.EOF
	47	}
	48	limit--
	49	return rand.Intn(1024) + 1, nil
	50	}
	51	}

+83

-0

_examples/io/multiple/main.go less more

	0	package main
	1
	2	import (
	3	"fmt"
	4	"io"
	5	"log"
	6	"net/http"
	7	"os"
	8	"path/filepath"
	9	"sync"
	10
	11	"github.com/vbauerster/mpb/v4"
	12	"github.com/vbauerster/mpb/v4/decor"
	13	)
	14
	15	func main() {
	16	log.SetOutput(os.Stderr)
	17
	18	url1 := "https://homebrew.bintray.com/bottles/youtube-dl-2016.12.12.sierra.bottle.tar.gz"
	19	url2 := "https://homebrew.bintray.com/bottles/libtiff-4.0.7.sierra.bottle.tar.gz"
	20
	21	var wg sync.WaitGroup
	22	p := mpb.New(mpb.WithWidth(64), mpb.WithWaitGroup(&wg))
	23
	24	for i, url := range [...]string{url1, url2} {
	25	wg.Add(1)
	26	name := fmt.Sprintf("url%d:", i+1)
	27	go download(&wg, p, name, url, i)
	28	}
	29
	30	p.Wait()
	31	}
	32
	33	func download(wg sync.WaitGroup, p mpb.Progress, name, url string, n int) {
	34	defer wg.Done()
	35	resp, err := http.Get(url)
	36	if err != nil {
	37	log.Printf("%s: %v", name, err)
	38	return
	39	}
	40	defer resp.Body.Close()
	41
	42	if resp.StatusCode != http.StatusOK {
	43	err = fmt.Errorf("non-200 status: %s", resp.Status)
	44	log.Printf("%s: %v", name, err)
	45	return
	46	}
	47
	48	size := resp.ContentLength
	49
	50	// create dest
	51	destName := filepath.Base(url)
	52	dest, err := os.Create(destName)
	53	if err != nil {
	54	err = fmt.Errorf("Can't create %s: %v", destName, err)
	55	log.Printf("%s: %v", name, err)
	56	return
	57	}
	58
	59	// create bar with appropriate decorators
	60	bar := p.AddBar(size, mpb.BarPriority(n),
	61	mpb.PrependDecorators(
	62	decor.Name(name, decor.WC{W: len(name) + 1, C: decor.DidentRight}),
	63	decor.CountersKibiByte("%6.1f / %6.1f", decor.WCSyncWidth),
	64	),
	65	mpb.AppendDecorators(
	66	decor.EwmaETA(decor.ET_STYLE_HHMMSS, 1024*4, decor.WCSyncWidth),
	67	decor.AverageSpeed(decor.UnitKiB, "% .2f"),
	68	),
	69	)
	70
	71	// create proxy reader
	72	reader := bar.ProxyReader(resp.Body)
	73	// and copy from reader
	74	_, err = io.Copy(dest, reader)
	75
	76	if e := dest.Close(); err == nil {
	77	err = e
	78	}
	79	if err != nil {
	80	log.Printf("%s: %v", name, err)
	81	}
	82	}

+63

-0

_examples/io/single/main.go less more

	0	package main
	1
	2	import (
	3	"fmt"
	4	"io"
	5	"net/http"
	6	"os"
	7	"path/filepath"
	8	"time"
	9
	10	"github.com/vbauerster/mpb/v4"
	11	"github.com/vbauerster/mpb/v4/decor"
	12	)
	13
	14	func main() {
	15	url := "https://github.com/onivim/oni/releases/download/v0.3.4/Oni-0.3.4-amd64-linux.deb"
	16
	17	resp, err := http.Get(url)
	18	if err != nil {
	19	panic(err)
	20	}
	21	defer resp.Body.Close()
	22
	23	if resp.StatusCode != http.StatusOK {
	24	fmt.Printf("Server return non-200 status: %s\n", resp.Status)
	25	return
	26	}
	27
	28	size := resp.ContentLength
	29
	30	// create dest
	31	destName := filepath.Base(url)
	32	dest, err := os.Create(destName)
	33	if err != nil {
	34	fmt.Printf("Can't create %s: %v\n", destName, err)
	35	return
	36	}
	37	defer dest.Close()
	38
	39	p := mpb.New(
	40	mpb.WithWidth(60),
	41	mpb.WithRefreshRate(180*time.Millisecond),
	42	)
	43
	44	bar := p.AddBar(size, mpb.BarStyle("[=>-\|"),
	45	mpb.PrependDecorators(
	46	decor.CountersKibiByte("% 6.1f / % 6.1f"),
	47	),
	48	mpb.AppendDecorators(
	49	decor.EwmaETA(decor.ET_STYLE_MMSS, float64(size)/2048),
	50	decor.Name(" ] "),
	51	decor.AverageSpeed(decor.UnitKiB, "% .2f"),
	52	),
	53	)
	54
	55	// create proxy reader
	56	reader := bar.ProxyReader(resp.Body)
	57
	58	// and copy from reader, ignoring errors
	59	io.Copy(dest, reader)
	60
	61	p.Wait()
	62	}

+57

-0

_examples/panic/main.go less more

	0	package main
	1
	2	import (
	3	"fmt"
	4	"os"
	5	"sync"
	6	"time"
	7
	8	"github.com/vbauerster/mpb/v4"
	9	"github.com/vbauerster/mpb/v4/decor"
	10	)
	11
	12	func main() {
	13	var wg sync.WaitGroup
	14	p := mpb.New(mpb.WithWaitGroup(&wg), mpb.WithDebugOutput(os.Stderr))
	15
	16	wantPanic := "Some really long panic panic panic panic panic panic panic, really it is very long"
	17	numBars := 3
	18	wg.Add(numBars)
	19
	20	for i := 0; i < numBars; i++ {
	21	name := fmt.Sprintf("b#%02d:", i)
	22	bar := p.AddBar(100, mpb.BarID(i), mpb.PrependDecorators(panicDecorator(name, wantPanic)))
	23
	24	go func() {
	25	defer wg.Done()
	26	for i := 0; i < 100; i++ {
	27	time.Sleep(50 * time.Millisecond)
	28	bar.Increment()
	29	}
	30	}()
	31	}
	32
	33	p.Wait()
	34	}
	35
	36	func panicDecorator(name, panicMsg string) decor.Decorator {
	37	d := &decorator{
	38	msg: name,
	39	panicMsg: panicMsg,
	40	}
	41	d.Init()
	42	return d
	43	}
	44
	45	type decorator struct {
	46	decor.WC
	47	msg string
	48	panicMsg string
	49	}
	50
	51	func (d decorator) Decor(st decor.Statistics) string {
	52	if st.ID == 1 && st.Current >= 42 {
	53	panic(d.panicMsg)
	54	}
	55	return d.FormatMsg(d.msg)
	56	}

+51

-0

_examples/remove/main.go less more

	0	package main
	1
	2	import (
	3	"fmt"
	4	"math/rand"
	5	"sync"
	6	"time"
	7
	8	"github.com/vbauerster/mpb/v4"
	9	"github.com/vbauerster/mpb/v4/decor"
	10	)
	11
	12	func init() {
	13	rand.Seed(time.Now().UnixNano())
	14	}
	15
	16	func main() {
	17	var wg sync.WaitGroup
	18	p := mpb.New(mpb.WithWaitGroup(&wg))
	19	total := 100
	20	numBars := 3
	21	wg.Add(numBars)
	22
	23	for i := 0; i < numBars; i++ {
	24	name := fmt.Sprintf("Bar#%d:", i)
	25	b := p.AddBar(int64(total), mpb.BarID(i),
	26	mpb.OptionOnCondition(mpb.BarRemoveOnComplete(), func() bool { return i == 0 }),
	27	mpb.PrependDecorators(
	28	decor.Name(name),
	29	decor.EwmaETA(decor.ET_STYLE_GO, 60, decor.WCSyncSpace),
	30	),
	31	mpb.AppendDecorators(decor.Percentage()),
	32	)
	33	go func() {
	34	defer wg.Done()
	35	max := 100 * time.Millisecond
	36	for i := 0; i < total; i++ {
	37	start := time.Now()
	38	if b.ID() == 2 && i == 42 {
	39	p.Abort(b, true)
	40	return
	41	}
	42	time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
	43	// ewma based decorators require work duration measurement
	44	b.IncrBy(1, time.Since(start))
	45	}
	46	}()
	47	}
	48
	49	p.Wait()
	50	}

+55

-0

_examples/simple/main.go less more

	0	package main
	1
	2	import (
	3	"fmt"
	4	"math/rand"
	5	"sync"
	6	"time"
	7
	8	"github.com/vbauerster/mpb/v4"
	9	"github.com/vbauerster/mpb/v4/decor"
	10	)
	11
	12	func init() {
	13	rand.Seed(time.Now().UnixNano())
	14	}
	15
	16	func main() {
	17	var wg sync.WaitGroup
	18	// pass &wg (optional), so p will wait for it eventually
	19	p := mpb.New(mpb.WithWaitGroup(&wg))
	20	total, numBars := 100, 3
	21	wg.Add(numBars)
	22
	23	for i := 0; i < numBars; i++ {
	24	name := fmt.Sprintf("Bar#%d:", i)
	25	bar := p.AddBar(int64(total),
	26	mpb.PrependDecorators(
	27	// simple name decorator
	28	decor.Name(name),
	29	// decor.DSyncWidth bit enables column width synchronization
	30	decor.Percentage(decor.WCSyncSpace),
	31	),
	32	mpb.AppendDecorators(
	33	// replace ETA decorator with "done" message, OnComplete event
	34	decor.OnComplete(
	35	// ETA decorator with ewma age of 60
	36	decor.EwmaETA(decor.ET_STYLE_GO, 60), "done",
	37	),
	38	),
	39	)
	40	// simulating some work
	41	go func() {
	42	defer wg.Done()
	43	max := 100 * time.Millisecond
	44	for i := 0; i < total; i++ {
	45	start := time.Now()
	46	time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
	47	// ewma based decorators require work duration measurement
	48	bar.IncrBy(1, time.Since(start))
	49	}
	50	}()
	51	}
	52	// Waiting for passed &wg and for all bars to complete and flush
	53	p.Wait()
	54	}

+42

-0

_examples/singleBar/main.go less more

	0	package main
	1
	2	import (
	3	"math/rand"
	4	"time"
	5
	6	"github.com/vbauerster/mpb/v4"
	7	"github.com/vbauerster/mpb/v4/decor"
	8	)
	9
	10	func main() {
	11	// initialize progress container, with custom width
	12	p := mpb.New(mpb.WithWidth(64))
	13
	14	total := 100
	15	name := "Single Bar:"
	16	// adding a single bar, which will inherit container's width
	17	bar := p.AddBar(int64(total),
	18	// set custom bar style, default one is "[=>-]"
	19	mpb.BarStyle("╢▌▌░╟"),
	20	mpb.PrependDecorators(
	21	// display our name with one space on the right
	22	decor.Name(name, decor.WC{W: len(name) + 1, C: decor.DidentRight}),
	23	// replace ETA decorator with "done" message, OnComplete event
	24	decor.OnComplete(
	25	// ETA decorator with ewma age of 60, and width reservation of 4
	26	decor.EwmaETA(decor.ET_STYLE_GO, 60, decor.WC{W: 4}), "done",
	27	),
	28	),
	29	mpb.AppendDecorators(decor.Percentage()),
	30	)
	31	// simulating some work
	32	max := 100 * time.Millisecond
	33	for i := 0; i < total; i++ {
	34	start := time.Now()
	35	time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
	36	// ewma based decorators require work duration measurement
	37	bar.IncrBy(1, time.Since(start))
	38	}
	39	// wait for our bar to complete and flush
	40	p.Wait()
	41	}

+55

-0

_examples/sort/main.go less more

	0	package main
	1
	2	import (
	3	"fmt"
	4	"math/rand"
	5	"sync"
	6	"time"
	7
	8	"github.com/vbauerster/mpb/v4"
	9	"github.com/vbauerster/mpb/v4/decor"
	10	)
	11
	12	func init() {
	13	rand.Seed(time.Now().UnixNano())
	14	}
	15
	16	func main() {
	17	var wg sync.WaitGroup
	18	p := mpb.New(mpb.WithWaitGroup(&wg))
	19	total := 100
	20	numBars := 3
	21	wg.Add(numBars)
	22
	23	for i := 0; i < numBars; i++ {
	24	var name string
	25	if i != 1 {
	26	name = fmt.Sprintf("Bar#%d:", i)
	27	}
	28	b := p.AddBar(int64(total),
	29	mpb.PrependDecorators(
	30	decor.Name(name, decor.WCSyncWidth),
	31	decor.CountersNoUnit("%d / %d", decor.WCSyncSpace),
	32	),
	33	mpb.AppendDecorators(
	34	decor.EwmaETA(decor.ET_STYLE_GO, 60, decor.WC{W: 3}),
	35	),
	36	)
	37	go func() {
	38	defer wg.Done()
	39	max := 100 * time.Millisecond
	40	for i := 0; i < total; i++ {
	41	start := time.Now()
	42	time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
	43	if i&1 == 1 {
	44	priority := total - int(b.Current())
	45	p.UpdateBarPriority(b, priority)
	46	}
	47	// ewma based decorators require work duration measurement
	48	b.IncrBy(1, time.Since(start))
	49	}
	50	}()
	51	}
	52
	53	p.Wait()
	54	}

+77

-0

_examples/spinner/main.go less more

	0	package main
	1
	2	import (
	3	"fmt"
	4	"math/rand"
	5	"sync"
	6	"time"
	7
	8	"github.com/vbauerster/mpb/v4"
	9	"github.com/vbauerster/mpb/v4/decor"
	10	)
	11
	12	func init() {
	13	rand.Seed(time.Now().UnixNano())
	14	}
	15
	16	func main() {
	17	var wg sync.WaitGroup
	18	p := mpb.New(
	19	mpb.WithWaitGroup(&wg),
	20	mpb.WithWidth(13),
	21	)
	22	total, numBars := 101, 3
	23	wg.Add(numBars)
	24
	25	for i := 0; i < numBars; i++ {
	26	name := fmt.Sprintf("Bar#%d:", i)
	27	var bar *mpb.Bar
	28	if i == 0 {
	29	bar = p.AddBar(int64(total),
	30	// set custom bar style, default one is "[=>-]"
	31	mpb.BarStyle("╢▌▌░╟"),
	32	mpb.PrependDecorators(
	33	// simple name decorator
	34	decor.Name(name),
	35	),
	36	mpb.AppendDecorators(
	37	// replace ETA decorator with "done" message, OnComplete event
	38	decor.OnComplete(
	39	// ETA decorator with ewma age of 60
	40	decor.EwmaETA(decor.ET_STYLE_GO, 60), "done",
	41	),
	42	),
	43	)
	44	} else {
	45	bar = p.AddSpinner(int64(total), mpb.SpinnerOnMiddle,
	46	// set custom spinner style, default one is {"⠋", "⠙", "⠹", "⠸", "⠼", "⠴", "⠦", "⠧", "⠇", "⠏"}
	47	mpb.SpinnerStyle([]string{"∙∙∙", "●∙∙", "∙●∙", "∙∙●", "∙∙∙"}),
	48	mpb.PrependDecorators(
	49	// simple name decorator
	50	decor.Name(name),
	51	),
	52	mpb.AppendDecorators(
	53	// replace ETA decorator with "done" message, OnComplete event
	54	decor.OnComplete(
	55	// ETA decorator with ewma age of 60
	56	decor.EwmaETA(decor.ET_STYLE_GO, 60), "done",
	57	),
	58	),
	59	)
	60	}
	61
	62	// simulating some work
	63	go func() {
	64	defer wg.Done()
	65	max := 100 * time.Millisecond
	66	for i := 0; i < total; i++ {
	67	start := time.Now()
	68	time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
	69	// ewma based decorators require work duration measurement
	70	bar.IncrBy(1, time.Since(start))
	71	}
	72	}()
	73	}
	74	// wait for all bars to complete and flush
	75	p.Wait()
	76	}

+55

-0

_examples/stress/main.go less more

	0	package main
	1
	2	import (
	3	"fmt"
	4	"math/rand"
	5	"sync"
	6	"time"
	7
	8	"github.com/vbauerster/mpb/v4"
	9	"github.com/vbauerster/mpb/v4/decor"
	10	)
	11
	12	const (
	13	totalBars = 32
	14	)
	15
	16	func init() {
	17	rand.Seed(time.Now().UnixNano())
	18	}
	19
	20	func main() {
	21	var wg sync.WaitGroup
	22	p := mpb.New(
	23	mpb.WithWaitGroup(&wg),
	24	mpb.WithRefreshRate(50*time.Millisecond),
	25	)
	26	wg.Add(totalBars)
	27
	28	for i := 0; i < totalBars; i++ {
	29	name := fmt.Sprintf("Bar#%02d: ", i)
	30	total := rand.Intn(320) + 10
	31	bar := p.AddBar(int64(total),
	32	mpb.PrependDecorators(
	33	decor.Name(name),
	34	decor.EwmaETA(decor.ET_STYLE_GO, 60, decor.WCSyncSpace),
	35	),
	36	mpb.AppendDecorators(
	37	decor.Percentage(decor.WC{W: 5}),
	38	),
	39	)
	40
	41	go func() {
	42	defer wg.Done()
	43	max := 100 * time.Millisecond
	44	for !bar.Completed() {
	45	start := time.Now()
	46	time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
	47	// ewma based decorators require work duration measurement
	48	bar.IncrBy(1, time.Since(start))
	49	}
	50	}()
	51	}
	52
	53	p.Wait()
	54	}

+1

-0

_svg/godEMrCZmJkHYH1X9dN4Nm0U7.svg less more

0

+1

-0

_svg/hIpTa3A5rQz65ssiVuRJu87X6.svg less more

0

+1

-0

_svg/wHzf1M7sd7B3zVa2scBMnjqRf.svg less more

0

+6

-10

example_test.go less more

6	6	"net/http"
7	7	"time"
8	8
9		"github.com/vbauerster/mpb"
10		"github.com/vbauerster/mpb/decor"
	9	"github.com/vbauerster/mpb/v4"
	10	"github.com/vbauerster/mpb/v4/decor"
11	11	)
12	12
13	13	func Example() {
14		p := mpb.New(
15		// override default (80) width
16		mpb.WithWidth(64),
17		// override default 120ms refresh rate
18		mpb.WithRefreshRate(180*time.Millisecond),
19		)
	14	// initialize progress container, with custom width
	15	p := mpb.New(mpb.WithWidth(64))
20	16
21	17	total := 100
22	18	name := "Single Bar:"
23		// adding a single bar
	19	// adding a single bar, which will inherit container's width
24	20	bar := p.AddBar(int64(total),
25		// override default "[=>-]" style
	21	// set custom bar style, default one is "[=>-]"
26	22	mpb.BarStyle("╢▌▌░╟"),
27	23	mpb.PrependDecorators(
28	24	// display our name with one space on the right

+0

-60

~~examples/barNewLineExtend/main.go~~ less more

0		package main
1
2		import (
3		"fmt"
4		"io"
5		"math/rand"
6		"sync"
7		"time"
8
9		"github.com/vbauerster/mpb"
10		"github.com/vbauerster/mpb/decor"
11		)
12
13		func init() {
14		rand.Seed(time.Now().UnixNano())
15		}
16
17		func main() {
18		var wg sync.WaitGroup
19		p := mpb.New(mpb.WithWaitGroup(&wg))
20		total, numBars := 100, 3
21		wg.Add(numBars)
22
23		for i := 0; i < numBars; i++ {
24		name := fmt.Sprintf("Bar#%d:", i)
25		efn := func(w io.Writer, s *decor.Statistics) {
26		if s.Completed {
27		fmt.Fprintf(w, "Bar id: %d has been completed\n", s.ID)
28		}
29		}
30		bar := p.AddBar(int64(total), mpb.BarNewLineExtend(efn),
31		mpb.PrependDecorators(
32		// simple name decorator
33		decor.Name(name),
34		// decor.DSyncWidth bit enables column width synchronization
35		decor.Percentage(decor.WCSyncSpace),
36		),
37		mpb.AppendDecorators(
38		// replace ETA decorator with "done" message, OnComplete event
39		decor.OnComplete(
40		// ETA decorator with ewma age of 60
41		decor.EwmaETA(decor.ET_STYLE_GO, 60), "done",
42		),
43		),
44		)
45		// simulating some work
46		go func() {
47		defer wg.Done()
48		max := 100 * time.Millisecond
49		for i := 0; i < total; i++ {
50		start := time.Now()
51		time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
52		// ewma based decorators require work duration measurement
53		bar.IncrBy(1, time.Since(start))
54		}
55		}()
56		}
57		// wait for all bars to complete and flush
58		p.Wait()
59		}

+0

-56

~~examples/cancel/main.go~~ less more

0		package main
1
2		import (
3		"context"
4		"fmt"
5		"math/rand"
6		"sync"
7		"time"
8
9		"github.com/vbauerster/mpb"
10		"github.com/vbauerster/mpb/decor"
11		)
12
13		func init() {
14		rand.Seed(time.Now().UnixNano())
15		}
16
17		func main() {
18		ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
19		defer cancel()
20
21		var wg sync.WaitGroup
22		p := mpb.New(
23		mpb.WithWaitGroup(&wg),
24		mpb.WithContext(ctx),
25		)
26		total := 300
27		numBars := 3
28		wg.Add(numBars)
29
30		for i := 0; i < numBars; i++ {
31		name := fmt.Sprintf("Bar#%d:", i)
32		bar := p.AddBar(int64(total),
33		mpb.PrependDecorators(
34		decor.Name(name),
35		decor.EwmaETA(decor.ET_STYLE_GO, 60, decor.WCSyncSpace),
36		),
37		mpb.AppendDecorators(
38		decor.Percentage(decor.WC{W: 5}),
39		),
40		)
41
42		go func() {
43		defer wg.Done()
44		max := 100 * time.Millisecond
45		for !bar.Completed() {
46		start := time.Now()
47		time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
48		// ewma based decorators require work duration measurement
49		bar.IncrBy(1, time.Since(start))
50		}
51		}()
52		}
53
54		p.Wait()
55		}

+0

-79

~~examples/complex/main.go~~ less more

0		package main
1
2		import (
3		"fmt"
4		"math/rand"
5		"sync"
6		"time"
7
8		"github.com/vbauerster/mpb"
9		"github.com/vbauerster/mpb/decor"
10		)
11
12		func init() {
13		rand.Seed(time.Now().UnixNano())
14		}
15
16		func main() {
17		doneWg := new(sync.WaitGroup)
18		p := mpb.New(mpb.WithWidth(64), mpb.WithWaitGroup(doneWg))
19		numBars := 4
20
21		var bars []*mpb.Bar
22		var downloadWgg []*sync.WaitGroup
23		for i := 0; i < numBars; i++ {
24		wg := new(sync.WaitGroup)
25		wg.Add(1)
26		downloadWgg = append(downloadWgg, wg)
27		task := fmt.Sprintf("Task#%02d:", i)
28		job := "downloading"
29		b := p.AddBar(rand.Int63n(201)+100,
30		mpb.BarRemoveOnComplete(),
31		mpb.PrependDecorators(
32		decor.Name(task, decor.WC{W: len(task) + 1, C: decor.DidentRight}),
33		decor.Name(job, decor.WCSyncSpaceR),
34		decor.CountersNoUnit("%d / %d", decor.WCSyncWidth),
35		),
36		mpb.AppendDecorators(decor.Percentage(decor.WC{W: 5})),
37		)
38		go newTask(wg, b, i+1)
39		bars = append(bars, b)
40		}
41
42		for i := 0; i < numBars; i++ {
43		doneWg.Add(1)
44		i := i
45		go func() {
46		task := fmt.Sprintf("Task#%02d:", i)
47		job := "installing"
48		// preparing delayed bars
49		b := p.AddBar(rand.Int63n(101)+100,
50		mpb.BarReplaceOnComplete(bars[i]),
51		mpb.BarClearOnComplete(),
52		mpb.PrependDecorators(
53		decor.Name(task, decor.WC{W: len(task) + 1, C: decor.DidentRight}),
54		decor.OnComplete(decor.Name(job, decor.WCSyncSpaceR), "done!"),
55		decor.OnComplete(decor.EwmaETA(decor.ET_STYLE_MMSS, 60, decor.WCSyncWidth), "")),
56		mpb.AppendDecorators(
57		decor.OnComplete(decor.Percentage(decor.WC{W: 5}), ""),
58		),
59		)
60		// waiting for download to complete, before starting install job
61		downloadWgg[i].Wait()
62		go newTask(doneWg, b, numBars-i)
63		}()
64		}
65
66		p.Wait()
67		}
68
69		func newTask(wg sync.WaitGroup, b mpb.Bar, incrBy int) {
70		defer wg.Done()
71		max := 100 * time.Millisecond
72		for !b.Completed() {
73		start := time.Now()
74		time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
75		// ewma based decorators require work duration measurement
76		b.IncrBy(incrBy, time.Since(start))
77		}
78		}

+0

-60

~~examples/differentWidth/main.go~~ less more

0		package main
1
2		import (
3		"fmt"
4		"math/rand"
5		"sync"
6		"time"
7
8		"github.com/vbauerster/mpb"
9		"github.com/vbauerster/mpb/decor"
10		)
11
12		func init() {
13		rand.Seed(time.Now().UnixNano())
14		}
15
16		func main() {
17		var wg sync.WaitGroup
18		p := mpb.New(
19		mpb.WithWaitGroup(&wg),
20		// container's width.
21		mpb.WithWidth(60),
22		)
23		total, numBars := 100, 3
24		wg.Add(numBars)
25
26		for i := 0; i < numBars; i++ {
27		name := fmt.Sprintf("Bar#%d:", i)
28		bar := p.AddBar(int64(total),
29		// set BarWidth 40 for bar 1 and 2
30		mpb.OptionOnCondition(mpb.BarWidth(40), func() bool { return i > 0 }),
31		mpb.PrependDecorators(
32		// simple name decorator
33		decor.Name(name),
34		// decor.DSyncWidth bit enables column width synchronization
35		decor.Percentage(decor.WCSyncSpace),
36		),
37		mpb.AppendDecorators(
38		// replace ETA decorator with "done" message, OnComplete event
39		decor.OnComplete(
40		// ETA decorator with ewma age of 60
41		decor.EwmaETA(decor.ET_STYLE_GO, 60), "done",
42		),
43		),
44		)
45		// simulating some work
46		go func() {
47		defer wg.Done()
48		max := 100 * time.Millisecond
49		for i := 0; i < total; i++ {
50		start := time.Now()
51		time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
52		// ewma based decorators require work duration measurement
53		bar.IncrBy(1, time.Since(start))
54		}
55		}()
56		}
57		// wait for all bars to complete and flush
58		p.Wait()
59		}

+0

-52

~~examples/dynTotal/main.go~~ less more

0		package main
1
2		import (
3		"io"
4		"math/rand"
5		"time"
6
7		"github.com/vbauerster/mpb"
8		"github.com/vbauerster/mpb/decor"
9		)
10
11		func init() {
12		rand.Seed(time.Now().UnixNano())
13		}
14
15		func main() {
16		p := mpb.New(mpb.WithWidth(64))
17
18		var total int64
19		bar := p.AddBar(total,
20		mpb.PrependDecorators(decor.Counters(decor.UnitKiB, "% .1f / % .1f")),
21		mpb.AppendDecorators(decor.Percentage()),
22		)
23
24		maxSleep := 100 * time.Millisecond
25		read := makeStream(200)
26		for {
27		n, err := read()
28		total += int64(n)
29		time.Sleep(time.Duration(rand.Intn(10)+1) * maxSleep / 10)
30		bar.IncrBy(n)
31		if err == io.EOF {
32		// total is known, final=true
33		bar.SetTotal(total, true)
34		break
35		}
36		// total is unknown, final=false
37		bar.SetTotal(total+2048, false)
38		}
39
40		p.Wait()
41		}
42
43		func makeStream(limit int) func() (int, error) {
44		return func() (int, error) {
45		if limit <= 0 {
46		return 0, io.EOF
47		}
48		limit--
49		return rand.Intn(1024) + 1, nil
50		}
51		}

+0

-1

~~examples/gifs/godEMrCZmJkHYH1X9dN4Nm0U7.svg~~ less more

0

+0

-1

~~examples/gifs/hIpTa3A5rQz65ssiVuRJu87X6.svg~~ less more

0

+0

-1

~~examples/gifs/wHzf1M7sd7B3zVa2scBMnjqRf.svg~~ less more

0

+0

-83

~~examples/io/multiple/main.go~~ less more

0		package main
1
2		import (
3		"fmt"
4		"io"
5		"log"
6		"net/http"
7		"os"
8		"path/filepath"
9		"sync"
10
11		"github.com/vbauerster/mpb"
12		"github.com/vbauerster/mpb/decor"
13		)
14
15		func main() {
16		log.SetOutput(os.Stderr)
17
18		url1 := "https://homebrew.bintray.com/bottles/youtube-dl-2016.12.12.sierra.bottle.tar.gz"
19		url2 := "https://homebrew.bintray.com/bottles/libtiff-4.0.7.sierra.bottle.tar.gz"
20
21		var wg sync.WaitGroup
22		p := mpb.New(mpb.WithWidth(64), mpb.WithWaitGroup(&wg))
23
24		for i, url := range [...]string{url1, url2} {
25		wg.Add(1)
26		name := fmt.Sprintf("url%d:", i+1)
27		go download(&wg, p, name, url, i)
28		}
29
30		p.Wait()
31		}
32
33		func download(wg sync.WaitGroup, p mpb.Progress, name, url string, n int) {
34		defer wg.Done()
35		resp, err := http.Get(url)
36		if err != nil {
37		log.Printf("%s: %v", name, err)
38		return
39		}
40		defer resp.Body.Close()
41
42		if resp.StatusCode != http.StatusOK {
43		err = fmt.Errorf("non-200 status: %s", resp.Status)
44		log.Printf("%s: %v", name, err)
45		return
46		}
47
48		size := resp.ContentLength
49
50		// create dest
51		destName := filepath.Base(url)
52		dest, err := os.Create(destName)
53		if err != nil {
54		err = fmt.Errorf("Can't create %s: %v", destName, err)
55		log.Printf("%s: %v", name, err)
56		return
57		}
58
59		// create bar with appropriate decorators
60		bar := p.AddBar(size, mpb.BarPriority(n),
61		mpb.PrependDecorators(
62		decor.Name(name, decor.WC{W: len(name) + 1, C: decor.DidentRight}),
63		decor.CountersKibiByte("%6.1f / %6.1f", decor.WCSyncWidth),
64		),
65		mpb.AppendDecorators(
66		decor.EwmaETA(decor.ET_STYLE_HHMMSS, 1024*4, decor.WCSyncWidth),
67		decor.AverageSpeed(decor.UnitKiB, "% .2f"),
68		),
69		)
70
71		// create proxy reader
72		reader := bar.ProxyReader(resp.Body)
73		// and copy from reader
74		_, err = io.Copy(dest, reader)
75
76		if e := dest.Close(); err == nil {
77		err = e
78		}
79		if err != nil {
80		log.Printf("%s: %v", name, err)
81		}
82		}

+0

-63

~~examples/io/single/main.go~~ less more

0		package main
1
2		import (
3		"fmt"
4		"io"
5		"net/http"
6		"os"
7		"path/filepath"
8		"time"
9
10		"github.com/vbauerster/mpb"
11		"github.com/vbauerster/mpb/decor"
12		)
13
14		func main() {
15		url := "https://github.com/onivim/oni/releases/download/v0.3.4/Oni-0.3.4-amd64-linux.deb"
16
17		resp, err := http.Get(url)
18		if err != nil {
19		panic(err)
20		}
21		defer resp.Body.Close()
22
23		if resp.StatusCode != http.StatusOK {
24		fmt.Printf("Server return non-200 status: %s\n", resp.Status)
25		return
26		}
27
28		size := resp.ContentLength
29
30		// create dest
31		destName := filepath.Base(url)
32		dest, err := os.Create(destName)
33		if err != nil {
34		fmt.Printf("Can't create %s: %v\n", destName, err)
35		return
36		}
37		defer dest.Close()
38
39		p := mpb.New(
40		mpb.WithWidth(60),
41		mpb.WithRefreshRate(180*time.Millisecond),
42		)
43
44		bar := p.AddBar(size, mpb.BarStyle("[=>-\|"),
45		mpb.PrependDecorators(
46		decor.CountersKibiByte("% 6.1f / % 6.1f"),
47		),
48		mpb.AppendDecorators(
49		decor.EwmaETA(decor.ET_STYLE_MMSS, float64(size)/2048),
50		decor.Name(" ] "),
51		decor.AverageSpeed(decor.UnitKiB, "% .2f"),
52		),
53		)
54
55		// create proxy reader
56		reader := bar.ProxyReader(resp.Body)
57
58		// and copy from reader, ignoring errors
59		io.Copy(dest, reader)
60
61		p.Wait()
62		}

+0

-57

~~examples/panic/main.go~~ less more

0		package main
1
2		import (
3		"fmt"
4		"os"
5		"sync"
6		"time"
7
8		"github.com/vbauerster/mpb"
9		"github.com/vbauerster/mpb/decor"
10		)
11
12		func main() {
13		var wg sync.WaitGroup
14		p := mpb.New(mpb.WithWaitGroup(&wg), mpb.WithDebugOutput(os.Stderr))
15
16		wantPanic := "Some really long panic panic panic panic panic panic panic, really it is very long"
17		numBars := 3
18		wg.Add(numBars)
19
20		for i := 0; i < numBars; i++ {
21		name := fmt.Sprintf("b#%02d:", i)
22		bar := p.AddBar(100, mpb.BarID(i), mpb.PrependDecorators(panicDecorator(name, wantPanic)))
23
24		go func() {
25		defer wg.Done()
26		for i := 0; i < 100; i++ {
27		time.Sleep(50 * time.Millisecond)
28		bar.Increment()
29		}
30		}()
31		}
32
33		p.Wait()
34		}
35
36		func panicDecorator(name, panicMsg string) decor.Decorator {
37		d := &decorator{
38		msg: name,
39		panicMsg: panicMsg,
40		}
41		d.Init()
42		return d
43		}
44
45		type decorator struct {
46		decor.WC
47		msg string
48		panicMsg string
49		}
50
51		func (d decorator) Decor(st decor.Statistics) string {
52		if st.ID == 1 && st.Current >= 42 {
53		panic(d.panicMsg)
54		}
55		return d.FormatMsg(d.msg)
56		}

+0

-51

~~examples/remove/main.go~~ less more

0		package main
1
2		import (
3		"fmt"
4		"math/rand"
5		"sync"
6		"time"
7
8		"github.com/vbauerster/mpb"
9		"github.com/vbauerster/mpb/decor"
10		)
11
12		func init() {
13		rand.Seed(time.Now().UnixNano())
14		}
15
16		func main() {
17		var wg sync.WaitGroup
18		p := mpb.New(mpb.WithWaitGroup(&wg))
19		total := 100
20		numBars := 3
21		wg.Add(numBars)
22
23		for i := 0; i < numBars; i++ {
24		name := fmt.Sprintf("Bar#%d:", i)
25		b := p.AddBar(int64(total), mpb.BarID(i),
26		mpb.OptionOnCondition(mpb.BarRemoveOnComplete(), func() bool { return i == 0 }),
27		mpb.PrependDecorators(
28		decor.Name(name),
29		decor.EwmaETA(decor.ET_STYLE_GO, 60, decor.WCSyncSpace),
30		),
31		mpb.AppendDecorators(decor.Percentage()),
32		)
33		go func() {
34		defer wg.Done()
35		max := 100 * time.Millisecond
36		for i := 0; i < total; i++ {
37		start := time.Now()
38		if b.ID() == 2 && i == 42 {
39		p.Abort(b, true)
40		return
41		}
42		time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
43		// ewma based decorators require work duration measurement
44		b.IncrBy(1, time.Since(start))
45		}
46		}()
47		}
48
49		p.Wait()
50		}

+0

-54

~~examples/simple/main.go~~ less more

0		package main
1
2		import (
3		"fmt"
4		"math/rand"
5		"sync"
6		"time"
7
8		"github.com/vbauerster/mpb"
9		"github.com/vbauerster/mpb/decor"
10		)
11
12		func init() {
13		rand.Seed(time.Now().UnixNano())
14		}
15
16		func main() {
17		var wg sync.WaitGroup
18		p := mpb.New(mpb.WithWaitGroup(&wg))
19		total, numBars := 100, 3
20		wg.Add(numBars)
21
22		for i := 0; i < numBars; i++ {
23		name := fmt.Sprintf("Bar#%d:", i)
24		bar := p.AddBar(int64(total),
25		mpb.PrependDecorators(
26		// simple name decorator
27		decor.Name(name),
28		// decor.DSyncWidth bit enables column width synchronization
29		decor.Percentage(decor.WCSyncSpace),
30		),
31		mpb.AppendDecorators(
32		// replace ETA decorator with "done" message, OnComplete event
33		decor.OnComplete(
34		// ETA decorator with ewma age of 60
35		decor.EwmaETA(decor.ET_STYLE_GO, 60), "done",
36		),
37		),
38		)
39		// simulating some work
40		go func() {
41		defer wg.Done()
42		max := 100 * time.Millisecond
43		for i := 0; i < total; i++ {
44		start := time.Now()
45		time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
46		// ewma based decorators require work duration measurement
47		bar.IncrBy(1, time.Since(start))
48		}
49		}()
50		}
51		// wait for all bars to complete and flush
52		p.Wait()
53		}

+0

-46

~~examples/singleBar/main.go~~ less more

0		package main
1
2		import (
3		"math/rand"
4		"time"
5
6		"github.com/vbauerster/mpb"
7		"github.com/vbauerster/mpb/decor"
8		)
9
10		func main() {
11		p := mpb.New(
12		// override default (80) width
13		mpb.WithWidth(64),
14		// override default 120ms refresh rate
15		mpb.WithRefreshRate(180*time.Millisecond),
16		)
17
18		total := 100
19		name := "Single Bar:"
20		// adding a single bar
21		bar := p.AddBar(int64(total),
22		// override default "[=>-]" style
23		mpb.BarStyle("╢▌▌░╟"),
24		mpb.PrependDecorators(
25		// display our name with one space on the right
26		decor.Name(name, decor.WC{W: len(name) + 1, C: decor.DidentRight}),
27		// replace ETA decorator with "done" message, OnComplete event
28		decor.OnComplete(
29		// ETA decorator with ewma age of 60, and width reservation of 4
30		decor.EwmaETA(decor.ET_STYLE_GO, 60, decor.WC{W: 4}), "done",
31		),
32		),
33		mpb.AppendDecorators(decor.Percentage()),
34		)
35		// simulating some work
36		max := 100 * time.Millisecond
37		for i := 0; i < total; i++ {
38		start := time.Now()
39		time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
40		// ewma based decorators require work duration measurement
41		bar.IncrBy(1, time.Since(start))
42		}
43		// wait for our bar to complete and flush
44		p.Wait()
45		}

+0

-55

~~examples/sort/main.go~~ less more

0		package main
1
2		import (
3		"fmt"
4		"math/rand"
5		"sync"
6		"time"
7
8		"github.com/vbauerster/mpb"
9		"github.com/vbauerster/mpb/decor"
10		)
11
12		func init() {
13		rand.Seed(time.Now().UnixNano())
14		}
15
16		func main() {
17		var wg sync.WaitGroup
18		p := mpb.New(mpb.WithWaitGroup(&wg))
19		total := 100
20		numBars := 3
21		wg.Add(numBars)
22
23		for i := 0; i < numBars; i++ {
24		var name string
25		if i != 1 {
26		name = fmt.Sprintf("Bar#%d:", i)
27		}
28		b := p.AddBar(int64(total),
29		mpb.PrependDecorators(
30		decor.Name(name, decor.WCSyncWidth),
31		decor.CountersNoUnit("%d / %d", decor.WCSyncSpace),
32		),
33		mpb.AppendDecorators(
34		decor.EwmaETA(decor.ET_STYLE_GO, 60, decor.WC{W: 3}),
35		),
36		)
37		go func() {
38		defer wg.Done()
39		max := 100 * time.Millisecond
40		for i := 0; i < total; i++ {
41		start := time.Now()
42		time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
43		if i&1 == 1 {
44		priority := total - int(b.Current())
45		p.UpdateBarPriority(b, priority)
46		}
47		// ewma based decorators require work duration measurement
48		b.IncrBy(1, time.Since(start))
49		}
50		}()
51		}
52
53		p.Wait()
54		}

+0

-77

~~examples/spinner/main.go~~ less more

0		package main
1
2		import (
3		"fmt"
4		"math/rand"
5		"sync"
6		"time"
7
8		"github.com/vbauerster/mpb"
9		"github.com/vbauerster/mpb/decor"
10		)
11
12		func init() {
13		rand.Seed(time.Now().UnixNano())
14		}
15
16		func main() {
17		var wg sync.WaitGroup
18		p := mpb.New(
19		mpb.WithWaitGroup(&wg),
20		mpb.WithWidth(13),
21		)
22		total, numBars := 101, 3
23		wg.Add(numBars)
24
25		for i := 0; i < numBars; i++ {
26		name := fmt.Sprintf("Bar#%d:", i)
27		var bar *mpb.Bar
28		if i == 0 {
29		bar = p.AddBar(int64(total),
30		// override default "[=>-]" style
31		mpb.BarStyle("╢▌▌░╟"),
32		mpb.PrependDecorators(
33		// simple name decorator
34		decor.Name(name),
35		),
36		mpb.AppendDecorators(
37		// replace ETA decorator with "done" message, OnComplete event
38		decor.OnComplete(
39		// ETA decorator with ewma age of 60
40		decor.EwmaETA(decor.ET_STYLE_GO, 60), "done",
41		),
42		),
43		)
44		} else {
45		bar = p.AddSpinner(int64(total), mpb.SpinnerOnMiddle,
46		// override default {"⠋", "⠙", "⠹", "⠸", "⠼", "⠴", "⠦", "⠧", "⠇", "⠏"} style
47		mpb.SpinnerStyle([]string{"∙∙∙", "●∙∙", "∙●∙", "∙∙●", "∙∙∙"}),
48		mpb.PrependDecorators(
49		// simple name decorator
50		decor.Name(name),
51		),
52		mpb.AppendDecorators(
53		// replace ETA decorator with "done" message, OnComplete event
54		decor.OnComplete(
55		// ETA decorator with ewma age of 60
56		decor.EwmaETA(decor.ET_STYLE_GO, 60), "done",
57		),
58		),
59		)
60		}
61
62		// simulating some work
63		go func() {
64		defer wg.Done()
65		max := 100 * time.Millisecond
66		for i := 0; i < total; i++ {
67		start := time.Now()
68		time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
69		// ewma based decorators require work duration measurement
70		bar.IncrBy(1, time.Since(start))
71		}
72		}()
73		}
74		// wait for all bars to complete and flush
75		p.Wait()
76		}

+0

-55

~~examples/stress/main.go~~ less more

0		package main
1
2		import (
3		"fmt"
4		"math/rand"
5		"sync"
6		"time"
7
8		"github.com/vbauerster/mpb"
9		"github.com/vbauerster/mpb/decor"
10		)
11
12		const (
13		totalBars = 32
14		)
15
16		func init() {
17		rand.Seed(time.Now().UnixNano())
18		}
19
20		func main() {
21		var wg sync.WaitGroup
22		p := mpb.New(
23		mpb.WithWaitGroup(&wg),
24		mpb.WithRefreshRate(50*time.Millisecond),
25		)
26		wg.Add(totalBars)
27
28		for i := 0; i < totalBars; i++ {
29		name := fmt.Sprintf("Bar#%02d: ", i)
30		total := rand.Intn(320) + 10
31		bar := p.AddBar(int64(total),
32		mpb.PrependDecorators(
33		decor.Name(name),
34		decor.EwmaETA(decor.ET_STYLE_GO, 60, decor.WCSyncSpace),
35		),
36		mpb.AppendDecorators(
37		decor.Percentage(decor.WC{W: 5}),
38		),
39		)
40
41		go func() {
42		defer wg.Done()
43		max := 100 * time.Millisecond
44		for !bar.Completed() {
45		start := time.Now()
46		time.Sleep(time.Duration(rand.Intn(10)+1) * max / 10)
47		// ewma based decorators require work duration measurement
48		bar.IncrBy(1, time.Since(start))
49		}
50		}()
51		}
52
53		p.Wait()
54		}

+9

-0

go.mod less more

	0	module github.com/vbauerster/mpb/v4
	1
	2	require (
	3	github.com/VividCortex/ewma v1.1.1
	4	github.com/mattn/go-isatty v0.0.4
	5	github.com/vbauerster/mpb v3.3.4+incompatible
	6	golang.org/x/crypto v0.0.0-20190129170551-bf88e3f4ba72
	7	golang.org/x/sys v0.0.0-20190129075346-302c3dd5f1cc // indirect
	8	)

+10

-0

go.sum less more

	0	github.com/VividCortex/ewma v1.1.1 h1:MnEK4VOv6n0RSY4vtRe3h11qjxL3+t0B8yOL8iMXdcM=
	1	github.com/VividCortex/ewma v1.1.1/go.mod h1:2Tkkvm3sRDVXaiyucHiACn4cqf7DpdyLvmxzcbUokwA=
	2	github.com/mattn/go-isatty v0.0.4 h1:bnP0vzxcAdeI1zdubAl5PjU6zsERjGZb7raWodagDYs=
	3	github.com/mattn/go-isatty v0.0.4/go.mod h1:M+lRXTBqGeGNdLjl/ufCoiOlB5xdOkqRJdNxMWT7Zi4=
	4	github.com/vbauerster/mpb v3.3.4+incompatible h1:DDIhnwmgTQIDZo+SWlEr5d6mJBxkOLBwCXPzunhEfJ4=
	5	github.com/vbauerster/mpb v3.3.4+incompatible/go.mod h1:zAHG26FUhVKETRu+MWqYXcI70POlC6N8up9p1dID7SU=
	6	golang.org/x/crypto v0.0.0-20190129170551-bf88e3f4ba72 h1:hOSpsWG5LMauyHIJqtLUU+44acN/ft/9cpzc1ynVDyg=
	7	golang.org/x/crypto v0.0.0-20190129170551-bf88e3f4ba72/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
	8	golang.org/x/sys v0.0.0-20190129075346-302c3dd5f1cc h1:WiYx1rIFmx8c0mXAFtv5D/mHyKe1+jmuP7PViuwqwuQ=
	9	golang.org/x/sys v0.0.0-20190129075346-302c3dd5f1cc/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=

+0

-12

~~go.test.sh~~ less more

0		#!/usr/bin/env bash
1
2		set -e
3		echo "" > coverage.txt
4
5		for d in $(go list ./... \| grep -v vendor); do
6		go test -race -coverprofile=profile.out -covermode=atomic $d
7		if [ -f profile.out ]; then
8		cat profile.out >> coverage.txt
9		rm profile.out
10		fi
11		done