driver

package

Go to main page

Versions in this module

v0

v0.11.4

Feb 28, 2025

v0.11.3

Feb 28, 2025

v0.11.2

Feb 27, 2025

v0.11.1

Feb 17, 2025

v0.11.0

Feb 12, 2025

v0.10.14

Feb 3, 2025

v0.10.13

Jan 31, 2025

v0.10.12

Jan 30, 2025

v0.10.11

Jan 22, 2025

v0.10.10

Jan 21, 2025

v0.10.8

Jan 16, 2025

v0.10.7

Jan 16, 2025

v0.10.6

Jan 8, 2025

v0.10.5

Nov 1, 2024

v0.10.4

Aug 5, 2024

v0.10.3

Jul 16, 2024

v0.10.2

May 16, 2024

v0.10.1

Mar 27, 2024

v0.9.11

Oct 24, 2023

v0.9.10

Sep 26, 2023

v0.9.9

Sep 1, 2023

v0.9.8

Aug 28, 2023

v0.9.7

Jun 29, 2023

v0.9.6

Jun 23, 2023

v0.9.5

Jun 6, 2023

v0.9.4

Mar 9, 2023

v0.9.2

Jan 9, 2023

v0.9.0

Dec 14, 2022

Changes in this version

+ type ControllerConfig struct

+ NotCreateVolumeDir bool

+ RetainData bool

+ VolumePath string

+ VolumeRootPath string

v0.8.7

Sep 1, 2022

Changes in this version

type Config

+ PrometheusExporterPort int

v0.8.4

Aug 16, 2022

v0.8.3

Jul 29, 2022

v0.8.2

Jul 26, 2022

Changes in this version

type IRODSConnectionInfo

+ NoPermissionCheck bool

type IRODSFSConfig

+ NoPermissionCheck bool

v0.8.1

Jul 7, 2022

Changes in this version

+ func ParsePoolServiceEndpoint(endpoint string) (string, error)

type Config

+ PoolServiceEndpoint string

type IRODSConnectionInfo

+ PoolEndpoint string

+ Resource string

type IRODSFSConfig

+ PoolEndpoint string

+ Resource string

+ TempRootPath string

type IRODSFSPathMapping

+ IgnoreNotExistError bool

v0.7.0

Mar 29, 2022

v0.6.4

Mar 16, 2022

v0.6.3

Mar 9, 2022

v0.6.2

Mar 5, 2022

v0.6.1

Feb 26, 2022

v0.6.0

Feb 26, 2022

v0.5.1

Jan 27, 2022

Changes in this version

+ const ConnectionLifespanDefault

type IRODSFSConfig

+ ConnectionLifespan time.Duration

v0.4.11

Dec 2, 2021

v0.4.10

Nov 2, 2021

Changes in this version

type IRODSConnectionInfo

+ Profile bool

+ ProfilePort int

type IRODSFSConfig

+ Profile bool

+ ProfileServicePort int

type Mounter

+ UnmountForcefully func(target string) error

type NodeMounter

+ func (mounter *NodeMounter) UnmountForcefully(target string) error

v0.4.9

Oct 14, 2021

Changes in this version

+ type ControllerVolume struct

+ ConnectionInfo *IRODSConnectionInfo

+ ID string

+ Name string

+ Path string

+ RetainData bool

+ RootPath string

type Driver

+ func (driver *Driver) CheckControllerVolume(id string) bool

+ func (driver *Driver) CheckNodeVolume(id string) bool

+ func (driver *Driver) GetControllerVolume(id string) *ControllerVolume

+ func (driver *Driver) GetNodeVolume(id string) *NodeVolume

+ func (driver *Driver) PopControllerVolume(id string) *ControllerVolume

+ func (driver *Driver) PopNodeVolume(id string) *NodeVolume

+ func (driver *Driver) PutControllerVolume(volume *ControllerVolume)

+ func (driver *Driver) PutNodeVolume(volume *NodeVolume)

+ type NodeVolume struct

+ DynamicVolumeProvisioning bool

+ ID string

+ MountPath string

+ StageVolume bool

+ StagingMountPath string

v0.4.7

Oct 11, 2021

v0.4.6

Oct 6, 2021

v0.4.5

Oct 4, 2021

Changes in this version

+ const BufferSizeMaxDefault

type IRODSConnectionInfo

+ PoolHostname string

+ PoolPort int

type IRODSFSConfig

+ BufferSizeMax int64

+ PoolHost string

+ PoolPort int

v0.4.4

Sep 8, 2021

Changes in this version

type IRODSConnectionInfo

+ MountTimeout int

v0.4.3

Sep 1, 2021

