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
	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
	// contains filtered or unexported fields
}

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

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
}