observer

type CatalogEntry struct {
	Harness       registry.Harness `json:"harness"`
	SessionID     string           `json:"session_id,omitempty"`
	SessionPath   string           `json:"session_path,omitempty"`
	ResumeCommand []string         `json:"resume_command,omitempty"`
	CWD           string           `json:"cwd,omitempty"`
	ProjectRoot   string           `json:"project_root,omitempty"`
	ProcessPID    int              `json:"process_pid,omitempty"`
	Current       bool             `json:"current"`
}

type CatalogLister func(context.Context) ([]CatalogEntry, error)

type Health struct {
	PID                          int           `json:"pid"`
	StartIdentity                string        `json:"start_identity,omitempty"`
	Interval                     time.Duration `json:"interval"`
	GracePeriod                  time.Duration `json:"grace_period"`
	StartedAt                    time.Time     `json:"started_at"`
	LastAttemptAt                time.Time     `json:"last_attempt_at"`
	LastSuccessAt                time.Time     `json:"last_success_at"`
	LastEnumerationErrorCategory string        `json:"last_enumeration_error_category,omitempty"`
	LastEnumerationError         string        `json:"last_enumeration_error,omitempty"`
	Cycles                       int           `json:"cycles"`
	Observations                 int           `json:"observations"`
	Sessions                     int           `json:"sessions"`
	Degraded                     bool          `json:"degraded"`
}

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

type Options struct {
	Store                    registry.Store
	StorePath                string
	Interval                 time.Duration
	GracePeriod              time.Duration
	HealthPath               string
	ProcessList              ProcessLister
	PaneList                 PaneLister
	CatalogList              CatalogLister
	ScreenCapture            ScreenCapturer
	MultiplexerPaneList      muxctx.PaneLister
	MultiplexerScreenCapture muxctx.ScreenCapturer
	DetectionConfigDir       string
	Now                      func() time.Time
	ErrorWriter              io.Writer
	Quiet                    bool
}

type PaneLister func(context.Context) ([]tmuxctx.Pane, error)

type ProcessLister func(context.Context) ([]processinfo.Process, error)

type Result struct {
	ObservedAt   time.Time `json:"observed_at"`
	Observations int       `json:"observations"`
	Sessions     int       `json:"sessions"`
	Processes    int       `json:"processes"`
	Panes        int       `json:"panes"`
	Catalog      int       `json:"catalog"`
	Present      int       `json:"present"`
	Gone         int       `json:"gone"`
	Changed      int       `json:"changed"`
	Degraded     bool      `json:"degraded"`
	Error        string    `json:"error,omitempty"`
}

type ScreenCapturer func(context.Context, tmuxctx.Pane) (tmuxctx.ScreenSnapshot, error)