MiFaZhan
31 lines
1.1 KiB
Go
31 lines
1.1 KiB
Go
package v1
|
|
|
|
import "github.com/gogf/gf/v2/frame/g"
|
|
|
|
type FullSyncReplayReq struct {
|
|
g.Meta `path:"/fullSyncRuns/replay" method:"post" tags:"全量同步" summary:"重投Run失败卡" x-check-permission:"cpm:iot:fullSyncRuns:replay"`
|
|
SourceRunID string `json:"sourceRunId" v:"required"`
|
|
// MaxRounds 省略或为 0 时使用 Worker 配置默认值（当前 3）；显式范围为 1..100。
|
|
MaxRounds int `json:"maxRounds" v:"min:0|max:100"`
|
|
}
|
|
|
|
type FullSyncReplayRes struct {
|
|
ReplayRunID string `json:"replayRunId"`
|
|
Status string `json:"status"`
|
|
}
|
|
|
|
type FullSyncReplayStatusReq struct {
|
|
g.Meta `path:"/fullSyncRuns/replay/{replayRunId}" method:"get" tags:"全量同步" summary:"查看重投状态" x-check-permission:"cpm:iot:fullSyncRuns:replay:view"`
|
|
ReplayRunID string `json:"replayRunId" v:"required"`
|
|
}
|
|
|
|
type FullSyncReplayStatusRes struct {
|
|
ReplayRunID string `json:"replayRunId"`
|
|
SourceRunID string `json:"sourceRunId"`
|
|
Status string `json:"status"`
|
|
Remaining int64 `json:"remaining"`
|
|
Enqueued int64 `json:"enqueued"`
|
|
RunStatus string `json:"runStatus,omitempty"`
|
|
Error string `json:"error,omitempty"`
|
|
}
|