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

5 files changed, 124 insertions, 121 deletions

diff --git a/.github/workflows/tests.yml b/.github/workflows/tests.yml
index a022464c..02be7531 100644
--- a/.github/workflows/tests.yml
+++ b/.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]
diff --git a/cmd/rr/command_test.go b/cmd/rr/command_test.go
index 84eef9d7..9b3e5f6a 100644
--- a/cmd/rr/command_test.go
+++ b/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")
diff --git a/container/plugins.go b/container/plugins.go
index 93741c79..57b1a4fa 100644
--- a/container/plugins.go
+++ b/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
diff --git a/go.mod b/go.mod
index 0f0e5407..bbaac34b 100644
--- a/go.mod
+++ b/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
diff --git a/go.sum b/go.sum
index 08243e3d..cb3a4f7d 100644
--- a/go.sum
+++ b/go.sum
@@ -765,86 +765,88 @@ github.com/rabbitmq/amqp091-go v1.7.0/go.mod h1:wfClAtY0C7bOHxd3GjmF26jEHn+rR/0B
 github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc=
 github.com/rivo/uniseg v0.4.3 h1:utMvzDsuh3suAEnhH0RdHmoPbU648o6CvXxTx4SBMOw=
 github.com/rivo/uniseg v0.4.3/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88=
-github.com/roadrunner-server/amqp/v4 v4.1.1 h1:WzOUWaYlAuOIPVyfaN6YwR1cEQQpWoSmBwwDWInHQck=
-github.com/roadrunner-server/amqp/v4 v4.1.1/go.mod h1:nVUBXcLcRLHuVw3GElw1HA6KvvPaVk0BufDssadKzLk=
+github.com/roadrunner-server/amqp/v4 v4.1.2 h1:xZxsEcpRXnMVbBwzhFqnVoVnbZfB5HxmIzJrLpDUcWE=
+github.com/roadrunner-server/amqp/v4 v4.1.2/go.mod h1:V5sw1foA6IxZfCCTMZi0cfXHWUmEAglKMc+eueFJyE8=
 github.com/roadrunner-server/api/v3 v3.2.1 h1:N4rokKVkN8Phoodbqtil90G65t2BqIWvHCKaxIKajvs=
 github.com/roadrunner-server/api/v3 v3.2.1/go.mod h1:hlv546SS3tZVIDu68YekPCLS/82Y/AoS8Eu5xysvwBQ=
 github.com/roadrunner-server/api/v4 v4.1.0 h1:VDFYfcLKCKi4hAsVNhRkbJ8yYVBY8vCdcmBDVtvBdI8=
 github.com/roadrunner-server/api/v4 v4.1.0/go.mod h1:IjNTjfefcwRyc/RoquIYRmUuLYQTcL1UQk2GVfP0m0c=
