elasticsearch/pull.go

36 lines
1.1 KiB
Go
Raw Normal View History

2022-03-19 04:59:43 +00:00
package elasticsearch
// Pull ...
type Pull struct {
}
// ProductUpsert ...
2022-03-21 02:19:46 +00:00
func (Pull) ProductUpsert(payload Payload) (bool, error) {
return publishWithJetStream(JetStreamSearchService, SubjectPullProductUpsert, toBytes(payload))
2022-03-19 04:59:43 +00:00
}
// UserUpsert ...
2022-03-21 02:19:46 +00:00
func (Pull) UserUpsert(payload Payload) (bool, error) {
return publishWithJetStream(JetStreamSearchService, SubjectPullUserUpsert, toBytes(payload))
2022-03-19 04:59:43 +00:00
}
// OrderUpsert ...
2022-03-21 02:19:46 +00:00
func (Pull) OrderUpsert(payload Payload) (bool, error) {
return publishWithJetStream(JetStreamSearchService, SubjectPullOrderUpsert, toBytes(payload))
2022-03-19 04:59:43 +00:00
}
2022-03-24 03:26:23 +00:00
// KeywordUpsert ...
func (Pull) KeywordUpsert(payload Payload) (bool, error) {
return publishWithJetStream(JetStreamSearchService, SubjectPullKeywordUpsert, toBytes(payload))
}
2022-04-28 03:59:43 +00:00
// ProductSkuUpsert ...
func (Pull) ProductSkuUpsert(payload Payload) (bool, error) {
return publishWithJetStream(JetStreamSearchService, SubjectPullProductSkuUpsert, toBytes(payload))
}
2022-08-22 03:06:29 +00:00
// ProductShopUpsert ...
func (Pull) ProductShopUpsert(payload Payload) (bool, error) {
return publishWithJetStream(JetStreamSearchService, SubjectPullShopProductUpsert, toBytes(payload))
}