chdfs

Documentation

Index

• func IsTrue(str string) (bool, error)
• func Mount(options *chdfsOptions, mountPoint string) error
• func NewNodeServer(driver *csicommon.CSIDriver) csi.NodeServer
• func Num(str string) (int, error)
• func WriteFile(file string, context string) error
• type ArgsErr
• type Cache
• type ChdfsConfig
  • func NewChdfsConfig(url, mountPoint, additionalArgs string) (*ChdfsConfig, error)
  • func NewDefaultChdfsConfig(url, mountPoint string) *ChdfsConfig
• type Client
• type Driver
  • func NewDriver(endpoint, driverName, nodeID string) *Driver
  • func (d *Driver) Start()
• type Log
• type LogFile
• type Proxy
• type Read
• type Security
• type Write

Functions

func IsTrue

func IsTrue(str string) (bool, error)

func Mount

func Mount(options *chdfsOptions, mountPoint string) error

func NewNodeServer

func NewNodeServer(driver *csicommon.CSIDriver) csi.NodeServer

func Num

func Num(str string) (int, error)

func WriteFile

func WriteFile(file string, context string) error

Types

type ArgsErr

type ArgsErr struct {
	Key string
	Err string
}

type Cache

type Cache struct {
	UpdateStsTimeSec        int
	CosClientTimeoutSec     int
	InodeAttrExpiredTimeSec int
	Read                    Read
	Write                   Write
}

type ChdfsConfig

type ChdfsConfig struct {
	Proxy    Proxy
	Security Security
	Client   Client
	Cache    Cache
	Log      Log
	LogFile  LogFile
}

func NewChdfsConfig

func NewChdfsConfig(url, mountPoint, additionalArgs string) (*ChdfsConfig, error)

func NewDefaultChdfsConfig

func NewDefaultChdfsConfig(url, mountPoint string) *ChdfsConfig

type Client

type Client struct {
	RenewSessionLeaseTimeSec int
	MountPoint               string
	MountSubDir              string
	User                     string
	Group                    string
	ForceSync                bool
}

type Driver

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

func NewDriver

func NewDriver(endpoint, driverName, nodeID string) *Driver

NewDriver creates a new CSI driver for CHDFS.

func (*Driver) Start

func (d *Driver) Start()

type Log

type Log struct {
	Level string
}

type LogFile

type LogFile struct {
	Filename   string
	LogRotate  bool
	MaxSize    int
	MaxDays    int
	MaxBackups int
}

type Proxy

type Proxy struct {
	Url string
}

type Read

type Read struct {
	BlockExpiredTimeSec int
	MaxBlockNum         int
	ReadAheadBlockNum   int
	MaxCosLoadQps       int
	LoadThreadNum       int
	SelectThreadNum     int
	RandRead            bool
}

type Security

type Security struct {
	SslCaPath string
}

type Write

type Write struct {
	MaxMemTableRangeNum int
	MaxMemTableSizeMb   int
	MaxCosFlushQps      int
	FlushThreadNum      int
	CommitQueueLen      int
	MaxCommitHeapSize   int
	AutoMerge           bool
	AutoSync            bool
	AutoSyncTimeMs      int
}