Relay 0.13.0 changes (#21)

Allow setting state on Job creation.

.github/workflows/workflow.yml

@@ -22,7 +22,7 @@ jobs:
           --health-timeout 5s
           --health-retries 5
       relay:
-        image: ghcr.io/rust-playground/relay-rs:0.11.0
+        image: ghcr.io/rust-playground/relay-rs:latest
         ports:
           - 8080:8080
         env:
@@ -57,6 +57,6 @@ jobs:
     steps:
       - uses: actions/checkout@v3
       - name: golangci-lint
-        uses: golangci/golangci-lint-action@v2
+        uses: golangci/golangci-lint-action@v3
         with:
           version: latest

_examples/consumer/main.go

@@ -3,7 +3,6 @@ package main
 import (
 	"context"
 	"fmt"
-	"math/rand"
 	"sync"
 	"sync/atomic"
 	"time"
@@ -16,10 +15,6 @@ var (
 	processed uint64
 )
 
-func init() {
-	rand.Seed(time.Now().UnixNano())
-}
-
 type payload struct {
 	Key string `json:"key"`
 }

_examples/producer/main.go

@@ -20,7 +20,6 @@ var (
 )
 
 func init() {
-	rand.Seed(time.Now().UnixNano())
 	http.DefaultTransport.(*http.Transport).MaxIdleConnsPerHost = 1024
 	http.DefaultTransport.(*http.Transport).MaxConnsPerHost = 1024
 }

client.go

@@ -41,22 +41,19 @@ type Job[P any, S any] struct {
 	Payload P `json:"payload"`
 
 	// State is the raw JSON payload that the job runner will receive.
-	//
-	// This state will be ignored when enqueueing a Job and can only be set via a Heartbeat
-	// request.
 	State *S `json:"state,omitempty"`
 
 	// RunAt can optionally schedule/set a Job to be run only at a specific time in the
 	// future. This option should mainly be used for one-time jobs and scheduled jobs that have
-	// the option of being self-perpetuated in combination with the reschedule endpoint.
+	// the option of being self-perpetuated in combination with the rescheduling endpoint.
 	RunAt *time.Time `json:"run_at,omitempty"`
 
 	// UpdatedAt indicates last time the Job was updated either through enqueue, reschedule or heartbeat.
 	// This value is for reporting purposes only and will be ignored when enqueuing and rescheduling Jobs.
 	UpdatedAt *time.Time `json:"updated_at"`
 }
 
-// Config contains all information to create a new REaly instance fo use.
+// Config contains all information to create a new Relay instance fo use.
 type Config struct {
 	// BasURL of the HTTP server
 	BaseURL string

client_test.go

@@ -13,13 +13,10 @@ import (
 )
 
 var (
-	baseURL = os.Getenv("RELAY_URL")
+	baseURL    = os.Getenv("RELAY_URL")
+	randSource = rand.New(rand.NewSource(time.Now().UnixNano()))
 )
 
-func init() {
-	rand.Seed(time.Now().UnixNano())
-}
-
 func TestOneTimeJob(t *testing.T) {
 
 	assert := require.New(t)
@@ -31,8 +28,8 @@ func TestOneTimeJob(t *testing.T) {
 	assert.NoError(err)
 
 	now := time.Now().UTC().Truncate(time.Millisecond)
-	id := strconv.Itoa(rand.Int())
-	queue := strconv.Itoa(rand.Int())
+	id := strconv.Itoa(randSource.Int())
+	queue := strconv.Itoa(randSource.Int())
 	job := Job[any, any]{
 		ID:         id,
 		Queue:      queue,
@@ -89,8 +86,8 @@ func TestReschedule(t *testing.T) {
 	assert.NoError(err)
 
 	now := time.Now().UTC().Truncate(time.Millisecond)
-	id := strconv.Itoa(rand.Int())
-	queue := strconv.Itoa(rand.Int())
+	id := strconv.Itoa(randSource.Int())
+	queue := strconv.Itoa(randSource.Int())
 	job := Job[any, any]{
 		ID:         id,
 		Queue:      queue,
@@ -147,9 +144,9 @@ func TestEnqueueMultiple(t *testing.T) {
 	assert.NoError(err)
 
 	now := time.Now().UTC().Truncate(time.Millisecond)
-	id := strconv.Itoa(rand.Int())
-	id2 := strconv.Itoa(rand.Int())
-	queue := strconv.Itoa(rand.Int())
+	id := strconv.Itoa(randSource.Int())
+	id2 := strconv.Itoa(randSource.Int())
+	queue := strconv.Itoa(randSource.Int())
 	job1 := Job[any, any]{
 		ID:         id,
 		Queue:      queue,

docker-compose.yml

@@ -11,7 +11,7 @@ services:
       POSTGRES_HOST_AUTH_METHOD: trust
 
   relay:
-    image: ghcr.io/rust-playground/relay-rs:0.9.0
+    image: ghcr.io/rust-playground/relay-rs:latest
     environment:
       - DATABASE_URL=postgres://username:pass@postgres:5432/relay?sslmode=disable
       - HTTP_PORT=8080

go.mod

@@ -4,15 +4,14 @@ go 1.18
 
 require (
 	github.com/go-playground/backoff-sys v1.1.1
-	github.com/go-playground/errors/v5 v5.2.3
-	github.com/go-playground/pkg/v5 v5.6.0
+	github.com/go-playground/errors/v5 v5.3.0
+	github.com/go-playground/pkg/v5 v5.16.0
 	github.com/stretchr/testify v1.8.0
 	golang.org/x/sync v0.0.0-20210220032951-036812b2e83c
 )
 
 require (
 	github.com/davecgh/go-spew v1.1.1 // indirect
-	github.com/go-playground/assert/v2 v2.2.0 // indirect
 	github.com/go-playground/form/v4 v4.2.0 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect

go.sum

@@ -3,15 +3,14 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/go-playground/assert/v2 v2.0.1/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4=
 github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s=
-github.com/go-playground/assert/v2 v2.2.0/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4=
 github.com/go-playground/backoff-sys v1.1.1 h1:wlzbS+239Px9AK8EtdG27lUvbX7AssIxFLYrZAud5KA=
 github.com/go-playground/backoff-sys v1.1.1/go.mod h1:v6FlV3rjJ/qeUH0MEpypQGrVaQfqW5FSv9D+nXI68bY=
-github.com/go-playground/errors/v5 v5.2.3 h1:RPxaFHgJZjgk/OFkUcfytJgRQKRINLtueVxgOdnfPpg=
-github.com/go-playground/errors/v5 v5.2.3/go.mod h1:DincxRGwraWmq39TZDqtnOtHGOJ+AbNbO0OmBzX6MLw=
+github.com/go-playground/errors/v5 v5.3.0 h1:Okot0WmH9v4bLz7wHad/gu1XrmqIHW6r5P4ubLv7QhE=
+github.com/go-playground/errors/v5 v5.3.0/go.mod h1:LcLhmzQ/RuEntAs9r38NSV+xtbHffhMx/1yuuEroc7M=
 github.com/go-playground/form/v4 v4.2.0 h1:N1wh+Goz61e6w66vo8vJkQt+uwZSoLz50kZPJWR8eic=
 github.com/go-playground/form/v4 v4.2.0/go.mod h1:q1a2BY+AQUUzhl6xA/6hBetay6dEIhMHjgvJiGo6K7U=
-github.com/go-playground/pkg/v5 v5.6.0 h1:97YpRFzIcS5NFP2Uzxj8cPYz4zTuwweyXADYcA1KfUQ=
-github.com/go-playground/pkg/v5 v5.6.0/go.mod h1:TvZ2nNtNh6VfoNteY9ApA2BXt1ZwJliFZ4hzPAwLS9Y=
+github.com/go-playground/pkg/v5 v5.16.0 h1:A/GZ5kitZuKQOEG1zm5tD9UrQRGl69k+MSck6Vojel8=
+github.com/go-playground/pkg/v5 v5.16.0/go.mod h1:eT8XZeFHnqZkfkpkbI8ayjfCw9GohV2/j8STbVmoR6s=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=