queues/sqs_producer/producer.go

@@ -11,7 +11,6 @@ import (
 	"github.com/aws/aws-sdk-go/service/sqs"
 	"gitlab.com/uafrica/go-utils/errors"
 	"gitlab.com/uafrica/go-utils/logger"
-	"gitlab.com/uafrica/go-utils/logs"
 	"gitlab.com/uafrica/go-utils/queues"
 )
 
@@ -95,11 +94,6 @@ type QueueProducer struct {
 }
 
 func (m *QueueProducer) Send(event queues.Event) (string, error) {
-	startTime := time.Now()
-	defer func() {
-		logs.LogSQSSent(startTime, event.QueueName, event.TypeName, event.BodyJSON)
-	}()
-
 	//add params as message attributes
 	msgAttrs := make(map[string]*sqs.MessageAttributeValue)
 	for key, val := range event.ParamValues {

search/document_store.go

@@ -8,12 +8,10 @@ import (
 	"net/http"
 	"reflect"
 	"strings"
-	"time"
 
 	opensearchapi "github.com/opensearch-project/opensearch-go/opensearchapi"
 	"gitlab.com/uafrica/go-utils/errors"
 	"gitlab.com/uafrica/go-utils/logger"
-	"gitlab.com/uafrica/go-utils/logs"
 	"gitlab.com/uafrica/go-utils/reflection"
 )
 
@@ -204,11 +202,6 @@ func (ds *documentStore) Search(query Query, limit int64) (ids []string, totalCo
 		Body:  bytes.NewReader(jsonBody),
 	}
 
-	startTime := time.Now()
-	defer func() {
-		logs.LogSearch(startTime, ds.name, string(jsonBody))
-	}()
-
 	searchResponse, err := search.Do(context.Background(), ds.w.client)
 	if err != nil {
 		err = errors.Wrapf(err, "failed to search documents")

search/time_series.go

@@ -13,7 +13,6 @@ import (
 	opensearchapi "github.com/opensearch-project/opensearch-go/opensearchapi"
 	"gitlab.com/uafrica/go-utils/errors"
 	"gitlab.com/uafrica/go-utils/logger"
-	"gitlab.com/uafrica/go-utils/logs"
 	"gitlab.com/uafrica/go-utils/reflection"
 )
 
@@ -392,11 +391,6 @@ func (ts *timeSeries) Search(query Query, limit int64) (docs interface{}, totalC
 		Body:  bytes.NewReader(jsonBody),
 	}
 
-	startTime := time.Now()
-	defer func() {
-		logs.LogSearch(startTime, ts.name+"-*", string(jsonBody))
-	}()
-
 	searchResponse, err := search.Do(context.Background(), ts.w.client)
 	if err != nil {
 		err = errors.Wrapf(err, "failed to search documents")

service/context.go

@@ -9,7 +9,6 @@ import (
 	"gitlab.com/uafrica/go-utils/audit"
 	"gitlab.com/uafrica/go-utils/errors"
 	"gitlab.com/uafrica/go-utils/logger"
-	"gitlab.com/uafrica/go-utils/logs"
 	"gitlab.com/uafrica/go-utils/queues"
 	"gitlab.com/uafrica/go-utils/string_utils"
 )
@@ -54,10 +53,6 @@ type Context interface {
 
 	//write a data change audit event
 	AuditChange(eventType string, orgValue, newValue interface{})
-
-	//Sleep() does a time.Sleep and record it in log actions so that we can account for the time spent sleeping
-	//vs e.g. time waiting for outgoing API calls or db queries
-	Sleep(dur time.Duration)
 }
 
 //values: are added to context and logger
@@ -233,11 +228,3 @@ func (ctx *serviceContext) AuditChange(eventType string, orgValue, newValue inte
 		return
 	}
 }
-
-func (ctx *serviceContext) Sleep(dur time.Duration) {
-	if dur > 0 {
-		startTime := time.Now()
-		time.Sleep(dur)
-		logs.LogSleep(startTime)
-	}
-}