summaryrefslogtreecommitdiffstats
path: root/vendor/gopkg.in/olivere/elastic.v5/bulk_delete_request_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/gopkg.in/olivere/elastic.v5/bulk_delete_request_test.go')
-rw-r--r--vendor/gopkg.in/olivere/elastic.v5/bulk_delete_request_test.go68
1 files changed, 68 insertions, 0 deletions
diff --git a/vendor/gopkg.in/olivere/elastic.v5/bulk_delete_request_test.go b/vendor/gopkg.in/olivere/elastic.v5/bulk_delete_request_test.go
new file mode 100644
index 000000000..6ac429d8b
--- /dev/null
+++ b/vendor/gopkg.in/olivere/elastic.v5/bulk_delete_request_test.go
@@ -0,0 +1,68 @@
+// Copyright 2012-present Oliver Eilhard. All rights reserved.
+// Use of this source code is governed by a MIT-license.
+// See http://olivere.mit-license.org/license.txt for details.
+
+package elastic
+
+import (
+ "testing"
+)
+
+func TestBulkDeleteRequestSerialization(t *testing.T) {
+ tests := []struct {
+ Request BulkableRequest
+ Expected []string
+ }{
+ // #0
+ {
+ Request: NewBulkDeleteRequest().Index("index1").Type("tweet").Id("1"),
+ Expected: []string{
+ `{"delete":{"_id":"1","_index":"index1","_type":"tweet"}}`,
+ },
+ },
+ // #1
+ {
+ Request: NewBulkDeleteRequest().Index("index1").Type("tweet").Id("1").Parent("2"),
+ Expected: []string{
+ `{"delete":{"_id":"1","_index":"index1","_parent":"2","_type":"tweet"}}`,
+ },
+ },
+ // #2
+ {
+ Request: NewBulkDeleteRequest().Index("index1").Type("tweet").Id("1").Routing("3"),
+ Expected: []string{
+ `{"delete":{"_id":"1","_index":"index1","_routing":"3","_type":"tweet"}}`,
+ },
+ },
+ }
+
+ for i, test := range tests {
+ lines, err := test.Request.Source()
+ if err != nil {
+ t.Fatalf("case #%d: expected no error, got: %v", i, err)
+ }
+ if lines == nil {
+ t.Fatalf("case #%d: expected lines, got nil", i)
+ }
+ if len(lines) != len(test.Expected) {
+ t.Fatalf("case #%d: expected %d lines, got %d", i, len(test.Expected), len(lines))
+ }
+ for j, line := range lines {
+ if line != test.Expected[j] {
+ t.Errorf("case #%d: expected line #%d to be %s, got: %s", i, j, test.Expected[j], line)
+ }
+ }
+ }
+}
+
+var bulkDeleteRequestSerializationResult string
+
+func BenchmarkBulkDeleteRequestSerialization(b *testing.B) {
+ r := NewBulkDeleteRequest().Index(testIndexName).Type("tweet").Id("1")
+ var s string
+ for n := 0; n < b.N; n++ {
+ s = r.String()
+ r.source = nil // Don't let caching spoil the benchmark
+ }
+ bulkDeleteRequestSerializationResult = s // ensure the compiler doesn't optimize
+}