[#1468]: pre-release: v2023.1.0-alpha.2

Author: rustatian

.github/workflows/tests.yml

@@ -40,7 +40,7 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@v3 # action page: <https://github.com/actions/setup-go>
         with:
-          go-version: '1.20'
+          go-version: '1.19'
 
       - name: Run linter
         uses: golangci/[email protected]

cmd/rr/command_test.go

@@ -5,24 +5,24 @@ import (
 	"io"
 	"os"
 	"testing"
+	"time"
 
 	"github.com/stretchr/testify/assert"
-	"github.com/stretchr/testify/require"
 )
 
 func Test_Main(t *testing.T) {
 	os.Args = []string{"rr", "--help"}
 	exitFn = func(code int) { assert.Equal(t, 0, code) }
 
-	r, w, err := os.Pipe()
-	require.NoError(t, err)
+	r, w, _ := os.Pipe()
 	os.Stdout = w
 
 	main()
 	_ = w.Close()
 	buf := new(bytes.Buffer)
-	_, err = io.Copy(buf, r)
-	require.NoError(t, err)
+
+	_ = r.SetReadDeadline(time.Now().Add(time.Second))
+	_, _ = io.Copy(buf, r)
 
 	assert.Contains(t, buf.String(), "Usage:")
 	assert.Contains(t, buf.String(), "Available Commands:")
@@ -33,15 +33,13 @@ func Test_MainWithoutCommands(t *testing.T) {
 	os.Args = []string{"rr"}
 	exitFn = func(code int) { assert.Equal(t, 0, code) }
 
-	r, w, err := os.Pipe()
-	require.NoError(t, err)
+	r, w, _ := os.Pipe()
 	os.Stdout = w
 
 	main()
-	_ = w.Close()
 	buf := new(bytes.Buffer)
-	_, err = io.Copy(buf, r)
-	require.NoError(t, err)
+	_ = r.SetReadDeadline(time.Now().Add(time.Second))
+	_, _ = io.Copy(buf, r)
 
 	assert.Contains(t, buf.String(), "Usage:")
 	assert.Contains(t, buf.String(), "Available Commands:")
@@ -52,15 +50,15 @@ func Test_MainUnknownSubcommand(t *testing.T) {
 	os.Args = []string{"", "foobar"}
 	exitFn = func(code int) { assert.Equal(t, 1, code) }
 
-	r, w, err := os.Pipe()
-	require.NoError(t, err)
+	r, w, _ := os.Pipe()
 	os.Stderr = w
 
 	main()
 	_ = w.Close()
 	buf := new(bytes.Buffer)
-	_, err = io.Copy(buf, r)
-	require.NoError(t, err)
+
+	_ = r.SetReadDeadline(time.Now().Add(time.Second))
+	_, _ = io.Copy(buf, r)
 
 	assert.Contains(t, buf.String(), "unknown command")
 	assert.Contains(t, buf.String(), "foobar")

container/plugins.go

@@ -14,6 +14,7 @@ import (
 	"github.com/roadrunner-server/informer/v4"
 	"github.com/roadrunner-server/jobs/v4"
 	"github.com/roadrunner-server/kv/v4"
+	"github.com/roadrunner-server/lock/v4"
 	"github.com/roadrunner-server/logger/v4"
 	"github.com/roadrunner-server/memcached/v4"
 	"github.com/roadrunner-server/memory/v4"
@@ -44,7 +45,8 @@ func Plugins() []any { //nolint:funlen
 		&informer.Plugin{},
 		// resetter plugin (./rr reset)
 		&resetter.Plugin{},
-
+		// mutexes(locks)
+		&lock.Plugin{},
 		// logger plugin
 		&logger.Plugin{},
 		// psr-3 logger extension

go.mod

@@ -8,48 +8,49 @@ require (
 	github.com/fatih/color v1.14.1
 	github.com/joho/godotenv v1.5.1
 	github.com/olekukonko/tablewriter v0.0.5
-	github.com/roadrunner-server/amqp/v4 v4.1.1
+	github.com/roadrunner-server/amqp/v4 v4.1.2
 	github.com/roadrunner-server/api/v3 v3.2.1
-	github.com/roadrunner-server/app-logger/v4 v4.0.1
-	github.com/roadrunner-server/beanstalk/v4 v4.1.1
-	github.com/roadrunner-server/boltdb/v4 v4.2.1
-	github.com/roadrunner-server/centrifuge/v4 v4.0.2
-	github.com/roadrunner-server/config/v4 v4.1.1
+	github.com/roadrunner-server/app-logger/v4 v4.0.2
+	github.com/roadrunner-server/beanstalk/v4 v4.1.2
+	github.com/roadrunner-server/boltdb/v4 v4.2.2
+	github.com/roadrunner-server/centrifuge/v4 v4.0.3
+	github.com/roadrunner-server/config/v4 v4.1.2
 	github.com/roadrunner-server/endure/v2 v2.2.0
 	github.com/roadrunner-server/errors v1.2.0
-	github.com/roadrunner-server/fileserver/v4 v4.0.1
+	github.com/roadrunner-server/fileserver/v4 v4.0.2
 	github.com/roadrunner-server/goridge/v3 v3.6.2
-	github.com/roadrunner-server/grpc/v4 v4.1.0
-	github.com/roadrunner-server/gzip/v4 v4.0.1
-	github.com/roadrunner-server/headers/v4 v4.0.1
-	github.com/roadrunner-server/http/v4 v4.0.3
-	github.com/roadrunner-server/informer/v4 v4.0.1
-	github.com/roadrunner-server/jobs/v4 v4.2.1
-	github.com/roadrunner-server/kv/v4 v4.1.1
-	github.com/roadrunner-server/logger/v4 v4.0.1
-	github.com/roadrunner-server/memcached/v4 v4.1.2
-	github.com/roadrunner-server/memory/v4 v4.1.1
-	github.com/roadrunner-server/metrics/v4 v4.0.1
-	github.com/roadrunner-server/nats/v4 v4.1.1
-	github.com/roadrunner-server/otel/v4 v4.1.0
-	github.com/roadrunner-server/prometheus/v4 v4.0.2
-	github.com/roadrunner-server/proxy_ip_parser/v4 v4.0.2
-	github.com/roadrunner-server/redis/v4 v4.1.1
-	github.com/roadrunner-server/reload/v4 v4.0.1
-	github.com/roadrunner-server/resetter/v4 v4.0.1
-	github.com/roadrunner-server/rpc/v4 v4.1.0
+	github.com/roadrunner-server/grpc/v4 v4.1.1
+	github.com/roadrunner-server/gzip/v4 v4.0.2
+	github.com/roadrunner-server/headers/v4 v4.0.2
+	github.com/roadrunner-server/http/v4 v4.0.4
+	github.com/roadrunner-server/informer/v4 v4.0.2
+	github.com/roadrunner-server/jobs/v4 v4.2.2
+	github.com/roadrunner-server/kv/v4 v4.1.2
+	github.com/roadrunner-server/lock/v4 v4.0.0-beta.1
+	github.com/roadrunner-server/logger/v4 v4.0.2
+	github.com/roadrunner-server/memcached/v4 v4.1.3
+	github.com/roadrunner-server/memory/v4 v4.1.2
+	github.com/roadrunner-server/metrics/v4 v4.0.2
+	github.com/roadrunner-server/nats/v4 v4.1.2
+	github.com/roadrunner-server/otel/v4 v4.1.1
+	github.com/roadrunner-server/prometheus/v4 v4.0.3
+	github.com/roadrunner-server/proxy_ip_parser/v4 v4.0.3
+	github.com/roadrunner-server/redis/v4 v4.1.2
+	github.com/roadrunner-server/reload/v4 v4.0.2
+	github.com/roadrunner-server/resetter/v4 v4.0.2
+	github.com/roadrunner-server/rpc/v4 v4.1.1
 	github.com/roadrunner-server/sdk/v4 v4.2.0
-	github.com/roadrunner-server/send/v4 v4.0.2
-	github.com/roadrunner-server/server/v4 v4.0.1
-	github.com/roadrunner-server/service/v4 v4.0.2
-	github.com/roadrunner-server/sqs/v4 v4.1.1
-	github.com/roadrunner-server/static/v4 v4.0.2
-	github.com/roadrunner-server/status/v4 v4.0.1
-	github.com/roadrunner-server/tcp/v4 v4.0.1
+	github.com/roadrunner-server/send/v4 v4.0.3
+	github.com/roadrunner-server/server/v4 v4.0.2
+	github.com/roadrunner-server/service/v4 v4.0.3
+	github.com/roadrunner-server/sqs/v4 v4.1.2
+	github.com/roadrunner-server/static/v4 v4.0.3
+	github.com/roadrunner-server/status/v4 v4.0.2
+	github.com/roadrunner-server/tcp/v4 v4.0.2
 	github.com/spf13/cobra v1.6.1
 	github.com/spf13/viper v1.15.0
 	github.com/stretchr/testify v1.8.1
-	github.com/temporalio/roadrunner-temporal/v4 v4.1.0
+	github.com/temporalio/roadrunner-temporal/v4 v4.2.0-alpha.1
 	go.buf.build/protocolbuffers/go/roadrunner-server/api v1.3.31
 	go.uber.org/automaxprocs v1.5.1
 	golang.org/x/exp v0.0.0-20230213192124-5e25df0256eb
@@ -129,7 +130,7 @@ require (
 	github.com/rabbitmq/amqp091-go v1.7.0 // indirect
 	github.com/rivo/uniseg v0.4.3 // indirect
 	github.com/roadrunner-server/api/v4 v4.1.0 // indirect
-	github.com/roadrunner-server/tcplisten v1.2.1 // indirect
+	github.com/roadrunner-server/tcplisten v1.3.0 // indirect
 	github.com/robfig/cron v1.2.0 // indirect
 	github.com/savsgio/dictpool v0.0.0-20221023140959-7bf2e61cea94 // indirect
 	github.com/savsgio/gotils v0.0.0-20230208104028-c358bd845dee // indirect