engine

type CacheKeyManifestError ¶

type CacheKeyManifestError struct {
	Reason     string
	DurationMs int64
}

func (e *CacheKeyManifestError) Error() string

type Engine ¶

type Engine struct {
	// contains filtered or unexported fields
}

func New(p project.Project, worktree string) (*Engine, error)

func (e *Engine) CacheKey(ctx context.Context, req Request) (*api.CacheKeyResult, error)

func (e *Engine) CacheKeyWithManifest(ctx context.Context, req Request) (*api.CacheKeyResult, *api.CacheKeyManifest, error)

func (e *Engine) Graph() *graph.Graph

func (e *Engine) Run(ctx context.Context, req Request) (*Outcome, error)

func (e *Engine) SubscribeEvents() <-chan api.Event

func (e *Engine) SubscribeEventsLossless() <-chan api.Event

func (e *Engine) Watch(ctx context.Context, req Request) error

type LifecycleController ¶

type LifecycleController struct {
	// contains filtered or unexported fields
}

LifecycleController serializes external stop and restart requests with the engine loop that owns the service handles. Calling handle.Stop from the daemon directly would make the engine interpret the expected exit as a crash and stop unrelated services.

func NewLifecycleController() *LifecycleController

func (c *LifecycleController) Restart(ctx context.Context, task string) (ServiceLifecycleResult, error)

func (c *LifecycleController) Stop(ctx context.Context, task string) (ServiceLifecycleResult, error)

type Outcome ¶

type Outcome struct {
	Result   api.RunResult
	Instance *api.Instance
}

type Request ¶

type Request struct {
	Target               string
	Worktree             string
	Mode                 api.RunMode
	MaxParallel          int
	CacheKeyManifestPath string
	LifecycleController  *LifecycleController
}

type ServiceIdentity ¶

type ServiceIdentity struct {
	PID        int    `json:"pid,omitempty"`
	Generation uint64 `json:"generation"`
}

ServiceIdentity identifies one concrete service process. Generation remains useful for non-process ServiceHandle implementations whose PID is zero, and prevents a late Wait result from an old handle from being attributed to its replacement.

type ServiceLifecycleResult ¶

type ServiceLifecycleResult struct {
	Task     string          `json:"task"`
	Action   string          `json:"action"`
	Previous ServiceIdentity `json:"previous"`
	Current  ServiceIdentity `json:"current"`
	Stopped  bool            `json:"stopped"`
	Ready    bool            `json:"ready"`
}

ServiceLifecycleResult describes the service process actually affected by a daemon lifecycle request.