jindofs

Documentation

Index

• Constants
• func GetMetaData(resource string) string
• func IsJindofsMounted(mountPath string) bool
• func IsLastSharedVol(pvName string) (string, error)
• type JindoFS
  • func NewDriver(nodeID, endpoint string) *JindoFS
  • func (d *JindoFS) Run()
• type Options

Constants

const (
	// JindofsCredentialPathInPod Pod side sts file
	JindofsCredentialPathInPod = "/oss-secret/sts-token"
	// JindofsCredentialPathOnHost Host side sts file
	JindofsCredentialPathOnHost = "/host/etc/jindofs-credentials"
)

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"
	// SharedPath is the shared mountpoint when UseSharedPath is "true"
	SharedPath = "/var/lib/kubelet/plugins/kubernetes.io/csi/pv/%s/globalmount"
	// JindoFsType is the oss filesystem type
	JindoFsType = "fuse.jindofs-fuse"
)

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/"
)

Functions

func GetMetaData

func GetMetaData(resource string) string

GetMetaData get host regionid, zoneid

func IsJindofsMounted

func IsJindofsMounted(mountPath string) bool

IsJindofsMounted return if Jindofs mountPath is mounted

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

Types

type JindoFS

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

JindoFS the JindoFS object

func NewDriver

func NewDriver(nodeID, endpoint string) *JindoFS

NewDriver init jindofs type of csi driver

func (*JindoFS) Run

func (d *JindoFS) 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"`
	AuthType  string `json:"authType"`
}

Options contains options for target oss