Starting internal goroutines for AgentClient.
(ctx context.Context)
| 119 | |
| 120 | // Starting internal goroutines for AgentClient. |
| 121 | func (e *AgentClient) Start(ctx context.Context) error { |
| 122 | ctxWithCancel, cancel := context.WithCancel(ctx) |
| 123 | e.notificationBatcherCancelFn = cancel |
| 124 | return e.notificationBatcher.start(ctxWithCancel) |
| 125 | } |
| 126 | |
| 127 | // Ends all internal goroutines and wait for them to finish pending works. |
| 128 | func (e *AgentClient) Stop() { |