oss

May 25, 2020

Changes in this version

+ const AuthTypeDefault

+ const CredentialFile

+ func IsFileExisting(filename string) bool

+ type ControllerServer struct

+ Client *kubernetes.Clientset

+ type IdentityServer struct

+ func NewIdentityServer(d *OssDriver) *IdentityServer

+ type NodeServer struct

+ func NewNodeServer(d *OssDriver) *NodeServer

+ func (n *NodeServer) NodeExpandVolume(context.Context, *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

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

+ func (n *NodeServer) NodeStageVolume(context.Context, *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

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

+ func (n *NodeServer) NodeUnstageVolume(context.Context, *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

+ type OssDriver struct

+ func NewDriver(driverName, nodeId, endpoint string) *OssDriver

+ func (d *OssDriver) Run()

+ type OssOpts struct

+ AkID string

+ AkSecret string

+ AuthType string

+ Bucket string

+ OtherOpts string

+ Path string

+ URL string

+ type PublishOptions struct

+ AllowSharePath bool

+ NodePublishPath string