体验新版 GitCode,发现更多精彩内容 >>
package com.xiaojukeji.kafka.manager.dao;
import com.xiaojukeji.kafka.manager.common.entity.pojo.*;
import java.util.Date; import java.util.List; /** * @author tukun * @date 2015/11/6. */ public interface BrokerMetricsDao { /** * 批量插入数据 */
int batchAdd(List<BrokerMetricsDO> doList);
/** * 根据时间区间获取Broker监控数据 */
List<BrokerMetricsDO> getBrokerMetrics(Long clusterId, Integer brokerId, Date startTime, Date endTime);
int deleteBeforeTime(Date endTime); }