feat: add retry strategy (#23)

Signed-off-by: enesbrsk <[email protected]>
Trendyol · Oct 22, 2024 · e7b88f9 · e7b88f9
1 parent 1cea7d1
commit e7b88f9
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/couchbase/client.go b/couchbase/client.go
@@ -137,6 +137,7 @@ func (s *client) CreateMultiPath(ctx context.Context,
 		Deadline:       deadline,
 		ScopeName:      scopeName,
 		CollectionName: collectionName,
+		RetryStrategy:  gocbcore.NewBestEffortRetryStrategy(nil),
 	}
 
 	if cas != nil {
@@ -177,6 +178,7 @@ func (s *client) CreatePath(ctx context.Context,
 		Deadline:       deadline,
 		ScopeName:      scopeName,
 		CollectionName: collectionName,
+		RetryStrategy:  gocbcore.NewBestEffortRetryStrategy(nil),
 	}
 
 	if cas != nil {
@@ -217,6 +219,7 @@ func (s *client) ArrayAppend(ctx context.Context,
 		Deadline:       deadline,
 		ScopeName:      scopeName,
 		CollectionName: collectionName,
+		RetryStrategy:  gocbcore.NewBestEffortRetryStrategy(nil),
 	}
 
 	if cas != nil {
@@ -250,6 +253,7 @@ func (s *client) Increment(ctx context.Context,
 		ScopeName:      scopeName,
 		Deadline:       deadline,
 		PreserveExpiry: preserveExpiry,
+		RetryStrategy:  gocbcore.NewBestEffortRetryStrategy(nil),
 	}
 
 	if cas != nil {
@@ -279,6 +283,7 @@ func (s *client) CreateDocument(ctx context.Context,
 		Expiry:         expiry,
 		ScopeName:      scopeName,
 		CollectionName: collectionName,
+		RetryStrategy:  gocbcore.NewBestEffortRetryStrategy(nil),
 	}, cb)
 
 	return err
@@ -298,6 +303,7 @@ func (s *client) DeleteDocument(ctx context.Context,
 		Deadline:       deadline,
 		ScopeName:      scopeName,
 		CollectionName: collectionName,
+		RetryStrategy:  gocbcore.NewBestEffortRetryStrategy(nil),
 	}
 
 	if cas != nil {
@@ -334,6 +340,7 @@ func (s *client) DeletePath(ctx context.Context,
 		Deadline:       deadline,
 		ScopeName:      scopeName,
 		CollectionName: collectionName,
+		RetryStrategy:  gocbcore.NewBestEffortRetryStrategy(nil),
 	}
 
 	if cas != nil {

diff --git a/couchbase/target_client.go b/couchbase/target_client.go
@@ -35,6 +35,7 @@ func (s *targetClient) Get(ctx context.Context,
 		Deadline:       deadline,
 		ScopeName:      s.scopeName,
 		CollectionName: s.collectionName,
+		RetryStrategy:  gocbcore.NewBestEffortRetryStrategy(nil),
 	}, func(result *gocbcore.GetResult, err error) {
 		if result == nil || err != nil {
 			cb(nil, err)