code: func ReportMessageProcessDelayFromCtx(ctx context.Context, reporters []Reporter, typ string) {
  	if len(reporters) > 0 {
  		startTime := pcontext.GetFromPropagateCtx(ctx, constants.StartTimeKey)
  		elapsed := time.Since(time.Unix(0, startTime.(int64)))
  		route := pcontext.GetFromPropagateCtx(ctx, constants.RouteKey)
  		tags := getTags(ctx, map[string]string{
  			"route": route.(string),
  			"type":  typ,
  		})
  		for _, r := range reporters {
  			r.ReportSummary(ProcessDelay, tags, float64(elapsed.Nanoseconds()))
  		}
  	}
  }
docs: // ReportMessageProcessDelayFromCtx reports the delay to process the messages