Method Graph

provisioner/echo/serve.go:235–259

(sess *provisionersdk.Session, req *proto.GraphRequest, canceledOrComplete <-chan struct{})

}

func (*echo) Graph(sess *provisionersdk.Session, req *proto.GraphRequest, canceledOrComplete <-chan struct{}) *proto.GraphComplete {
	responses, err := readResponses(
		sess,
		strings.ToLower(req.GetMetadata().GetWorkspaceTransition().String()),
		"graph.protobuf")
	if err != nil {
		return &proto.GraphComplete{Error: err.Error()}
	}
	for _, response := range responses {
		if log := response.GetLog(); log != nil {
			sess.ProvisionLog(log.Level, log.Output)
		}
		if complete := response.GetGraph(); complete != nil {
			if len(complete.AiTasks) > 0 {
				// These two fields are linked; if there are AI tasks, indicate that.
				complete.HasAiTasks = true
			}
			return complete
		}
	}

	// some tests use Echo without a complete response to test cancel
	<-canceledOrComplete
	return provisionersdk.GraphError("canceled")
}

// Plan reads requests from the provided directory to stream responses.
func (*echo) Plan(sess *provisionersdk.Session, req *proto.PlanRequest, canceledOrComplete <-chan struct{}) *proto.PlanComplete {