crontab

type BaseResponse struct {
	ErrorCode int    `json:"error_code"`
	Error     string `json:"error"`
}

type GatewayStatsItem struct {
	TimePeriod   time.Duration
	SuccessCount int64
	FailCount    int64
}

type GatewayStatsResp struct {
	BaseResponse
	Data map[string]*GatewayStatsItem `json:"data"`
}

type MachineStatsResp struct {
	BaseResponse
	Data struct {
		CPU    float64
		Load   float64
		Memory float64
	} `json:"data"`
}

type MuxStatsResp struct {
	BaseResponse
	Node string
	Data map[string]map[string]struct {
		TimePeriod   time.Duration
		SuccessCount int64
		FailCount    int64
		MaxTime      time.Duration
		MinTime      time.Duration
		TotalTime    time.Duration
	} `json:"data"`
}

type QueueCollect struct {
	// contains filtered or unexported fields
}

type RedisStateCollect struct {
	// contains filtered or unexported fields
}

type RedisStatus struct {
	*dao.Storage

	RunStatus string
	Msg       string
}

type RetryErrorResp struct {
	BaseResponse
	Data []*struct {
		Time     string
		Jobs     string
		SysCode  string
		SysError string
		UserCode string
		UserMsg  string
	} `json:"data"`
}

type SendToCgiReq struct {
	Queue string `binding:"required" json:"queue"`
	Topic string `binding:"required" json:"topic"`
	Node  string `binding:"required" json:"node"`
	Type  string `binding:"required" json:"type"`
	Value string `binding:"required" json:"value"`
}

type SendToTopicResp struct {
	BaseResponse
	Data interface{} `json:"data"`
}

type SystemJobExecCollect struct {
	// contains filtered or unexported fields
}

type TaskDebugData struct {
	Time string
	Jobs string
}

type TaskStatusCollect struct {
	// contains filtered or unexported fields
}

type TopicAlarmCollect struct {
	// contains filtered or unexported fields
}

type TopicAlarmEntry struct {
	Alarm      int `json:"alarm"`
	AlarmRetry int `json:"alarm_retry"`
}

type TopicLengthCollect struct {
	// contains filtered or unexported fields
}

type TopicLengthResp struct {
	BaseResponse
	Data struct {
		Normal  int64
		Retry   int64
		Timeout int64
	} `json:"data"`
}

type TopicMachineMetric struct {
	Node        string
	ConsumeLe50 float64
	ConsumeLe90 float64
	ConsumeLe99 float64
	Succ        float64
	Fail        float64
	SuccQpm     float64
	FailQpm     float64
	Question    string
}

type TopicMachineMetricsCollect struct {
	// contains filtered or unexported fields
}

type TopicOperateResp struct {
	BaseResponse
	Data int64 `json:"data"`
}

type TopicScriptsStatusCheck struct {
	// contains filtered or unexported fields
}