Method SetMessageTrend

service/monitor/iml.go:218–228

(ctx context.Context, partitionId string, start, end time.Time, wheres []MonWhereItem, val *MonMessageTrend)

}

func (i *imlMonitorStatisticsCacheService) SetMessageTrend(ctx context.Context, partitionId string, start, end time.Time, wheres []MonWhereItem, val *MonMessageTrend) error {
	key := fmt.Sprintf("monitor:message_trend:%s:%d_%d:%s", partitionId, start.Unix(), end.Unix(), formatWhereKey(wheres))

	bytes, err := json.Marshal(val)
	if err != nil {
		log.Errorf("SetMessageTrend json.Marshal key=%s val=%v err=%s", key, val, err.Error())
		return err
	}

	return i.commonCache.Set(ctx, key, bytes, 5*time.Minute)
}

func formatWhereKey(wheres []MonWhereItem) string {