dict

Documentation

Index

• Variables
• func GetFileHead(downloadMode string, transferAddr string, wgetPort string) string
• type CubeAgentRequest
• type CubeAgentResponse
• type DictInfo
• type DictInstance
• type DictShardInfo
  • func GetDictShardScaler(shard int, dictVersionInfo DictVersionInfo, downloadMode string, ...) (info DictShardInfo)
• type DictShardMetaInfo
• type DictStatus
  • func (this DictStatus) String() DictStatusStr
• type DictStatusStr
  • func (this DictStatusStr) Int() (DictStatus, error)
• type DictVersionInfo
• type DonefileInfo
• type InstanceStatus
  • func (this InstanceStatus) String() InstanceStatusStr
• type InstanceStatusStr
  • func (this InstanceStatusStr) Int() (InstanceStatus, error)
• type MetaInfo

Variables

var (
	// Dict Mode
	BASE_ONLY  = "base_only"
	BASR_DELTA = "base_delta"

	// Deploy Mode
	BASE  = "base"
	DELTA = "delta"

	// Succ or Failed Status
	SUCC   = "succ"
	FAILED = "failed"

	//command
	DOWNLOAD = "download"
	RELOAD   = "reload"
	ENABLE   = "enable"

	FTP_HEADER  = "ftp://"
	HTTP_HEADER = "http://"
)

Functions

func GetFileHead

func GetFileHead(downloadMode string, transferAddr string, wgetPort string) string

Types

type CubeAgentRequest

type CubeAgentRequest struct {
	Command           string `json:"command"`
	DictName          string `json:"dict_name"`
	DeployPath        string `json:"deploy_path"`
	Version           string `json:"version"`
	Depend            string `json:"depend"`
	Id                string `json:"id"`
	Key               string `json:"key"`
	Mode              string `json:"mode"`
	ShardSeq          int    `json:"shard_seq"`
	Source            string `json:"source"`
	Service           string `json:"service,omitempty"`
	SlotIdList        string `json:"slot_id_list,omitempty"`
	ActiveVersionList string `json:"active_version_list,omitempty"`
	Port              string `json:"port,omitempty"`
	VersionSign       string `json:"version_sign,omitempty"`
}

type CubeAgentResponse

type CubeAgentResponse struct {
	Success string `json:"success"`
	Message string `json:"message"`
	Data    string `json:"data"`
}

type DictInfo

type DictInfo struct {
	DictName           string            `json:"dict_name"`
	DictMode           string            `json:"dict_mode"`
	ShardNum           int               `json:"shard_num"`
	CopyNum            int               `json:"copy_num"`
	InstancesNum       int               `json:"inst_num"`
	DeployPath         string            `json:"deploy_path"`
	DonefileAddress    string            `json:"donefile_addr"`
	OutputAddress      string            `json:"output_addr"`
	TmpAddress         string            `json:"tmp_addr"`
	DownloadMode       string            `json:"download_mode"`
	WgetPort           string            `json:"wget_port"`
	DownloadSuccInsts  int               `json:"download_inst"`
	ReloadSuccInsts    int               `json:"reload_insts"`
	EnableSuccInsts    int               `json:"enable_insts"`
	Instances          []DictInstance    `json:"instances"`
	WaitVersionInfo    DictVersionInfo   `json:"wait_version_info"`
	CurrentVersionInfo []DictVersionInfo `json:"current_version_info"`
}

type DictInstance

