config

Documentation

Index

• Variables
• func AddKubeConfigFlagSet(fs *pflag.FlagSet, kubeConf *KubeConfig)
• func FileNumsInDir(path string) (int, error)
• func GetServiceAddress() string
• func InitConfigFromYaml(conf interface{}, configPath string) error
• func InitDefaultPV(path string) error
• func InitDefaultPVC(path string) error
• func InitKubeConfig(kubeConf KubeConfig) *rest.Config
• func InitKubeConfigFromBytes(configBytes []byte) (*rest.Config, error)
• func PathExists(path string) (bool, error)
• func PrettyFormat(data interface{}) []byte
• type ApiServerConfig
• type FsServerConf
• type ImageConfig
• type JobConfig
• type KubeConfig
• type PrometheusConfig
• type ReclaimConfig
• type ServerConfig
• type StorageConfig

Variables

var (
	GlobalServerConfig *ServerConfig                // the global ServerConfig
	DefaultPV          *apiv1.PersistentVolume      // the global default pv instance
	DefaultPVC         *apiv1.PersistentVolumeClaim // the global default pvc instance

	DefaultRunYamlPath = "./run.yaml"

	// DefaultClusterName for default cluster in single cluster
	DefaultClusterName = "default-cluster"
	// DefaultQueueName for default queue in single cluster
	DefaultQueueName = "default-queue"
	// DefaultNamespace for default namespace of default queue in single cluster
	DefaultNamespace = "default"
)

Functions

func AddKubeConfigFlagSet

func AddKubeConfigFlagSet(fs *pflag.FlagSet, kubeConf *KubeConfig)

func FileNumsInDir

func FileNumsInDir(path string) (int, error)

FileNumsInDir caculate files number in path, include dir type

func GetServiceAddress

func GetServiceAddress() string

func InitConfigFromYaml

func InitConfigFromYaml(conf interface{}, configPath string) error

func InitDefaultPV

func InitDefaultPV(path string) error

InitDefaultPV initialize the default pv instance

func InitDefaultPVC

func InitDefaultPVC(path string) error

InitDefaultPVC initialize the default pvc instance

func InitKubeConfig

func InitKubeConfig(kubeConf KubeConfig) *rest.Config

func InitKubeConfigFromBytes

func InitKubeConfigFromBytes(configBytes []byte) (*rest.Config, error)

func PathExists

func PathExists(path string) (bool, error)

PathExists indicate path exist or not 1. path exist: return true, nil 2. path not exist: return false, nil 3. unknown error: return false, err

func PrettyFormat

func PrettyFormat(data interface{}) []byte

Types

type ApiServerConfig

type ApiServerConfig struct {
	// Host Port used for FS to create pv/pvc with volumeAttributes point pfs-server pod
	Host                string `yaml:"host"`
	Port                int    `yaml:"port"`
	TokenExpirationHour int    `yaml:"tokenExpirationHour"`
}

type FsServerConf

type FsServerConf struct {
	DefaultPVPath             string        `yaml:"defaultPVPath"`
	DefaultPVCPath            string        `yaml:"defaultPVCPath"`
	LinkMetaDirPrefix         string        `yaml:"linkMetaDirPrefix"`
	MountPodExpire            time.Duration `yaml:"mountPodExpire"`
	CleanMountPodIntervalTime time.Duration `yaml:"cleanMountPodIntervalTime"`
}

type ImageConfig

type ImageConfig struct {
	Server           string `yaml:"server"`
	Namespace        string `yaml:"namespace"`
	Username         string `yaml:"username"`
	Password         string `yaml:"password"`
	Concurrency      int    `yaml:"concurrency"`
	RemoveLocalImage bool   `yaml:"removeLocalImage"`
}

type JobConfig

type JobConfig struct {
	Reclaim       ReclaimConfig `yaml:"reclaim"`
	SchedulerName string        `yaml:"schedulerName"`
	// period second for job manager
	ClusterSyncPeriod int `yaml:"clusterSyncPeriod"`
	QueueExpireTime   int `yaml:"queueExpireTime"`
	QueueCacheSize    int `yaml:"queueCacheSize"`
	JobLoopPeriod     int `yaml:"jobLoopPeriod"`
	// SyncClusterQueue defines whether aware cluster resource or not, such as queue
	SyncClusterQueue bool `yaml:"syncClusterQueue"`
	// DefaultJobYamlDir is directory that stores default template yaml files for job
	DefaultJobYamlDir string `yaml:"defaultJobYamlDir"`
	IsSingleCluster   bool   `yaml:"isSingleCluster"`
}

type KubeConfig

type KubeConfig struct {
	ConfigPath    string `yaml:"configPath"`
	ClientQPS     int    `yaml:"clientQps"`
	ClientBurst   int    `yaml:"clientBurst"`
	ClientTimeout int    `yaml:"clientTimeout"`
}

type PrometheusConfig

type PrometheusConfig struct {
	Server              string `yaml:"server"`
	ExporterServicePort int    `yaml:"exporterServicePort"`
}

type ReclaimConfig

type ReclaimConfig struct {
	CleanJob               bool `yaml:"isCleanJob"`
	SkipCleanFailedJob     bool `yaml:"isSkipCleanFailedJob"`
	FailedJobTTLSeconds    int  `yaml:"failedJobTTLSeconds,omitempty"`
	SucceededJobTTLSeconds int  `yaml:"succeededJobTTLSeconds,omitempty"`
	PendingJobTTLSeconds   int  `yaml:"pendingJobTTLSeconds,omitempty"`
}

type ServerConfig

type ServerConfig struct {
	Storage   StorageConfig                  `yaml:"database"`
	Log       logger.LogConfig               `yaml:"log"`
	TraceLog  trace_logger.TraceLoggerConfig `yaml:"traceLog"`
	ApiServer ApiServerConfig                `yaml:"apiServer"`
	Job       JobConfig                      `yaml:"job"`
	Fs        FsServerConf                   `yaml:"fs"`
	ImageConf ImageConfig                    `yaml:"imageRepository"`
	Monitor   PrometheusConfig               `yaml:"monitor"`
}

type StorageConfig

type StorageConfig struct {
	Driver                               string `yaml:"driver"`
	Host                                 string `yaml:"host"`
	Port                                 string `yaml:"port"`
	User                                 string `yaml:"user"`
	Password                             string `yaml:"password"`
	Database                             string `yaml:"database"`
	ConnectTimeoutInSeconds              int    `yaml:"connectTimeoutInSeconds,omitempty"`
	LockTimeoutInMilliseconds            int    `yaml:"lockTimeoutInMilliseconds,omitempty"`
	IdleTransactionTimeoutInMilliseconds int    `yaml:"idleTransactionTimeoutInMilliseconds,omitempty"`
	MaxIdleConns                         *int   `yaml:"maxIdleConns,omitempty"`
	MaxOpenConns                         *int   `yaml:"maxOpenConns,omitempty"`
	ConnMaxLifetimeInHours               *int   `yaml:"connMaxLifetimeInHours,omitempty"`
}