(nodeID string, body []byte)
| 39 | // 实现可注入到 Hub.Options,用于解耦 hub 与业务逻辑(usage 入库、SSE 转发等)。 |
| 40 | type PushHandler interface { |
| 41 | OnHello(nodeID string, body []byte) |
| 42 | // OnUsagePush 返回 nil 时,hub 会向 node ack。 |
| 43 | OnUsagePush(nodeID string, seq uint64, body []byte) error |
| 44 | OnLog(nodeID, reqID string, body []byte) |
no outgoing calls
no test coverage detected