(info *uctypes.RateLimitInfo)
| 158 | } |
| 159 | |
| 160 | func updateRateLimit(info *uctypes.RateLimitInfo) { |
| 161 | if info == nil { |
| 162 | return |
| 163 | } |
| 164 | rateLimitLock.Lock() |
| 165 | defer rateLimitLock.Unlock() |
| 166 | globalRateLimitInfo = info |
| 167 | go func() { |
| 168 | wps.Broker.Publish(wps.WaveEvent{ |
| 169 | Event: wps.Event_WaveAIRateLimit, |
| 170 | Data: info, |
| 171 | }) |
| 172 | }() |
| 173 | } |
| 174 | |
| 175 | func GetGlobalRateLimit() *uctypes.RateLimitInfo { |
| 176 | rateLimitLock.Lock() |
no test coverage detected