WaitAck 阻塞等待对应 seq 的 ack(usage_push 用),ctx 控制超时。 在 WaitAck 之前调用 PushEvent;同一个 seq 仅会被 Wait 一次。
(ctx context.Context, seq uint64)
| 47 | // WaitAck 阻塞等待对应 seq 的 ack(usage_push 用),ctx 控制超时。 |
| 48 | // 在 WaitAck 之前调用 PushEvent;同一个 seq 仅会被 Wait 一次。 |
| 49 | WaitAck(ctx context.Context, seq uint64) error |
| 50 | } |
| 51 | |
| 52 | // Config 是 Run 的输入。 |
no outgoing calls