schedule

type CleanupService struct {
	DBMap map[string]*gorm.DB
	// contains filtered or unexported fields
}

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

type DBCleanupReq struct {
	Cnn            string   //connection name
	Tables         []string //tables to be clean
	PrefixIncluded bool     // table names included table prefix
	DeletedField   string   //field name, default is deletedAt
	Duration       string   // only delete DeletedAt <  now - duration
	Batch          int      // batch per deleted
}

type DBCronJob struct {
	Name     string
	Schedule string
	Sql      []string
	Logger   *zap.Logger
	DB       *gorm.DB
}

type JobHistory struct {
	Job      string
	Start    time.Time
	Finished time.Time
	Duration time.Duration
	Succeed  bool
	Message  string
}

type JobHistoryProvider struct {
	Bus       EventBus.Bus
	Persister cache.Hash
}

type JobParams struct {
	dig.In
	DB     *gorm.DB `optional:"true"`
	Logger *zap.Logger
	Bus    EventBus.Bus `optional:"true"`
}

type ScheduleLoker struct {
	Locker  locker.Locker
	Bus     EventBus.Bus
	Jobname string
}