go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-12-25 07:12:17 +08:00
Code Issues Projects Releases Wiki Activity

chore(lint): fix from gofmt -s

Browse Source
This commit is contained in:
Bo-Yi Wu 2020-03-14 08:50:27 +08:00 committed by Ken Hibino
parent 310d38620d
commit 30b68728d4
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/base/base_test.go
View File

@ -110,9 +110,9 @@ func TestProcessStateConcurrentAccess(t *testing.T) {
var wg sync.WaitGroup var wg sync.WaitGroup
started := time.Now() started := time.Now()
msgs := []*TaskMessage{ msgs := []*TaskMessage{
&TaskMessage{ID: xid.New(), Type: "type1", Payload: map[string]interface{}{"user_id": 42}}, {ID: xid.New(), Type: "type1", Payload: map[string]interface{}{"user_id": 42}},
&TaskMessage{ID: xid.New(), Type: "type2"}, {ID: xid.New(), Type: "type2"},
&TaskMessage{ID: xid.New(), Type: "type3"}, {ID: xid.New(), Type: "type3"},
} }
// Simulate hearbeater calling SetStatus and SetStarted. // Simulate hearbeater calling SetStatus and SetStarted.

4
internal/rdb/rdb_test.go
View File

@ -884,7 +884,7 @@ func TestWriteProcessStateWithWorkers(t *testing.T) {
gotWorkers[key] = &w gotWorkers[key] = &w
} }
wantWorkers := map[string]*base.WorkerInfo{ wantWorkers := map[string]*base.WorkerInfo{
msg1.ID.String(): &base.WorkerInfo{ msg1.ID.String(): {
Host: host, Host: host,
PID: pid, PID: pid,
ID: msg1.ID, ID: msg1.ID,
@ -893,7 +893,7 @@ func TestWriteProcessStateWithWorkers(t *testing.T) {
Payload: msg1.Payload, Payload: msg1.Payload,
Started: w1Started, Started: w1Started,
}, },
msg2.ID.String(): &base.WorkerInfo{ msg2.ID.String(): {
Host: host, Host: host,
PID: pid, PID: pid,
ID: msg2.ID, ID: msg2.ID,