-github.com/roadrunner-server/app-logger/v4 v4.0.1 h1:WLKt/mgVl5Nc/j31mklsqbn82UsWZ2VpU2pBojI9xXo=
-github.com/roadrunner-server/app-logger/v4 v4.0.1/go.mod h1:cWV6nWhwQmkyGZtefeWrqs59v0XTrQdm5B7y8ukFpQU=
-github.com/roadrunner-server/beanstalk/v4 v4.1.1 h1:Y1OvPJdJ71Bhtqgo83ZE0c0n0MaEYVP2duGS92hQ06E=
-github.com/roadrunner-server/beanstalk/v4 v4.1.1/go.mod h1:Ekpce6ise0aet/WJDregbecSho502uIgu9sKfce5/T4=
-github.com/roadrunner-server/boltdb/v4 v4.2.1 h1:jykVxfJWOtYIYLQwM0PKMeHTYEzRXFbEQXed6bIoCGg=
-github.com/roadrunner-server/boltdb/v4 v4.2.1/go.mod h1:dVgez5eFAVivFeCEcycVT2fbb33dKbgESjXrkqmck3o=
-github.com/roadrunner-server/centrifuge/v4 v4.0.2 h1:HcqGSJVdxAcKlx8Iot2U1nGNShUjMm61EajsjigfaLw=
-github.com/roadrunner-server/centrifuge/v4 v4.0.2/go.mod h1:oGPwAOZ1n9jguzcjxDl6hUzK1/D3Xi70fu+c3zqS54M=
-github.com/roadrunner-server/config/v4 v4.1.1 h1:YICoAy0E8wpicqTFIQCxUUg+z2GDE5hVtH6p8gwitIo=
-github.com/roadrunner-server/config/v4 v4.1.1/go.mod h1:dlrCUD2OxFxCiaXXiKY+/OqIJKz3BZbtkBVnrtvGWks=
+github.com/roadrunner-server/app-logger/v4 v4.0.2 h1:JBYMkh0gl5hgkeTzW7H/DFPk3ZGSPuFjHmC+JkrXmnk=
+github.com/roadrunner-server/app-logger/v4 v4.0.2/go.mod h1:sqEfHaQy98fbAxD9zbEHIUN6p07WMDN8XDEvl58nECg=
+github.com/roadrunner-server/beanstalk/v4 v4.1.2 h1:NAyDePY3KbacKeBJqSQPq6MBrXboxIkJRjLshFU96yM=
+github.com/roadrunner-server/beanstalk/v4 v4.1.2/go.mod h1:8mYBbwIKupYH4Xl/nXk6So+xy/4l6awwQgfrj6xZsW8=
+github.com/roadrunner-server/boltdb/v4 v4.2.2 h1:ogWmRxJge+gtJlkZY27v2wm84QQTnrqD/nd4c523K/o=
+github.com/roadrunner-server/boltdb/v4 v4.2.2/go.mod h1:xyfzooiNb9bwdMWCJWbPsr0U9kTTPA0QL1swLv+Cb/o=
+github.com/roadrunner-server/centrifuge/v4 v4.0.3 h1:EQOH+U02mPI/SJouEjrBggkJcPh4ZiQ1skWbRhXr9zE=
+github.com/roadrunner-server/centrifuge/v4 v4.0.3/go.mod h1:yyRI0V6SGf3eeDcXSj2dczP7XuqG8mu1QQVPAj/4248=
+github.com/roadrunner-server/config/v4 v4.1.2 h1:cvJRhdoEMsK1UjoYWm7q5/MHTnpaCtSHLcMRlNjDrvI=
+github.com/roadrunner-server/config/v4 v4.1.2/go.mod h1:bwlJrS7rRFQja62osWcjW3eWw6v642LX32MQt4/4C3M=
 github.com/roadrunner-server/endure/v2 v2.2.0 h1:oh4f7buoWygXRj0IBc5KQ7QTUckIytDv/RQU1GKivgA=
 github.com/roadrunner-server/endure/v2 v2.2.0/go.mod h1:igEYk0KVxCxfbcMhV/mffDDY6ZK+AkGVHi31Jz0z21Y=
 github.com/roadrunner-server/errors v1.2.0 h1:qBmNXt8Iex9QnYTjCkbJKsBZu2EtYkQCM06GUDcQBbI=
 github.com/roadrunner-server/errors v1.2.0/go.mod h1:z0ECxZp/dDa5RahtMcy4mBIavVxiZ9vwE5kByl7kFtY=
-github.com/roadrunner-server/fileserver/v4 v4.0.1 h1:+TInwLPHz+7AP1u1p38n16SlakHpKM1oLtr7kqYN4BE=
-github.com/roadrunner-server/fileserver/v4 v4.0.1/go.mod h1:XX4nCWno1iQgM+c46qf0bLnTrOuI8uxLVu4UVPLxH3M=
+github.com/roadrunner-server/fileserver/v4 v4.0.2 h1:NaAAxWaOSH+B4FPyLFio3ROHocLrEX/51AFU2VipgVc=
+github.com/roadrunner-server/fileserver/v4 v4.0.2/go.mod h1:XIyN5E7cGDuZuGLGjyTcGyMD2W0SKbpHNGNosT0dT7U=
 github.com/roadrunner-server/goridge/v3 v3.6.2 h1:LH5HXfCygDp05KnOaXpa4fqVPWTsH7V3lfvPtMwFU3k=
 github.com/roadrunner-server/goridge/v3 v3.6.2/go.mod h1:3B95k/wM5GGAD0h2hZlJagS9PlTDGs5jh8MpZYC12vA=
