common

package
v0.0.0-...-161ecb4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 15, 2020 License: MIT Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CrontabFlowDetailInputModel 

type CrontabFlowDetailInputModel struct {
	Id string `json:"id"`
}

type CrontabFlowListInputModel 

type CrontabFlowListInputModel struct {
	PaginationInputModel
	Id       string `json:"id"`
	Name     string `json:"name"`
	FlowType int32  `json:"flow_type"`
	Status   int32  `json:"status"`
}

type CrontabFlowListOutputModel 

type CrontabFlowListOutputModel struct {
	PaginationOutputModel
	Data []*CrontabFlowModel `json:"data"`
}

type CrontabFlowModel 

type CrontabFlowModel struct {
	Id         string `gorm:"not null; column:id" json:"id"`
	Name       string `gorm:"not null; column:name" json:"name"`
	Info       string `gorm:"not null; column:info" json:"info"`
	FlowType   int32  `gorm:"not null; column:flow_type" json:"flow_type"`
	Spec       string `gorm:"not null; column:spec" json:"spec"`
	Desc       string `gorm:"not null; column:desc" json:"desc"`
	Status     int32  `gorm:"not null; column:status" json:"status"`
	CreateTime int64  `gorm:"not null; column:create_time" json:"create_time"`
	UpdateTime int64  `gorm:"not null; column:update_time" json:"update_time"`
}

type CrontabJobDetailInputModel 

type CrontabJobDetailInputModel struct {
	Id string `json:"id"`
}

type CrontabJobListInputModel 

type CrontabJobListInputModel struct {
	PaginationInputModel
	Id      string `json:"id"`
	Name    string `json:"name"`
	JobType int32  `json:"job_type"`
	Status  int32  `json:"status"`
}

type CrontabJobListOutputModel 

type CrontabJobListOutputModel struct {
	PaginationOutputModel
	Data []*CrontabJobModel `json:"data"`
}

type CrontabJobModel 

type CrontabJobModel struct {
	Id         string `gorm:"not null; column:id" json:"id"`
	Name       string `gorm:"not null; column:name" json:"name"`
	JobType    int32  `gorm:"not null; column:job_type" json:"job_type"`
	Info       string `gorm:"not null; column:info" json:"info"`
	Desc       string `gorm:"not null; column:desc" json:"desc"`
	Status     int32  `gorm:"not null; column:status" json:"status"`
	CreateTime int64  `gorm:"not null; column:create_time" json:"create_time"`
	UpdateTime int64  `gorm:"not null; column:update_time" json:"update_time"`
}

type CrontabLogFlowListInputModel 

type CrontabLogFlowListInputModel struct {
	PaginationInputModel
	Id        *bigint.BigInt `json:"id"`
	FatherId  *bigint.BigInt `json:"father_id"`
	WorkIp    string         `json:"name"`
	FlowId    string         `json:"flow_id"`
	FlowName  string         `json:"flow_name"`
	StartTime int64          `json:"start_time"`
	EndTime   int64          `json:"end_time"`
}

type CrontabLogFlowListOutputModel 

type CrontabLogFlowListOutputModel struct {
	PaginationOutputModel
	Data []*CrontabLogFlowModel `json:"data"`
}

type CrontabLogFlowModel 

type CrontabLogFlowModel struct {
	Id         int64                 `gorm:"not null; column:id" json:"id"`
	FatherId   int64                 `gorm:"not null; column:father_id" json:"father_id"`
	WorkerIp   string                `gorm:"not null; column:worker_ip" json:"worker_ip"`
	FlowId     string                `gorm:"not null; column:flow_id" json:"flow_id"`
	FlowName   string                `gorm:"not null; column:flow_name" json:"flow_name"`
	FlowInfo   string                `gorm:"not null; column:flow_info" json:"flow_info"`
	StartTime  int64                 `gorm:"not null; column:start_time" json:"start_time"`
	EndTime    int64                 `gorm:"not null; column:end_time" json:"end_time"`
	Input      string                `gorm:"not null; column:input" json:"input"`
	Output     string                `gorm:"not null; column:output" json:"output"`
	ErrorMsg   string                `gorm:"not null; column:error_msg" json:"error_msg"`
	Desc       string                `gorm:"not null; column:desc" json:"desc"`
	CreateTime int64                 `gorm:"not null; column:create_time" json:"create_time"`
	UpdateTime int64                 `gorm:"not null; column:update_time" json:"update_time"`
	LogJob     []*CrontabLogJobModel `json:"log_job"`
}

