package proto const ( NtfClickHouseSqlId = "write_clickhouse_sql" ReqInsertClickHouseId = "insert_clickhouse" ReqGetOnlineFlowId = "get_online_flow_clickhouse" ) type NtfClickHouseSql struct { UId int64 `json:"u"` Sql string `json:"a"` } type ReqInsertClickHouse struct { TableName string `json:"t"` Values map[string]interface{} `json:"v"` } type ReqGetOnlineFlow struct { // 日期 (20060102) Date string `json:"d"` // 时间戳 TimeStamp int64 `json:"t"` } type RspGetOnlineFlow struct { Err string `json:"e"` Flows []OnlineFlow `json:"f"` } type OnlineFlow struct { Time int64 `json:"t"` Api int `json:"a"` Date string `json:"d"` Online int64 `json:"o"` Onplay int64 `json:"op"` }