Versions in this module Expand all Collapse all v0 v0.1.1 Apr 30, 2024 v0.1.0 Apr 29, 2024 Changes in this version + var Close_chan chan int + var Close_done_chan chan int + func Start() + type Trend int + func (this *Trend) Ping(req model.NullRpcRequest, resp *model.SimpleRpcResponse) error + func (this *Trend) Send(items []*model.TrendItem, resp *model.SimpleRpcResponse) error