v0.4.2

Aug 27, 2021

Changes in this version

type IRODSFSPathMapping

+ ReadOnly bool

v0.4.1

Aug 24, 2021

Changes in this version

+ const FileBufferSizeMaxDefault

+ const FileBufferStoragePathDefault

+ const MetadataCacheCleanupTimeDefault

+ const MetadataCacheTimeoutDefault

+ const ReadAheadMaxDefault

type IRODSConnectionInfo

+ GID int

+ SystemUser string

+ UID int

type IRODSFSConfig

+ FileBufferSizeMax int64

+ FileBufferStoragePath string

+ GID int

+ MetadataCacheCleanupTime time.Duration

+ MetadataCacheTimeout time.Duration

+ ReadAheadMax int

+ SystemUser string

+ UID int

v0.4.0

Aug 14, 2021

Changes in this version

type IRODSConnectionInfo

+ MonitorURL string

type IRODSFSConfig

+ MonitorURL string

v0.3.1

Apr 5, 2021

Changes in this version

type IRODSFSPathMapping

+ CreateDir bool

+ IgnoreNotExist bool

v0.3.0

Mar 17, 2021

Changes in this version

+ const CacheCleanupTimeDefault

+ const CacheTimeoutDefault

+ const ConnectionIdleTimeoutDefault

+ const ConnectionMaxDefault

+ const OperationTimeoutDefault

+ const PerFileBlockCacheMaxDefault

+ const PortDefault

+ func IRODSTestConnection(conn *IRODSConnectionInfo) error

+ type IRODSConnectionInfo struct

+ ClientUser string

+ Hostname string

+ Password string

+ PathMappings []IRODSFSPathMapping

+ Port int

+ User string

+ Zone string

+ func ExtractIRODSConnectionInfo(params map[string]string, secrets map[string]string) (*IRODSConnectionInfo, error)

+ func NewIRODSConnectionInfo(hostname string, port int, zone string, user string, password string, ...) *IRODSConnectionInfo

+ type IRODSFSConfig struct

+ AllowOther bool

+ CacheCleanupTime time.Duration

+ CacheTimeout time.Duration

+ ClientUser string

+ ConnectionIdleTimeout time.Duration

+ ConnectionMax int

+ Host string

+ LogPath string

+ OperationTimeout time.Duration

+ Password string

+ PathMappings []IRODSFSPathMapping

+ PerFileBlockCacheMax int

+ Port int

+ ProxyUser string

+ Zone string

+ func NewDefaultIRODSFSConfig() *IRODSFSConfig

+ type IRODSFSPathMapping struct

+ IRODSPath string

+ MappingPath string

+ ResourceType string

+ type IRODSNFSConnectionInfo struct

+ Hostname string

+ Path string

+ Port int

+ func ExtractIRODSNFSConnectionInfo(params map[string]string, secrets map[string]string) (*IRODSNFSConnectionInfo, error)

+ func NewIRODSNFSConnectionInfo(hostname string, port int, path string) *IRODSNFSConnectionInfo

type IRODSVolume

+ ConnectionInfo *IRODSConnectionInfo

+ type IRODSWebDAVConnectionInfo struct

+ Password string

+ URL string

+ User string

+ func ExtractIRODSWebDAVConnectionInfo(params map[string]string, secrets map[string]string) (*IRODSWebDAVConnectionInfo, error)

+ func NewIRODSWebDAVConnectionInfo(url string, user string, password string) *IRODSWebDAVConnectionInfo

v0.2.3

Dec 4, 2020

v0.2.2

Oct 28, 2020

Changes in this version

+ type ClientType string

+ func GetValidiRODSClientType(client string, defaultClient ClientType) ClientType

v0.2.1

Sep 14, 2020

v0.2.0

Sep 8, 2020

Changes in this version

+ var DefaultVolumeSize int64 = 100 * 1024 * 1024 * 1024

+ func CheckIRODSVolume(id string) bool

+ func ExtractIRODSClientType(params map[string]string, secrets map[string]string, defaultClient string) string

+ func IRODSLs(conn *IRODSConnection, path string) ([]string, error)

+ func IRODSMkdir(conn *IRODSConnection, path string) error

+ func IRODSRmdir(conn *IRODSConnection, path string) error

+ func IsValidIRODSClientType(client string) bool

+ func PutIRODSVolume(volume *IRODSVolume)

+ func ReadIRODSSecrets(secretPath string) (map[string]string, error)

type Config

+ SecretPath string

type Driver

+ func (driver *Driver) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

+ func (driver *Driver) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

+ func (driver *Driver) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

+ func (driver *Driver) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

