conf

Documentation

Index

• Constants
• func Debug() bool
• func DefaultRuntimeExecutor() string
• func KafkaBrokers() string
• func KafkaContainerTopic() string
• func KafkaGroup() string
• func ListenAddr() string
• func Load()
• func PlaceHolderImage() string
• func PoolSize() int
• func TerminalSecurity() bool
• func TraceLogEnv() string
• func WsDiceRootDomain() string
• type Conf
• type ConfStore
  • func GetConfStore() *ConfStore

Constants

const (
	CLUSTERS_CONFIG_PATH = "/dice/scheduler/configs/cluster/"
)

Functions

func Debug

func Debug() bool

Debug return cfg.Debug

func DefaultRuntimeExecutor

func DefaultRuntimeExecutor() string

DefaultRuntimeExecutor return cfg.DefaultRuntimeExecutor

func KafkaBrokers

func KafkaBrokers() string

func KafkaContainerTopic

func KafkaContainerTopic() string

func KafkaGroup

func KafkaGroup() string

func ListenAddr

func ListenAddr() string

ListenAddr return cfg.ListenAddr

func Load

func Load()

Load environment variable

func PlaceHolderImage

func PlaceHolderImage() string

PlaceHolderImage return cfg.PlaceHolderImage

func PoolSize

func PoolSize() int

PoolSize return cfg.PoolSize

func TerminalSecurity

func TerminalSecurity() bool

TerminalSecurity return cfg.TerminalSecurity

func TraceLogEnv

func TraceLogEnv() string

TraceLogEnv return cfg.TraceLogEnv

func WsDiceRootDomain

func WsDiceRootDomain() string

Types

type Conf

type Conf struct {
	// Debug Control log level
	Debug bool `env:"DEBUG" default:"false"`
	// PoolSize goroutine pool size
	PoolSize int `env:"POOL_SIZE" default:"50"`
	// ListenAddr scheduler listening address , eg: ":9091"
	ListenAddr             string `env:"LISTEN_ADDR" default:":9091"`
	DefaultRuntimeExecutor string `env:"DEFAULT_RUNTIME_EXECUTOR" default:"MARATHON"`
	// TraceLogEnv shows the key of environment variable defined for tracing log
	TraceLogEnv string `env:"TRACELOGENV" default:"TERMINUS_DEFINE_TAG"`
	// PlaceHolderImage Image used to occupy the seat when disassembling the service deployment
	PlaceHolderImage string `env:"PLACEHOLDER_IMAGE" default:"registry.cn-hangzhou.aliyuncs.com/terminus/busybox"`

	KafkaBrokers        string `env:"BOOTSTRAP_SERVERS"`
	KafkaContainerTopic string `env:"CMDB_CONTAINER_TOPIC"`
	KafkaGroup          string `env:"CMDB_GROUP"`

	TerminalSecurity bool `env:"TERMINAL_SECURITY" default:"false"`

	WsDiceRootDomain string `env:"WS_DICE_ROOT_DOMAIN" default:"app.terminus.io,erda.cloud"`
}

Conf scheduler conf, use envconf to load configuration

type ConfStore

type ConfStore struct {
	ExecutorStore sync.Map
}

func GetConfStore

func GetConfStore() *ConfStore