(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem)
| 145 | } |
| 146 | |
| 147 | func (e *executor) MessageTrend(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) (*monitor.MonMessageTrend, string, error) { |
| 148 | newStartTime, every, windowOffset, bucket := getTimeIntervalAndBucket(start, end) |
| 149 | |
| 150 | filters := formatFilter(wheres) |
| 151 | |
| 152 | fieldsConditions := []string{"request", "response"} |
| 153 | |
| 154 | dates, groupValues, err := e.fluxQuery.CommonTendency(ctx, e.openApi, newStartTime, end, bucket, "request", filters, fieldsConditions, every, windowOffset, flux.SumFn) |
| 155 | if err != nil { |
| 156 | return nil, "", err |
| 157 | } |
| 158 | |
| 159 | resultVal := &monitor.MonMessageTrend{ |
| 160 | Dates: dates, |
| 161 | ReqMessage: formatMessageTrendData(groupValues["request"]), |
| 162 | RespMessage: formatMessageTrendData(groupValues["response"]), |
| 163 | } |
| 164 | |
| 165 | return resultVal, every, nil |
| 166 | } |
| 167 | |
| 168 | func (e *executor) ProxyTrend(ctx context.Context, start time.Time, end time.Time, wheres []monitor.MonWhereItem) (*monitor.MonInvokeCountTrend, string, error) { |
| 169 | newStartTime, every, windowOffset, bucket := getTimeIntervalAndBucket(start, end) |
nothing calls this directly
no test coverage detected