[Add] Create index #6

Merged
trunglt251292 merged 1 commits from v1 into master 2022-03-25 03:02:11 +00:00
2 changed files with 7 additions and 0 deletions

View File

@ -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 (

View File

@ -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))
}