instance

Documentation

Index

• Variables
• func CacheRoot() string
• func ClearSupervisor(inst *api.Instance) error
• func ConsumeInteractionAnswer(worktree, instanceID, promptID string) (string, bool, error)
• func DaemonSocketPath(instanceID string) (string, error)
• func DisplayDB(db api.DBInstance) api.DBInstance
• func EventsPath(worktree, instanceID string) string
• func FlushAckPath(worktree, instanceID, requestID string) string
• func FlushRequestPath(worktree, instanceID, requestID string) string
• func FlushRoot(worktree, instanceID string) string
• func FlushSyncDir(worktree, instanceID string) string
• func FlushSyncPath(worktree, instanceID, requestID string) string
• func FlushWatchReadyPath(worktree, instanceID string) string
• func GitCommonDir(worktree string) (string, error)
• func GlobalStateRoot() (string, error)
• func IDForWorktree(worktree string) (string, string, error)
• func InteractionAnswerPath(worktree, instanceID, promptID string) string
• func List() ([]api.InstanceSummary, error)
• func Load(worktree, instanceID string) (*api.Instance, error)
• func LoadFlushAck(worktree, instanceID, requestID string) (api.FlushResult, error)
• func LoadFlushRequest(worktree, instanceID, requestID string) (api.FlushRequest, error)
• func LogPath(worktree, instanceID, task string) string
• func ProcessAlive(pid int) bool
• func RecordDaemon(inst *api.Instance, pid int, logPath string) error
• func RecordDetachedRun(inst *api.Instance, cfg api.RunConfig, supervisorPID int, logPath string) error
• func RecordSupervisorExec(worktree string, pid int) error
• func RemoveFlushRequest(worktree, instanceID, requestID string) error
• func RemoveTaskStamp(worktree, instanceID, task string) error
• func RemoveTaskStamps(worktree, instanceID string) error
• func RepoSharedStateRoot(worktree string) (string, error)
• func Resolve(worktree, label string) (*api.Instance, error)
• func Save(inst *api.Instance) error
• func SaveStatus(worktree, instanceID, target string, mode api.RunMode, ...) error
• func StopAll(inst *api.Instance, extra map[string]int) ([]string, error)
• func StopDaemonWork(inst *api.Instance, extra map[string]int, daemonPID int) ([]string, error)
• func StopProcesses(inst *api.Instance, task string) ([]string, error)
• func StopSupervisor(inst *api.Instance) error
• func TaskStampPath(worktree, instanceID, task string) string
• func WriteFlushAck(worktree, instanceID string, result api.FlushResult) error
• func WriteFlushRequest(worktree, instanceID string, req api.FlushRequest) error
• func WriteInteractionAnswer(worktree, instanceID, promptID, value string) error
• func WriteTaskStamp(worktree, instanceID, task, key string) error
• type State
  • func LoadStatus(worktree, instanceID string) (*State, error)
• type TaskStamp
  • func LoadTaskStamp(worktree, instanceID, task string) (TaskStamp, bool, error)

Variables

var ErrSupervisorNotRecorded = errors.New("detached supervisor is not recorded yet")

Functions

func CacheRoot

func CacheRoot() string

func ClearSupervisor

func ClearSupervisor(inst *api.Instance) error

func ConsumeInteractionAnswer

func ConsumeInteractionAnswer(worktree, instanceID, promptID string) (string, bool, error)

func DaemonSocketPath

func DaemonSocketPath(instanceID string) (string, error)

func DisplayDB

func DisplayDB(db api.DBInstance) api.DBInstance

func EventsPath

func EventsPath(worktree, instanceID string) string

func FlushAckPath

func FlushAckPath(worktree, instanceID, requestID string) string

func FlushRequestPath

func FlushRequestPath(worktree, instanceID, requestID string) string

func FlushRoot

func FlushRoot(worktree, instanceID string) string

func FlushSyncDir

func FlushSyncDir(worktree, instanceID string) string

func FlushSyncPath

func FlushSyncPath(worktree, instanceID, requestID string) string

func FlushWatchReadyPath

func FlushWatchReadyPath(worktree, instanceID string) string

func GitCommonDir

func GitCommonDir(worktree string) (string, error)

func GlobalStateRoot

func GlobalStateRoot() (string, error)

func IDForWorktree

func IDForWorktree(worktree string) (string, string, error)

func InteractionAnswerPath

func InteractionAnswerPath(worktree, instanceID, promptID string) string

func List

func List() ([]api.InstanceSummary, error)

func Load

func Load(worktree, instanceID string) (*api.Instance, error)

func LoadFlushAck

func LoadFlushAck(worktree, instanceID, requestID string) (api.FlushResult, error)

func LoadFlushRequest

func LoadFlushRequest(worktree, instanceID, requestID string) (api.FlushRequest, error)

func LogPath

func LogPath(worktree, instanceID, task string) string

func ProcessAlive

func ProcessAlive(pid int) bool

func RecordDaemon

func RecordDaemon(inst *api.Instance, pid int, logPath string) error

func RecordDetachedRun

func RecordDetachedRun(inst *api.Instance, cfg api.RunConfig, supervisorPID int, logPath string) error

func RecordSupervisorExec

func RecordSupervisorExec(worktree string, pid int) error

func RemoveFlushRequest

func RemoveFlushRequest(worktree, instanceID, requestID string) error

func RemoveTaskStamp

func RemoveTaskStamp(worktree, instanceID, task string) error

func RemoveTaskStamps

func RemoveTaskStamps(worktree, instanceID string) error

func RepoSharedStateRoot

func RepoSharedStateRoot(worktree string) (string, error)

func Resolve

func Resolve(worktree, label string) (*api.Instance, error)

func Save

func Save(inst *api.Instance) error

func SaveStatus

func SaveStatus(worktree, instanceID, target string, mode api.RunMode, nodes map[string]api.NodeStatus) error

func StopAll

func StopAll(inst *api.Instance, extra map[string]int) ([]string, error)

func StopDaemonWork

func StopDaemonWork(inst *api.Instance, extra map[string]int, daemonPID int) ([]string, error)

func StopProcesses

func StopProcesses(inst *api.Instance, task string) ([]string, error)

func StopSupervisor

func StopSupervisor(inst *api.Instance) error

func TaskStampPath

func TaskStampPath(worktree, instanceID, task string) string

func WriteFlushAck

func WriteFlushAck(worktree, instanceID string, result api.FlushResult) error

func WriteFlushRequest

func WriteFlushRequest(worktree, instanceID string, req api.FlushRequest) error

func WriteInteractionAnswer

func WriteInteractionAnswer(worktree, instanceID, promptID, value string) error

func WriteTaskStamp

func WriteTaskStamp(worktree, instanceID, task, key string) error

Types

type State

type State struct {
	Target    string                    `json:"target"`
	Mode      api.RunMode               `json:"mode"`
	Nodes     map[string]api.NodeStatus `json:"nodes"`
	UpdatedAt time.Time                 `json:"updatedAt"`
}

func LoadStatus

func LoadStatus(worktree, instanceID string) (*State, error)

type TaskStamp

type TaskStamp struct {
	Task      string    `json:"task"`
	Key       string    `json:"key"`
	UpdatedAt time.Time `json:"updatedAt"`
}

func LoadTaskStamp

func LoadTaskStamp(worktree, instanceID, task string) (TaskStamp, bool, error)