dbfs

Documentation

Index

• Constants
• Variables
• func GetMetaData(resource string) string
• func GetPvNameFormMntPoint(mntPath string) string
• func GetRegionID() string
• func GlobalConfigSet(region string)
• func NewControllerServer(d *csicommon.CSIDriver, client *dbfs.Client, region string) csi.ControllerServer
• func NewIdentityServer(d *csicommon.CSIDriver) csi.IdentityServer
• type DBFS
  • func NewDriver(nodeID, endpoint string) *DBFS
  • func (d *DBFS) Run()
• type GlobalConfig
• type Options

Constants

const (
	// DRIVER tag
	DRIVER = "driver"
	// SERVER tag
	SERVER = "server"
	// MODE tag
	MODE = "mode"
	// ModeType tag
	ModeType = "modeType"
	// PATH tag
	PATH = "path"
	// ProtocolType tag
	ProtocolType = "protocolType"
	// FileSystemType tag
	FileSystemType = "fileSystemType"
	// ZoneID tag
	ZoneID = "zoneId"
	// ZoneIDTag tag
	ZoneIDTag = "zone-id"
	// TopologyZoneKey tag
	TopologyZoneKey = "topology." + driverName + "/zone"
)

const (

	// InstanceID is instance id
	InstanceID = "instance-id"
	// DBFSAttachByController tag
	DBFSAttachByController = "DBFS_AD_CONTROLLER"
	// DbfsDetachDisable tag
	DbfsDetachDisable = "DBFS_DETACH_DISABLE"
)

const (
	// MetadataURL is metadata url
	MetadataURL = "http://100.100.100.200/latest/meta-data/"
	// RegionTag is region id
	RegionTag = "region-id"
	// NsenterCmd is the nsenter command
	NsenterCmd = "/nsenter --mount=/proc/1/ns/mnt"
	// GetDBFSMountCmd get dbfs mount path
	GetDBFSMountCmd = "/usr/sbin/get_dbfs_mount_path"
)

const (
	// DbfsMetricByPlugin tag
	DbfsMetricByPlugin = "DBFS_METRIC_BY_PLUGIN"
)

Variables

var (
	// VERSION should be updated by hand at each release
	VERSION = "v1.14.8"
	// GITCOMMIT will be overwritten automatically by the build system
	GITCOMMIT = "HEAD"
	// KubernetesAlicloudIdentity is the system identity for ecs client request
	KubernetesAlicloudIdentity = fmt.Sprintf("Kubernetes.Alicloud/CsiProvision.Nas-%s", VERSION)
)

Functions

func GetMetaData

func GetMetaData(resource string) string

GetMetaData get host regionid, zoneid

func GetPvNameFormMntPoint

func GetPvNameFormMntPoint(mntPath string) string

GetPvNameFormMntPoint get pv name

func GetRegionID

func GetRegionID() string

GetRegionID Get RegionID from Environment Variables or Metadata

func GlobalConfigSet

func GlobalConfigSet(region string)

GlobalConfigSet set global config

func NewControllerServer

func NewControllerServer(d *csicommon.CSIDriver, client *dbfs.Client, region string) csi.ControllerServer

NewControllerServer is to create controller server

func NewIdentityServer

func NewIdentityServer(d *csicommon.CSIDriver) csi.IdentityServer

NewIdentityServer create identity server

Types

type DBFS

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

DBFS define driver

func NewDriver

func NewDriver(nodeID, endpoint string) *DBFS

NewDriver create the identity/node/controller server and dbfs driver

func (*DBFS) Run

func (d *DBFS) Run()

Run start a new NodeServer

type GlobalConfig

type GlobalConfig struct {
	Region       string
	DbfsClient   *dbfs.Client
	MetricEnable bool
	NodeName     string
	DBFSDomain   string
	// only useful in node
	EcsInstanceID      string
	ADControllerEnable bool
	DBFSDetachDisable  bool
}

GlobalConfig save global values for plugin

var (

	// GlobalConfigVar Global Config
	GlobalConfigVar GlobalConfig
)

type Options

type Options struct {
	FileSystemID string `json:"fileSystemID"`
	Options      string `json:"options"`
}

Options struct definition