Skip to content

Commit e91415a

Browse files
committed
Frontend config.
1 parent 983b28e commit e91415a

File tree

2 files changed

+12
-3
lines changed

2 files changed

+12
-3
lines changed

crawler-distributed/config/config.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,4 +27,6 @@ const (
2727
// ItemSaverService.Save
2828

2929
ItemSaverServiceSave = "ItemSaverService.Save"
30+
31+
ElasticsearchHosts = "http://192.168.1.9:9200"
3032
)

crawler/frontend/controller/searchresult.go

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,9 @@ package controller
33
import (
44
"context"
55
"github.com/olivere/elastic"
6+
"github.com/olivere/elastic/config"
67
"net/http"
8+
cfg "polaris/crawler-distributed/config"
79
"polaris/crawler/engine"
810
"polaris/crawler/frontend/model"
911
"polaris/crawler/frontend/view"
@@ -38,9 +40,10 @@ func (h SearchResultHandler) getSearchResult(s string, i int) (model.SearchResul
3840
var result model.SearchResult
3941
// fill in query string
4042
result.Query = s
41-
resp, err := h.client.Search("polaris").
43+
// set index for search.
44+
resp, err := h.client.Search("").
4245
Query(elastic.NewQueryStringQuery(
43-
rewriteQueryString(s))).From(i).Do(context.Background())
46+
rewriteQueryString(s))).From(i).Do(context.Background())
4447
if err != nil {
4548
return result, err
4649
}
@@ -54,7 +57,11 @@ func (h SearchResultHandler) getSearchResult(s string, i int) (model.SearchResul
5457
return result, nil
5558
}
5659

57-
var client, err = elastic.NewClient(elastic.SetSniff(false))
60+
var sniff = false
61+
var client, err = elastic.NewClientFromConfig(&config.Config{
62+
Sniff: &sniff,
63+
URL: cfg.ElasticsearchHosts,
64+
})
5865

5966
func CreateSearchResultHandler(template string) SearchResultHandler {
6067
if err != nil {

0 commit comments

Comments
 (0)