type CrontabLogJobListInputModel 

type CrontabLogJobListInputModel struct {
	PaginationInputModel
	Id        *bigint.BigInt `json:"id"`
	FatherId  *bigint.BigInt `json:"father_id"`
	TraceId   *bigint.BigInt `json:"trace_id"`
	WorkIp    string         `json:"name"`
	FlowId    string         `json:"flow_id"`
	FlowName  string         `json:"flow_name"`
	JobId     string         `json:"job_id"`
	JobName   string         `json:"job_name"`
	StartTime int64          `json:"start_time"`
	EndTime   int64          `json:"end_time"`
}

type CrontabLogJobListOutputModel 

type CrontabLogJobListOutputModel struct {
	PaginationOutputModel
	Data []*CrontabLogJobModel `json:"data"`
}

type CrontabLogJobModel 

type CrontabLogJobModel struct {
	Id         int64  `gorm:"not null; column:id" json:"id"`
	FatherId   int64  `gorm:"not null; column:father_id" json:"father_id"`
	TraceId    int64  `gorm:"not null; column:trace_id" json:"trace_id"`
	WorkerIp   string `gorm:"not null; column:worker_ip" json:"worker_ip"`
	FlowId     string `gorm:"not null; column:flow_id" json:"flow_id"`
	FlowName   string `gorm:"not null; column:flow_name" json:"flow_name"`
	FlowInfo   string `gorm:"not null; column:flow_info" json:"flow_info"`
	JobId      string `gorm:"not null; column:job_id" json:"job_id"`
	JobName    string `gorm:"not null; column:job_name" json:"job_name"`
	JobInfo    string `gorm:"not null; column:job_info" json:"job_info"`
	StartTime  int64  `gorm:"not null; column:start_time" json:"start_time"`
	EndTime    int64  `gorm:"not null; column:end_time" json:"end_time"`
	Input      string `gorm:"not null; column:input" json:"input"`
	Output     string `gorm:"not null; column:output" json:"output"`
	ErrorMsg   string `gorm:"not null; column:error_msg" json:"error_msg"`
	Desc       string `gorm:"not null; column:desc" json:"desc"`
	CreateTime int64  `gorm:"not null; column:create_time" json:"create_time"`
	UpdateTime int64  `gorm:"not null; column:update_time" json:"update_time"`
}

type CrontabWorkerModel 

type CrontabWorkerModel struct {
	Id           int64    `gorm:"not null; column:id" json:"id"`
	Name         string   `gorm:"not null; column:name" json:"name"`
	OS           string   `gorm:"not null; column:os" json:"os"`
	ARCH         string   `gorm:"not null; column:arch" json:"arch"`
	Ip           string   `gorm:"not null; column:ip" json:"ip"`
	JobList      []string `gorm:"type:varchar[]; not null; column:job_list" json:"job_list"`
	StatusOnline int32    `gorm:"not null; column:status_online" json:"status_online"`
	Status       int32    `gorm:"not null; column:status" json:"status"`
	CreateTime   int64    `gorm:"not null; column:create_time" json:"create_time"`
	UpdateTime   int64    `gorm:"not null; column:update_time" json:"update_time"`
}

type ETCDKeysInputModel 

type ETCDKeysInputModel struct {
	Client string          `json:"client"`
	Prefix etcd.PrefixEnum `json:"prefix"`
	Key    string          `json:"key"`
}

type ETCDKeysOutputModel 

