// watch client filtering on database name
|
var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<BsonDocument>>()
|
.Match(x => x.DatabaseNamespace.DatabaseName.StartsWith("MyPrefix"));
|
var changeStream = client.Watch(pipeline);
|
|
// watch client filtering on collection name
|
var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<BsonDocument>>()
|
.Match(x => x.CollectionNamespace.CollectionName.StartsWith("MyPrefix"));
|
var changeStream = client.Watch(pipeline);
|
|
// watch database filtering on collection name
|
var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<BsonDocument>>()
|
.Match(x => x.CollectionNamespace.CollectionName.StartsWith("MyPrefix"));
|
var changeStream = database.Watch(pipeline);
|