jobs

type ArgChain struct {
	ChainSeq  int  `json:"chain_seq,omitempty" form:"-"`
	ChainData bool `json:"chain_data,omitempty" form:"chain_data"`
}

type ArgIDRange struct {
	IdFrom int64 `json:"id_from,omitempty" form:"id_from,strip" validate:"min=0"`
	IdTo   int64 `json:"id_to,omitempty" form:"id_to,strip" validate:"omitempty,min=0,gtefield=IdFrom"`
}

type ArgItems struct {
	Items int `json:"items,omitempty" form:"items,strip" validate:"min=0"`
}

type ArgPeriod struct {
	Start time.Time `json:"start,omitempty" form:"start"`
	End   time.Time `json:"end,omitempty" form:"end" validate:"omitempty,gtefield=Start"`
}

type FailedItem struct {
	ID    int64  `json:"id"`
	Title string `json:"title"`
	Error string `json:"error"`
}

type IArg interface {
	Bind(c *xin.Context) error
}

type IArgChain interface {
	GetChain() (int, bool)
	SetChain(chainSeq int, chainData bool)
}

type IRun interface {
	Run()
}

type JobArgCreater func(*tenant.Tenant) IArg

type JobRunCreator func(*tenant.Tenant, *xjm.Job) IRun

type JobRunState struct {
	JID    int64    `json:"jid"`
	Name   string   `json:"name"`
	Status string   `json:"status"`
	Error  string   `json:"error"`
	State  JobState `json:"state"`
}

type JobRunner[T any] struct {
	*xjm.JobRunner
	ArgChain

	Tenant *tenant.Tenant
	Logger log.Logger
	Arg    T
}

type JobState struct {
	Step    int `json:"step,omitempty"`
	Count   int `json:"count,omitempty"`
	Total   int `json:"total,omitempty"`
	Limit   int `json:"limit,omitempty"`
	Exists  int `json:"exists,omitempty"`
	Skipped int `json:"skipped,omitempty"`
	Success int `json:"success,omitempty"`
	Failure int `json:"failure,omitempty"`
}

type JobStateEx struct {
	JobState
	LastID int64 `json:"last_id,omitempty"`
}

type JobStateFsx struct {
	JobStateSx
	LastID        int64     `json:"last_id,omitempty"`
	LastUpdatedAt time.Time `json:"last_updated_at,omitempty"`
}

type JobStateSx struct {
	JobState
}