add proxy protocol support for UDP proxies

.github/workflows/stale.yml

@@ -1,4 +1,4 @@
-name: "Close stale issues and PRs"
+name: "Close stale issues"
 on:
   schedule:
   - cron: "20 0 * * *"

pkg/proto/udp/udp_test.go

@@ -3,16 +3,16 @@ package udp
 import (
 	"testing"
 
-	"github.com/stretchr/testify/require"
+	"github.com/stretchr/testify/assert"
 )
 
 func TestUdpPacket(t *testing.T) {
-	require := require.New(t)
+	assert := assert.New(t)
 
 	buf := []byte("hello world")
 	udpMsg := NewUDPPacket(buf, nil, nil)
 
 	newBuf, err := GetContent(udpMsg)
-	require.NoError(err)
-	require.EqualValues(buf, newBuf)
+	assert.NoError(err)
+	assert.EqualValues(buf, newBuf)
 }

pkg/util/metric/counter_test.go

@@ -3,21 +3,21 @@ package metric
 import (
 	"testing"
 
-	"github.com/stretchr/testify/require"
+	"github.com/stretchr/testify/assert"
 )
 
 func TestCounter(t *testing.T) {
-	require := require.New(t)
+	assert := assert.New(t)
 	c := NewCounter()
 	c.Inc(10)
-	require.EqualValues(10, c.Count())
+	assert.EqualValues(10, c.Count())
 
 	c.Dec(5)
-	require.EqualValues(5, c.Count())
+	assert.EqualValues(5, c.Count())
 
 	cTmp := c.Snapshot()
-	require.EqualValues(5, cTmp.Count())
+	assert.EqualValues(5, cTmp.Count())
 
 	c.Clear()
-	require.EqualValues(0, c.Count())
+	assert.EqualValues(0, c.Count())
 }

pkg/util/metric/date_counter_test.go

@@ -3,25 +3,25 @@ package metric
 import (
 	"testing"
 
-	"github.com/stretchr/testify/require"
+	"github.com/stretchr/testify/assert"
 )
 
 func TestDateCounter(t *testing.T) {
-	require := require.New(t)
+	assert := assert.New(t)
 
 	dc := NewDateCounter(3)
 	dc.Inc(10)
-	require.EqualValues(10, dc.TodayCount())
+	assert.EqualValues(10, dc.TodayCount())
 
 	dc.Dec(5)
-	require.EqualValues(5, dc.TodayCount())
+	assert.EqualValues(5, dc.TodayCount())
 
 	counts := dc.GetLastDaysCount(3)
-	require.EqualValues(3, len(counts))
-	require.EqualValues(5, counts[0])
-	require.EqualValues(0, counts[1])
-	require.EqualValues(0, counts[2])
+	assert.EqualValues(3, len(counts))
+	assert.EqualValues(5, counts[0])
+	assert.EqualValues(0, counts[1])
+	assert.EqualValues(0, counts[2])
 
 	dcTmp := dc.Snapshot()
-	require.EqualValues(5, dcTmp.TodayCount())
+	assert.EqualValues(5, dcTmp.TodayCount())
 }

pkg/util/util/util_test.go

@@ -3,41 +3,45 @@ package util
 import (
 	"testing"
 
-	"github.com/stretchr/testify/require"
+	"github.com/stretchr/testify/assert"
 )
 
 func TestRandId(t *testing.T) {
-	require := require.New(t)
+	assert := assert.New(t)
 	id, err := RandID()
-	require.NoError(err)
+	assert.NoError(err)
 	t.Log(id)
-	require.Equal(16, len(id))
+	assert.Equal(16, len(id))
 }
 
 func TestGetAuthKey(t *testing.T) {
-	require := require.New(t)
+	assert := assert.New(t)
 	key := GetAuthKey("1234", 1488720000)
-	require.Equal("6df41a43725f0c770fd56379e12acf8c", key)
+	assert.Equal("6df41a43725f0c770fd56379e12acf8c", key)
 }
 
 func TestParseRangeNumbers(t *testing.T) {
-	require := require.New(t)
+	assert := assert.New(t)
 	numbers, err := ParseRangeNumbers("2-5")
-	require.NoError(err)
-	require.Equal([]int64{2, 3, 4, 5}, numbers)
+	if assert.NoError(err) {
+		assert.Equal([]int64{2, 3, 4, 5}, numbers)
+	}
 
 	numbers, err = ParseRangeNumbers("1")
-	require.NoError(err)
-	require.Equal([]int64{1}, numbers)
+	if assert.NoError(err) {
+		assert.Equal([]int64{1}, numbers)
+	}
 
 	numbers, err = ParseRangeNumbers("3-5,8")
-	require.NoError(err)
-	require.Equal([]int64{3, 4, 5, 8}, numbers)
+	if assert.NoError(err) {
+		assert.Equal([]int64{3, 4, 5, 8}, numbers)
+	}
 
 	numbers, err = ParseRangeNumbers(" 3-5,8, 10-12 ")
-	require.NoError(err)
-	require.Equal([]int64{3, 4, 5, 8, 10, 11, 12}, numbers)
+	if assert.NoError(err) {
+		assert.Equal([]int64{3, 4, 5, 8, 10, 11, 12}, numbers)
+	}
 
 	_, err = ParseRangeNumbers("3-a")
-	require.Error(err)
+	assert.Error(err)
 }