type DictInstance struct {
	DictName          string            `json:"dict_name"`
	Mode              string            `json:"mode"`
	Version           int               `json:"version"`
	Depend            int               `json:"depend"`
	Id                int               `json:"id"`
	Key               int               `json:"key"`
	Shard             int               `json:"shard"`
	Source            string            `json:"source"`
	DeployPath        string            `json:"deploy_path"`
	IP                string            `json:"ip"`
	Port              int               `json:"port"`
	AgentIp           string            `json:"agent_ip"`
	AgentPort         int               `json:"agent_port"`
	Status            InstanceStatus    `json:"status_id"`
	StatusStr         InstanceStatusStr `json:"status"`
	BuildedTime       int               `json:"builded_time"`
	DownloadStartTime int               `json:"download_start_time"`
	DownloadedTime    int               `json:"downloaded_time"`
	ReloadStartTime   int               `json:"reload_start_time"`
	ReloadedTime      int               `json:"reloaded_time"`
	EnablStartTime    int               `json:"enable_start_time"`
	EnabledTime       int               `json:"enabled_time"`
	CreateTime        int               `json:"create_time"`
}

type DictShardInfo

type DictShardInfo struct {
	Name           string `json:"name"`
	Version        string `json:"version"`
	Depend         string `json:"depend"`
	Id             string `json:"id"`
	Key            string `json:"key"`
	Shard          int    `json:"shard"`
	Mode           string `json:"mode"`
	DictMode       string `json:"dict_mode,omitempty"`
	Source         string `json:"data_source"`
	Service        string `json:"service,omitempty"`
	DeltaInfo      string `json:"delta_info,omitempty"`
	BuildedTime    int    `json:"builded_time,omitempty"`
	BuildedTimeStr string `json:"build_finish_time,omitempty"`
	CreateTime     int    `json:"create_time,omitempty"`
	IsActive       bool   `json:"is_active,omitempty"`
}

func GetDictShardScaler

func GetDictShardScaler(shard int, dictVersionInfo DictVersionInfo, downloadMode string, transferAddr string, wgetPort string) (info DictShardInfo)

type DictShardMetaInfo

type DictShardMetaInfo struct {
	Name    string `json:"name"`
	Version int    `json:"version"`
	Depend  int    `json:"depend"`
	Shard   int    `json:"shard"`
	Split   int    `json:"split"`
	Meta    string `json:"meta"`
}

type DictStatus

type DictStatus int

Dict Status

const (
	// Dict Status
	//clear状态编码参考InstanceStatus
	Dict_Status_Clearing      DictStatus = 1
	Dict_Status_Cleared       DictStatus = 2
	Dict_Status_Trigging      DictStatus = 10
	Dict_Status_Building      DictStatus = 20
	Dict_Status_Deploying     DictStatus = 30
	Dict_Status_Downloading   DictStatus = 40
	Dict_Status_Download_Succ DictStatus = 50
	Dict_Status_Reloading     DictStatus = 60
	Dict_Status_Reload_Succ   DictStatus = 70
	Dict_Status_Enabling      DictStatus = 80
	Dict_Status_Finished      DictStatus = 90
	Dict_Status_Restarting    DictStatus = 100
)

func (DictStatus) String

func (this DictStatus) String() DictStatusStr

type DictStatusStr

type DictStatusStr string

const (
	// Dict Status
	Dict_Status_Trigging_Str      DictStatusStr = "Trigging"
	Dict_Status_Building_Str      DictStatusStr = "Building"
	Dict_Status_Deploying_Str     DictStatusStr = "deploying"
	Dict_Status_Downloading_Str   DictStatusStr = "downloading"
	Dict_Status_Download_Succ_Str DictStatusStr = "download_succ"
	Dict_Status_Reloading_Str     DictStatusStr = "reloading"
	Dict_Status_Reload_Succ_Str   DictStatusStr = "reload_succ"
	Dict_Status_Enabling_Str      DictStatusStr = "enabling"
	Dict_Status_Finished_Str      DictStatusStr = "finished"
	Dict_Status_Restarting_Str    DictStatusStr = "restarting"
	Dict_Status_Clearing_Str      DictStatusStr = "clearing"
	Dict_Status_Cleared_Str       DictStatusStr = "cleared"
)

func (DictStatusStr) Int

func (this DictStatusStr) Int() (DictStatus, error)

type DictVersionInfo

