refactor: replace pkg/errors with native go errors

apm-lambda-extension/extension/process_metadata.go

@@ -22,11 +22,10 @@ import (
 	"bytes"
 	"compress/gzip"
 	"compress/zlib"
+	"errors"
 	"fmt"
 	"io/ioutil"
 	"strings"
-
-	"github.com/pkg/errors"
 )
 
 type MetadataContainer struct {
@@ -38,7 +37,7 @@ type MetadataContainer struct {
 func ProcessMetadata(data AgentData) ([]byte, error) {
 	uncompressedData, err := GetUncompressedBytes(data.Data, data.ContentEncoding)
 	if err != nil {
-		return nil, errors.New(fmt.Sprintf("Error uncompressing agent data for metadata extraction : %v", err))
+		return nil, fmt.Errorf("Error uncompressing agent data for metadata extraction: %w", err)
 	}
 	scanner := bufio.NewScanner(strings.NewReader(string(uncompressedData)))
 	scanner.Scan()

apm-lambda-extension/go.mod

@@ -6,7 +6,6 @@ require (
 	github.com/google/uuid v1.3.0
 	github.com/joho/godotenv v1.4.0
 	github.com/magefile/mage v1.13.0 // indirect
-	github.com/pkg/errors v0.9.1
 	github.com/stretchr/testify v1.7.0
 	go.elastic.co/ecszap v1.0.1
 	go.uber.org/atomic v1.9.0 // indirect
@@ -33,6 +32,7 @@ require (
 	github.com/aws/aws-sdk-go-v2/service/sts v1.16.9 // indirect
 	github.com/aws/smithy-go v1.12.0 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
+	github.com/pkg/errors v0.9.1 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	github.com/santhosh-tekuri/jsonschema v1.2.4 // indirect
 	gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b // indirect

apm-lambda-extension/logsapi/client.go

@@ -20,11 +20,10 @@ package logsapi
 import (
 	"bytes"
 	"encoding/json"
+	"errors"
 	"fmt"
 	"io/ioutil"
 	"net/http"
-
-	"github.com/pkg/errors"
 )
 
 const lambdaAgentIdentifierHeaderKey string = "Lambda-Extension-Identifier"
@@ -153,7 +152,7 @@ func (c *Client) Subscribe(types []EventType, destinationURI URI, extensionId st
 			Destination:   destination,
 		})
 	if err != nil {
-		return nil, errors.WithMessage(err, "failed to marshal SubscribeRequest")
+		return nil, fmt.Errorf("failed to marshal SubscribeRequest: %w", err)
 	}
 
 	headers := make(map[string]string)
@@ -166,14 +165,14 @@ func (c *Client) Subscribe(types []EventType, destinationURI URI, extensionId st
 	defer resp.Body.Close()
 
 	if resp.StatusCode == http.StatusAccepted {
-		return nil, errors.Errorf("Logs API is not supported in this environment")
+		return nil, errors.New("Logs API is not supported in this environment")
 	} else if resp.StatusCode != http.StatusOK {
 		body, err := ioutil.ReadAll(resp.Body)
 		if err != nil {
-			return nil, errors.Errorf("%s failed: %d[%s]", url, resp.StatusCode, resp.Status)
+			return nil, fmt.Errorf("%s failed: %d[%s]", url, resp.StatusCode, resp.Status)
 		}
 
-		return nil, errors.Errorf("%s failed: %d[%s] %s", url, resp.StatusCode, resp.Status, string(body))
+		return nil, fmt.Errorf("%s failed: %d[%s] %s", url, resp.StatusCode, resp.Status, string(body))
 	}
 
 	body, _ := ioutil.ReadAll(resp.Body)

apm-lambda-extension/logsapi/subscribe.go

@@ -19,15 +19,14 @@ package logsapi
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"net"
 	"net/http"
 	"os"
 	"time"
 
 	"elastic/apm-lambda-extension/extension"
-
-	"github.com/pkg/errors"
 )
 
 // TODO: Remove global variable and find another way to retrieve Logs Listener network info when testing main