volume

Documentation

Index

• func StartVolumeController(ctx context.Context, nodeID string) error
• func SyncVolumeCRDVersions(ctx context.Context, nodeID string)
• type DirectCSIVolumeListener
  • func (b *DirectCSIVolumeListener) Add(ctx context.Context, obj *directcsi.DirectCSIVolume) error
  • func (b *DirectCSIVolumeListener) Delete(ctx context.Context, obj *directcsi.DirectCSIVolume) error
  • func (b *DirectCSIVolumeListener) InitializeDirectCSIClient(bc clientset.Interface)
  • func (b *DirectCSIVolumeListener) InitializeKubeClient(k kubeclientset.Interface)
  • func (b *DirectCSIVolumeListener) Update(ctx context.Context, old, new *directcsi.DirectCSIVolume) error
• type VolumeUpdateType

Functions

func StartVolumeController

func StartVolumeController(ctx context.Context, nodeID string) error

func SyncVolumeCRDVersions

func SyncVolumeCRDVersions(ctx context.Context, nodeID string)

Types

type DirectCSIVolumeListener

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

func (*DirectCSIVolumeListener) Add

func (b *DirectCSIVolumeListener) Add(ctx context.Context, obj *directcsi.DirectCSIVolume) error

func (*DirectCSIVolumeListener) Delete

func (b *DirectCSIVolumeListener) Delete(ctx context.Context, obj *directcsi.DirectCSIVolume) error

func (*DirectCSIVolumeListener) InitializeDirectCSIClient

func (b *DirectCSIVolumeListener) InitializeDirectCSIClient(bc clientset.Interface)

func (*DirectCSIVolumeListener) InitializeKubeClient

func (b *DirectCSIVolumeListener) InitializeKubeClient(k kubeclientset.Interface)

func (*DirectCSIVolumeListener) Update

func (b *DirectCSIVolumeListener) Update(ctx context.Context, old, new *directcsi.DirectCSIVolume) error

type VolumeUpdateType

type VolumeUpdateType int

const (
	VolumeUpdateTypeDeleting VolumeUpdateType = iota
	VolumeUpdateTypeUnknown
)