@@ -32,6 +32,7 @@ import (
3232 "github.com/arangodb/go-driver/v2/connection"
3333
3434 pbAuthenticationV1 "github.com/arangodb/kube-arangodb/integrations/authentication/v1/definition"
35+ "github.com/arangodb/kube-arangodb/pkg/util"
3536 "github.com/arangodb/kube-arangodb/pkg/util/cache"
3637 "github.com/arangodb/kube-arangodb/pkg/util/errors"
3738 operatorHTTP "github.com/arangodb/kube-arangodb/pkg/util/http"
@@ -167,11 +168,11 @@ func (d *Database) KVCollectionFromClient(clientO cache.Object[arangodb.Client],
167168 return nil , 0 , err
168169 }
169170
170- if _ , err := db .CreateCollectionWithOptions (ctx , collection , & arangodb.CreateCollectionProperties {
171- IsSystem : true ,
172- WriteConcern : d .WriteConcern ,
173- ReplicationFactor : arangodb .ReplicationFactor (d .ReplicationFactor ),
174- }, nil ); err != nil {
171+ if _ , err := db .CreateCollectionV2 (ctx , collection , & arangodb.CreateCollectionPropertiesV2 {
172+ IsSystem : util . NewType ( true ) ,
173+ WriteConcern : util . NewType ( d .WriteConcern ) ,
174+ ReplicationFactor : util . NewType ( arangodb .ReplicationFactor (d .ReplicationFactor ) ),
175+ }); err != nil {
175176 if ! shared .IsConflict (err ) {
176177 return nil , 0 , err
177178 }
0 commit comments