README
¶
mongo-go-driver Examples
- TestAggregateArray
- TestAggregateFilter
- TestAggregateGraphLookup
- TestAggregateGroup
- TestAggregateJSON
- TestAggregateLookup
- TestAggregateMatch
- TestAggregatePipeline
- TestAggregateRedact
- TestChangeStreamClient
- TestChangeStreamCollection
- TestChangeStreamCollectionWithPipeline
- TestChangeStreamDatabase
- TestCount
- TestDeleteMany
- TestDeleteOne
- TestFindMany
- TestFindManyWithOptions
- TestFindOne
- TestFindOneAndReplace
- TestInsertMany
- TestInsertOne
- TestInsertOneWithOptions
- TestReplaceLoop
- TestReplaceOne
- TestRunCommand
- TestTransactionAbort
- TestTransactionCommit
- TestUpdateMany
- TestUpdateOne
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ChangeStream ¶
type ChangeStream struct {
// contains filtered or unexported fields
}
ChangeStream defines what to watch? client, database or collection
func (*ChangeStream) SetCollection ¶
func (cs *ChangeStream) SetCollection(collection string)
SetCollection sets collection
func (*ChangeStream) SetDatabase ¶
func (cs *ChangeStream) SetDatabase(database string)
SetDatabase sets database
func (*ChangeStream) SetPipeline ¶
func (cs *ChangeStream) SetPipeline(pipeline []bson.D)
SetPipeline sets pipeline
func (*ChangeStream) Watch ¶
func (cs *ChangeStream) Watch(client *mongo.Client, cb callback)
Watch prints oplogs in JSON format
Source Files
Click to show internal directories.
Click to hide internal directories.