Fix: use 1e6 as ms

common/url.go

@@ -156,7 +156,9 @@ func WithToken(token string) option {
 		if len(token) > 0 {
 			value := token
 			if strings.ToLower(token) == "true" || strings.ToLower(token) == "default" {
-				value = uuid.NewV4().String()
+				if id, err := uuid.NewV4(); err == nil {
+					value = id.String()
+				}
 			}
 			url.SetParam(constant.TOKEN_KEY, value)
 		}

filter/impl/tps/impl/tps_limit_fix_window_strategy.go

@@ -79,7 +79,7 @@ func (impl *FixedWindowTpsLimitStrategyImpl) IsAllowable() bool {
 func NewFixedWindowTpsLimitStrategyImpl(rate int, interval int) tps.TpsLimitStrategy {
 	return &FixedWindowTpsLimitStrategyImpl{
 		rate:      int32(rate),
-		interval:  int64(interval * 1000), // convert to ns
+		interval:  int64(interval) * int64(time.Millisecond), // convert to ns
 		count:     0,
 		timestamp: time.Now().UnixNano(),
 	}

filter/impl/tps/impl/tps_limit_fix_window_strategy_test.go

@@ -36,7 +36,7 @@ func TestFixedWindowTpsLimitStrategyImpl_IsAllowable(t *testing.T) {
 	assert.True(t, strategy.IsAllowable())
 	assert.True(t, strategy.IsAllowable())
 	assert.False(t, strategy.IsAllowable())
-	time.Sleep(time.Duration(2100 * 1000))
+	time.Sleep(2100 * time.Millisecond)
 	assert.True(t, strategy.IsAllowable())
 	assert.True(t, strategy.IsAllowable())
 	assert.False(t, strategy.IsAllowable())

filter/impl/tps/impl/tps_limit_sliding_window_strategy.go

@@ -83,7 +83,7 @@ func (impl *SlidingWindowTpsLimitStrategyImpl) IsAllowable() bool {
 func NewSlidingWindowTpsLimitStrategyImpl(rate int, interval int) tps.TpsLimitStrategy {
 	return &SlidingWindowTpsLimitStrategyImpl{
 		rate:     rate,
-		interval: int64(interval * 1000),
+		interval: int64(interval) * int64(time.Millisecond),
 		mutex:    &sync.Mutex{},
 		queue:    list.New(),
 	}

filter/impl/tps/impl/tps_limit_sliding_window_strategy_test.go

@@ -31,14 +31,14 @@ func TestSlidingWindowTpsLimitStrategyImpl_IsAllowable(t *testing.T) {
 	assert.True(t, strategy.IsAllowable())
 	assert.True(t, strategy.IsAllowable())
 	assert.False(t, strategy.IsAllowable())
-	time.Sleep(time.Duration(2100 * 1000))
+	time.Sleep(2100 * time.Millisecond)
 	assert.False(t, strategy.IsAllowable())
 
 	strategy = NewSlidingWindowTpsLimitStrategyImpl(2, 2000)
 	assert.True(t, strategy.IsAllowable())
 	assert.True(t, strategy.IsAllowable())
 	assert.False(t, strategy.IsAllowable())
-	time.Sleep(time.Duration(2100 * 1000))
+	time.Sleep(2100 * time.Millisecond)
 	assert.True(t, strategy.IsAllowable())
 	assert.True(t, strategy.IsAllowable())
 	assert.False(t, strategy.IsAllowable())

filter/impl/tps/impl/tps_limit_thread_safe_fix_window_strategy_test.go

@@ -36,7 +36,7 @@ func TestThreadSafeFixedWindowTpsLimitStrategyImpl_IsAllowable(t *testing.T) {
 	assert.True(t, strategy.IsAllowable())
 	assert.True(t, strategy.IsAllowable())
 	assert.False(t, strategy.IsAllowable())
-	time.Sleep(time.Duration(2100 * 1000))
+	time.Sleep(2100 * time.Millisecond)
 	assert.True(t, strategy.IsAllowable())
 	assert.True(t, strategy.IsAllowable())
 	assert.False(t, strategy.IsAllowable())

filter/impl/tps/impl/tps_limiter_mock.go

@@ -20,11 +20,17 @@
 // Package filter is a generated GoMock package.
 package impl
 
+import (
+	reflect "reflect"
+)
+
+import (
+	gomock "github.com/golang/mock/gomock"
+)
+
 import (
 	common "github.com/apache/dubbo-go/common"
 	protocol "github.com/apache/dubbo-go/protocol"
-	gomock "github.com/golang/mock/gomock"
-	reflect "reflect"
 )
 
 // MockTpsLimiter is a mock of TpsLimiter interface