mirror of https://github.com/docker/buildx.git
108 lines
2.2 KiB
Go
108 lines
2.2 KiB
Go
package history
|
|
|
|
import (
|
|
"context"
|
|
"io"
|
|
"os"
|
|
|
|
"github.com/docker/buildx/util/cobrautil/completion"
|
|
"github.com/docker/buildx/util/progress"
|
|
"github.com/docker/cli/cli/command"
|
|
controlapi "github.com/moby/buildkit/api/services/control"
|
|
"github.com/moby/buildkit/client"
|
|
"github.com/moby/buildkit/util/progress/progressui"
|
|
"github.com/pkg/errors"
|
|
"github.com/spf13/cobra"
|
|
)
|
|
|
|
type logsOptions struct {
|
|
builder string
|
|
ref string
|
|
progress string
|
|
}
|
|
|
|
func runLogs(ctx context.Context, dockerCli command.Cli, opts logsOptions) error {
|
|
nodes, err := loadNodes(ctx, dockerCli, opts.builder)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
recs, err := queryRecords(ctx, opts.ref, nodes, nil)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if len(recs) == 0 {
|
|
if opts.ref == "" {
|
|
return errors.New("no records found")
|
|
}
|
|
return errors.Errorf("no record found for ref %q", opts.ref)
|
|
}
|
|
|
|
rec := &recs[0]
|
|
c, err := rec.node.Driver.Client(ctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
cl, err := c.ControlClient().Status(ctx, &controlapi.StatusRequest{
|
|
Ref: rec.Ref,
|
|
})
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
mode := progressui.DisplayMode(opts.progress)
|
|
if mode == progressui.AutoMode {
|
|
mode = progressui.PlainMode
|
|
}
|
|
printer, err := progress.NewPrinter(context.TODO(), os.Stderr, mode)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
loop0:
|
|
for {
|
|
select {
|
|
case <-ctx.Done():
|
|
cl.CloseSend()
|
|
return context.Cause(ctx)
|
|
default:
|
|
ev, err := cl.Recv()
|
|
if err != nil {
|
|
if errors.Is(err, io.EOF) {
|
|
break loop0
|
|
}
|
|
return err
|
|
}
|
|
printer.Write(client.NewSolveStatus(ev))
|
|
}
|
|
}
|
|
|
|
return printer.Wait()
|
|
}
|
|
|
|
func logsCmd(dockerCli command.Cli, rootOpts RootOptions) *cobra.Command {
|
|
var options logsOptions
|
|
|
|
cmd := &cobra.Command{
|
|
Use: "logs [OPTIONS] [REF]",
|
|
Short: "Print the logs of a build record",
|
|
Args: cobra.MaximumNArgs(1),
|
|
RunE: func(cmd *cobra.Command, args []string) error {
|
|
if len(args) > 0 {
|
|
options.ref = args[0]
|
|
}
|
|
options.builder = *rootOpts.Builder
|
|
return runLogs(cmd.Context(), dockerCli, options)
|
|
},
|
|
ValidArgsFunction: completion.Disable,
|
|
DisableFlagsInUseLine: true,
|
|
}
|
|
|
|
flags := cmd.Flags()
|
|
flags.StringVar(&options.progress, "progress", "plain", "Set type of progress output (plain, rawjson, tty)")
|
|
|
|
return cmd
|
|
}
|