demo

type Assets struct {
	Root, CLI, Dispatcher, Executor, Guest string
	Manifest                               Manifest
}

type BackupManifest struct {
	SchemaVersion int                      `json:"schema_version"`
	ObservedAt    time.Time                `json:"observed_at"`
	Layout        string                   `json:"layout"`
	Package       Manifest                 `json:"package"`
	Roles         []BackupRole             `json:"roles"`
	Files         map[string]artifact.File `json:"files"`
	Protection    string                   `json:"protection"`
	History       string                   `json:"history"`
}

type BackupOptions struct {
	StateDir, Destination string
	// Offline acknowledges that no unmanaged daemon is writing this directory.
	// A completed foreground shutdown receipt and its free lock are also required.
	Offline bool
	Package Manifest
}

type BackupRole struct {
	Role          storagecheck.Role `json:"role"`
	Identity      string            `json:"identity"`
	SchemaVersion int64             `json:"schema_version"`
}

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

type ChildProcess interface {
	PID() int
	Done() <-chan struct{}
	Wait(context.Context) error
	Stop(context.Context) error
	CleanupComplete() bool
}

type ChildSpec struct {
	Path, Dir      string
	Args, Env      []string
	Stdout, Stderr io.Writer
}

type LocalEnvironment struct {
	State      string `json:"state"`
	Endpoint   string `json:"endpoint"`
	ExecutorID string `json:"executor_id"`
	StateDir   string `json:"state_dir"`
}

type LocalOptions struct {
	StateDir string
	Port     int
	Ready    func(LocalEnvironment) error
	Logs     LogOptions
}

type LogOptions struct {
	MaxBytes int64
	Files    int
	MaxAge   time.Duration
}

type Manifest = artifact.Manifest

type ProcessCleanup struct {
	Joined      bool
	ForcedKills int
}

type RestoreOptions struct {
	BackupDir, StateDir string
	Package             Manifest
}

type Result struct {
	Version    string `json:"version"`
	ExecutorID string `json:"executor_id"`
	RunID      string `json:"run_id"`
	Response   string `json:"response"`
	State      string `json:"state"`
	Cleanup    string `json:"cleanup"`
}

type RoleEnvironment struct {
	State        string `json:"state"`
	Role         string `json:"role"`
	Name         string `json:"name"`
	Endpoint     string `json:"endpoint"`
	GRPCAddress  string `json:"grpc_address,omitempty"`
	YamuxAddress string `json:"yamux_address,omitempty"`
	ExecutorID   string `json:"executor_id,omitempty"`
	StateDir     string `json:"state_dir"`
}

type RoleOptions struct {
	Name, StateDir string
	Port, GRPCPort int
	Dispatcher     connections.Profile
	Ready          func(RoleEnvironment) error
	Logs           LogOptions
}

type RoleProcess struct {
	Role                                                     storagecheck.Role
	Directory, Executable, ConfigPath, ReadyPath, ExecutorID string
	Configuration                                            map[string]any
	Stdout, Stderr                                           io.Writer
}

type RoleState struct {
	SchemaVersion int               `json:"schema_version"`
	Version       string            `json:"version"`
	SourceSHA     string            `json:"source_sha"`
	Identity      string            `json:"identity"`
	Role          storagecheck.Role `json:"role"`
	// EarlierIdentity is the key earlier builds wrote the identity under. It
	// is read when the file carries no identity value and is never written.
	EarlierIdentity string `json:"executor_id,omitempty"`
}

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