-github.com/roadrunner-server/grpc/v4 v4.1.0 h1:pWL7OfA7dcMih844tB/xCtYlYEDgvkHt+HnF0HYZ+l8=
-github.com/roadrunner-server/grpc/v4 v4.1.0/go.mod h1:RoC++f9H/grsHeURGJN/0DQgCR5zu3lvLQQapQY5lXA=
-github.com/roadrunner-server/gzip/v4 v4.0.1 h1:7tqynGSqhIJBFGtAsWjfgS9JPyccZb+a/ql5Dx5Pncw=
-github.com/roadrunner-server/gzip/v4 v4.0.1/go.mod h1:+bAl80yCNCR0DYHJE/DfxALBY29p74yh9/2Q4NpGW5E=
-github.com/roadrunner-server/headers/v4 v4.0.1 h1:D48KqR6v9+pQK3IJDmubeTPUYIzXxo7VvVm+x9DawlU=
-github.com/roadrunner-server/headers/v4 v4.0.1/go.mod h1:rIH4+xTtmIL0O0tFeUrmZ8Wf9gahlW8GqH9hvoLKEJI=
-github.com/roadrunner-server/http/v4 v4.0.3 h1:cQy6jxTtqsjdHwj+YlO/M2biJxgvFPWmEcPnUaBxYII=
-github.com/roadrunner-server/http/v4 v4.0.3/go.mod h1:EydCF3Kz6UGrWk/IgfUDtGmb+++fShpm0eZt4wAtTTI=
-github.com/roadrunner-server/informer/v4 v4.0.1 h1:Zv0iiuXZjXtV9zBDs4kVzRbYCjVpxQ4Xjh+HOuQnl3M=
-github.com/roadrunner-server/informer/v4 v4.0.1/go.mod h1:E8jbsSlsRUs/q8cUbRHS+bfj336RRhQoqmCtsfKvAmw=
-github.com/roadrunner-server/jobs/v4 v4.2.1 h1:Ja0lflRP1iKyjouLohUNACFsbSNXQ46/rsYZYoRfLJU=
-github.com/roadrunner-server/jobs/v4 v4.2.1/go.mod h1:UhOCFpJrWYPzSZTe32w8e+FborXbsC0zg0wIN1G202Q=
-github.com/roadrunner-server/kv/v4 v4.1.1 h1:eUth+RUTxRmtPHmTgfM7WyupyZyevUNFb4T1kSi3ygQ=
-github.com/roadrunner-server/kv/v4 v4.1.1/go.mod h1:OkPP8M2xqas1JpzlwkvP/CrRhr9+lVHkLI3QATA1MD0=
-github.com/roadrunner-server/logger/v4 v4.0.1 h1:2sZYaLIG4hnxgIqVhBKQ1n8ximdbztpNcf2IXzOp0bU=
-github.com/roadrunner-server/logger/v4 v4.0.1/go.mod h1:rZn2gwJLCzsCkEnkoBMR8I+lEYhqJagozAo4tE1NYeE=
-github.com/roadrunner-server/memcached/v4 v4.1.2 h1:EAbHKIIaYWAKMYtlHGHroqzZXqusf4Q9VKsmGHRU3EU=
-github.com/roadrunner-server/memcached/v4 v4.1.2/go.mod h1:U1Pm9Vjldw/KdIMLlZIHJ4PvYVAUM1VJWx7/6Dd3Mrs=
-github.com/roadrunner-server/memory/v4 v4.1.1 h1:HWq5xfJwsBrhodFSH9Z5VcXNfR/sS9myhXIjdicAfBA=
-github.com/roadrunner-server/memory/v4 v4.1.1/go.mod h1:S8vKQmpu7fjGl0xSJcWkuoZyF0JMLoArlmniGcYP8uk=
-github.com/roadrunner-server/metrics/v4 v4.0.1 h1:KzZqaM+Wu2awx5TduMt90cPWAMa28mArvWDWAYc+2JI=
-github.com/roadrunner-server/metrics/v4 v4.0.1/go.mod h1:gWIYZcckdLQsBkB+3ahElYkn61XF3WLWnGvHW8SHr94=
-github.com/roadrunner-server/nats/v4 v4.1.1 h1:R0xwE4d7z2kMdV+Fd3ql6pdWDCKmI9x5zU8wNewOxc0=
-github.com/roadrunner-server/nats/v4 v4.1.1/go.mod h1:m0XK3VLzbAiww8cpG9/qSwX335pFWcmxYoykpg/NUXg=
-github.com/roadrunner-server/otel/v4 v4.1.0 h1:ueV9HIaTVwOsxlX1f9MfsGehqoBXkjxQY1ezcUfkios=
-github.com/roadrunner-server/otel/v4 v4.1.0/go.mod h1:TIPTTw4sWJUS6eYTvbFpOlhb5G/S6Uej+RvmQwoZ3+I=
-github.com/roadrunner-server/prometheus/v4 v4.0.2 h1:XMRSZ4FGFAXgin6j2v/PKARuEgsRF4pzjqPQoBZ4+m4=
-github.com/roadrunner-server/prometheus/v4 v4.0.2/go.mod h1:vl9qe5+xLQLRWM90hifDCXlhVvKBdLGhPO3h0McOHI4=
-github.com/roadrunner-server/proxy_ip_parser/v4 v4.0.2 h1:Y5YsQvi35QMTso4coXpfsS2z1Ve55gHMMLXDbVGDmhE=
-github.com/roadrunner-server/proxy_ip_parser/v4 v4.0.2/go.mod h1:BMylWxcEeZJzQB4MbHDTLhcaGpb9zsVI9bQsV4Qr0Is=
-github.com/roadrunner-server/redis/v4 v4.1.1 h1:kQm+f6et32hD0XS84Njswffe/C6KbxAAxvy8ccY4Cx0=
-github.com/roadrunner-server/redis/v4 v4.1.1/go.mod h1:TE5pe6wzfgfgAd7Y6zB6g+NRFEh6x5ck+1c80UZe6eE=
-github.com/roadrunner-server/reload/v4 v4.0.1 h1:zzyXqVI0lpJGghQ7b+L1ABMvCmu+C/Er9QnLRwREAww=
-github.com/roadrunner-server/reload/v4 v4.0.1/go.mod h1:o6N85BsxcV7emsMBcK0CXSKoAOopyN4oIGAj62747uY=
-github.com/roadrunner-server/resetter/v4 v4.0.1 h1:mbGJYLG1KqIjxb9w09VpU3DJ6iHSKpeq1ZwqRArjqjc=
-github.com/roadrunner-server/resetter/v4 v4.0.1/go.mod h1:cJnriPp1I7eolQW+4LrX1Q2/wi1Sbowk6ik1M1+qZEc=
-github.com/roadrunner-server/rpc/v4 v4.1.0 h1:PQ+xZVC7afvQTHEQIFsmMPLh3zbyyR2wUffHmtG9ZOo=
-github.com/roadrunner-server/rpc/v4 v4.1.0/go.mod h1:u8WYnrWj8/zFRJgFnMdJ7fe75A/JWBwoTwqwYJAoF/M=
+github.com/roadrunner-server/grpc/v4 v4.1.1 h1:H4y+fwgawYL3LptiX4f6YxLPKKN84M+u6tjPRxd/5zo=
+github.com/roadrunner-server/grpc/v4 v4.1.1/go.mod h1:kor3dbSZrXzE/b9ZfLoqO6311GWHjQkag05uxDOmRhM=
+github.com/roadrunner-server/gzip/v4 v4.0.2 h1:wl9TErTPWRLpsV6JVzGZE0MfL/Rmc/9QDS+JStrxy8k=
+github.com/roadrunner-server/gzip/v4 v4.0.2/go.mod h1:I7N+YnBjMZ2a7zkt8YsaoxE6IyUXWYPZuaQ5BtB8lcQ=
+github.com/roadrunner-server/headers/v4 v4.0.2 h1:5COtDjkMPZmOOAefGLCEIJsajj177sdD85FkMUgzrtQ=
+github.com/roadrunner-server/headers/v4 v4.0.2/go.mod h1:YtQdSApjxESZWacXs6tOgGadakj/qCaMk92UPU9TZKA=
+github.com/roadrunner-server/http/v4 v4.0.4 h1:tJGM06S6Df9TeyGgBB0Q4exEA2AXYXJ3lYFgyV8wUO4=
+github.com/roadrunner-server/http/v4 v4.0.4/go.mod h1:YOakL5GRHU66fJ+kloNOZgUn2Oy5vv3T0XhBggaDwSA=
+github.com/roadrunner-server/informer/v4 v4.0.2 h1:LHDirDWayHgpymzKOdEU4rySHEE7tmTosULyLpSsV0Q=
+github.com/roadrunner-server/informer/v4 v4.0.2/go.mod h1:NSjaNqz5IsE577Nzfh+RJt9eTHSn7yXKHGFP/sGfiDo=
+github.com/roadrunner-server/jobs/v4 v4.2.2 h1:jwvL6KfdINx7HlgryJi5MfbEwTnPjvDD19u/Gz3Bpi8=
+github.com/roadrunner-server/jobs/v4 v4.2.2/go.mod h1:TQ+Jsi+aJcQNpitQXBAEMLcwKB0tbjs1vwNqzyVq5zI=
+github.com/roadrunner-server/kv/v4 v4.1.2 h1:1gMnBTk5txR2fXROLOsAn9qeskaz2Gm8wFgUsVzrYTs=
+github.com/roadrunner-server/kv/v4 v4.1.2/go.mod h1:fTQDKK07J0HTyfgsChZbmbT4OaoWIBh4OW19uoYw4c4=
+github.com/roadrunner-server/lock/v4 v4.0.0-beta.1 h1:b0QEmI8NW2OyZOtzIZEOoFTEwkBNhcurkca38ROso5I=
+github.com/roadrunner-server/lock/v4 v4.0.0-beta.1/go.mod h1:kCuU9cfDY17sh8ovL37fUs9Nw2sDLQsrh+RYF9sVg00=
+github.com/roadrunner-server/logger/v4 v4.0.2 h1:73h2abKyEKNOrN/SEfmzRL910MFKk8/IMzfGO3mxJ4g=
+github.com/roadrunner-server/logger/v4 v4.0.2/go.mod h1:3bwQj5L8Bu3OtBTmur1oGgdX8cb+SFk78cght9loj0c=
+github.com/roadrunner-server/memcached/v4 v4.1.3 h1:SNrTM57oFZzc7Lz75huhWKWQJR6NWE0A2ADMwcpNayI=
+github.com/roadrunner-server/memcached/v4 v4.1.3/go.mod h1:/9OW57klFir1+H51N4TYqPOEPk2Hf3fkVpAAQtFHY2k=
+github.com/roadrunner-server/memory/v4 v4.1.2 h1:EuN2woAsWO9VjsP/jW+28esH+RfilEW9dasBk3wRchY=
+github.com/roadrunner-server/memory/v4 v4.1.2/go.mod h1:1TD3nXwhA6vku7rO/CQsV5dKbBvvpXTa6pG9e5RsQwU=
+github.com/roadrunner-server/metrics/v4 v4.0.2 h1:gEG0llhF6ROqzhPvwYheDSWw1YZql/00lQTBKboK2yM=
+github.com/roadrunner-server/metrics/v4 v4.0.2/go.mod h1:Uur2reMHaCTMalvm0Emfh/myyGw4td1MkmDvUSLVg2Y=
+github.com/roadrunner-server/nats/v4 v4.1.2 h1:2FKuOV5o573M9a2dfl3sCawl1c+fDEnGEqLD15y/of4=
+github.com/roadrunner-server/nats/v4 v4.1.2/go.mod h1:/VnTOoopEQ9Vgs3o5SOtcxY/n3qOT1a4DllMqt9S1qY=
+github.com/roadrunner-server/otel/v4 v4.1.1 h1:E0u642TZE7OP06x9H+amhg88aAtonlhE5JglIBsELlc=
+github.com/roadrunner-server/otel/v4 v4.1.1/go.mod h1:XYM2Xw1S5szvxwDPnx3oxGMjw5+OPTZdrM6OxuRMerI=
+github.com/roadrunner-server/prometheus/v4 v4.0.3 h1:NoMCyrTerWQ8A0nCSyb+VCVv6PxMcnmy08p20Rh5Kbk=
+github.com/roadrunner-server/prometheus/v4 v4.0.3/go.mod h1:DPZCzWJXeSZjYDuwLXC6AG9fEVTXFyvq2px31LRlm5I=
+github.com/roadrunner-server/proxy_ip_parser/v4 v4.0.3 h1:nVWcOZgVjOPcBGpOsRV8UB7LUSAcMQDDhwL2tObgDXo=
+github.com/roadrunner-server/proxy_ip_parser/v4 v4.0.3/go.mod h1:p65Hp0NjTdrKCzZk9irVqfje5NODdvRtNisckB2td/8=
+github.com/roadrunner-server/redis/v4 v4.1.2 h1:jEcfvekLbmmfN/QaW6qZu2dmrPcNVRdoRJRMvEr0zoU=
+github.com/roadrunner-server/redis/v4 v4.1.2/go.mod h1:cyi5sA7ecSTGClT1DNiH92B7sJPzBmV4PCbtVj0bsmo=
+github.com/roadrunner-server/reload/v4 v4.0.2 h1:RJ3Tyc3gUBqtHHHp5hx1KhDRteZCGp9khIfJ7+tGrKE=
+github.com/roadrunner-server/reload/v4 v4.0.2/go.mod h1:5t+jHSttbmaL1kn5zvqLYxqr4Yn/CtAXq5JDtFxvoPg=
+github.com/roadrunner-server/resetter/v4 v4.0.2 h1:IUT5va8h0x7fliYbcRCj6e5uEhU8y1mVMCh6uJuCLYA=
+github.com/roadrunner-server/resetter/v4 v4.0.2/go.mod h1:aMBbcnJrVlUm3QayCUyuEStAprAu42c9tNhuvS97Ue4=
+github.com/roadrunner-server/rpc/v4 v4.1.1 h1:K9umvREAmGlof5PsuZ3BGVNsLMiPS9Q6EX1ZT8xazts=
+github.com/roadrunner-server/rpc/v4 v4.1.1/go.mod h1:bp5jrrsyoBuoOkq2k16RPEfiYYDaqywsjfL5gGk/UZQ=
 github.com/roadrunner-server/sdk/v4 v4.2.0 h1:hqNlqJV2MXZ8DF1wJnouUdV/55Hae6VL37fVXT1aIr8=
 github.com/roadrunner-server/sdk/v4 v4.2.0/go.mod h1:aIzXmg8DZBJ4Tbtvihp/s6VH4e2oSdivOqm/8V+HuUc=
