commit
d8cb5a1cfd
|
@ -16,6 +16,8 @@ const (
|
||||||
SubjectRequestKeywordUpsert = "selly.request.keyword.upsert"
|
SubjectRequestKeywordUpsert = "selly.request.keyword.upsert"
|
||||||
SubjectPullKeywordUpsert = "selly.pull.keyword.upsert"
|
SubjectPullKeywordUpsert = "selly.pull.keyword.upsert"
|
||||||
SubjectRequestKeywordSearch = "selly.request.keyword.search"
|
SubjectRequestKeywordSearch = "selly.request.keyword.search"
|
||||||
|
|
||||||
|
SubjectRequestCreateIndex = "selly.request.es.create_index"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
|
|
@ -43,3 +43,8 @@ func (Request) KeywordSearch(query ESQuery) (*Response, error) {
|
||||||
func (Request) KeywordUpsert(payload Payload) (*Response, error) {
|
func (Request) KeywordUpsert(payload Payload) (*Response, error) {
|
||||||
return requestNats(SubjectRequestKeywordUpsert, toBytes(payload))
|
return requestNats(SubjectRequestKeywordUpsert, toBytes(payload))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// CreateIndex ...
|
||||||
|
func (Request) CreateIndex(payload Payload) (*Response, error) {
|
||||||
|
return requestNats(SubjectRequestCreateIndex, toBytes(payload))
|
||||||
|
}
|
||||||
|
|
Loading…
Reference in New Issue