+ func (driver *Driver) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

+ func (driver *Driver) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

+ func (driver *Driver) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

+ func (driver *Driver) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

+ func (driver *Driver) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

+ func (driver *Driver) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

+ func (driver *Driver) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

+ func (driver *Driver) Stop()

+ func (driver *Driver) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

+ type IRODSConnection struct

+ ClientUser string

+ Hostname string

+ Password string

+ Path string

+ Port int

+ User string

+ Zone string

+ func ExtractIRODSConnection(params map[string]string, secrets map[string]string) (*IRODSConnection, error)

+ func NewIRODSConnection(hostname string, port int, zone string, user string, password string, ...) *IRODSConnection

+ func (conn *IRODSConnection) GetHostArgs() []string

+ func (conn *IRODSConnection) GetLoginInfoArgs() []string

+ type IRODSNFSConnection struct

+ Hostname string

+ Path string

+ Port int

+ func ExtractIRODSNFSConnection(params map[string]string, secrets map[string]string) (*IRODSNFSConnection, error)

+ func NewIRODSNFSConnection(hostname string, port int, path string) *IRODSNFSConnection

+ type IRODSVolume struct

+ Connection *IRODSConnection

+ ID string

+ Name string

+ Path string

+ RetainData bool

+ RootPath string

+ func GetIRODSVolume(id string) *IRODSVolume

+ func NewIRODSVolume(id string, name string, rootPath string, path string, conn *IRODSConnection, ...) *IRODSVolume

+ func PopIRODSVolume(id string) *IRODSVolume

+ type IRODSWebDAVConnection struct

+ Password string

+ URL string

+ User string

+ func ExtractIRODSWebDAVConnection(params map[string]string, secrets map[string]string) (*IRODSWebDAVConnection, error)

+ func NewIRODSWebDAVConnection(url string, user string, password string) *IRODSWebDAVConnection

v0.1.1

Aug 11, 2020

v0.1.0

Jul 27, 2020

Changes in this version

+ const FuseType

+ const NfsType

+ const WebdavType

+ func GetDriverVersion() string

+ func GetVersionJSON() (string, error)

+ func IsCorruptedMnt(err error) bool

+ func ListProcMounts(mountFilePath string) ([]mount.MountPoint, error)

+ func MakeDir(path string) error

+ func MakeMountArgsSensitive(source, sourceMasked, target, fstype string, options []string, ...) (mountArgs []string, mountArgsLogStr string)

+ func ParseEndpoint(endpoint string) (string, string, error)

+ func PathExists(path string) (bool, error)

+ func SearchMountPoints(hostSource, mountInfoPath string) ([]string, error)

+ type Config struct

+ Endpoint string

+ NodeID string

+ type Driver struct

+ func NewDriver(conf *Config) *Driver

+ func (driver *Driver) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

+ func (driver *Driver) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

+ func (driver *Driver) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

+ func (driver *Driver) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

+ func (driver *Driver) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

+ func (driver *Driver) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

+ func (driver *Driver) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

+ func (driver *Driver) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

+ func (driver *Driver) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

+ func (driver *Driver) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

+ func (driver *Driver) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

+ func (driver *Driver) Run() error

+ type MountInfo struct

+ FsType string

+ ID int

+ Major int

+ Minor int

+ MountOptions []string

+ MountPoint string

+ OptionalFields []string

+ ParentID int

+ Root string

+ Source string

+ SuperOptions []string

+ func ParseMountInfo(filename string) ([]MountInfo, error)

+ type Mounter interface

+ GetDeviceName func(mountPath string) (string, int, error)

+ MountSensitive2 func(source string, sourceMasked string, target string, fstype string, ...) error

+ type NodeMounter struct

+ func (mounter *NodeMounter) GetDeviceName(mountPath string) (string, int, error)

+ func (mounter *NodeMounter) GetMountRefs(pathname string) ([]string, error)

+ func (mounter *NodeMounter) IsLikelyNotMountPoint(file string) (bool, error)

+ func (mounter *NodeMounter) List() ([]mount.MountPoint, error)

+ func (mounter *NodeMounter) Mount(source string, target string, fstype string, options []string) error

+ func (mounter *NodeMounter) MountSensitive(source string, target string, fstype string, options []string, ...) error

+ func (mounter *NodeMounter) MountSensitive2(source string, sourceMasked string, target string, fstype string, ...) error

+ func (mounter *NodeMounter) Unmount(target string) error

+ type VersionInfo struct

+ BuildDate string

+ Compiler string

+ DriverVersion string

+ GitCommit string

+ GoVersion string

+ Platform string

+ func GetVersion() VersionInfo

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL