diff options
| author | Lunny Xiao <xiaolunwen@gmail.com> | 2019-02-21 13:01:28 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-02-21 13:01:28 +0800 |
| commit | 477ef462510d69a8a31e008fb6e64059dc6cc148 (patch) | |
| tree | 2c7884ad454e6301d71e6f5ed3fc2247a190dedc /modules/indexer/issues/queue_channel.go | |
| parent | 0751153613bfd2e39cf28e83bbe04b76641d222f (diff) | |
| download | gitea-477ef462510d69a8a31e008fb6e64059dc6cc148.tar.gz gitea-477ef462510d69a8a31e008fb6e64059dc6cc148.zip | |
Add more tests and docs for issue indexer, add db indexer type for searching from database (#6144)
* add more tests and docs for issue indexer, add db indexer type for searching from database
* fix typo
* fix typo
* fix lint
* improve docs
Diffstat (limited to 'modules/indexer/issues/queue_channel.go')
| -rw-r--r-- | modules/indexer/issues/queue_channel.go | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/modules/indexer/issues/queue_channel.go b/modules/indexer/issues/queue_channel.go index 99a90ad499..bd92f6b7b1 100644 --- a/modules/indexer/issues/queue_channel.go +++ b/modules/indexer/issues/queue_channel.go @@ -33,6 +33,11 @@ func (c *ChannelQueue) Run() error { for { select { case data := <-c.queue: + if data.IsDelete { + c.indexer.Delete(data.IDs...) + continue + } + datas = append(datas, data) if len(datas) >= c.batchNumber { c.indexer.Index(datas) @@ -51,6 +56,7 @@ func (c *ChannelQueue) Run() error { } // Push will push the indexer data to queue -func (c *ChannelQueue) Push(data *IndexerData) { +func (c *ChannelQueue) Push(data *IndexerData) error { c.queue <- data + return nil } |