mirror of
https://github.com/holos-run/holos.git
synced 2026-03-20 09:15:02 +00:00
53fcdf307b
This patch implements the v1alpha4 component rendering builder for a component BuildPlan. We don't yet have the CUE definitions, so this hasn't been end to end tested yet, the next step is defining the generators and transforms in the core API BuildPlan.
75 lines
2.3 KiB
Go
75 lines
2.3 KiB
Go
package render
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"io"
|
|
"path/filepath"
|
|
"time"
|
|
|
|
core "github.com/holos-run/holos/api/core/v1alpha2"
|
|
"github.com/holos-run/holos/internal/errors"
|
|
"github.com/holos-run/holos/internal/server/middleware/logger"
|
|
"github.com/holos-run/holos/internal/util"
|
|
"golang.org/x/sync/errgroup"
|
|
)
|
|
|
|
// Deprecated: Use Platform instead.
|
|
func LegacyPlatform(ctx context.Context, concurrency int, pf *core.Platform, stderr io.Writer) error {
|
|
parentStart := time.Now()
|
|
total := len(pf.Spec.Components)
|
|
|
|
g, ctx := errgroup.WithContext(ctx)
|
|
// Limit the number of concurrent goroutines due to CUE memory usage concerns
|
|
// while rendering components. One more for the producer.
|
|
g.SetLimit(concurrency + 1)
|
|
|
|
// Spawn a producer because g.Go() blocks when the group limit is reached.
|
|
g.Go(func() error {
|
|
for idx, component := range pf.Spec.Components {
|
|
select {
|
|
case <-ctx.Done():
|
|
return ctx.Err()
|
|
default:
|
|
// Capture idx and component to avoid issues with closure. Can be removed on Go 1.22.
|
|
idx, component := idx, component
|
|
// Worker go routine. Blocks if limit has been reached.
|
|
g.Go(func() error {
|
|
select {
|
|
case <-ctx.Done():
|
|
return ctx.Err()
|
|
default:
|
|
start := time.Now()
|
|
log := logger.FromContext(ctx).With("path", component.Path, "cluster", component.Cluster, "num", idx+1, "total", total)
|
|
log.DebugContext(ctx, "render component")
|
|
|
|
// Execute a sub-process to limit CUE memory usage.
|
|
args := []string{"render", "component", "--cluster-name", component.Cluster, component.Path}
|
|
result, err := util.RunCmd(ctx, "holos", args...)
|
|
if err != nil {
|
|
_, _ = io.Copy(stderr, result.Stderr)
|
|
return errors.Wrap(fmt.Errorf("could not render component: %w", err))
|
|
}
|
|
|
|
duration := time.Since(start)
|
|
msg := fmt.Sprintf("rendered %s for cluster %s in %s", filepath.Base(component.Path), component.Cluster, duration)
|
|
log.InfoContext(ctx, msg, "duration", duration)
|
|
return nil
|
|
}
|
|
})
|
|
}
|
|
}
|
|
return nil
|
|
})
|
|
|
|
// Wait for completion and return the first error (if any)
|
|
if err := g.Wait(); err != nil {
|
|
return err
|
|
}
|
|
|
|
duration := time.Since(parentStart)
|
|
msg := fmt.Sprintf("rendered platform in %s", duration)
|
|
logger.FromContext(ctx).InfoContext(ctx, msg, "duration", duration)
|
|
return nil
|
|
}
|