Add protocol.Result into Report method

common/extension/metrics_test.go

@@ -42,5 +42,5 @@ func TestGetMetricReporter(t *testing.T) {
 type mockReporter struct {
 }
 
-func (m mockReporter) Report(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation, cost time.Duration) {
+func (m mockReporter) Report(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation, cost time.Duration, res protocol.Result) {
 }

filter/filter_impl/metrics_filter.go

@@ -61,7 +61,7 @@ func (p *metricsFilter) Invoke(ctx context.Context, invoker protocol.Invoker, in
 	duration := end.Sub(start)
 	go func() {
 		for _, reporter := range p.reporters {
-			reporter.Report(ctx, invoker, invocation, duration)
+			reporter.Report(ctx, invoker, invocation, duration, nil)
 		}
 	}()
 	return res

filter/filter_impl/metrics_filter_test.go

@@ -75,7 +75,7 @@ type mockReporter struct {
 	wg sync.WaitGroup
 }
 
-func (m *mockReporter) Report(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation, cost time.Duration) {
+func (m *mockReporter) Report(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation, cost time.Duration, res protocol.Result) {
 	m.Called(ctx, invoker, invocation)
 	m.wg.Done()
 }

metrics/prometheus/reporter.go

@@ -73,7 +73,7 @@ type PrometheusReporter struct {
 }
 
 // report the duration to Prometheus
-func (reporter *PrometheusReporter) Report(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation, cost time.Duration) {
+func (reporter *PrometheusReporter) Report(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation, cost time.Duration, res protocol.Result) {
 	url := invoker.GetUrl()
 	var sumVec *prometheus.SummaryVec
 	if isProvider(url) {

metrics/prometheus/reporter_test.go

@@ -44,5 +44,5 @@ func TestPrometheusReporter_Report(t *testing.T) {
 	inv := invocation.NewRPCInvocation("MethodName", []interface{}{"OK", "Hello"}, attach)
 
 	ctx := context.Background()
-	reporter.Report(ctx, invoker, inv, 100*time.Millisecond)
+	reporter.Report(ctx, invoker, inv, 100*time.Millisecond, nil)
 }

metrics/reporter.go

@@ -31,5 +31,6 @@ const (
 // it will be use to report the invocation's duration
 type Reporter interface {
 	// report the duration of an invocation
-	Report(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation, cost time.Duration)
+	Report(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation,
+		cost time.Duration, res protocol.Result)
 }