type DictVersionInfo struct {
	DictName   string         `json:"dict_name"`
	Version    int            `json:"version"`
	Depend     int            `json:"depend"`
	Id         int            `json:"id"`
	Key        int            `json:"key"`
	Mode       string         `json:"mode"`
	Input      string         `json:"input"`
	Output     string         `json:"output"`
	Status     DictStatus     `json:"status"`
	StatusStr  DictStatusStr  `json:"status_str"`
	FinishTime int            `json:"finish_time"`
	CreateTime int            `json:"create_time"`
	MetaInfos  map[int]string `json:"meta_infos"`
}

type DonefileInfo

type DonefileInfo struct {
	Id    string `json:"id"`
	Key   string `json:"key"`
	Input string `json:"input"`
}

type InstanceStatus

type InstanceStatus int

Instance Status:

const (
	//各种状态都有可能进入clear状态，因此clear相关的状态都小于init状态
	Instance_Status_Clear           InstanceStatus = 1
	Instance_Status_Clearing        InstanceStatus = 2
	Instance_Status_Clear_Failed    InstanceStatus = 3
	Instance_Status_Clear_Succ      InstanceStatus = 4
	Instance_Status_Init            InstanceStatus = 10
	Instance_Status_Downloading     InstanceStatus = 20
	Instance_Status_Download_Failed InstanceStatus = 30
	Instance_Status_Download_Succ   InstanceStatus = 40
	Instance_Status_Reloading       InstanceStatus = 50
	Instance_Status_Reload_Failed   InstanceStatus = 60
	Instance_Status_Reload_Succ     InstanceStatus = 70
	Instance_Status_Enabling        InstanceStatus = 80
	Instance_Status_Enable_Failed   InstanceStatus = 90
	Instance_Status_Enable_Succ     InstanceStatus = 100
	Instance_Status_Poping          InstanceStatus = 110
	Instance_Status_Pop_Failed      InstanceStatus = 120
	Instance_Status_Pop_Succ        InstanceStatus = 130
	Instance_Status_Dead            InstanceStatus = 250
)

func (InstanceStatus) String

func (this InstanceStatus) String() InstanceStatusStr

type InstanceStatusStr

type InstanceStatusStr string

const (
	Instance_Status_Init_Str            InstanceStatusStr = "init"
	Instance_Status_Downloading_Str     InstanceStatusStr = "downloading"
	Instance_Status_Download_Failed_Str InstanceStatusStr = "download_failed"
	Instance_Status_Download_Succ_Str   InstanceStatusStr = "download_succ"
	Instance_Status_Reloading_Str       InstanceStatusStr = "reloading"
	Instance_Status_Reload_Failed_Str   InstanceStatusStr = "finish_reload_failed"
	Instance_Status_Reload_Succ_Str     InstanceStatusStr = "finish_reload_succ"
	Instance_Status_Enabling_Str        InstanceStatusStr = "enabling"
	Instance_Status_Enable_Failed_Str   InstanceStatusStr = "enable_failed"
	Instance_Status_Enable_Succ_Str     InstanceStatusStr = "enable_succ"
	Instance_Status_Dead_Str            InstanceStatusStr = "dead"
	Instance_Status_Clear_Str           InstanceStatusStr = "clear"
	Instance_Status_Clearing_Str        InstanceStatusStr = "clearing"
	Instance_Status_Clear_Failed_Str    InstanceStatusStr = "clear_failed"
	Instance_Status_Clear_Succ_Str      InstanceStatusStr = "clear_succ"
	Instance_Status_Poping_Str          InstanceStatusStr = "poping"
	Instance_Status_Pop_Failed_Str      InstanceStatusStr = "pop_failed"
	Instance_Status_Pop_Succ_Str        InstanceStatusStr = "pop_succ"
)

func (InstanceStatusStr) Int

func (this InstanceStatusStr) Int() (InstanceStatus, error)

type MetaInfo

type MetaInfo struct {
	IndexTotalCount string   `json:"index_total_count"`
	IndexLenList    []string `json:"index_len_list"`
	DataLenList     []string `json:"data_len_list"`
}