Fix: Correcting time unit for logs of http-service as well as datasources

pkg/gofr/datasource/cassandra/cassandra.go

@@ -328,7 +328,7 @@ func (*Client) getColumnsFromColumnsInfo(columns []gocql.ColumnInfo) []string {
 }
 
 func (c *Client) sendOperationStats(ql *QueryLog, startTime time.Time, method string, span trace.Span) {
-	duration := time.Since(startTime).Milliseconds()
+	duration := time.Since(startTime).Microseconds()
 
 	ql.Duration = duration
 

pkg/gofr/datasource/clickhouse/clickhouse.go

@@ -169,7 +169,7 @@ func (c *client) AsyncInsert(ctx context.Context, query string, wait bool, args
 
 func (c *client) sendOperationStats(start time.Time, methodType, query string, method string,
 	span trace.Span, args ...interface{}) {
-	duration := time.Since(start).Milliseconds()
+	duration := time.Since(start).Microseconds()
 
 	c.logger.Debug(&Log{
 		Type:     methodType,

pkg/gofr/datasource/file/ftp/file.go

@@ -389,7 +389,7 @@ func (f *file) WriteAt(p []byte, off int64) (n int, err error) {
 }
 
 func (f *file) sendOperationStats(fl *FileLog, startTime time.Time) {
-	duration := time.Since(startTime).Milliseconds()
+	duration := time.Since(startTime).Microseconds()
 
 	fl.Duration = duration
 

pkg/gofr/datasource/file/ftp/fs.go

@@ -326,7 +326,7 @@ func (f *fileSystem) Rename(oldname, newname string) error {
 }
 
 func (f *fileSystem) sendOperationStats(fl *FileLog, startTime time.Time) {
-	duration := time.Since(startTime).Milliseconds()
+	duration := time.Since(startTime).Microseconds()
 
 	fl.Duration = duration
 

pkg/gofr/datasource/file/s3/file.go

@@ -468,7 +468,7 @@ func (f *s3file) Seek(offset int64, whence int) (int64, error) {
 
 // sendOperationStats logs the FileLog of any file operations performed in S3.
 func (f *s3file) sendOperationStats(fl *FileLog, startTime time.Time) {
-	duration := time.Since(startTime).Milliseconds()
+	duration := time.Since(startTime).Microseconds()
 
 	fl.Duration = duration
 

pkg/gofr/datasource/file/s3/fs_dir.go

@@ -291,7 +291,7 @@ func (f *fileSystem) renameDirectory(st, msg *string, oldPath, newPath string) e
 
 // sendOperationStats logs the FileLog of any file operations performed in S3.
 func (f *fileSystem) sendOperationStats(fl *FileLog, startTime time.Time) {
-	duration := time.Since(startTime).Milliseconds()
+	duration := time.Since(startTime).Microseconds()
 
 	fl.Duration = duration
 

pkg/gofr/datasource/file/sftp/fs.go

@@ -257,7 +257,7 @@ func (f *fileSystem) Getwd() (string, error) {
 }
 
 func (f *fileSystem) sendOperationStats(fl *FileLog, startTime time.Time) {
-	duration := time.Since(startTime).Milliseconds()
+	duration := time.Since(startTime).Microseconds()
 
 	fl.Duration = duration
 

pkg/gofr/datasource/kv-store/badger/badger.go

@@ -148,7 +148,7 @@ func (c *client) useTransaction(f func(txn *badger.Txn) error) error {
 
 func (c *client) sendOperationStats(start time.Time, methodType string, method string,
 	span trace.Span, kv ...string) {
-	duration := time.Since(start).Milliseconds()
+	duration := time.Since(start).Microseconds()
 
 	c.logger.Debug(&Log{
 		Type:     methodType,

pkg/gofr/datasource/mongo/mongo.go

@@ -285,7 +285,7 @@ func (c *Client) CreateCollection(ctx context.Context, name string) error {
 }
 
 func (c *Client) sendOperationStats(ql *QueryLog, startTime time.Time, method string, span trace.Span) {
-	duration := time.Since(startTime).Milliseconds()
+	duration := time.Since(startTime).Microseconds()
 
 	ql.Duration = duration
 

pkg/gofr/datasource/opentsdb/observability.go

@@ -36,7 +36,7 @@ func (ql *QueryLog) PrettyPrint(writer io.Writer) {
 }
 
 func sendOperationStats(logger Logger, start time.Time, operation string, status, message *string, span trace.Span) {
-	duration := time.Since(start).Milliseconds()
+	duration := time.Since(start).Microseconds()
 
 	logger.Debug(&QueryLog{
 		Operation: operation,

pkg/gofr/datasource/redis/hook.go

@@ -65,7 +65,7 @@ func (ql *QueryLog) String() string {
 
 // logQuery logs the Redis query information.
 func (r *redisHook) sendOperationStats(start time.Time, query string, args ...interface{}) {
-	duration := time.Since(start).Milliseconds()
+	duration := time.Since(start).Microseconds()
 
 	r.logger.Debug(&QueryLog{
 		Query:    query,

pkg/gofr/datasource/solr/solr.go

@@ -290,7 +290,7 @@ func (c *Client) createRequest(ctx context.Context, method, url string, params m
 }
 
 func (c *Client) sendOperationStats(ctx context.Context, ql *QueryLog, startTime time.Time, method string, span trace.Span) {
-	duration := time.Since(startTime).Milliseconds()
+	duration := time.Since(startTime).Microseconds()
 
 	ql.Duration = duration
 

pkg/gofr/datasource/sql/db.go

@@ -45,7 +45,7 @@ func clean(query string) string {
 }
 
 func (d *DB) sendOperationStats(start time.Time, queryType, query string, args ...interface{}) {
-	duration := time.Since(start).Milliseconds()
+	duration := time.Since(start).Microseconds()
 
 	d.logger.Debug(&Log{
 		Type:     queryType,
@@ -129,7 +129,7 @@ type Tx struct {
 }
 
 func (t *Tx) sendOperationStats(start time.Time, queryType, query string, args ...interface{}) {
-	duration := time.Since(start).Milliseconds()
+	duration := time.Since(start).Microseconds()
 
 	t.logger.Debug(&Log{
 		Type:     queryType,

pkg/gofr/grpc/log.go

@@ -67,7 +67,7 @@ func LoggingInterceptor(logger Logger) grpc.UnaryServerInterceptor {
 			l := RPCLog{
 				ID:           trace.SpanFromContext(ctx).SpanContext().TraceID().String(),
 				StartTime:    start.Format("2006-01-02T15:04:05.999999999-07:00"),
-				ResponseTime: time.Since(start).Milliseconds(),
+				ResponseTime: time.Since(start).Microseconds(),
 				Method:       info.FullMethod,
 			}
 

pkg/gofr/service/new.go

@@ -180,7 +180,7 @@ func (h *httpService) createAndSendRequest(ctx context.Context, method string, p
 
 	respTime := time.Since(requestStart)
 
-	log.ResponseTime = respTime.Milliseconds()
+	log.ResponseTime = respTime.Microseconds()
 
 	if err != nil {
 		log.ResponseCode = http.StatusInternalServerError