| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/gopkg.in/olivere/elastic.v3/ |
| H A D | reindexer_test.go | 19 targetCount, err := client.Count(testIndexName2).Do()
27 r := NewReindexer(client, testIndexName, CopyToTargetIndex(testIndexName2))
45 if _, err := client.Flush().Index(testIndexName2).Do(); err != nil {
49 targetCount, err = client.Count(testIndexName2).Do()
71 targetCount, err := client.Count(testIndexName2).Do()
79 r := NewReindexer(client, testIndexName, CopyToTargetIndex(testIndexName2))
98 if _, err := client.Flush().Index(testIndexName2).Do(); err != nil {
102 targetCount, err = client.Count(testIndexName2).Do()
171 targetCount, err := targetClient.Count(testIndexName2).Do()
202 targetCount, err = targetClient.Count(testIndexName2).Do()
[all …]
|
| H A D | indices_get_aliases_test.go | 31 _, err = client.Index().Index(testIndexName2).Type("tweet").Id("3").BodyJson(&tweet3).Do()
41 _, err = client.Flush().Index(testIndexName2).Do()
48 Index(testIndexName, testIndexName2).
66 Add(testIndexName2, testAliasName).
78 Index(testIndexName, testIndexName2).
104 indexInfo2, found := aliasesResult2.Indices[testIndexName2]
110 …t.Errorf("expected alias %s to include index %s; got %v", testAliasName, testIndexName2, aliasFoun…
126 aliasesResult3, err := client.Aliases().Index(testIndexName, testIndexName2).Do()
138 } else if indexName == testIndexName2 {
|
| H A D | indices_put_warmer_test.go | 65 client.Flush(testIndexName2).Do()
67 …putresp, err := client.PutWarmer().Index(testIndexName2).Type("tweet").Name("warmer_1").BodyString…
78 getresp, err := client.GetWarmer().Index(testIndexName2).Name("warmer_1").Do()
85 props, ok := getresp[testIndexName2]
90 delresp, err := client.DeleteWarmer().Index(testIndexName2).Name("warmer_1").Do()
|
| H A D | indices_put_mapping_test.go | 58 putresp, err := client.PutMapping().Index(testIndexName2).Type("tweetdoc").BodyString(mapping).Do()
69 getresp, err := client.GetMapping().Index(testIndexName2).Type("tweetdoc").Do()
76 props, ok := getresp[testIndexName2]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/olivere/elastic/ |
| H A D | indices_get_aliases_test.go | 100 …_, err = client.Index().Index(testIndexName2).Type("doc").Id("3").BodyJson(&tweet3).Do(context.TOD…
110 _, err = client.Flush().Index(testIndexName2).Do(context.TODO())
117 Index(testIndexName, testIndexName2).
137 Index(testIndexName2).
151 Index(testIndexName, testIndexName2).
178 if indexName == testIndexName2 {
180 t.Errorf("expected alias on %s to be a write index", testIndexName2)
185 t.Errorf("expected alias on %s not to be a write index", testIndexName2)
201 indexInfo2, found := aliasesResult2.Indices[testIndexName2]
223 aliasesResult3, err := client.Aliases().Index(testIndexName, testIndexName2).Do(context.TODO())
[all …]
|
| H A D | indices_put_alias_test.go | 40 …_, err = client.Index().Index(testIndexName2).Type("doc").Id("3").BodyJson(&tweet3).Do(context.TOD…
50 _, err = client.Flush().Index(testIndexName2).Do(context.TODO())
58 Action(NewAliasAddAction(testAliasName).Index(testIndexName2)).
115 Action(NewAliasAddAction(testAliasName).Index(testIndexName2).IsWriteIndex(true)).
135 _, err = client.Flush().Index(testIndexName, testIndexName2).Do(context.TODO())
140 …searchResult3, err := client.Search().Index(testIndexName2).Query(NewIdsQuery("doc").Ids("4")).Do(…
|
| H A D | reindex_test.go | 294 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
304 dst := NewReindexDestination().Index(testIndexName2)
330 targetCount, err = client.Count(testIndexName2).Do(context.TODO())
350 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
360 dst := NewReindexDestination().Index(testIndexName2)
408 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
418 dst := NewReindexDestination().Index(testIndexName2)
|
| H A D | cat_aliases_test.go | 19 Action(NewAliasAddAction(testAliasName2).Index(testIndexName2)).
28 Remove(testIndexName2, testAliasName2).
|
| /dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/github.com/olivere/elastic/ |
| H A D | indices_get_aliases_test.go | 100 …_, err = client.Index().Index(testIndexName2).Type("doc").Id("3").BodyJson(&tweet3).Do(context.TOD…
110 _, err = client.Flush().Index(testIndexName2).Do(context.TODO())
117 Index(testIndexName, testIndexName2).
137 Index(testIndexName2).
151 Index(testIndexName, testIndexName2).
178 if indexName == testIndexName2 {
180 t.Errorf("expected alias on %s to be a write index", testIndexName2)
185 t.Errorf("expected alias on %s not to be a write index", testIndexName2)
201 indexInfo2, found := aliasesResult2.Indices[testIndexName2]
223 aliasesResult3, err := client.Aliases().Index(testIndexName, testIndexName2).Do(context.TODO())
[all …]
|
| H A D | indices_put_alias_test.go | 40 …_, err = client.Index().Index(testIndexName2).Type("doc").Id("3").BodyJson(&tweet3).Do(context.TOD…
50 _, err = client.Flush().Index(testIndexName2).Do(context.TODO())
58 Action(NewAliasAddAction(testAliasName).Index(testIndexName2)).
115 Action(NewAliasAddAction(testAliasName).Index(testIndexName2).IsWriteIndex(true)).
135 _, err = client.Flush().Index(testIndexName, testIndexName2).Do(context.TODO())
140 …searchResult3, err := client.Search().Index(testIndexName2).Query(NewIdsQuery("doc").Ids("4")).Do(…
|
| H A D | reindex_test.go | 294 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
304 dst := NewReindexDestination().Index(testIndexName2)
330 targetCount, err = client.Count(testIndexName2).Do(context.TODO())
350 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
360 dst := NewReindexDestination().Index(testIndexName2)
408 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
418 dst := NewReindexDestination().Index(testIndexName2)
|
| H A D | cat_aliases_test.go | 19 Action(NewAliasAddAction(testAliasName2).Index(testIndexName2)).
28 Remove(testIndexName2, testAliasName2).
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/olivere/elastic/v7/ |
| H A D | indices_get_aliases_test.go | 100 _, err = client.Index().Index(testIndexName2).Id("3").BodyJson(&tweet3).Do(context.TODO())
106 _, err = client.Refresh().Index(testIndexName, testIndexName2).Do(context.TODO())
113 Index(testIndexName, testIndexName2).
133 Index(testIndexName2).
147 Index(testIndexName, testIndexName2).
174 if indexName == testIndexName2 {
176 t.Errorf("expected alias on %s to be a write index", testIndexName2)
181 t.Errorf("expected alias on %s not to be a write index", testIndexName2)
197 indexInfo2, found := aliasesResult2.Indices[testIndexName2]
219 aliasesResult3, err := client.Aliases().Index(testIndexName, testIndexName2).Do(context.TODO())
[all …]
|
| H A D | indices_put_alias_test.go | 40 _, err = client.Index().Index(testIndexName2).Id("3").BodyJson(&tweet3).Do(context.TODO())
46 _, err = client.Refresh().Index(testIndexName, testIndexName2).Do(context.TODO())
54 Action(NewAliasAddAction(testAliasName).Index(testIndexName2)).
111 Action(NewAliasAddAction(testAliasName).Index(testIndexName2).IsWriteIndex(true)).
131 _, err = client.Refresh().Index(testIndexName, testIndexName2).Do(context.TODO())
136 …searchResult3, err := client.Search().Index(testIndexName2).Query(NewIdsQuery().Ids("4")).Do(conte…
|
| H A D | reindex_test.go | 294 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
304 dst := NewReindexDestination().Index(testIndexName2)
330 targetCount, err = client.Count(testIndexName2).Do(context.TODO())
350 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
360 dst := NewReindexDestination().Index(testIndexName2)
408 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
418 dst := NewReindexDestination().Index(testIndexName2)
|
| H A D | cat_aliases_test.go | 19 Action(NewAliasAddAction(testAliasName2).Index(testIndexName2)).
28 Remove(testIndexName2, testAliasName2).
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/gopkg.in/olivere/elastic.v5/ |
| H A D | indices_get_aliases_test.go | 65 …_, err = client.Index().Index(testIndexName2).Type("tweet").Id("3").BodyJson(&tweet3).Do(context.T…
75 _, err = client.Flush().Index(testIndexName2).Do(context.TODO())
82 Index(testIndexName, testIndexName2).
100 Add(testIndexName2, testAliasName).
112 Index(testIndexName, testIndexName2).
138 indexInfo2, found := aliasesResult2.Indices[testIndexName2]
144 …t.Errorf("expected alias %s to include index %s; got %v", testAliasName, testIndexName2, aliasFoun…
160 aliasesResult3, err := client.Aliases().Index(testIndexName, testIndexName2).Do(context.TODO())
172 } else if indexName == testIndexName2 {
|
| H A D | indices_put_mapping_test.go | 61 …putresp, err := client.PutMapping().Index(testIndexName2).Type("tweetdoc").BodyString(mapping).Do(…
72 getresp, err := client.GetMapping().Index(testIndexName2).Type("tweetdoc").Do(context.TODO())
79 props, ok := getresp[testIndexName2]
|
| H A D | reindex_test.go | 281 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
291 dst := NewReindexDestination().Index(testIndexName2)
309 targetCount, err = client.Count(testIndexName2).Do(context.TODO())
336 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
346 dst := NewReindexDestination().Index(testIndexName2)
386 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
396 dst := NewReindexDestination().Index(testIndexName2)
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/gopkg.in/olivere/elastic.v5/ |
| H A D | indices_get_aliases_test.go | 65 …_, err = client.Index().Index(testIndexName2).Type("tweet").Id("3").BodyJson(&tweet3).Do(context.T…
75 _, err = client.Flush().Index(testIndexName2).Do(context.TODO())
82 Index(testIndexName, testIndexName2).
100 Add(testIndexName2, testAliasName).
112 Index(testIndexName, testIndexName2).
138 indexInfo2, found := aliasesResult2.Indices[testIndexName2]
144 …t.Errorf("expected alias %s to include index %s; got %v", testAliasName, testIndexName2, aliasFoun…
160 aliasesResult3, err := client.Aliases().Index(testIndexName, testIndexName2).Do(context.TODO())
172 } else if indexName == testIndexName2 {
|
| H A D | indices_put_mapping_test.go | 61 …putresp, err := client.PutMapping().Index(testIndexName2).Type("tweetdoc").BodyString(mapping).Do(…
72 getresp, err := client.GetMapping().Index(testIndexName2).Type("tweetdoc").Do(context.TODO())
79 props, ok := getresp[testIndexName2]
|
| H A D | reindex_test.go | 281 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
291 dst := NewReindexDestination().Index(testIndexName2)
309 targetCount, err = client.Count(testIndexName2).Do(context.TODO())
336 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
346 dst := NewReindexDestination().Index(testIndexName2)
386 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
396 dst := NewReindexDestination().Index(testIndexName2)
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/olivere/elastic/ |
| H A D | indices_get_aliases_test.go | 100 …_, err = client.Index().Index(testIndexName2).Type("doc").Id("3").BodyJson(&tweet3).Do(context.TOD…
110 _, err = client.Flush().Index(testIndexName2).Do(context.TODO())
117 Index(testIndexName, testIndexName2).
135 Add(testIndexName2, testAliasName).
147 Index(testIndexName, testIndexName2).
187 indexInfo2, found := aliasesResult2.Indices[testIndexName2]
193 …t.Errorf("expected alias %s to include index %s; got %v", testAliasName, testIndexName2, aliasFoun…
209 aliasesResult3, err := client.Aliases().Index(testIndexName, testIndexName2).Do(context.TODO())
221 } else if indexName == testIndexName2 {
|
| H A D | cat_aliases_test.go | 19 Action(NewAliasAddAction(testAliasName).Index(testIndexName2)).
28 Remove(testIndexName2, testAliasName).
|
| H A D | reindex_test.go | 281 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
291 dst := NewReindexDestination().Index(testIndexName2)
309 targetCount, err = client.Count(testIndexName2).Do(context.TODO())
336 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
346 dst := NewReindexDestination().Index(testIndexName2)
386 targetCount, err := client.Count(testIndexName2).Do(context.TODO())
396 dst := NewReindexDestination().Index(testIndexName2)
|