issue1808: add test

session_test.go

@@ -347,3 +347,52 @@ func TestIsUseStatement(t *testing.T) {
 		}
 	}
 }
+
+type simpleTestRetryPolycy struct {
+	retryType   RetryType
+	maxAttempts int
+}
+
+func (p *simpleTestRetryPolycy) Attempt(q RetryableQuery) bool {
+	if q.Attempts() >= p.maxAttempts {
+		return false
+	}
+	return true
+}
+
+func (p *simpleTestRetryPolycy) GetRetryType(error) RetryType {
+	return p.retryType
+}
+
+// TestRetryType_Ignore verify that with Ignore retry type:
+// - retries stopped
+// - return error is nil
+// - observed error is not nil
+func TestRetryType_Ignore(t *testing.T) {
+	session := createSession(t)
+	defer session.Close()
+
+	var observedErr error
+	var observedAttempts int
+
+	observer := funcQueryObserver(func(ctx context.Context, o ObservedQuery) {
+		observedErr = o.Err
+		observedAttempts++
+	})
+
+	retryPolicy := &simpleTestRetryPolycy{retryType: Ignore, maxAttempts: 2}
+
+	err := session.Query("INSERT INTO gocql_test.invalid_table(value) VALUES(1)").Idempotent(true).RetryPolicy(retryPolicy).Observer(observer).Exec()
+
+	if err != nil {
+		t.Fatalf("Expected no error, got: %s", err)
+	}
+
+	if observedErr == nil {
+		t.Fatalf("Expected unconfigured table error in Obserer, got: nil")
+	}
+
+	if observedAttempts > 1 {
+		t.Fatal("Expected one attempt")
+	}
+}