Struct NodeService 

pub struct NodeService { /* private fields */ }

CSI NodeService implementation.

Implementations

impl NodeService

pub const DEFAULT_MAX_VOLUMES: usize = 128usize

Default maximum volumes per node.

pub fn new(node_id: String) -> Self

Create a new node service.

pub fn node_id(&self) -> &str

Get the node ID.

pub fn node_stage_volume( &mut self, volume_id: u64, staging_target: String, device_path: String, fs_type: String, mount_options: Vec<String>, ) -> Result<(), NodeError>

Stage a volume on this node (make the device available).

pub fn node_unstage_volume(&mut self, volume_id: u64) -> Result<(), NodeError>

Unstage a volume (unmount from staging).

pub fn node_publish_volume( &mut self, volume_id: u64, target_path: String, read_only: bool, ) -> Result<(), NodeError>

Publish a volume into a container path (bind mount from staging).

pub fn node_unpublish_volume( &mut self, volume_id: u64, target_path: String, ) -> Result<(), NodeError>

Unpublish a volume from a container path.

pub fn list_staged(&self) -> Vec<&StagedVolume>

List staged volumes.

pub fn list_published(&self) -> Vec<&PublishedVolume>

List published volumes.

pub fn get_staged(&self, volume_id: u64) -> Option<&StagedVolume>

Get staged volume info.

pub fn staged_count(&self) -> usize

Get the number of staged volumes.

pub fn published_count(&self) -> usize

Get the number of published volumes.

pub fn can_accept_volume(&self) -> bool

Check if this node can accept more volumes.

Trait Implementations

impl Debug for NodeService

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.