[GODRIVER-1101] Use new driver library in change streams Created: 03/Jun/19  Updated: 12/Jun/19  Resolved: 12/Jun/19

Status: Closed
Project: Go Driver
Component/s: Core API
Affects Version/s: None
Fix Version/s: None

Type: Task Priority: Major - P3
Reporter: Divjot Arora (Inactive) Assignee: Emmanuel Eppinger (Inactive)
Resolution: Done Votes: 0
Labels: neweng
Remaining Estimate: Not Specified
Time Spent: Not Specified
Original Estimate: Not Specified


 Description   

Now that RunCommand uses the new driver library, the change stream code can depend on driver instead of driverlegacy. A new KillCursors operation might be necessary because change streams have to manually kill their cursor to avoid closing the implicit session they're using.



 Comments   
Comment by Emmanuel Eppinger (Inactive) [ 12/Jun/19 ]

https://review.gerrithub.io/c/mongodb/mongo-go-driver/+/457513

Comment by Githook User [ 12/Jun/19 ]

Author:

{'name': 'Emmanuel', 'email': 'manny.eppinger@mongodb.com', 'username': 'eppingere'}

Message: Move ChangeStream to Driver

GODRIVER-1101

Change-Id: Icd6ca7605baa5d1ee454181ee39771fd709e4ea5
Branch: master
https://github.com/mongodb/mongo-go-driver/commit/df0f8c44059d04f60f45ebc8510065d4357cb408

Comment by Emmanuel Eppinger (Inactive) [ 11/Jun/19 ]

https://review.gerrithub.io/c/mongodb/mongo-go-driver/+/457513

Comment by Emmanuel Eppinger (Inactive) [ 10/Jun/19 ]

https://review.gerrithub.io/c/mongodb/mongo-go-driver/+/457513

Comment by Emmanuel Eppinger (Inactive) [ 10/Jun/19 ]

https://evergreen.mongodb.com/version/5cfeaace0305b943445b79c8##1

Comment by Divjot Arora (Inactive) [ 05/Jun/19 ]

Something that I didn't notice earlier: this will also involve replacing command.Read with operation.Aggregate in the change stream code. This should be possible if the aggregate TOML specifies database = true to indicate that a collection of 1 should be used if a collection name is not present.

Generated at Thu Feb 08 08:35:41 UTC 2024 using Jira 9.7.1#970001-sha1:2222b88b221c4928ef0de3161136cc90c8356a66.