-github.com/roadrunner-server/send/v4 v4.0.2 h1:65ZhgCO1PUPICd7xQ9OCCt7mZwDJkgficE2EmUDQJi0=
-github.com/roadrunner-server/send/v4 v4.0.2/go.mod h1:K99UlDZ8y24VHBhwSso7CvcmXlwDpxbFL3wimxfi7Ko=
-github.com/roadrunner-server/server/v4 v4.0.1 h1:hWvngTrbCHnAIwjK7mWPnSr8G5DMwNtkY8/dZkceu4A=
-github.com/roadrunner-server/server/v4 v4.0.1/go.mod h1:obFiXYPZb4gYtatPQsi0IOdfVv2hfxHpFjkWC8qDOk4=
-github.com/roadrunner-server/service/v4 v4.0.2 h1:uSeHJsnaJI/AEiVEwFxvKwadTAHQbJTInXRbwFHwvBM=
-github.com/roadrunner-server/service/v4 v4.0.2/go.mod h1:ACrVtE4LjPAFWl6grDTTE4rHP84QEVFPlyFjlUIiIs8=
-github.com/roadrunner-server/sqs/v4 v4.1.1 h1:fL15srKB/TYf1pEokZ4UrtR2OCclSFGvkiKbzQHQjSQ=
-github.com/roadrunner-server/sqs/v4 v4.1.1/go.mod h1:tFhXniMBq4i5jfyCn9i0AG9eRbvGfLkksDKSP4XcnX4=
-github.com/roadrunner-server/static/v4 v4.0.2 h1:5Dodv2xeWE3EVsgRc8iFrIG8mKbEZX4Pw14yPtULU+M=
-github.com/roadrunner-server/static/v4 v4.0.2/go.mod h1:RKOsiNiHr3+K7bdZpmakQH8NqZiWfBmgu8U03JyB2wY=
-github.com/roadrunner-server/status/v4 v4.0.1 h1:3xRN6Kyh6tyYkJKV1VVTuIHEQFctTy+VH9EdsF+jPXo=
-github.com/roadrunner-server/status/v4 v4.0.1/go.mod h1:GfyQGw30coNNO4nPmkx0cNI/sEIN0X0r3yLyLgR5vVk=
-github.com/roadrunner-server/tcp/v4 v4.0.1 h1:qCrb8LrfkMkWSxR/5mfYAGocO82oFhZKRQZ/BKSQxQM=
-github.com/roadrunner-server/tcp/v4 v4.0.1/go.mod h1:njvNgrR/90XzVFDxKtgodhFq+0hVsNBjkBIRP07sqA0=
-github.com/roadrunner-server/tcplisten v1.2.1 h1:9hVVMlCRvMPewnJCnfSe/kKAqn2ZOF3wHy+ji0M/NKU=
-github.com/roadrunner-server/tcplisten v1.2.1/go.mod h1:TRJLGwIruiJ7QhmGVRgJFY5Ch72mPoLhLAxuxLnavpU=
+github.com/roadrunner-server/send/v4 v4.0.3 h1:X4MoB450IyVHrFZLaRxBNErXQCwtZjAy2DoP/y5m9sc=
+github.com/roadrunner-server/send/v4 v4.0.3/go.mod h1:vSxx1G6ez6FFMWvX4yyK9wA+mGPdRxUKxj1Tbx+u4xk=
+github.com/roadrunner-server/server/v4 v4.0.2 h1:fcehawygmWPXx1CVEhXccj5BDYfv0xJtadZwzhYeC/I=
+github.com/roadrunner-server/server/v4 v4.0.2/go.mod h1:QCvMiVMNWOyb8xxidbup/8d3PUduCwMdf/nkjlU155M=
+github.com/roadrunner-server/service/v4 v4.0.3 h1:4VAenSdiRdCt86OX8iLNoe3vkVWGaggKu0TQtZdN7OQ=
+github.com/roadrunner-server/service/v4 v4.0.3/go.mod h1:8cg6iQNeFX51HylaBD3LKRMREWyF2Y70hZ7R1CRRUdk=
+github.com/roadrunner-server/sqs/v4 v4.1.2 h1:wypawz/SlnRPqRa0pxRqqW7G12xW9JdA70cML3OcONA=
+github.com/roadrunner-server/sqs/v4 v4.1.2/go.mod h1:4BHeJngJFpar5uq9lKYJIF3o+N1uVTee+8SWIjj5it4=
+github.com/roadrunner-server/static/v4 v4.0.3 h1:ulWDAus57UA5rvgnpmm4+Y8oZPbK1oc8k4//GtfaOww=
+github.com/roadrunner-server/static/v4 v4.0.3/go.mod h1:jT5V0qHqN01WHBmUwgzn7/6PlxjU6JkQeGg1rLqQt5Q=
+github.com/roadrunner-server/status/v4 v4.0.2 h1:K3crpLufOQUUUHyHy+ARwus0gl6ChEmWRJSJQI/MomQ=
+github.com/roadrunner-server/status/v4 v4.0.2/go.mod h1:Vdj2VfuldaTOBiNyjLwZUX2g2zOvYNlduEkXBuGEqfY=
+github.com/roadrunner-server/tcp/v4 v4.0.2 h1:YggCtz2MiUJKreua0yOufxe4enOKo+UvgPrQcTz777E=
+github.com/roadrunner-server/tcp/v4 v4.0.2/go.mod h1:hSzTrCZAQH9R+sCdfFQDBLMCoE+cQSHRBCUQ+07QSyc=
+github.com/roadrunner-server/tcplisten v1.3.0 h1:VDd6IbP8oIjm5vKvMVozeZgeHgOcoP0XYLOyOqcZHCY=
+github.com/roadrunner-server/tcplisten v1.3.0/go.mod h1:VR6Ob5am0oEuLMOeLiVvQxG9ShykAEgrlvZddX8EfoU=
 github.com/robfig/cron v1.2.0 h1:ZjScXvvxeQ63Dbyxy76Fj3AT3Ut0aKsyd2/tl3DTMuQ=
 github.com/robfig/cron v1.2.0/go.mod h1:JGuDeoQd7Z6yL4zQhZ3OPEVHB7fL6Ka6skscFHfmt2k=
 github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ=
