oss

Documentation

Index

• Constants
• Variables
• func GetMetaData(resource string) string
• func GetRAMRoleOption(mntCmd string) string
• func IsHostMounted(mountPath string) bool
• func IsLastSharedVol(pvName string) (string, error)
• func IsOssfsMounted(mountPath string) bool
• type OSS
  • func NewDriver(nodeID, endpoint string) *OSS
  • func (d *OSS) Run()
• type Options

Constants

const (
	//CredentialFile is the path of oss ak credential file
	CredentialFile = "/host/etc/passwd-ossfs"
	// NsenterCmd is nsenter mount command
	NsenterCmd = "/nsenter --mount=/proc/1/ns/mnt"
	// SocketPath is path of connector sock
	SocketPath = "/host/etc/csi-tool/connector.sock"
	// AkID is Ak ID
	AkID = "akId"
	// AkSecret is Ak Secret
	AkSecret = "akSecret"
	// OssFsType is the oss filesystem type
	OssFsType = "fuse.ossfs"
	// JindoFsType tag
	JindoFsType = "jindofs"
	// JindofsCredentialPathInPod Pod side sts file
	JindofsCredentialPathInPod = "/oss-secret/sts-token"
	// JindofsCredentialPathOnHost Host side sts file
	JindofsCredentialPathOnHost = "/host/etc/jindofs-credentials"
)

const (
	// MetadataURL is metadata url
	MetadataURL = "http://100.100.100.200/latest/meta-data/"
	// InstanceID is instance ID
	InstanceID = "instance-id"
	// RAMRoleResource is ram-role url subpath
	RAMRoleResource = "ram/security-credentials/"
)

Variables

var (
	// SharedPath is the shared mountpoint when UseSharedPath is "true"
	SharedPath = filepath.Join(utils.KubeletRootDir, "/plugins/kubernetes.io/csi/pv/%s/globalmount")
)

Functions

func GetMetaData

func GetMetaData(resource string) string

GetMetaData get host regionid, zoneid

func GetRAMRoleOption

func GetRAMRoleOption(mntCmd string) string

GetRAMRoleOption get command line's ram_role option

func IsHostMounted

func IsHostMounted(mountPath string) bool

IsHostMounted return status of host mounted or not

func IsLastSharedVol

func IsLastSharedVol(pvName string) (string, error)

IsLastSharedVol return code status to help check if this oss volume uses UseSharedPath and is the last one

func IsOssfsMounted

func IsOssfsMounted(mountPath string) bool

IsOssfsMounted return if oss mountPath is mounted

Types

type OSS

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

OSS the OSS object

func NewDriver

func NewDriver(nodeID, endpoint string) *OSS

NewDriver init oss type of csi driver

func (*OSS) Run

func (d *OSS) Run()

Run start a newNodeServer

type Options

type Options struct {
	Bucket        string `json:"bucket"`
	URL           string `json:"url"`
	OtherOpts     string `json:"otherOpts"`
	AkID          string `json:"akId"`
	AkSecret      string `json:"akSecret"`
	Path          string `json:"path"`
	UseSharedPath bool   `json:"useSharedPath"`
	AuthType      string `json:"authType"`
	FuseType      string `json:"fuseType"`
}

Options contains options for target oss