Stop stops the channel cache and it's background tasks.
(ctx context.Context)
| 144 | |
| 145 | // Stop stops the channel cache and it's background tasks. |
| 146 | func (c *channelCacheImpl) Stop(ctx context.Context) { |
| 147 | // Signal to terminate channel cache background tasks. |
| 148 | close(c.terminator) |
| 149 | |
| 150 | // Wait for channel cache background tasks to finish. |
| 151 | waitForBGTCompletion(ctx, BGTCompletionMaxWait, c.backgroundTasks, c.dbName) |
| 152 | } |
| 153 | |
| 154 | func (c *channelCacheImpl) Init(initialSequence uint64) { |
| 155 | c.seqLock.Lock() |
nothing calls this directly
no test coverage detected