option

Documentation

Index

• type Config
• type Helm
• type Worker
  • func NewWorker() *Worker
  • func (a *Worker) AddFlags(fs *pflag.FlagSet)
  • func (a *Worker) CheckEnv() error
  • func (a *Worker) SetLog()

Types

type Config

type Config struct {
	EtcdEndPoints           []string
	EtcdCaFile              string
	EtcdCertFile            string
	EtcdKeyFile             string
	EtcdTimeout             int
	EtcdPrefix              string
	ClusterName             string
	MysqlConnectionInfo     string
	DBType                  string
	PrometheusMetricPath    string
	EventLogServers         []string
	KubeConfig              string
	KubeAPIQPS              int
	KubeAPIBurst            int
	MaxTasks                int
	MQAPI                   string
	NodeName                string
	Listen                  string
	HostIP                  string
	ServerPort              int
	KubeClient              kubernetes.Interface
	LeaderElectionNamespace string
	LeaderElectionIdentity  string
	WTNamespace             string
	WTDataPVCName           string
	Helm                    Helm
	DefaultOTELServerHost   string // WT_OTEL_SERVER
}

Config config server

type Helm

type Helm struct {
	DataDir    string
	RepoFile   string
	RepoCache  string
	ChartCache string
}

Helm helm configuration.

type Worker

type Worker struct {
	Config
	LogLevel string
	RunMode  string //default,sync
}

Worker worker server

func NewWorker

func NewWorker() *Worker

NewWorker new server

func (*Worker) AddFlags

func (a *Worker) AddFlags(fs *pflag.FlagSet)

AddFlags config

func (*Worker) CheckEnv

func (a *Worker) CheckEnv() error

CheckEnv 检测环境变量

func (*Worker) SetLog

func (a *Worker) SetLog()

SetLog 设置log