Documentation ¶
Index ¶
- Constants
- Variables
- func CreateSymlink(dictName, service, version, depend, dataPath, deployPath string, ...) (err error)
- func DoDownload(dictName, service, version, depend, mode, source, deployPath string, ...) (err error)
- func DoDownloadIndividual(source, downloadDir string, isService bool, timeOut int, ch chan error, ...)
- func FtpDownload(source string, dest string, timeOut int) (err error)
- func GetDataLinkDirs(dictName, service, version, depend, deployPath string, shardSeq, split int) []string
- func GetDownloadDirs(dictName, service, version, depend, deployPath string, shardSeq, split int) ([]string, error)
- func GetFileName(source string) (fileName string)
- func GetHdfsMeta(src string) (master, ugi, path string, err error)
- func GetLocalHostname() (hostname string, err error)
- func GetLocalHostnameCmd() (hostname string, err error)
- func GetMaster(master string) (host, port string, err error)
- func GetStatus(subpath string, m map[string]string, b []byte) (string, string, error)
- func JsonReq(method, requrl string, timeout int, kv *map[string]string, out interface{}) error
- func PostCmd(subpath string, m map[string]string, b []byte) (string, string, error)
- func RemoveStateFile(dictName string, shardSeq int, service string)
- func RestReq(method, requrl string, timeout int, kv *map[string]string) (string, error)
- func RetryCmd(cmd string, retryTimes int) (stdoutStr string, stderrStr string, err error)
- func RetryCmdWithSleep(cmd string, retryTimes int) (stdoutStr string, stderrStr string, err error)
- func StartHttp(addr string) error
- func UnTar(dictName, service, version, depend, source, deployPath string, shardSeq int) (err error)
- type CubeResp
- type MasterResp
- type PoolWorker
- type ShardInfo
- type Status
- type VersionInfo
- type Work
- func (work *Work) Check() (err error)
- func (work *Work) CheckToReload() bool
- func (work *Work) Clear() (err error)
- func (work *Work) DoWork() error
- func (work *Work) Download() (err error)
- func (work *Work) Enable() (err error)
- func (work *Work) Pop() (err error)
- func (work *Work) Reload() (err error)
- func (work *Work) Token() string
- func (work *Work) Valid() bool
- type WorkPool
Constants ¶
View Source
const ( COMMAND_DOWNLOAD = "download" COMMAND_RELOAD = "reload" COMMAND_SWITCH = "enable" COMMAND_ROLLBACK = "rollback" COMMAND_CHECK = "check" COMMAND_CLEAR = "clear" COMMAND_POP = "pop" RETRY_TIMES = 3 REQUEST_MASTER_TIMEOUT_SECOND = 60 MAX_DOWN_CO = 7 RELOAD_RETRY_TIMES = 3 RELOAD_RETRY_INTERVAL_SECOND = 10 DOWNLOAD_DONE_MARK_FILE = ".download_done" )
Variables ¶
View Source
var ( Dir string WorkerNum int QueueCapacity int32 MasterHost []string MasterPort []string TestHostname string TestIdc string ShardLock sync.RWMutex CmdWorkPool *WorkPool CmdWorkFilter sync.Map )
View Source
var BUILTIN_STATUS = Status{"RUNNING", "3.0.0.1"}
View Source
var ShardInfoMap map[string]map[string]*ShardInfo
Functions ¶
func CreateSymlink ¶
func DoDownload ¶
func DoDownloadIndividual ¶
func GetDataLinkDirs ¶
func GetDownloadDirs ¶
func GetFileName ¶
func GetHdfsMeta ¶
func GetLocalHostname ¶
func GetLocalHostnameCmd ¶
func RemoveStateFile ¶
func RetryCmdWithSleep ¶
Types ¶
type MasterResp ¶
type PoolWorker ¶
type PoolWorker interface { Token() string DoWork() }
type VersionInfo ¶
type Work ¶
type Work struct { DictName string `json:"dict_name"` ShardSeq int `json:"shard_seq"` DeployPath string `json:"deploy_path"` Command string `json:"command"` Version string `json:"version"` Depend string `json:"depend"` Source string `json:"source"` Mode string `json:"mode"` DictMode string `json:"dict_mode"` Port string `json:"port"` RollbackInfo []VersionInfo `json:"rollback_info"` Status string `json:"status"` FinishStatus string `json:"finish_status"` Service string `json:"service,omitempty"` VersionSign string `json:"version_sign,omitempty"` MasterAddress string `json:"master_address,omitempty"` ActiveVersionList string `json:"active_version_list,omitempty"` // contains filtered or unexported fields }
func (*Work) CheckToReload ¶
type WorkPool ¶
type WorkPool struct {
// contains filtered or unexported fields
}
func NewWorkPool ¶
func (*WorkPool) PostWork ¶
func (workPool *WorkPool) PostWork(poolWorker PoolWorker) (err error)
func (*WorkPool) PostWorkWithToken ¶
func (workPool *WorkPool) PostWorkWithToken(poolWorker PoolWorker) (err error)
Click to show internal directories.
Click to hide internal directories.