dbfs

Documentation

Index

• Constants
• Variables
• func GetPvNameFormMntPoint(mntPath string) 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 (
	// DbfsMetricByPlugin tag
	DbfsMetricByPlugin = "DBFS_METRIC_BY_PLUGIN"
	// DdbfROOT tag
	DdbfROOT = "/mnt/dbfs/"
)

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

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 GetPvNameFormMntPoint

func GetPvNameFormMntPoint(mntPath string) string

GetPvNameFormMntPoint get pv name

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