Method Setup

pkgcache/cache_setup.go:134–193

()

}

func (n *NFSClientSetup) Setup() error {
	// Parse --nfs-client-dir
	mountPoint, serverExport, err := parseNFSClientDir(n.nfsClientDir)
	if err != nil {
		return err
	}

	//	Check if dir to mount NFS exist.
	mountPoint = filepath.Clean(mountPoint)
	if !fileio.PathExists(mountPoint) {
		return fmt.Errorf("directory to mount NFS is not exist: %s", mountPoint)
	}

	// Install NFS client packages.
	if err := checkClientTools(); err != nil {
		return err
	}

	// Unmount if already mounted.
	if err := n.unmountExisting(mountPoint); err != nil {
		return err
	}

	// Probe server reachability before mount(8). mount.nfs has built-in retries
	// (default ~2 minutes) that make the command look hung.
	if err := n.probeNFSServer(serverExport); err != nil {
		return err
	}

	// Mount NFS dir first to validate the server export and detect its numeric GID.
	if err := n.mountNFSDir(serverExport, mountPoint); err != nil {
		return err
	}

	// Read GID of mounted dir.
	mountedGID, err := mountedDirGID(mountPoint)
	if err != nil {
		return err
	}

	// Create celer group/user with the mounted export's numeric GID.
	// NFS sec=sys checks numeric IDs, not group names.
	if err := createSystemGroupAndUser(nfsUser, mountedGID); err != nil {
		return err
	}

	// Add the current user to the celer group.
	if err := addCurrentUserToGroup(nfsUser); err != nil {
		return err
	}

	// Manage fstab entry only after the mounted share is known to be usable.
	if err := n.updateFSTabEntry(serverExport, mountPoint); err != nil {
		return err
	}

	fmt.Println() // Just a blank line.
	color.PrintSuccess("NFS cache client setup complete: %q mounted from %q", mountPoint, serverExport)