Skip to content

Latest commit

 

History

History
64 lines (47 loc) · 1.63 KB

README.md

File metadata and controls

64 lines (47 loc) · 1.63 KB
Raw

MongoDB mongo-go-driver and Change Streams Examples

  • 01/09/2020: Replaced with go.mongodb.org/mongo-driver (v1.2.0)
  • 02/25/2019: Replaced with go.mongodb.org/mongo-driver (v1.0.0-rc1)

A MongoDB Change Streams implementation using mongodb-go-driver.

mongo-go-driver Examples

Examples can be found at examples.

  • Aggregate
    • $group
    • $redact
    • $filter
    • $lookup
    • $elemMatch
  • Change Streams
  • CRUD
  • RunCommand
  • Transactions

Change Streams Demo

Set up a replica set

mkdir -p data/db
rm -rf data/db/*
mongod --port 30097 --dbpath data/db --logpath data/mongod.log --fork --wiredTigerCacheSizeGB .5  --replSet replset
mongo --quiet mongodb://localhost:30097/admin --eval 'rs.initiate()'
mongo --quiet mongodb://localhost:30097/argos?replicaSet=replset --eval 'db.oplogs.insert({"_id": "30097", "scores": [100]})'

Case 1: Watch All Changes

argos "mongodb://localhost:30097/?replicaSet=replset"

Case 2: Watch Changes From a Database

argos "mongodb://localhost:30097/argos?replicaSet=replset"

Case 3: Watch Changes From a Collection

argos --collection oplogs "mongodb://localhost:30097/argos?replicaSet=replset"

Case 4: Watch Changes From a Collection With a Pipeline

argos --collection --pipeline '[{"$match": {"operationType": "update"}}]' \
  "mongodb://localhost:30097/argos?replicaSet=replset"

Stream POC

It would be nice mongo-go-drive can do stream. See POC for an example.

client.Database(db).Collection(collection).Find(filter).Project(project).Sort(sort).Decode(&docs)