66 lines
1.9 KiB
Go
66 lines
1.9 KiB
Go
package elasticsearch
|
|
|
|
// Request ...
|
|
type Request struct {
|
|
}
|
|
|
|
// ProductSearch ...
|
|
func (Request) ProductSearch(query ESQuery) (*Response, error) {
|
|
return requestNats(SubjectRequestProductSearch, toBytes(query))
|
|
}
|
|
|
|
// ProductUpsert ...
|
|
func (Request) ProductUpsert(payload Payload) (*Response, error) {
|
|
return requestNats(SubjectRequestProductUpsert, toBytes(payload))
|
|
}
|
|
|
|
// ProductCreateIndex ...
|
|
func (Request) ProductCreateIndex() (*Response, error) {
|
|
return requestNats(SubjectRequestProductCreateIndex, toBytes(Payload{}))
|
|
}
|
|
|
|
// UserSearch ...
|
|
func (Request) UserSearch(query ESQuery) (*Response, error) {
|
|
return requestNats(SubjectRequestUserSearch, toBytes(query))
|
|
}
|
|
|
|
// UserUpsert ...
|
|
func (Request) UserUpsert(payload Payload) (*Response, error) {
|
|
return requestNats(SubjectRequestUserUpsert, toBytes(payload))
|
|
}
|
|
|
|
// UserCreateIndex ...
|
|
func (Request) UserCreateIndex() (*Response, error) {
|
|
return requestNats(SubjectRequestUserCreateIndex, toBytes(Payload{}))
|
|
}
|
|
|
|
// OrderSearch ...
|
|
func (Request) OrderSearch(query ESQuery) (*Response, error) {
|
|
return requestNats(SubjectRequestOrderSearch, toBytes(query))
|
|
}
|
|
|
|
// OrderUpsert ...
|
|
func (Request) OrderUpsert(payload Payload) (*Response, error) {
|
|
return requestNats(SubjectRequestOrderUpsert, toBytes(payload))
|
|
}
|
|
|
|
// OrderCreateIndex ...
|
|
func (Request) OrderCreateIndex() (*Response, error) {
|
|
return requestNats(SubjectRequestOrderCreateIndex, toBytes(Payload{}))
|
|
}
|
|
|
|
// KeywordSearch ...
|
|
func (Request) KeywordSearch(query ESQuery) (*Response, error) {
|
|
return requestNats(SubjectRequestKeywordSearch, toBytes(query))
|
|
}
|
|
|
|
// KeywordUpsert ...
|
|
func (Request) KeywordUpsert(payload Payload) (*Response, error) {
|
|
return requestNats(SubjectRequestKeywordUpsert, toBytes(payload))
|
|
}
|
|
|
|
// KeywordCreateIndex ...
|
|
func (Request) KeywordCreateIndex() (*Response, error) {
|
|
return requestNats(SubjectRequestKeywordCreateIndex, toBytes(Payload{}))
|
|
}
|