udscsi

type Config struct {
	// NodeID is reported by NodeGetInfo: the node's name.
	NodeID string
	// KubeletRoot is the kubelet's --root-dir. Every target_path must lie under
	// <KubeletRoot>/pods/<pod-uid>/.
	KubeletRoot string
	// Root is the host directory holding the per-pod tmpfs mounts.
	Root string
	// SizeBytes caps each per-pod tmpfs.
	SizeBytes int64
	// Inodes caps the number of inodes (files, directories, sockets — the
	// root directory included) on each per-pod tmpfs: its nr_inodes. At least
	// MinInodes.
	Inodes int64
	// Version is reported by GetPluginInfo.
	Version string
}

type Driver struct {
	csi.UnimplementedIdentityServer
	csi.UnimplementedNodeServer
	// contains filtered or unexported fields
}

type Mounter interface {
	// MountedFS reports whether path is itself a mount point and, if so, the
	// filesystem type of the topmost mount there.
	MountedFS(path string) (fstype string, mounted bool, err error)
	// MkdirAll is os.MkdirAll.
	MkdirAll(path string, perm os.FileMode) error
	// Mount is mount(2). The returned error wraps the errno.
	Mount(source, target, fstype string, flags uintptr, data string) error
	// Unmount is umount2(2).
	Unmount(target string, flags int) error
	// Remove is os.Remove; a missing path is NOT an error.
	Remove(path string) error
}

type RegistrationServer struct {
	pluginregistrationv1.UnimplementedRegistrationServer

	// Endpoint is the CSI socket path AS THE KUBELET SEES IT.
	Endpoint string
	Log      *slog.Logger
	// OnFailure is called when the kubelet reports that registration failed.
	// A plugin the kubelet refused serves nothing, so the caller exits
	// non-zero and lets the kubelet's restart backoff try again (with the
	// reason in the pod's last termination state) rather than sit Running
	// with the driver absent from the node's CSINode.
	OnFailure func(error)
}

type ServeConfig struct {
	CSISocket          string
	RegistrationSocket string
	// ShutdownGrace bounds the graceful gRPC stop; zero means 5s.
	ShutdownGrace time.Duration
}