diff --git a/CHANGELOG.md b/CHANGELOG.md
index 8c8a7b1..c3ddc11 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,6 +1,12 @@
 # <img src="https://uploads-ssl.webflow.com/5ea5d3315186cf5ec60c3ee4/5edf1c94ce4c859f2b188094_logo.svg" alt="Pip.Services Logo" width="200"> <br/> Remote Procedure Calls for Pip.Services in Go Changelog
 
-## <a name="1.3.0"></a> 1.3.0 (2021-04-33) 
+## <a name="1.3.1"></a> 1.3.1 (2021-04-23) 
+
+### Features
+* Add InstrumentTiming 
+
+
+## <a name="1.3.0"></a> 1.3.0 (2021-04-23) 
 
 ### Breaking Changes
 * **test** Added TestRestClient
diff --git a/services/InstrumentTiming.go b/services/InstrumentTiming.go
new file mode 100644
index 0000000..2bfc6fb
--- /dev/null
+++ b/services/InstrumentTiming.go
@@ -0,0 +1,86 @@
+package services
+
+import (
+	ccount "github.com/pip-services3-go/pip-services3-components-go/count"
+	clog "github.com/pip-services3-go/pip-services3-components-go/log"
+	ctrace "github.com/pip-services3-go/pip-services3-components-go/trace"
+)
+
+type InstrumentTiming struct {
+	correlationId string
+	name          string
+	verb          string
+	logger        clog.ILogger
+	counters      ccount.ICounters
+	counterTiming *ccount.CounterTiming
+	traceTiming   *ctrace.TraceTiming
+}
+
+func NewInstrumentTiming(correlationId string, name string,
+	verb string, logger clog.ILogger, counters ccount.ICounters,
+	counterTiming *ccount.CounterTiming, traceTiming *ctrace.TraceTiming) *InstrumentTiming {
+
+	if len(verb) == 0 {
+		verb = "call"
+	}
+	return &InstrumentTiming{
+		correlationId: correlationId,
+		name:          name,
+		verb:          verb,
+		logger:        logger,
+		counters:      counters,
+		counterTiming: counterTiming,
+		traceTiming:   traceTiming,
+	}
+}
+
+func (c *InstrumentTiming) clear() {
+	// Clear references to avoid double processing
+	c.counters = nil
+	c.logger = nil
+	c.counterTiming = nil
+	c.traceTiming = nil
+}
+
+func (c *InstrumentTiming) EndTiming(err error) {
+	if err == nil {
+		c.EndSuccess()
+	} else {
+		c.EndFailure(err)
+	}
+}
+
+func (c *InstrumentTiming) EndSuccess() {
+	if c.counterTiming != nil {
+		c.counterTiming.EndTiming()
+	}
+	if c.traceTiming != nil {
+		c.traceTiming.EndTrace()
+	}
+
+	c.clear()
+}
+
+func (c *InstrumentTiming) EndFailure(err error) {
+	if c.counterTiming != nil {
+		c.counterTiming.EndTiming()
+	}
+
+	if err != nil {
+		if c.logger != nil {
+			c.logger.Error(c.correlationId, err, "Failed to call %s method", c.name)
+		}
+		if c.counters != nil {
+			c.counters.IncrementOne(c.name + "." + c.verb + "_errors")
+		}
+		if c.traceTiming != nil {
+			c.traceTiming.EndFailure(err)
+		}
+	} else {
+		if c.traceTiming != nil {
+			c.traceTiming.EndTrace()
+		}
+	}
+
+	c.clear()
+}