feat: register storage service with cron
This commit is contained in:
parent
16a3b531ac
commit
48e3c690ce
|
@ -216,10 +216,16 @@ func (s *StorageServiceImpl) Init() error {
|
|||
s.tus = tus
|
||||
s.tusStore = store
|
||||
|
||||
s.portal.CronService().RegisterService(s)
|
||||
|
||||
go s.tusWorker()
|
||||
|
||||
return nil
|
||||
}
|
||||
func (s *StorageServiceImpl) LoadInitialTasks(cron interfaces.CronService) error {
|
||||
return nil
|
||||
}
|
||||
|
||||
func (s *StorageServiceImpl) createBucketIfNotExists(bucket string) error {
|
||||
resp, err := s.httpApi.R().
|
||||
SetPathParam("bucket", bucket).
|
||||
|
|
Loading…
Reference in New Issue