format: golang style code

Signed-off-by: rfyiamcool <rfyiamcool@163.com>
go-co-op · Nov 14, 2023 · 259ef4c · 259ef4c
1 parent 4af7149
commit 259ef4c
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 4 deletions.
diff --git a/gormlock.go → gorm_lock.go b/gormlock.go → gorm_lock.go
@@ -8,7 +8,12 @@ import (
 	"gorm.io/gorm"
 )
 
-var defaultPrecision = time.Second
+var (
+	defaultPrecision = time.Second
+
+	StatusRunning  = "RUNNING"
+	StatusFinished = "FINISHED"
+)
 
 func NewGormLocker(db *gorm.DB, worker string, options ...LockOption) (gocron.Locker, error) {
 	gl := &gormLocker{db: db, worker: worker}
@@ -34,7 +39,7 @@ func (g *gormLocker) Lock(ctx context.Context, key string) (gocron.Lock, error)
 		JobName:       key,
 		JobIdentifier: ji,
 		Worker:        g.worker,
-		Status:        "RUNNING",
+		Status:        StatusRunning,
 	}
 	tx := g.db.Create(cjb)
 	if tx.Error != nil {
@@ -58,5 +63,5 @@ type gormLock struct {
 }
 
 func (g *gormLock) Unlock(_ context.Context) error {
-	return g.db.Model(&CronJobLock{ID: g.id}).Updates(&CronJobLock{Status: "FINISHED"}).Error
+	return g.db.Model(&CronJobLock{ID: g.id}).Updates(&CronJobLock{Status: StatusFinished}).Error
 }
diff --git a/gormlockoptions.go → gorm_lock_options.go b/gormlockoptions.go → gorm_lock_options.go
diff --git a/gormlock_test.go → gorm_lock_test.go b/gormlock_test.go → gorm_lock_test.go
@@ -186,7 +186,7 @@ func TestJobReturningExceptionWhenUnique(t *testing.T) {
 		JobName:       "job",
 		JobIdentifier: time.Now().Truncate(60 * time.Minute).Format("2006-01-02 15:04:05.000"),
 		Worker:        "local",
-		Status:        "RUNNING",
+		Status:        StatusRunning,
 	}
 	require.NoError(t, db.Create(cjb).Error)
 

diff --git a/job-lock-struct.go → job_lock_struct.go b/job-lock-struct.go → job_lock_struct.go