Documentation ¶
Index ¶
- Constants
- func IsFileExisting(filename string) bool
- type ControllerServer
- type IdentityServer
- type 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
- type OssOpts
- type PublishOptions
Constants ¶
View Source
const ( AuthTypeDefault = "saveAkFile" LocalCredentialFile = "/host/etc/s3pass" CredentialFile = "/etc/s3pass" )
Variables ¶
This section is empty.
Functions ¶
func IsFileExisting ¶
IsFileExisting check file exist in volume driver or not
Types ¶
type ControllerServer ¶
type ControllerServer struct { *csicommon.DefaultControllerServer Client *kubernetes.Clientset }
type IdentityServer ¶
type IdentityServer struct {
*csicommon.DefaultIdentityServer
}
func NewIdentityServer ¶
func NewIdentityServer(d *OssDriver) *IdentityServer
type NodeServer ¶
type NodeServer struct {
*csicommon.DefaultNodeServer
}
func NewNodeServer ¶
func NewNodeServer(d *OssDriver) *NodeServer
func (*NodeServer) NodeExpandVolume ¶
func (n *NodeServer) NodeExpandVolume(context.Context, *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)
func (*NodeServer) NodePublishVolume ¶
func (n *NodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)
func (*NodeServer) NodeStageVolume ¶
func (n *NodeServer) NodeStageVolume(context.Context, *csi.NodeStageVolumeRequest) ( *csi.NodeStageVolumeResponse, error)
func (*NodeServer) NodeUnpublishVolume ¶
func (n *NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)
func (*NodeServer) NodeUnstageVolume ¶
func (n *NodeServer) NodeUnstageVolume(context.Context, *csi.NodeUnstageVolumeRequest) ( *csi.NodeUnstageVolumeResponse, error)
type PublishOptions ¶
Click to show internal directories.
Click to hide internal directories.