node

Documentation

Index

• func NewFakeSafeFormatAndMounter(fakeMounter mount.Interface) *mount.SafeFormatAndMount
• func NewSafeMounter() *mount.SafeFormatAndMount
• type FakeMetadataGetter
  • func NewFakeMetadataGetter(instID, zoneID string) *FakeMetadataGetter
  • func (f *FakeMetadataGetter) InstanceID() (string, error)
  • func (f *FakeMetadataGetter) ZoneID() (string, error)
• type FakeVolumeStats
  • func (f FakeVolumeStats) GetVolumeStats(s string) (bytesStats, inodeStats *VolStats, err error)
• type FileXattrs
• type Options
  • func DefaultOptions() Options
• type Service
  • func New(mounter *mount.SafeFormatAndMount, hostUtil hostutil.HostUtils, ...) *Service
  • func NewTestNodeService(mounter mount.Interface, hostUtil hostutil.HostUtils, fileXattrs FileXattrs, ...) *Service
  • func (n *Service) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)
  • func (n *Service) NodeGetCapabilities(context.Context, *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)
  • func (n *Service) NodeGetInfo(context.Context, *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)
  • func (n *Service) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)
  • func (n *Service) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
  • func (n *Service) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)
  • func (n *Service) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
  • func (n *Service) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)
• type VolStats
• type VolumeStats

Functions

func NewFakeSafeFormatAndMounter

func NewFakeSafeFormatAndMounter(fakeMounter mount.Interface) *mount.SafeFormatAndMount

func NewSafeMounter

func NewSafeMounter() *mount.SafeFormatAndMount

Types

type FakeMetadataGetter

type FakeMetadataGetter struct {
	// contains filtered or unexported fields
}

func NewFakeMetadataGetter

func NewFakeMetadataGetter(instID, zoneID string) *FakeMetadataGetter

func (*FakeMetadataGetter) InstanceID

func (f *FakeMetadataGetter) InstanceID() (string, error)

func (*FakeMetadataGetter) ZoneID

func (f *FakeMetadataGetter) ZoneID() (string, error)

type FakeVolumeStats

type FakeVolumeStats struct {
}

func (FakeVolumeStats) GetVolumeStats

func (f FakeVolumeStats) GetVolumeStats(s string) (bytesStats, inodeStats *VolStats, err error)

type FileXattrs

type FileXattrs interface {
	SetImmutable(target string) error
	UnsetImmutable(target string) error
}

type Options

type Options struct {
	MaxVolumesPerNode int
}

func DefaultOptions

func DefaultOptions() Options

type Service

type Service struct {
	// contains filtered or unexported fields
}

func New

func New(mounter *mount.SafeFormatAndMount, hostUtil hostutil.HostUtils, volStat VolumeStats,
	fileXattrs FileXattrs, metadataGetter instancemeta.MetadataGetter, caps []*csi.NodeServiceCapability, opts Options) *Service

func NewTestNodeService

func NewTestNodeService(mounter mount.Interface, hostUtil hostutil.HostUtils, fileXattrs FileXattrs,
	mdGetter instancemeta.MetadataGetter, caps []*csi.NodeServiceCapability) *Service

func (*Service) NodeExpandVolume

func (n *Service) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

func (*Service) NodeGetCapabilities

func (n *Service) NodeGetCapabilities(context.Context, *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

func (*Service) NodeGetInfo

func (n *Service) NodeGetInfo(context.Context, *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

func (*Service) NodeGetVolumeStats

func (n *Service) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

func (*Service) NodePublishVolume

func (n *Service) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

func (*Service) NodeStageVolume

func (n *Service) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

func (*Service) NodeUnpublishVolume

func (n *Service) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

func (*Service) NodeUnstageVolume

func (n *Service) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

type VolStats

type VolStats struct {
	Total     int64
	Used      int64
	Available int64
}

type VolumeStats

type VolumeStats interface {
	GetVolumeStats(string) (*VolStats, *VolStats, error)
}