(ctx context.Context, providerId string, input *monitor_dto.CommonInput)
| 691 | } |
| 692 | |
| 693 | func (i *imlMonitorStatisticModule) ProviderTrend(ctx context.Context, providerId string, input *monitor_dto.CommonInput) (*monitor_dto.MonInvokeCountTrend, string, error) { |
| 694 | clusterId := cluster.DefaultClusterID |
| 695 | wheres, err := i.genCommonWheres(ctx, clusterId) |
| 696 | if err != nil { |
| 697 | return nil, "", err |
| 698 | } |
| 699 | wheres = append(wheres, monitor.MonWhereItem{ |
| 700 | Key: "provider", |
| 701 | Operation: "=", |
| 702 | Values: []string{providerId}, |
| 703 | }) |
| 704 | executor, err := i.getExecutor(ctx, clusterId) |
| 705 | if err != nil { |
| 706 | return nil, "", err |
| 707 | } |
| 708 | result, timeInterval, err := executor.InvokeTrend(ctx, formatTimeByMinute(input.Start), formatTimeByMinute(input.End), wheres) |
| 709 | if err != nil { |
| 710 | return nil, "", err |
| 711 | } |
| 712 | return monitor_dto.ToMonInvokeCountTrend(result), timeInterval, nil |
| 713 | } |
| 714 | |
| 715 | func (i *imlMonitorStatisticModule) SubscriberTrend(ctx context.Context, subscriberId string, input *monitor_dto.CommonInput) (*monitor_dto.MonInvokeCountTrend, string, error) { |
| 716 | clusterId := cluster.DefaultClusterID |
nothing calls this directly
no test coverage detected