@@ -11,12 +11,14 @@ func InitOpenSearch() error {
1111 for intent := 0 ; intent <= 10 ; intent ++ {
1212 time .Sleep (1 * time .Minute )
1313
14- _ , err := grequests .Get (baseURL + "_cluster/health" , & grequests.RequestOptions {
15- Params : map [string ]string {
16- "wait_for_status" : "green" ,
17- "timeout" : "50s" ,
18- },
19- })
14+ _ , err := grequests .Get (baseURL + "_cluster/health" ,
15+ grequests .FromRequestOptions (& grequests.RequestOptions {
16+ Params : map [string ]string {
17+ "wait_for_status" : "green" ,
18+ "timeout" : "50s" ,
19+ },
20+ }),
21+ )
2022
2123 if err != nil {
2224 if intent >= 10 {
@@ -27,21 +29,21 @@ func InitOpenSearch() error {
2729 }
2830 }
2931
30- _ , err := grequests .Put (baseURL + "_snapshot/.utm_geoip" , & grequests. RequestOptions {
31- JSON : map [string ]any {
32+ _ , err := grequests .Put (baseURL + "_snapshot/.utm_geoip" ,
33+ grequests . JSON ( map [string ]any {
3234 "type" : "fs" ,
3335 "settings" : map [string ]interface {}{
3436 "location" : "/usr/share/opensearch/.utm_geoip/" ,
3537 "compress" : true ,
3638 },
37- },
38- } )
39+ }) ,
40+ )
3941 if err != nil {
4042 return err
4143 }
4244
43- _ , err = grequests .Put (baseURL + "_index_template/utmstack_indexes" , & grequests. RequestOptions {
44- JSON : map [string ]any {
45+ _ , err = grequests .Put (baseURL + "_index_template/utmstack_indexes" ,
46+ grequests . JSON ( map [string ]any {
4547 "index_patterns" : []string {"v11-alert-" , "v11-log-" , ".utm-" , ".utmstack-" },
4648 "template" : map [string ]any {
4749 "settings" : map [string ]any {
@@ -50,18 +52,18 @@ func InitOpenSearch() error {
5052 "index.mapping.total_fields.limit" : 50000 ,
5153 },
5254 },
53- },
54- } )
55+ }) ,
56+ )
5557 if err != nil {
5658 return err
5759 }
5860
59- _ , err = grequests .Post (baseURL + "_snapshot/.utm_geoip/.utm_geoip/_restore" , & grequests. RequestOptions {
60- JSON : map [string ]interface {}{
61+ _ , err = grequests .Post (baseURL + "_snapshot/.utm_geoip/.utm_geoip/_restore" ,
62+ grequests . JSON ( map [string ]interface {}{
6163 "indices" : ".utm-geoip" ,
6264 "include_global_state" : false ,
63- },
64- } )
65+ }) ,
66+ )
6567 if err != nil {
6668 return err
6769 }
0 commit comments