Documentation ¶
Index ¶
- Constants
- Variables
- func CleanOutdatedJobs()
- func NewClientError(err error) error
- func NewDatabaseResetJob(tt tenant.Tenant, job *xjm.Job) iRunner
- func NewUserCsvImportJob(tt tenant.Tenant, job *xjm.Job) iRunner
- func Reappend()
- func StartJobs(tt tenant.Tenant) error
- func Starts()
- func Stats() string
- type ArgFilter
- type ArgLocale
- type ClientError
- type DatabaseResetArg
- type DatabaseResetJob
- type FailedItem
- type JobRunner
- type JobRunnerCreator
- type JobState
- type JobStateEx
- type TenantJobs
- type UserCsvImportArg
- type UserCsvImportJob
Constants ¶
View Source
const ( JobNameUserCsvImport = "UserCsvImport" JobNameDatabaseReset = "DatabaseReset" )
Variables ¶
View Source
var ErrClient = &ClientError{}
View Source
var (
ErrItemSkip = errors.New("item skip")
)
View Source
var ErrJobOverflow = errors.New("Job Overflow")
Functions ¶
func CleanOutdatedJobs ¶
func CleanOutdatedJobs()
------------------------------------ CleanOutdatedJobs iterate schemas to clean outdated jobs
func NewClientError ¶
Types ¶
type ArgFilter ¶
type ClientError ¶
type ClientError struct {
Err error
}
func (*ClientError) Error ¶
func (ce *ClientError) Error() string
func (*ClientError) Is ¶
func (ce *ClientError) Is(err error) (ok bool)
func (*ClientError) Unwrap ¶
func (ce *ClientError) Unwrap() error
type DatabaseResetArg ¶
type DatabaseResetArg ArgLocale
type DatabaseResetJob ¶
type DatabaseResetJob struct { *JobRunner // contains filtered or unexported fields }
func (*DatabaseResetJob) Run ¶
func (dr *DatabaseResetJob) Run()
type FailedItem ¶
type FailedItem struct { ID int64 `json:"id"` Title string `json:"title"` Error string `json:"error"` }
func (*FailedItem) Quoted ¶
func (si *FailedItem) Quoted() string
func (*FailedItem) String ¶
func (si *FailedItem) String() string
type JobRunner ¶
func (*JobRunner) AddFailedItem ¶
type JobState ¶
type JobStateEx ¶
func (*JobStateEx) String ¶
func (jse *JobStateEx) String() string
type TenantJobs ¶
type TenantJobs struct {
// contains filtered or unexported fields
}
func NewTenantJobs ¶
func NewTenantJobs() *TenantJobs
func (*TenantJobs) Stats ¶
func (tj *TenantJobs) Stats() string
func (*TenantJobs) Total ¶
func (tj *TenantJobs) Total() int
type UserCsvImportArg ¶
type UserCsvImportArg ArgLocale
type UserCsvImportJob ¶
func (*UserCsvImportJob) Run ¶
func (uci *UserCsvImportJob) Run()
Click to show internal directories.
Click to hide internal directories.