csi

Documentation

Index

• func GetS3EndPoint(s3host string) (string, error)
• type Driver
• type FuseDriver
  • func NewFuseDriver(nodeID, endpoint, driverName string, kubeClient *kubernetes.Clientset) (*FuseDriver, error)
  • func (s3 *FuseDriver) Run()

Functions

func GetS3EndPoint

func GetS3EndPoint(s3host string) (string, error)

Types

type Driver

type Driver interface {
	CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)
	DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)
	ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)
	NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (
		*csi.NodeExpandVolumeResponse, error)
	NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)
	NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)
	NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
	NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
	NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)
}

type FuseDriver

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

func NewFuseDriver

func NewFuseDriver(nodeID, endpoint, driverName string, kubeClient *kubernetes.Clientset) (*FuseDriver, error)

NewFuseDriver initializes the driver

func (*FuseDriver) Run

func (s3 *FuseDriver) Run()