主流程:

完成buildkit配置文件构建并启动，Earthly config文件的构建，环境变量的读取，根据传入的target参数解析执行earthfile为buildkit接收的llb state，由buildkit完成最终的执行。

主流程核心代码:

Earthly是通过命令行APP的方式来运行的，cmd/earthly/main.go是程序的入口，Earthly使用https://github.com/urfave/cli来构建命令行APP。

func (app *earthlyApp) actionBuildImp(c *cli.Context, flagArgs, nonFlagArgs []string) error {
    // 解析命令行传入的target（local or github）
    target, err = domain.ParseTarget(targetName)
    // 构建并启动buildkitd服务
    bkClient, err := buildkitd.NewClient(c.Context, app.console, app.buildkitdImage, app.containerName, app.buildkitdSettings)
    // 根据用户输入参数构建核心的Builder结构
    b, err := builder.NewBuilder(c.Context, builderOpts)
    // 执行target的构建
    _, err = b.BuildTarget(c.Context, target, buildOpts)
}

// 根据传入的target执行构建
func (b *Builder) BuildTarget(ctx context.Context, target domain.Target, opt BuildOpt) (*states.MultiTarget, error) {
    mts, err := b.convertAndBuild(ctx, target, opt)
    if err != nil {
        return nil, err
    }
    return mts, nil
}

func (b *Builder) convertAndBuild(ctx context.Context, target domain.Target, opt BuildOpt) (*states.MultiTarget, error) {
    bf := func(childCtx context.Context, gwClient gwclient.Client) (*gwclient.Result, error) {
        // 通过buildkit将传入的earthfile数据结构转化为buildkit能够使用的LLB states
        mts, err = earthfile2llb.Earthfile2LLB(....)
    }
    err := b.s.buildMainMulti(ctx, bf, onImage, onArtifact, onFinalArtifact, onPull, "main")
}

// 通过buildkit api，用Build call back的方式，将上边的bf方法（eathfile转成LLB）、solveOpt（定义输出格式）作为参数，执行真正的build过程。
func (s *solver) buildMainMulti(...) {
    _, err = s.bkClient.Build(ctx, *solveOpt, "", bf, ch)
}

// 将arthfile文件通过[antlr](https://github.com/antlr/antlr4/tree/master/runtime/Go/antlr)解析成spec.Earthfile结构，方便进一步解析成buildkit的LLB 
func (r *Resolver) parseEarthfile(ctx context.Context, path string) (spec.Earthfile, error) {
    ast.Parse(ctx, k.(string), true)
}

// Earthfile struct是Earthfile文件的AST语法树表示
type Earthfile struct {
    Version        *Version        `json:"version,omitempty"`
    BaseRecipe     Block           `json:"baseRecipe"`
    Targets        []Target        `json:"targets,omitempty"`
    UserCommands   []UserCommand   `json:"userCommands,omitempty"`
    SourceLocation *SourceLocation `json:"sourceLocation,omitempty"`
}

// Statement对应Command
type Statement struct {
    Command        *Command        `json:"command,omitempty"`
    With           *WithStatement  `json:"with,omitempty"`
    If             *IfStatement    `json:"if,omitempty"`
    For            *ForStatement   `json:"for,omitempty"`
    SourceLocation *SourceLocation `json:"sourceLocation,omitempty"`
}

// 对应Earthfile文件一行行的命令，如COPY RUN等
type Command struct {
    Name           string          `json:"name"`
    Args           []string        `json:"args"`
    ExecMode       bool            `json:"execMode,omitempty"`
    SourceLocation *SourceLocation `json:"sourceLocation,omitempty"`
}

// earthfile2llb/interpreter.go Interpreter结合Converter完成核心的语法树解析功能，将spec.Command解析成对应的buildkit LLB
//
// 将earthfile命令解析成buildkit的llb.State（LLB）
func (i *Interpreter) handleCommand(ctx context.Context, cmd spec.Command) (err error) {
    switch cmd.Name {
    case "FROM":
        return i.handleFrom(ctx, cmd)
    case "RUN":
        return i.handleRun(ctx, cmd)
        ...
        ...
}

解析实例：

earthfile文件：

FROM golang:1.15-alpine3.13
WORKDIR /go-example
deps:
    COPY go.mod go.sum ./
    RUN go mod download

earthfile文件解析转化成Earthfile结构ast语法树，对应Json格式如下：

{
  "baseRecipe":  [
    {
      "command": {
        "args": [
          "golang:1.15-alpine3.13"
        ],
        "name": "FROM"
      }
    }
  ],
  "targets": [
    {
      "name": "deps",
      "recipe": [
        {
          "command": {
            "name": "COPY",
            "args": [
              "go.mod", "go.sum", "./"
            ]
          }
        },
        {
          "command": {
            "name": "RUN",
            "args": ["go", "mod", "download"]
          }
        }
}

Earthly日志输出

Earthly 通过buildkit的 ch := make(chan *client.SolveStatus) SolveStatus 管道，同步的读取buildkit的输出结果（logs）， 通过solverMonitor解析buildkit输出，并对输出进行加工，形成自己的日志输出信息。Earthly的日志输出相对buildkit原生日志更直观，更好理解。

func (sm *solverMonitor) monitorProgress(ctx context.Context, ch chan *client.SolveStatus, phaseText string, sideRun bool) (string, error) {
    for {
        select {
        case ss, ok := <-ch:
            if !ok {
                break Loop
            }
            err := sm.processStatus(ss)
            if err != nil {
                return "", err
            }
        case <-sm.noOutputTicker.C:
            err := sm.processNoOutputTick()
            if err != nil {
                return "", err
            }
        }
    }
}

type SolveStatus struct {
    Vertexes []*Vertex
    Statuses []*VertexStatus
    Logs     []*VertexLog
}