Documentation
¶
Index ¶
- Constants
- Variables
- func BackupTransfer()
- func BuildIndex(versionInfo dict.DictVersionInfo) string
- func BuilderStart(versionInfo dict.DictVersionInfo) error
- func CmdInstsDownload()
- func CmdInstsEnable()
- func CmdInstsReload()
- func DeployStart(versionInfo dict.DictVersionInfo) error
- func ExeCommad(files string, params []string) (err error)
- func GetDictDeployHistory(subpath string, m map[string]string) (string, string, int, error)
- func GetDictInfo(subpath string, m map[string]string) (string, string, int, error)
- func GetDictScaler(subpath string, m map[string]string) (string, string, int, error)
- func GetDictShardMetaInfo(subpath string, m map[string]string) (string, string, int, error)
- func GetDictShardMetaInfos(dictName string, version int, depend int, shard int, split int) (dict.DictShardMetaInfo, error)
- func GetDoneFileInfo(addr string) (version dict.DictVersionInfo, err error)
- func GetInstanceStatus(subpath string, m map[string]string) (string, string, int, error)
- func InitAllInstances()
- func PostDictShardMetaInfoRegister(subpath string, m map[string]string) (string, string, int, error)
- func Start()
- func TriggerStart(addr string) (version dict.DictVersionInfo, err error)
- func UpdateDictShardMetaInfo(shardMetaInfo dict.DictShardMetaInfo) error
- func Wget(ftpPath string, downPath string)
- func WriteCurrentVersionInfoToFile()
- func WriteWaitVersionInfoToFile()
- type ConfigManager
- type HDFSAddress
- type LocalAddress
Constants ¶
View Source
const ( STATUS_OK int = 0 STATUS_WRONG_API int = 2 STATUS_RETRY_LATER int = 10 STATUS_FAIL int = 255 )
Variables ¶
Functions ¶
func BackupTransfer ¶
func BackupTransfer()
func BuildIndex ¶
func BuildIndex(versionInfo dict.DictVersionInfo) string
func BuilderStart ¶
func BuilderStart(versionInfo dict.DictVersionInfo) error
func CmdInstsDownload ¶
func CmdInstsDownload()
func CmdInstsEnable ¶
func CmdInstsEnable()
func CmdInstsReload ¶
func CmdInstsReload()
func DeployStart ¶
func DeployStart(versionInfo dict.DictVersionInfo) error
func GetDictDeployHistory ¶
func GetDictInfo ¶
func GetDictScaler ¶
func GetDictShardMetaInfo ¶
func GetDictShardMetaInfos ¶
func GetDoneFileInfo ¶
func GetDoneFileInfo(addr string) (version dict.DictVersionInfo, err error)
func GetInstanceStatus ¶
func InitAllInstances ¶
func InitAllInstances()
func TriggerStart ¶
func TriggerStart(addr string) (version dict.DictVersionInfo, err error)
func UpdateDictShardMetaInfo ¶
func UpdateDictShardMetaInfo(shardMetaInfo dict.DictShardMetaInfo) error
func WriteCurrentVersionInfoToFile ¶
func WriteCurrentVersionInfoToFile()
func WriteWaitVersionInfoToFile ¶
func WriteWaitVersionInfoToFile()
Types ¶
type ConfigManager ¶
func (*ConfigManager) Init ¶
func (c *ConfigManager) Init(path string)
func (ConfigManager) Read ¶
func (c ConfigManager) Read(node, key string) string
type HDFSAddress ¶
type HDFSAddress string
type LocalAddress ¶
type LocalAddress string
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.