type ETCDKeysOutputModel struct {
	Keys []*etcd.EtcdItem `json:"keys"`
}

type FlowDoInputModel 

type FlowDoInputModel struct {
	FlowId  string             `json:"flow_id"`
	DoForce map[int32]struct{} `json:"do_force"`
	Date    int64              `json:"date"`
}

type FlowInfo 

type FlowInfo struct {
	FlowId  string             `json:"flow_id"`
	Force   bool               `json:"force"`
	DoForce map[int32]struct{} `json:"do_force"`
	Date    int64              `json:"date"`
}

type FlowInfoEnvironModel 

type FlowInfoEnvironModel struct {
	FlowInfoModel
	FlowDirLinux   string `json:"flow_dir_linux"`
	InitDirLinux   string `json:"init_dir_linux"`
	FlowDirWindows string `json:"flow_dir_windows"`
	InitDirWindows string `json:"init_dir_windows"`
}

type FlowInfoEnvironScrapyModel 

type FlowInfoEnvironScrapyModel struct {
	FlowInfoModel
}

type FlowInfoModel 

type FlowInfoModel struct {
	Jobs map[int32][]string `json:"jobs"`
}

type JobInfo 

type JobInfo struct {
	DoForce   bool                   `json:"do_force"`
	TraceId   int64                  `json:"trace_id"`
	FlowId    string                 `json:"flow_id"`
	FlowName  string                 `json:"flow_name"`
	FlowInfo  string                 `json:"flow_info"`
	FlowTye   int32                  `json:"flow_tye"`
	JobId     string                 `json:"job_id"`
	JobName   string                 `json:"job_name"`
	JobType   int32                  `json:"job_type"`
	JobInfo   string                 `json:"job_info"`
	FlowInput map[string]interface{} `json:"flow_input"`
	JobInput  map[string]interface{} `json:"job_input"`
}

type JobInfoBaseModel 

type JobInfoBaseModel struct {
	Id      string `json:"id"`
	Name    string `json:"name"`
	JobType int32  `json:"job_type"`
}

type JobInfoCommandModel 

type JobInfoCommandModel struct {
	JobInfoBaseModel
	Command string   `json:"command"`
	Args    []string `json:"args"`
}

type JobInfoEnvironCalMetModel 

type JobInfoEnvironCalMetModel struct {
	JobInfoBaseModel
	JobDir     string `json:"job_dir"`
	Shell      string `json:"shell"`
	Arg        string `json:"arg"`
	Exe        string `json:"exe"`
	LogFile    string `json:"log_file"`
	InitExeDir string `json:"init_exe_dir"`
	InitConfig string `json:"init_config"`
	CalWRFDir  string `json:"cal_wrf_dir"`
}

type JobInfoEnvironCalPostModel 

type JobInfoEnvironCalPostModel struct {
	JobInfoBaseModel
	JobDir         string  `json:"job_dir"`
	Shell          string  `json:"shell"`
	Arg            string  `json:"arg"`
	Rec            []int32 `json:"rec"`
	LogFile        string  `json:"log_file"`
	InitExeFile    string  `json:"init_exe_file"`
	ModelDir       string  `json:"model_dir"`
	InitConfigFile string  `json:"init_config_file"`
	CalSumDir      string  `json:"cal_sum_dir"`
	PostUtilDir    string  `json:"post_util_dir"`
}

type JobInfoEnvironCalPuffModel 

type JobInfoEnvironCalPuffModel struct {
	JobInfoBaseModel
	JobDir     string   `json:"job_dir"`
	Shell      string   `json:"shell"`
	Arg        string   `json:"arg"`
	Exe        []string `json:"exe"`
	LogFiles   []string `json:"log_files"`
	InitExeDir string   `json:"init_exe_dir"`
	CalMETDir  string   `json:"cal_met_dir"`
	InitConfig string   `json:"init_config"`
}

type JobInfoEnvironCalSumModel 

