Skip to content

Commit 5b50894

Browse files
mingmingshiliyumingmingshiliyu
committed
给公司用，方便维护
1 parent 686dc29 commit 5b50894

35 files changed

+105
-106
lines changed

‎README.md‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -223,11 +223,11 @@ import (
223223
"log"
224224
"time"
225225
226-
"github.com/shiningrush/fastflow"
227-
mongoKeeper "github.com/shiningrush/fastflow/keeper/mongo"
228-
"github.com/shiningrush/fastflow/pkg/entity/run"
229-
"github.com/shiningrush/fastflow/pkg/mod"
230-
mongoStore "github.com/shiningrush/fastflow/store/mongo"
226+
"github.com/mingmingshiliyu/fastflow"
227+
mongoKeeper "github.com/mingmingshiliyu/fastflow/keeper/mongo"
228+
"github.com/mingmingshiliyu/fastflow/pkg/entity/run"
229+
"github.com/mingmingshiliyu/fastflow/pkg/mod"
230+
mongoStore "github.com/mingmingshiliyu/fastflow/store/mongo"
231231
)
232232
233233
type PrintAction struct {

‎examples/mongo/main.go‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -7,14 +7,14 @@ import (
77
"net/http"
88
"time"
99

10-
"github.com/shiningrush/fastflow"
11-
mongoKeeper "github.com/shiningrush/fastflow/keeper/mongo"
12-
"github.com/shiningrush/fastflow/pkg/entity"
13-
"github.com/shiningrush/fastflow/pkg/entity/run"
14-
"github.com/shiningrush/fastflow/pkg/exporter"
15-
"github.com/shiningrush/fastflow/pkg/mod"
16-
"github.com/shiningrush/fastflow/pkg/utils/data"
17-
mongoStore "github.com/shiningrush/fastflow/store/mongo"
10+
"github.com/mingmingshiliyu/fastflow"
11+
mongoKeeper "github.com/mingmingshiliyu/fastflow/keeper/mongo"
12+
"github.com/mingmingshiliyu/fastflow/pkg/entity"
13+
"github.com/mingmingshiliyu/fastflow/pkg/entity/run"
14+
"github.com/mingmingshiliyu/fastflow/pkg/exporter"
15+
"github.com/mingmingshiliyu/fastflow/pkg/mod"
16+
"github.com/mingmingshiliyu/fastflow/pkg/utils/data"
17+
mongoStore "github.com/mingmingshiliyu/fastflow/store/mongo"
1818
)
1919

2020
type ActionParam struct {

‎examples/programming/main.go‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -6,13 +6,13 @@ import (
66
"log"
77
"time"
88

9-
"github.com/shiningrush/fastflow"
10-
mongoKeeper "github.com/shiningrush/fastflow/keeper/mongo"
11-
"github.com/shiningrush/fastflow/pkg/entity"
12-
"github.com/shiningrush/fastflow/pkg/entity/run"
13-
"github.com/shiningrush/fastflow/pkg/mod"
14-
"github.com/shiningrush/fastflow/pkg/utils/data"
15-
mongoStore "github.com/shiningrush/fastflow/store/mongo"
9+
"github.com/mingmingshiliyu/fastflow"
10+
mongoKeeper "github.com/mingmingshiliyu/fastflow/keeper/mongo"
11+
"github.com/mingmingshiliyu/fastflow/pkg/entity"
12+
"github.com/mingmingshiliyu/fastflow/pkg/entity/run"
13+
"github.com/mingmingshiliyu/fastflow/pkg/mod"
14+
"github.com/mingmingshiliyu/fastflow/pkg/utils/data"
15+
mongoStore "github.com/mingmingshiliyu/fastflow/store/mongo"
1616
)
1717

1818
type PrintAction struct {

‎examples/simple/main.go‎

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -2,18 +2,17 @@ package main
22

33
import (
44
"fmt"
5-
"github.com/shiningrush/fastflow/pkg/entity"
6-
"github.com/shiningrush/fastflow/pkg/mod"
7-
"gopkg.in/yaml.v3"
5+
"github.com/mingmingshiliyu/fastflow/pkg/entity"
6+
"github.com/mingmingshiliyu/fastflow/pkg/mod"
87
"log"
98
"os"
109
"reflect"
1110
"time"
1211

13-
"github.com/shiningrush/fastflow"
14-
mongoKeeper "github.com/shiningrush/fastflow/keeper/mongo"
15-
"github.com/shiningrush/fastflow/pkg/entity/run"
16-
mongoStore "github.com/shiningrush/fastflow/store/mongo"
12+
"github.com/mingmingshiliyu/fastflow"
13+
mongoKeeper "github.com/mingmingshiliyu/fastflow/keeper/mongo"
14+
"github.com/mingmingshiliyu/fastflow/pkg/entity/run"
15+
mongoStore "github.com/mingmingshiliyu/fastflow/store/mongo"
1716
)
1817

1918
func init() {

‎fastflow.go‎

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -13,15 +13,14 @@ import (
1313
"syscall"
1414
"time"
1515

16-
"github.com/shiningrush/fastflow/pkg/actions"
17-
"github.com/shiningrush/fastflow/pkg/entity"
18-
"github.com/shiningrush/fastflow/pkg/entity/run"
19-
"github.com/shiningrush/fastflow/pkg/event"
20-
"github.com/shiningrush/fastflow/pkg/mod"
21-
"github.com/shiningrush/fastflow/pkg/utils"
22-
"github.com/shiningrush/fastflow/pkg/utils/data"
16+
"github.com/mingmingshiliyu/fastflow/pkg/actions"
17+
"github.com/mingmingshiliyu/fastflow/pkg/entity"
18+
"github.com/mingmingshiliyu/fastflow/pkg/entity/run"
19+
"github.com/mingmingshiliyu/fastflow/pkg/event"
20+
"github.com/mingmingshiliyu/fastflow/pkg/mod"
21+
"github.com/mingmingshiliyu/fastflow/pkg/utils"
22+
"github.com/mingmingshiliyu/fastflow/pkg/utils/data"
2323
"github.com/shiningrush/goevent"
24-
"gopkg.in/yaml.v3"
2524
)
2625

2726
var closers []mod.Closer

‎fastflow_test.go‎

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5,12 +5,11 @@ import (
55
"testing"
66
"time"
77

8-
"github.com/shiningrush/fastflow/pkg/entity"
9-
"github.com/shiningrush/fastflow/pkg/mod"
10-
"github.com/shiningrush/fastflow/pkg/utils"
8+
"github.com/mingmingshiliyu/fastflow/pkg/entity"
9+
"github.com/mingmingshiliyu/fastflow/pkg/mod"
10+
"github.com/mingmingshiliyu/fastflow/pkg/utils"
1111
"github.com/stretchr/testify/assert"
1212
"github.com/stretchr/testify/mock"
13-
"gopkg.in/yaml.v3"
1413
)
1514

1615
func Test_checkOption(t *testing.T) {

‎keeper/mongo/mongo.go‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,11 +8,11 @@ import (
88
"sync/atomic"
99
"time"
1010

11-
"github.com/shiningrush/fastflow/keeper"
12-
"github.com/shiningrush/fastflow/pkg/event"
13-
"github.com/shiningrush/fastflow/pkg/log"
14-
"github.com/shiningrush/fastflow/pkg/mod"
15-
"github.com/shiningrush/fastflow/store"
11+
"github.com/mingmingshiliyu/fastflow/keeper"
12+
"github.com/mingmingshiliyu/fastflow/pkg/event"
13+
"github.com/mingmingshiliyu/fastflow/pkg/log"
14+
"github.com/mingmingshiliyu/fastflow/pkg/mod"
15+
"github.com/mingmingshiliyu/fastflow/store"
1616
"github.com/shiningrush/goevent"
1717
"go.mongodb.org/mongo-driver/bson"
1818
"go.mongodb.org/mongo-driver/mongo"

‎keeper/mongo/mutex.go‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@ import (
55
"fmt"
66
"time"
77

8-
"github.com/shiningrush/fastflow/pkg/mod"
9-
"github.com/shiningrush/fastflow/pkg/utils/data"
8+
"github.com/mingmingshiliyu/fastflow/pkg/mod"
9+
"github.com/mingmingshiliyu/fastflow/pkg/utils/data"
1010
"go.mongodb.org/mongo-driver/bson"
1111
"go.mongodb.org/mongo-driver/mongo"
1212
)
@@ -111,7 +111,6 @@ func (m *MongoMutex) spinLock(ctx context.Context, opt *mod.LockOption) error {
111111
return nil
112112
}
113113

114-
//
115114
func (m *MongoMutex) Unlock(ctx context.Context) error {
116115
if m.lockDetail == nil {
117116
return fmt.Errorf("the mutex is not locked")

‎keeper/mongo/mutex_integ_test.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,8 @@ import (
99
"testing"
1010
"time"
1111

12-
"github.com/shiningrush/fastflow/pkg/mod"
13-
"github.com/shiningrush/fastflow/pkg/utils/data"
12+
"github.com/mingmingshiliyu/fastflow/pkg/mod"
13+
"github.com/mingmingshiliyu/fastflow/pkg/utils/data"
1414
"github.com/stretchr/testify/assert"
1515
)
1616

‎pkg/actions/wait.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import (
66
"strconv"
77
"time"
88

9-
"github.com/shiningrush/fastflow/pkg/entity/run"
9+
"github.com/mingmingshiliyu/fastflow/pkg/entity/run"
1010
)
1111

1212
const (

0 commit comments

Comments
 (0)