Replaced github.com/pkg/errors with stdlib

Author: vgarvardt

driver/sql/postgres/advisory_lock_aggregate_projection_storage.go

@@ -3,12 +3,12 @@ package postgres
 import (
 	"context"
 	"database/sql"
+	"errors"
 	"fmt"
 	"strings"
 
 	"github.com/hellofresh/goengine"
 	driverSQL "github.com/hellofresh/goengine/driver/sql"
-	"github.com/pkg/errors"
 )
 
 var _ driverSQL.AggregateProjectorStorage = &AdvisoryLockAggregateProjectionStorage{}

driver/sql/projection.go

@@ -3,11 +3,11 @@ package sql
 import (
 	"context"
 	"database/sql"
+	"errors"
 	"time"
 
 	"github.com/mailru/easyjson/jlexer"
 	"github.com/mailru/easyjson/jwriter"
-	"github.com/pkg/errors"
 
 	"github.com/hellofresh/goengine"
 )
@@ -37,7 +37,7 @@ type (
 
 	// ProjectionStateSerialization is an interface describing how a projection state can be initialized, serialized/encoded anf deserialized/decoded
 	ProjectionStateSerialization interface {
-		// init initializes the state
+		// Init initializes the state
 		Init(ctx context.Context) (interface{}, error)
 
 		// DecodeState reconstitute the projection state based on the provided state data
@@ -156,7 +156,7 @@ type nopProjectionStateSerialization struct {
 }
 
 // DecodeState reconstitute the projection state based on the provided state data
-func (nopProjectionStateSerialization) DecodeState(data []byte) (interface{}, error) {
+func (nopProjectionStateSerialization) DecodeState([]byte) (interface{}, error) {
 	return nil, nil
 }
 

driver/sql/projection_notification_processor.go

@@ -2,11 +2,11 @@ package sql
 
 import (
 	"context"
+	"errors"
 	"runtime"
 	"sync"
 
 	"github.com/hellofresh/goengine"
-	"github.com/pkg/errors"
 )
 
 type (

driver/sql/projector_notification.go

@@ -3,9 +3,10 @@ package sql
 import (
 	"context"
 	"database/sql"
+	"errors"
+	"fmt"
 
 	"github.com/hellofresh/goengine"
-	"github.com/pkg/errors"
 )
 
 // Ensure the notificationProjector.Execute is a ProjectionTrigger
@@ -210,7 +211,7 @@ func wrapProjectionHandlerToTrapError(handler goengine.MessageHandler) goengine.
 			case error:
 				err = x
 			default:
-				err = errors.Errorf("unknown panic: (%T) %v", x, x)
+				err = fmt.Errorf("unknown panic: (%T) %v", x, x)
 			}
 
 			handlerErr = NewProjectionHandlerError(err)

driver/sql/projector_notification_test.go

@@ -4,13 +4,14 @@ package sql
 
 import (
 	"context"
+	"errors"
 	"testing"
 
-	"github.com/hellofresh/goengine"
-	"github.com/hellofresh/goengine/aggregate"
-	"github.com/pkg/errors"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
+
+	"github.com/hellofresh/goengine"
+	"github.com/hellofresh/goengine/aggregate"
 )
 
 func TestWrapProjectionHandlerToTrapError(t *testing.T) {

driver/sql/projector_stream.go

@@ -3,11 +3,11 @@ package sql
 import (
 	"context"
 	"database/sql"
+	"fmt"
 	"math"
 	"sync"
 
 	"github.com/hellofresh/goengine"
-	"github.com/pkg/errors"
 )
 
 // StreamProjector is a postgres projector used to execute a projection against an event stream.
@@ -149,8 +149,8 @@ func (s *StreamProjector) processNotification(
 		}
 	}
 
-	return errors.Errorf(
-		"seriously %d retries is enough! maybe it's time to fix your projection or error handling code?",
+	return fmt.Errorf(
+		"seriously %d retries is enough! maybe it's time to fix your projection or error handling code",
 		math.MaxInt16,
 	)
 }

go.mod

@@ -8,7 +8,6 @@ require (
 	github.com/google/uuid v1.3.0
 	github.com/lib/pq v1.10.2
 	github.com/mailru/easyjson v0.7.7
-	github.com/pkg/errors v0.9.1
 	github.com/prometheus/client_golang v1.11.0
 	github.com/sirupsen/logrus v1.8.1
 	github.com/streadway/amqp v1.0.0

metadata/metadata.go

@@ -2,11 +2,11 @@ package metadata
 
 import (
 	"encoding/json"
+	"fmt"
 
 	"github.com/mailru/easyjson"
 	"github.com/mailru/easyjson/jlexer"
 	"github.com/mailru/easyjson/jwriter"
-	"github.com/pkg/errors"
 )
 
 type (
@@ -214,7 +214,7 @@ func marshalJSONKeyValues(out *jwriter.Writer, parent Metadata) {
 
 	plen := len(parentJSON)
 	if parentJSON[1] != '{' || parentJSON[plen-1] != '}' {
-		out.Raw(parentJSON, errors.Errorf("JSON unmarshal failed for Metadata of type %T", parent))
+		out.Raw(parentJSON, fmt.Errorf("JSON unmarshal failed for Metadata of type %T", parent))
 		return
 	}