You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
53 lines
1.0 KiB
Go
53 lines
1.0 KiB
Go
package progress
|
|
|
|
import (
|
|
"context"
|
|
"os"
|
|
|
|
"github.com/containerd/console"
|
|
"github.com/moby/buildkit/client"
|
|
"github.com/moby/buildkit/util/progress/progressui"
|
|
)
|
|
|
|
type printer struct {
|
|
status chan *client.SolveStatus
|
|
done <-chan struct{}
|
|
err error
|
|
}
|
|
|
|
func (p *printer) Done() <-chan struct{} {
|
|
return p.done
|
|
}
|
|
|
|
func (p *printer) Err() error {
|
|
return p.err
|
|
}
|
|
|
|
func (p *printer) Status() chan *client.SolveStatus {
|
|
if p == nil {
|
|
return nil
|
|
}
|
|
return p.status
|
|
}
|
|
|
|
func NewPrinter(ctx context.Context, out *os.File, mode string) Writer {
|
|
statusCh := make(chan *client.SolveStatus)
|
|
doneCh := make(chan struct{})
|
|
|
|
pw := &printer{
|
|
status: statusCh,
|
|
done: doneCh,
|
|
}
|
|
|
|
go func() {
|
|
var c console.Console
|
|
if cons, err := console.ConsoleFromFile(out); err == nil && (mode == "auto" || mode == "tty") {
|
|
c = cons
|
|
}
|
|
// not using shared context to not disrupt display but let is finish reporting errors
|
|
pw.err = progressui.DisplaySolveStatus(ctx, "", c, out, statusCh)
|
|
close(doneCh)
|
|
}()
|
|
return pw
|
|
}
|