@@ -900,8 +902,8 @@ github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKs
 github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
 github.com/subosito/gotenv v1.4.2 h1:X1TuBLAMDFbaTAChgCBLu3DU3UPyELpnF2jjJ2cz/S8=
 github.com/subosito/gotenv v1.4.2/go.mod h1:ayKnFf/c6rvx/2iiLrJUk1e6plDbT3edrFNGqEflhK0=
-github.com/temporalio/roadrunner-temporal/v4 v4.1.0 h1:ilS355zImrQ10yIhpaGusJIpZBuqo9o5bJmzjI7AiCg=
-github.com/temporalio/roadrunner-temporal/v4 v4.1.0/go.mod h1:0w8k6fQakvmZZJ92L5uuR67sBfi9pSCZ+54MU0OJ3+Q=
+github.com/temporalio/roadrunner-temporal/v4 v4.2.0-alpha.1 h1:YFk/xaP/XLrzTKAfbVEnOthDlkAH0iVr1aD3Y6qnl88=
+github.com/temporalio/roadrunner-temporal/v4 v4.2.0-alpha.1/go.mod h1:Oel4gAUANw63Jz83FDW1n78+L5Cgks+ykCMd3y7SrzU=
 github.com/tinylib/msgp v1.1.6/go.mod h1:75BAfg2hauQhs3qedfdDZmWAPcFMAvJE5b9rGOMufyw=
 github.com/tinylib/msgp v1.1.8 h1:FCXC1xanKO4I8plpHGH2P7koL/RzZs12l/+r7vakfm0=
 github.com/tinylib/msgp v1.1.8/go.mod h1:qkpG+2ldGg4xRFmx+jfTvZPxfGFhi64BcnL9vkCm/Tw=