Selly-Modules
/
elasticsearch
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Update] Remove queue

This commit is contained in:
trunglt251292 2022-03-19 12:08:07 +07:00
parent f26bf10ea0
commit a6e7982be6
2 changed files with 0 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
constants.go
View File

@ -2,17 +2,14 @@ package elasticsearch
const ( const (
SubjectRequestProductUpsert = "elasticsearch/selly.request.product.upsert" SubjectRequestProductUpsert = "elasticsearch/selly.request.product.upsert"
SubjectQueueProductUpsert = "elasticsearch/selly.queue.product.upsert"
SubjectPullProductUpsert = "elasticsearch/selly.pull.product.upsert" SubjectPullProductUpsert = "elasticsearch/selly.pull.product.upsert"
SubjectRequestProductSearch = "elasticsearch/selly.request.product.search" SubjectRequestProductSearch = "elasticsearch/selly.request.product.search"
SubjectRequestOrderUpsert = "elasticsearch/selly.request.order.upsert" SubjectRequestOrderUpsert = "elasticsearch/selly.request.order.upsert"
SubjectQueueOrderUpsert = "elasticsearch/selly.queue.order.upsert"
SubjectPullOrderUpsert = "elasticsearch/selly.pull.order.upsert" SubjectPullOrderUpsert = "elasticsearch/selly.pull.order.upsert"
SubjectRequestOrderSearch = "elasticsearch/selly.request.order.search" SubjectRequestOrderSearch = "elasticsearch/selly.request.order.search"
SubjectRequestUserUpsert = "elasticsearch/selly.request.order.upsert" SubjectRequestUserUpsert = "elasticsearch/selly.request.order.upsert"
SubjectQueueUserUpsert = "elasticsearch/selly.queue.order.upsert"
SubjectPullUserUpsert = "elasticsearch/selly.pull.order.upsert" SubjectPullUserUpsert = "elasticsearch/selly.pull.order.upsert"
SubjectRequestUserSearch = "elasticsearch/selly.request.user.search" SubjectRequestUserSearch = "elasticsearch/selly.request.user.search"
) )

15
queue.go
View File

@ -3,18 +3,3 @@ package elasticsearch
// Queue ... // Queue ...
type Queue struct { type Queue struct {
} }
// ProductUpsert ...
func (r Queue) ProductUpsert(query UpdateDataPayload) (bool, error) {
return GetClient().PublishWithJetStream(JetStreamSearchService, SubjectQueueProductUpsert, toBytes(query))
}
// UserUpsert ...
func (r Queue) UserUpsert(query UpdateDataPayload) (bool, error) {
return GetClient().PublishWithJetStream(JetStreamSearchService, SubjectQueueUserUpsert, toBytes(query))
}
// OrderUpsert ...
func (r Queue) OrderUpsert(query UpdateDataPayload) (bool, error) {
return GetClient().PublishWithJetStream(JetStreamSearchService, SubjectQueueOrderUpsert, toBytes(query))
}