algorithms:
  - id: UserUsedFlow
    name: DailyUserUsedFlow
    input: tp_client_conn
    type: realtime
    windowSize: 1d
    desc: 用户每日使用流量

  - id: UserData
    type: realtime
    name: DailyUserData
    input: tp_client_session
    windowSize: 1d
    desc: 每天用户的会话次数等数据

  - id: ConnectUserCount
    name: HourlyConnectUserCount
    input: tp_client_session
    type: realtime
    windowSize: 1h
    desc: 每小时连接用户

  - id: ActiveUser
    name: HourlyActiveUser
    input: sys_login
    type: realtime
    windowSize: 1h
    desc: 每小时活跃用户

  - id: MinerConnectRate
    name: HourlyMinerConnectRate
    input: tp_client_conn
    type: realtime
    windowSize: 1h
    desc: 每小时矿机连接成功率

  - id: MinerDataReturnRate
    name: HourlyMinerDataReturnRate
    input: tp_share_conn
    type: realtime
    windowSize: 1h
    desc: 每小时矿机数据返回成功率

  - id: ConnectRate
    name: HourlyConnectRate
    input: tp_client_conn
    type: realtime
    windowSize: 1h
    desc: 每小时连通率

  - id: ConnectRate
    name: HalfHourlyConnectRate
    input: tp_client_conn
    type: realtime
    windowSize: 30min
    desc: 每半小时监控连通率

events:
  - id: DailyUserDataEvent
    listen: DailyUserData
    desc: 将每天的用户的会话次数，选择的路由，使用的时长入库

  - id: DailyUserUsedFlowEvent
    listen: DailyUserUsedFlow
    desc: 将每天的用户的使用上下行流量和时长入库

  - id: HalfHourlyConnectRateEvent
    listen: HalfHourlyConnectRate
    desc: 每半小时监听矿机连通率，如果错误率超过40%，发送告警邮件，并更换IP

  - id: HourlyActiveUserAlertEvent
    listen: HourlyActiveUser
    desc: 每一小时将活跃用户同前一天同个小时的活跃用户数进行对比

  - id: HourlyActiveUserEvent
    listen: HourlyActiveUser
    desc: 每一小时将活跃用户数据入库

  - id: HourlyConnectRateEvent
    listen: HourlyConnectRate
    desc: 每一小时将矿机的国家连接成功率数据入库

  - id: HourlyConnectUserCountEvent
    listen: HourlyConnectUserCount
    desc: 每一小时将连接用户数入库

  - id: HourlyMinerConnectRateEvent
    listen: HourlyMinerConnectRate
    desc: 每一小时将矿机连通率数据入库

  - id: HourlyMinerDataReturnRateEvent
    listen: HourlyMinerDataReturnRate
    desc: 每小时矿机数据返回成功率

crons:
  - id: DailyReportMail
    cronExp: "0 10 0 * * *"
    desc: 定时每天发送日报