common

Documentation

Index

• Constants
• func GetFsNameAndUserNameByFsID(fsID string) (userName string, fsName string)
• type FSMeta
• type FsCacheConfig

Constants

const (
	LocalType            = "local"
	HDFSType             = "hdfs"
	HDFSWithKerberosType = "hdfsWithKerberos"
	S3Type               = "s3"
	SFTPType             = "sftp"
	MockType             = "mock"
	CFSType              = "cfs"

	// common
	Owner = "owner"
	Group = "group"

	// local properties and root path
	RootKey = "root"
	SubPath = "subpath"

	// HDFS properties
	NameNodeAddress = "dfs.namenode.address"
	UserKey         = "user"
	BlockSizeKey    = "blockSize"
	ReplicationKey  = "replication"

	// HDFS Kerbers properties
	Realm                  = "kerberos.realm"
	Kdc                    = "kerberos.kdc"
	NameNodePrincipal      = "kerberos.namenode.principal"
	Principal              = "kerberos.principal"
	DataTransferProtection = "kerberos.data.transfer.protection"
	KeyTabData             = "kerberos.keytab.data"

	// S3 properties
	AccessKey = "accessKey"
	SecretKey = "secretKey"
	Endpoint  = "endpoint"
	Bucket    = "bucket"
	Region    = "region"

	// sftp properties
	Address  = "address"
	Password = "password"

	// mock properties
	PVC       = "pvc"
	Namespace = "namespace"

	// FSMeta类型
	FSType   = "fs"
	LinkType = "link"

	// Link操作
	ADD    = "ADD"
	DELETE = "DELETE"

	// Link Meta
	LinkMetaDir  = ".config"
	LinkMetaFile = "links_meta"
)

Functions

func GetFsNameAndUserNameByFsID

func GetFsNameAndUserNameByFsID(fsID string) (userName string, fsName string)

Types

type FSMeta

type FSMeta struct {
	ID            string
	Name          string
	UfsType       string
	ServerAddress string
	SubPath       string
	Properties    map[string]string
	// type: fs 表示是默认的后端存储；link 表示是外部存储
	Type string
}

type FsCacheConfig

type FsCacheConfig struct {
	CacheDir            string
	Quota               int
	MetaDriver          string
	BlockSize           int
	Debug               bool
	NodeAffinity        map[string]interface{}
	NodeTaintToleration map[string]interface{}
	ExtraConfig         map[string]string
	FsName              string
	Username            string
}