[Add] Create index

This commit is contained in:
trunglt251292 2022-03-25 09:59:45 +07:00
parent 30bead253d
commit 4e39cd3861
2 changed files with 7 additions and 0 deletions

View File

@ -16,6 +16,8 @@ const (
SubjectRequestKeywordUpsert = "selly.request.keyword.upsert"
SubjectPullKeywordUpsert = "selly.pull.keyword.upsert"
SubjectRequestKeywordSearch = "selly.request.keyword.search"
SubjectRequestCreateIndex = "selly.request.es.create_index"
)
const (

View File

@ -43,3 +43,8 @@ func (Request) KeywordSearch(query ESQuery) (*Response, error) {
func (Request) KeywordUpsert(payload Payload) (*Response, error) {
return requestNats(SubjectRequestKeywordUpsert, toBytes(payload))
}
// CreateIndex ...
func (Request) CreateIndex(payload Payload) (*Response, error) {
return requestNats(SubjectRequestCreateIndex, toBytes(payload))
}