config

Documentation

Index

• type CertConfig
• type ServerConfig
  • func NewConfig() *ServerConfig
  • func (dsc *ServerConfig) Dump() []byte
  • func (dsc *ServerConfig) Parse()

Types

type CertConfig

type CertConfig struct {
	CAFile   string
	CertFile string
	KeyFile  string
	CertPwd  string
	IsSSL    bool
}

CertConfig configuration of Cert

type ServerConfig

type ServerConfig struct {
	conf.FileConfig
	conf.ServiceConfig
	conf.LogConfig
	conf.ProcessConfig
	conf.ServerOnlyCertConfig
	conf.LocalConfig

	ServerCert *CertConfig // cert of the server

	LocalSlots     int `json:"local_slots" value:"0" usage:"local slots define the max slots controller can get from localhost, default is NumCPU-2"`
	LocalPreSlots  int `` /* 139-byte string literal not displayed */
	LocalExeSlots  int `` /* 139-byte string literal not displayed */
	LocalPostSlots int `` /* 142-byte string literal not displayed */
	RemainTime     int `json:"remain_time" value:"120" usage:"controller remain time after there is no active work (seconds)"`

	NoWait             bool `json:"no_wait" value:"false" usage:"if true, controller will quit immediately when no more running task"`
	UseLocalCPUPercent int  `json:"use_local_cpu_percent" value:"0" usage:"how many local idle cpu will be used to execute tasks(0~100)"`
	DisableFileLock    bool `json:"disable_file_lock" value:"false" usage:"if true, controller will launch without file lock"`

	AutoResourceMgr    bool `json:"auto_resource_mgr" value:"false" usage:"if true, controller will auto free and apply resource while work running"`
	ResIdleSecsForFree int  `json:"res_idle_secs_for_free" value:"120" usage:"controller free resource while detect resource has been idle over this"`

	SendCork            bool  `json:"send_cork" value:"false" usage:"if true, controller will send files like tcp cork"`
	SendFileMemoryLimit int64 `json:"send_file_memory_limit" value:"0" usage:"set send file memory limit"`

	SendMemoryCache bool `json:"send_memory_cache" value:"false" usage:"if true, controller will send files with memory cache"`

	NetErrorLimit    int `json:"net_error_limit" value:"3" usage:"define net error limit,make a worker disabled when it's net errors reach this limit"`
	RemoteRetryTimes int `json:"remote_retry_times" value:"1" usage:"define retry times when remote execute failed"`

	EnableLib  bool `json:"enable_lib" value:"false" usage:"if true, controller will enable remote lib.exe"`
	EnableLink bool `json:"enable_link" value:"false" usage:"if true, controller will enable remote link.exe"`

	LongTCP bool `json:"long_tcp" value:"false" usage:"if true, controller will connect to remote worker with long tcp connection"`

	UseDefaultWorker bool `json:"use_default_worker" value:"true" usage:"if true, controller will use first worker available"`

	DynamicPort bool `json:"dynamic_port" value:"false" usage:"if true, controller will listen dynamic port"`

	WorkerOfferSlot bool `json:"worker_offer_slot" value:"false" usage:"if true, controller will get remote slot by worker offer"`
}

ServerConfig : server config

func NewConfig

func NewConfig() *ServerConfig

NewConfig : return config of server

func (*ServerConfig) Dump

func (dsc *ServerConfig) Dump() []byte

Dump encode ServerConfig into json bytes

func (*ServerConfig) Parse

func (dsc *ServerConfig) Parse()

Parse : parse server config