add delete

Author: qingyang-hu

mongo/collection.go

@@ -534,6 +534,9 @@ func (coll *Collection) delete(
 		}
 		op = op.Let(let)
 	}
+	if args.RawData != nil {
+		op = op.RawData(*args.RawData)
+	}
 
 	// deleteMany cannot be retried
 	retryMode := driver.RetryNone
@@ -575,6 +578,7 @@ func (coll *Collection) DeleteOne(
 		Comment:   args.Comment,
 		Hint:      args.Hint,
 		Let:       args.Let,
+		RawData:   args.RawData,
 	}
 
 	return coll.delete(ctx, filter, true, rrOne, deleteOptions)

mongo/options/deleteoptions.go

@@ -15,6 +15,7 @@ type DeleteOneOptions struct {
 	Comment   interface{}
 	Hint      interface{}
 	Let       interface{}
+	RawData   *bool
 }
 
 // DeleteOneOptionsBuilder contains options to configure DeleteOne operations. Each
@@ -93,6 +94,18 @@ func (do *DeleteOneOptionsBuilder) SetLet(let interface{}) *DeleteOneOptionsBuil
 	return do
 }
 
+// SetRawData sets the value for the RawData field. If true, it allows the CRUD operations to access timeseries
+// collections on the bucket-level. This option is only valid for MongoDB versions >= 9.0. The default value is false.
+func (do *DeleteOneOptionsBuilder) SetRawData(rawData bool) *DeleteOneOptionsBuilder {
+	do.Opts = append(do.Opts, func(opts *DeleteOneOptions) error {
+		opts.RawData = &rawData
+
+		return nil
+	})
+
+	return do
+}
+
 // DeleteManyOptions represents arguments that can be used to configure DeleteMany
 // operations.
 //
@@ -102,6 +115,7 @@ type DeleteManyOptions struct {
 	Comment   interface{}
 	Hint      interface{}
 	Let       interface{}
+	RawData   *bool
 }
 
 // DeleteManyOptionsBuilder contains options to configure DeleteMany operations.
@@ -179,3 +193,15 @@ func (do *DeleteManyOptionsBuilder) SetLet(let interface{}) *DeleteManyOptionsBu
 
 	return do
 }
+
+// SetRawData sets the value for the RawData field. If true, it allows the CRUD operations to access timeseries
+// collections on the bucket-level. This option is only valid for MongoDB versions >= 9.0. The default value is false.
+func (do *DeleteManyOptionsBuilder) SetRawData(rawData bool) *DeleteManyOptionsBuilder {
+	do.Opts = append(do.Opts, func(opts *DeleteManyOptions) error {
+		opts.RawData = &rawData
+
+		return nil
+	})
+
+	return do
+}

x/mongo/driver/operation/delete.go

@@ -43,6 +43,7 @@ type Delete struct {
 	serverAPI     *driver.ServerAPIOptions
 	let           bsoncore.Document
 	timeout       *time.Duration
+	rawData       *bool
 	logger        *logger.Logger
 }
 
@@ -139,6 +140,10 @@ func (d *Delete) command(dst []byte, desc description.SelectedServer) ([]byte, e
 	if d.let != nil {
 		dst = bsoncore.AppendDocumentElement(dst, "let", d.let)
 	}
+	// Set rawData for 8.2+ servers.
+	if d.rawData != nil && desc.WireVersion != nil && driverutil.VersionRangeIncludes(*desc.WireVersion, 27) {
+		dst = bsoncore.AppendBooleanElement(dst, "rawData", *d.rawData)
+	}
 	return dst, nil
 }
 
@@ -337,3 +342,13 @@ func (d *Delete) Authenticator(authenticator driver.Authenticator) *Delete {
 	d.authenticator = authenticator
 	return d
 }
+
+// RawData sets the rawData to access timeseries data in the compressed format.
+func (d *Delete) RawData(rawData bool) *Delete {
+	if d == nil {
+		d = new(Delete)
+	}
+
+	d.rawData = &rawData
+	return d
+}