(ctx context.Context, input *monitor_dto.CommonInput)
| 934 | } |
| 935 | |
| 936 | func (i *imlMonitorStatisticModule) MessageTrend(ctx context.Context, input *monitor_dto.CommonInput) (*monitor_dto.MonMessageTrend, string, error) { |
| 937 | clusterId := cluster.DefaultClusterID |
| 938 | wheres, err := i.genCommonWheres(ctx, clusterId) |
| 939 | if err != nil { |
| 940 | return nil, "", err |
| 941 | } |
| 942 | executor, err := i.getExecutor(ctx, clusterId) |
| 943 | if err != nil { |
| 944 | return nil, "", err |
| 945 | } |
| 946 | result, timeInterval, err := executor.MessageTrend(ctx, formatTimeByMinute(input.Start), formatTimeByMinute(input.End), wheres) |
| 947 | if err != nil { |
| 948 | return nil, "", err |
| 949 | } |
| 950 | return monitor_dto.ToMonMessageTrend(result), timeInterval, nil |
| 951 | } |
| 952 | |
| 953 | func (i *imlMonitorStatisticModule) InvokeTrend(ctx context.Context, input *monitor_dto.CommonInput) (*monitor_dto.MonInvokeCountTrend, string, error) { |
| 954 | clusterId := cluster.DefaultClusterID |
nothing calls this directly
no test coverage detected