Function daemonStatus

cmd/daemon.go:172–201

─── status / ping / install ──────────────────────────────────

(ctx context.Context, args []string)

// ─── status / ping / install ──────────────────────────────────

func daemonStatus(ctx context.Context, args []string) error {
	fs := flag.NewFlagSet("daemon status", flag.ContinueOnError)
	socket := fs.String("socket", "", "override socket path")
	if err := fs.Parse(args); err != nil {
		return err
	}
	cfg := scheduler.LoadConfigFromEnv()
	if *socket != "" {
		cfg.DaemonSocket = *socket
	}
	sock := scheduler.DefaultSocketPath(cfg)
	if err := scheduler.CheckDaemon(sock); err != nil {
		_, _ = fmt.Fprintln(os.Stdout, "chatcli daemon: not running")
		return nil
	}
	c, err := scheduler.Dial(sock)
	if err != nil {
		return err
	}
	defer func() { _ = c.Close() }()
	ctx, cancel := context.WithTimeout(ctx, 3*time.Second)
	defer cancel()
	stats, err := c.Stats(ctx)
	if err != nil {
		return err
	}
	_, _ = fmt.Fprintf(os.Stdout, "chatcli daemon\n  socket   : %s\n  uptime   : %s\n  jobs     : %d active, queue=%d\n  wal segs : %d\n  clients  : %d\n",
		sock, stats.Uptime, stats.JobsActive, stats.QueueDepth, stats.WALSegments, stats.Connections)
	return nil
}

func daemonPing(args []string) error {
	fs := flag.NewFlagSet("daemon ping", flag.ContinueOnError)