util

Documentation

Index

• Constants
• func GetMesosAgentInnerIP(attributes []*mesos.Attribute) (string, bool)
• func ParseMesosResources(resources []*mesos.Resource) (float64, float64, float64, string)
• func ReportAlertManagerAPIMetrics(handler, method, status string, started time.Time)
• func SetSchedulerCfg(config *SchedConfig, op *SchedulerOptions)
• type AlertManagerConfig
• type HttpListener
• type ObjectLock
  • func (l *ObjectLock) Lock(obj interface{}, key string)
  • func (l *ObjectLock) UnLock(obj interface{}, key string)
• type SchedConfig
  • func NewSchedulerCfg() *SchedConfig
• type Scheduler
• type SchedulerOptions

Constants

const (
	// ErrStatus for call api failure
	ErrStatus = "failure"
	// SucStatus for success status
	SucStatus = "success"
)

Functions

func GetMesosAgentInnerIP

func GetMesosAgentInnerIP(attributes []*mesos.Attribute) (string, bool)

func ParseMesosResources

func ParseMesosResources(resources []*mesos.Resource) (float64, float64, float64, string)

func ReportAlertManagerAPIMetrics

func ReportAlertManagerAPIMetrics(handler, method, status string, started time.Time)

ReportAlertManagerAPIMetrics report all api action metrics

func SetSchedulerCfg

func SetSchedulerCfg(config *SchedConfig, op *SchedulerOptions)

Types

type AlertManagerConfig

type AlertManagerConfig struct {
	Server     string
	Token      string
	ClientAuth bool
	Debug      bool
}

AlertManagerConfig for bcs-alert-manager config

type HttpListener

type HttpListener struct {
	TCPAddr  string
	UnixAddr string
	IsSSL    bool
	//CertDir    string
	CAFile     string
	CertFile   string
	KeyFile    string
	CertPasswd string
}

HttpListener for http server conf

type ObjectLock

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

var Lock *ObjectLock

func (*ObjectLock) Lock

func (l *ObjectLock) Lock(obj interface{}, key string)

func (*ObjectLock) UnLock

func (l *ObjectLock) UnLock(obj interface{}, key string)

type SchedConfig

type SchedConfig struct {
	Scheduler    Scheduler
	HttpListener HttpListener
	AlertManager AlertManagerConfig
	ZkHost       string
}

SchedConfig for parse conf

func NewSchedulerCfg

func NewSchedulerCfg() *SchedConfig

NewSchedulerCfg init scheduler config

type Scheduler

type Scheduler struct {
	Hostname      string
	MesosMasterZK string
	BcsZK         string
	RegDiscvSvr   string
	Address       string
	Scheme        string
	ZK            string
	UseCache      bool
	DoRecover     bool
	Plugins       string
	PluginDir     string

	ClientCAFile   string
	ClientCertFile string
	ClientKeyFile  string

	ServerCAFile   string
	ServerCertFile string
	ServerKeyFile  string
	MetricPort     uint

	Cluster           string
	ContainerExecutor string
	ProcessExecutor   string
	CniDir            string
	NetImage          string

	Kubeconfig  string
	StoreDriver string

	//whether use pprof
	DebugMode bool
}

Scheduler for scheduler config

type SchedulerOptions

type SchedulerOptions struct {
	conf.FileConfig
	conf.ServiceConfig
	conf.MetricConfig
	conf.ZkConfig
	conf.CertConfig
	conf.LicenseServerConfig

	conf.LogConfig
	conf.ProcessConfig

	AlertServer       string `json:"alertServer" value:"" usage:"bcs-alert-manager server address"`
	ClientAuth        bool   `json:"clientAuth" value:"false" usage:"bcs-alert-manager server client auth"`
	Token             string `json:"token" value:"" usage:"api-gateway token for call alertmanager api"`
	AlertDebug        bool   `json:"alertDebug" value:"false" usage:"alertDebug debug bcs-alert-manager http api"`
	MesosMasterZK     string `json:"mesos_regdiscv" value:"" usage:"the address to discove mesos master"`
	RegDiscvSvr       string `json:"regdiscv" value:"" usage:"the address to register and discove scheduler"`
	UseCache          bool   `json:"use_cache" value:"false" usage:"whether use cache or not"`
	DoRecover         bool   `json:"do_recover" value:"false" usage:"whether recover taskgroup LOST to RUNNING in master role"`
	Plugins           string `json:"plugins" value:"" usage:"whether use plugins"`
	ZkHost            string `json:"zkhost" value:"" usage:"zk address"`
	Cluster           string `json:"cluster" value:"" usage:"the cluster ID under bcs"`
	PluginDir         string `json:"plugin_dir" value:"" usage:"the plugin dir"`
	ContainerExecutor string `json:"container_executor" value:"" usage:"the container executor path"`
	ProcessExecutor   string `json:"process_executor" value:"" usage:"the process executor path"`
	CniDir            string `json:"cni_dir" value:"" usage:"the cni directory"`
	NetImage          string `json:"net_image" value:"" usage:"the network image"`
	Kubeconfig        string `json:"kubeconfig" value:"" usage:"kubeconfig, when store_driver is etcd"`
	StoreDriver       string `json:"store_driver" value:"zookeeper" usage:"the store driver, enum: zookeeper, etcd"`
	DebugMode         bool   `json:"debug_mode" value:"false" usage:"Debug mode, use pprof."`
}

SchedulerOptions for bcs-scheduler