type JobInfoEnvironCalSumModel struct {
	JobInfoBaseModel
	JobDir     string `json:"job_dir"`
	Shell      string `json:"shell"`
	Arg        string `json:"arg"`
	Exe        string `json:"exe"`
	LogFile    string `json:"log_file"`
	InitExeDir string `json:"init_exe_dir"`
	CalPuffDir string `json:"cal_puff_dir"`
	InitConfig string `json:"init_config"`
}

type JobInfoEnvironCalWrfModel 

type JobInfoEnvironCalWrfModel struct {
	JobInfoBaseModel
	JobDir     string `json:"job_dir"`
	Shell      string `json:"shell"`
	Arg        string `json:"arg"`
	Exe        string `json:"exe"`
	LogFile    string `json:"log_file"`
	WRFOutDir  string `json:"wrf_out_dir"`
	InitExeDir string `json:"init_exe_dir"`
	InitConfig string `json:"init_config"`
}

type JobInfoEnvironDownloadModel 

type JobInfoEnvironDownloadModel struct {
	JobInfoBaseModel
	JobDir       string `json:"job_dir"`
	UCARUsername string `json:"ucar_username"`
	UCARPassword string `json:"ucar_password"`
}

type JobInfoEnvironPostUtilModel 

type JobInfoEnvironPostUtilModel struct {
	JobInfoBaseModel
	JobDir     string `json:"job_dir"`
	Shell      string `json:"shell"`
	Arg        string `json:"arg"`
	Exe        string `json:"exe"`
	LogFile    string `json:"log_file"`
	InitExeDir string `json:"init_exe_dir"`
	InitConfig string `json:"init_config"`
	CalSumDir  string `json:"cal_sum_dir"`
}

type JobInfoEnvironScrapyModel 

type JobInfoEnvironScrapyModel struct {
	JobInfoBaseModel
	JobDir string `json:"job_dir"`
}

type JobInfoEnvironWpsWrfModel 

type JobInfoEnvironWpsWrfModel struct {
	JobInfoBaseModel
	JobDir            string              `json:"job_dir"`
	Shell             string              `json:"shell"`
	Arg               string              `json:"arg"`
	Command           string              `json:"command"`
	LogFiles          map[string][]string `json:"log_files"`
	WorkDir           string              `json:"work_dir"`
	InitConfigCommand string              `json:"init_config_command"`
	InitConfigWPS     []string            `json:"init_config_wps"`
	InitConfigWRF     []string            `json:"init_config_wrf"`
}

type JobResultInfo 

type JobResultInfo struct {
	DoForce    bool                   `json:"do_force"`
	TraceId    int64                  `json:"trace_id"`
	FlowId     string                 `json:"flow_id"`
	FlowName   string                 `json:"flow_name"`
	FlowInfo   string                 `json:"flow_info"`
	FlowTye    int32                  `json:"flow_tye"`
	JobId      string                 `json:"job_id"`
	JobName    string                 `json:"job_name"`
	JobInfo    string                 `json:"job_info"`
	JobType    int32                  `json:"job_type"`
	StartTime  int64                  `json:"start_time"`
	EndTime    int64                  `json:"end_time"`
	FlowInput  map[string]interface{} `json:"flow_input"`
	JobInput   map[string]interface{} `json:"job_input"`
	FlowOutput map[string]interface{} `json:"flow_output"`
	JobOutput  map[string]interface{} `json:"job_output"`
	ErrorMsg   string                 `json:"error_msg"`
	Desc       string                 `json:"desc"`
}

type PaginationInputModel 

type PaginationInputModel struct {
	SortValue string `json:"sort_value"` //排序方式，id desc
	Offset    int64  `json:"offset"`     //跳过的数据条数
	Limit     int64  `json:"limit"`      //单页条数
}

type PaginationOutputModel 

type PaginationOutputModel struct {
	Total  int64 `json:"total"`  //总条数
	Offset int64 `json:"offset"` //跳过的数据条数，同传入数据
	Limit  int64 `json:"limit"`  //单页条数，同传入数据
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.