Ignore $clusterTime (#3830)

FerretDB · Dec 7, 2023 · d8de8af · d8de8af
1 parent 514acee
commit d8de8af
Show file tree

Hide file tree

Showing 7 changed files with 7 additions and 0 deletions.
diff --git a/internal/handler/common/count.go b/internal/handler/common/count.go
@@ -38,6 +38,7 @@ type CountParams struct {
 	ReadConcern *types.Document `ferretdb:"readConcern,ignored"`
 	Comment     string          `ferretdb:"comment,ignored"`
 	LSID        any             `ferretdb:"lsid,ignored"`
+	ClusterTime any             `ferretdb:"$clusterTime,ignored"`
 }
 
 // GetCountParams returns the parameters for the count command.

diff --git a/internal/handler/common/delete_params.go b/internal/handler/common/delete_params.go
@@ -36,6 +36,7 @@ type DeleteParams struct {
 
 	WriteConcern *types.Document `ferretdb:"writeConcern,ignored"`
 	LSID         any             `ferretdb:"lsid,ignored"`
+	ClusterTime  any             `ferretdb:"$clusterTime,ignored"`
 }
 
 // Delete represents single delete operation parameters.

diff --git a/internal/handler/common/distinct.go b/internal/handler/common/distinct.go
@@ -44,6 +44,7 @@ type DistinctParams struct {
 
 	ReadConcern *types.Document `ferretdb:"readConcern,ignored"`
 	LSID        any             `ferretdb:"lsid,ignored"`
+	ClusterTime any             `ferretdb:"$clusterTime,ignored"`
 }
 
 // GetDistinctParams returns `distinct` command parameters.

diff --git a/internal/handler/common/find.go b/internal/handler/common/find.go
@@ -51,6 +51,7 @@ type FindParams struct {
 	Min          *types.Document `ferretdb:"min,ignored"`
 	Hint         any             `ferretdb:"hint,ignored"`
 	LSID         any             `ferretdb:"lsid,ignored"`
+	ClusterTime  any             `ferretdb:"$clusterTime,ignored"`
 
 	ReturnKey           bool `ferretdb:"returnKey,unimplemented-non-default"`
 	ShowRecordId        bool `ferretdb:"showRecordId,opt"`

diff --git a/internal/handler/common/findandmodify.go b/internal/handler/common/findandmodify.go
@@ -68,6 +68,7 @@ type FindAndModifyParams struct {
 	WriteConcern             *types.Document `ferretdb:"writeConcern,ignored"`
 	BypassDocumentValidation bool            `ferretdb:"bypassDocumentValidation,ignored"`
 	LSID                     any             `ferretdb:"lsid,ignored"`
+	ClusterTime              any             `ferretdb:"$clusterTime,ignored"`
 }
 
 // UpsertParams represents parameters for upsert, if the document exists UpdateParams is set.

diff --git a/internal/handler/common/insert.go b/internal/handler/common/insert.go
@@ -36,6 +36,7 @@ type InsertParams struct {
 	BypassDocumentValidation bool   `ferretdb:"bypassDocumentValidation,ignored"`
 	Comment                  string `ferretdb:"comment,ignored"`
 	LSID                     any    `ferretdb:"lsid,ignored"`
+	ClusterTime              any    `ferretdb:"$clusterTime,ignored"`
 }
 
 // GetInsertParams returns the parameters for an insert command.

diff --git a/internal/handler/common/update_params.go b/internal/handler/common/update_params.go
@@ -38,6 +38,7 @@ type UpdateParams struct {
 	BypassDocumentValidation bool            `ferretdb:"bypassDocumentValidation,ignored"`
 	WriteConcern             *types.Document `ferretdb:"writeConcern,ignored"`
 	LSID                     any             `ferretdb:"lsid,ignored"`
+	ClusterTime              any             `ferretdb:"$clusterTime,ignored"`
 }
 
 // Update represents a single update operation parameters.