update mod

Author: iGoogle-ink

errgroup_test.go

@@ -3,11 +3,10 @@ package errgroup
 import (
 	"context"
 	"errors"
+	"log"
 	"sync/atomic"
 	"testing"
 	"time"
-
-	"github.com/go-pay/xlog"
 )
 
 func TestErrgroup(t *testing.T) {
@@ -34,14 +33,13 @@ func TestErrgroup(t *testing.T) {
 	if err := eg.Wait(); err != nil {
 		// do some thing
 		count = countBackup
-		xlog.Error(err)
+		log.Println(err)
 		//return
 	}
-	xlog.Debug(count)
+	log.Println(count)
 }
 
 func TestErrgroupLimit1(t *testing.T) {
-	xlog.Level = xlog.DebugLevel
 	var (
 		eg    Group
 		goNum = 3 // every times run goNum goroutine
@@ -50,25 +48,24 @@ func TestErrgroupLimit1(t *testing.T) {
 		var count = int64(i)
 		eg.Go(func(ctx context.Context) error {
 			atomic.AddInt64(&count, 1)
-			xlog.Debug("count:", count)
+			log.Println("count:", count)
 			return nil
 		})
 		if eg.WorkNum() == goNum {
 			if err := eg.Wait(); err != nil {
-				xlog.Error("err1:", err)
+				log.Println("err1:", err)
 				// to do something you need
 			}
-			xlog.Info("wait")
+			log.Println("wait")
 			time.Sleep(time.Second)
 		}
 	}
 	if err := eg.Wait(); err != nil {
-		xlog.Error("err2:", err)
+		log.Println("err2:", err)
 	}
 }
 
 func TestErrgroupLimit2(t *testing.T) {
-	xlog.Level = xlog.DebugLevel
 	var (
 		eg Group
 	)
@@ -77,13 +74,13 @@ func TestErrgroupLimit2(t *testing.T) {
 		var count = int64(i)
 		eg.Go(func(ctx context.Context) error {
 			atomic.AddInt64(&count, 1)
-			xlog.Debug("count:", count)
+			log.Println("count:", count)
 			time.Sleep(time.Second * 3)
 			return nil
 		})
 	}
 	if err := eg.Wait(); err != nil {
-		xlog.Error("err2:", err)
+		log.Println("err2:", err)
 	}
 }
 
@@ -95,9 +92,9 @@ func timeSleep1(c context.Context) error {
 	}()
 	select {
 	case <-c.Done():
-		xlog.Infof("timeSleep1 cancel")
+		log.Println("timeSleep1 cancel")
 	case rsp := <-data:
-		xlog.Info(rsp)
+		log.Println(rsp)
 	}
 	return nil
 }
@@ -115,9 +112,9 @@ func timeTimeoutSleep3(c context.Context) error {
 	}()
 	select {
 	case <-c.Done():
-		xlog.Infof("timeSleep3 timeout")
+		log.Println("timeSleep3 timeout")
 	case rsp := <-data:
-		xlog.Info(rsp)
+		log.Println(rsp)
 	}
 	return nil
 }
@@ -130,9 +127,9 @@ func timeCancelSleep5(c context.Context) error {
 	}()
 	select {
 	case <-c.Done():
-		xlog.Infof("timeCancelSleep5 cancel")
+		log.Println("timeCancelSleep5 cancel")
 	case rsp := <-data:
-		xlog.Info(rsp)
+		log.Println(rsp)
 	}
 	return nil
 }
@@ -147,13 +144,12 @@ func timeTimeoutSleep5(c context.Context) error {
 	case <-c.Done():
 		return errors.New("timeTimeoutSleep5 timeout")
 	case rsp := <-data:
-		xlog.Info(rsp)
+		log.Println(rsp)
 	}
 	return nil
 }
 
 func TestErrgroupWithCancel(t *testing.T) {
-	xlog.Level = xlog.DebugLevel
 	var (
 		eg = WithCancel(context.Background())
 	)
@@ -163,14 +159,14 @@ func TestErrgroupWithCancel(t *testing.T) {
 	})
 	eg.Go(func(ctx context.Context) error {
 		if err := timeErrSleep3(ctx); err != nil {
-			xlog.Error(err)
+			log.Println(err)
 			return err
 		}
 		return nil
 	})
 	eg.Go(func(ctx context.Context) error {
 		if err := timeCancelSleep5(ctx); err != nil {
-			xlog.Errorf("err:%v", err)
+			log.Printf("err:%v", err)
 			return err
 		}
 		return nil
@@ -181,7 +177,6 @@ func TestErrgroupWithCancel(t *testing.T) {
 }
 
 func TestErrgroupWithTimeout(t *testing.T) {
-	xlog.Level = xlog.DebugLevel
 	var (
 		eg = WithTimeout(context.Background(), time.Second*4)
 	)
@@ -195,7 +190,7 @@ func TestErrgroupWithTimeout(t *testing.T) {
 	})
 	eg.Go(func(ctx context.Context) error {
 		if err := timeTimeoutSleep5(ctx); err != nil {
-			xlog.Errorf("err:%v", err)
+			log.Printf("err:%v", err)
 			return err
 		}
 		return nil

go.mod

@@ -1,10 +1,3 @@
 module github.com/go-pay/errgroup
 
 go 1.20
-
-require github.com/go-pay/xlog v0.0.1
-
-require (
-	go.uber.org/multierr v1.11.0 // indirect
-	go.uber.org/zap v1.26.0 // indirect
-)

go.sum

@@ -1,11 +0,0 @@
-github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
-github.com/go-pay/xlog v0.0.1 h1:hbOHN+Rn6pH83JQzk6904fL7fsHsr9iKCZoBVX+tF9Y=
-github.com/go-pay/xlog v0.0.1/go.mod h1:RgjidhvsA+4Qwpk9wN8U9zb/R3Wq+HtaAO0xUXdmSdo=
-github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
-github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk=
-go.uber.org/goleak v1.2.0 h1:xqgm/S+aQvhWFTtR0XK3Jvg7z8kGV8P4X14IzwN3Eqk=
-go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
-go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
-go.uber.org/zap v1.26.0 h1:sI7k6L95XOKS281NhVKOFCUNIvv9e0w4BF8N3u+tCRo=
-go.uber.org/zap v1.26.0/go.mod h1:dtElttAiwGvoJ/vj4IwHBS/gXsEu/pZ50mUIRWuG0so=
-gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=