/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/vendor/gopkg.in/mgo.v2/ |
H A D | changestreams.go | 11 type ChangeStream struct { struct 46 options ChangeStreamOptions) (*ChangeStream, error) { 65 return &ChangeStream{ 95 func (changeStream *ChangeStream) Next(result interface{}) bool { argument 149 func (changeStream *ChangeStream) Err() error { argument 157 func (changeStream *ChangeStream) Close() error { argument 171 func (changeStream *ChangeStream) ResumeToken() *bson.Raw { argument 216 func (changeStream *ChangeStream) resume() error { argument 247 func (changeStream *ChangeStream) fetchResumeToken(rawResult *bson.Raw) error { argument 265 func (changeStream *ChangeStream) fetchResultSet(result interface{}) error { argument
|
/dports/security/vault/vault-1.8.2/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | change_stream.go | 66 type ChangeStream struct { struct 105 cs := &ChangeStream{ 293 func (cs *ChangeStream) updatePbrtFromCommand() { argument 300 func (cs *ChangeStream) storeResumeToken() error { argument 440 func (cs *ChangeStream) ID() int64 { argument 449 func (cs *ChangeStream) Decode(val interface{}) error { argument 458 func (cs *ChangeStream) Err() error { argument 489 func (cs *ChangeStream) ResumeToken() bson.Raw { argument 500 func (cs *ChangeStream) Next(ctx context.Context) bool { argument 590 func (cs *ChangeStream) isResumableError() bool { argument [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-database-mongodbatlas/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | change_stream.go | 66 type ChangeStream struct { struct 105 cs := &ChangeStream{ 293 func (cs *ChangeStream) updatePbrtFromCommand() { argument 300 func (cs *ChangeStream) storeResumeToken() error { argument 440 func (cs *ChangeStream) ID() int64 { argument 449 func (cs *ChangeStream) Decode(val interface{}) error { argument 458 func (cs *ChangeStream) Err() error { argument 489 func (cs *ChangeStream) ResumeToken() bson.Raw { argument 500 func (cs *ChangeStream) Next(ctx context.Context) bool { argument 590 func (cs *ChangeStream) isResumableError() bool { argument [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | change_stream.go | 66 type ChangeStream struct { struct 105 cs := &ChangeStream{ 290 func (cs *ChangeStream) updatePbrtFromCommand() { argument 297 func (cs *ChangeStream) storeResumeToken() error { argument 437 func (cs *ChangeStream) ID() int64 { argument 446 func (cs *ChangeStream) Decode(val interface{}) error { argument 455 func (cs *ChangeStream) Err() error { argument 486 func (cs *ChangeStream) ResumeToken() bson.Raw { argument 497 func (cs *ChangeStream) Next(ctx context.Context) bool { argument 587 func (cs *ChangeStream) isResumableError() bool { argument [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | change_stream.go | 66 type ChangeStream struct { struct 105 cs := &ChangeStream{ 293 func (cs *ChangeStream) updatePbrtFromCommand() { argument 300 func (cs *ChangeStream) storeResumeToken() error { argument 440 func (cs *ChangeStream) ID() int64 { argument 449 func (cs *ChangeStream) Decode(val interface{}) error { argument 458 func (cs *ChangeStream) Err() error { argument 489 func (cs *ChangeStream) ResumeToken() bson.Raw { argument 500 func (cs *ChangeStream) Next(ctx context.Context) bool { argument 590 func (cs *ChangeStream) isResumableError() bool { argument [all …]
|
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | change_stream.go | 43 type ChangeStream struct { struct 80 cs := &ChangeStream{ 261 func (cs *ChangeStream) updatePbrtFromCommand() { argument 268 func (cs *ChangeStream) storeResumeToken() error { argument 408 func (cs *ChangeStream) ID() int64 { argument 417 func (cs *ChangeStream) Decode(val interface{}) error { argument 426 func (cs *ChangeStream) Err() error { argument 439 func (cs *ChangeStream) Close(ctx context.Context) error { argument 457 func (cs *ChangeStream) ResumeToken() bson.Raw { argument 468 func (cs *ChangeStream) Next(ctx context.Context) bool { argument [all …]
|
/dports/net-mgmt/semaphore/semaphore-2.6.8/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | change_stream.go | 43 type ChangeStream struct { struct 80 cs := &ChangeStream{ 261 func (cs *ChangeStream) updatePbrtFromCommand() { argument 268 func (cs *ChangeStream) storeResumeToken() error { argument 408 func (cs *ChangeStream) ID() int64 { argument 417 func (cs *ChangeStream) Decode(val interface{}) error { argument 426 func (cs *ChangeStream) Err() error { argument 439 func (cs *ChangeStream) Close(ctx context.Context) error { argument 457 func (cs *ChangeStream) ResumeToken() bson.Raw { argument 468 func (cs *ChangeStream) Next(ctx context.Context) bool { argument [all …]
|
/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | change_stream.go | 43 type ChangeStream struct { struct 80 cs := &ChangeStream{ 261 func (cs *ChangeStream) updatePbrtFromCommand() { argument 268 func (cs *ChangeStream) storeResumeToken() error { argument 408 func (cs *ChangeStream) ID() int64 { argument 417 func (cs *ChangeStream) Decode(val interface{}) error { argument 426 func (cs *ChangeStream) Err() error { argument 439 func (cs *ChangeStream) Close(ctx context.Context) error { argument 457 func (cs *ChangeStream) ResumeToken() bson.Raw { argument 468 func (cs *ChangeStream) Next(ctx context.Context) bool { argument [all …]
|
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | change_stream.go | 43 type ChangeStream struct { struct 242 opts ...*options.ChangeStreamOptions) (*ChangeStream, error) { 271 cs := &ChangeStream{ 325 cs := &ChangeStream{ 378 cs := &ChangeStream{ 401 func (cs *ChangeStream) storeResumeToken() error { argument 425 func (cs *ChangeStream) ID() int64 { argument 435 func (cs *ChangeStream) Next(ctx context.Context) bool { argument 475 func (cs *ChangeStream) Decode(out interface{}) error { argument 484 func (cs *ChangeStream) Err() error { argument [all …]
|
/dports/net-mgmt/semaphore/semaphore-2.6.8/vendor/go.mongodb.org/mongo-driver/data/change-streams/ |
H A D | README.rst | 151 #. ``ChangeStream`` must continuously track the last seen ``resumeToken`` 154 #. ``ChangeStream`` will not attempt to resume on any error encountered while executing an ``aggreg… 155 #. ``ChangeStream`` will not attempt to resume after encountering error code 11601 (Interrupted), 1… 156 #. ``ChangeStream`` will perform server selection before attempting to resume, using initial ``read… 160 #. ``ChangeStream`` will resume after a ``killCursors`` command is issued for its child cursor. 161 #. - For a ``ChangeStream`` under these conditions: 166 #. - For a ``ChangeStream`` under these conditions: 174 #. - For a ``ChangeStream`` under these conditions: 179 #. - For a ``ChangeStream`` under these conditions: 187 #. - For a ``ChangeStream`` under these conditions: [all …]
|
/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/vendor/go.mongodb.org/mongo-driver/data/change-streams/ |
H A D | README.rst | 151 #. ``ChangeStream`` must continuously track the last seen ``resumeToken`` 154 #. ``ChangeStream`` will not attempt to resume on any error encountered while executing an ``aggreg… 155 #. ``ChangeStream`` will not attempt to resume after encountering error code 11601 (Interrupted), 1… 156 #. ``ChangeStream`` will perform server selection before attempting to resume, using initial ``read… 160 #. ``ChangeStream`` will resume after a ``killCursors`` command is issued for its child cursor. 161 #. - For a ``ChangeStream`` under these conditions: 166 #. - For a ``ChangeStream`` under these conditions: 174 #. - For a ``ChangeStream`` under these conditions: 179 #. - For a ``ChangeStream`` under these conditions: 187 #. - For a ``ChangeStream`` under these conditions: [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/go.mongodb.org/mongo-driver/mongo/integration/unified/ |
H A D | entity_test.go | 55 changeStreams map[string]*mongo.ChangeStream 69 changeStreams: make(map[string]*mongo.ChangeStream), 87 func (em *EntityMap) AddChangeStreamEntity(id string, stream *mongo.ChangeStream) error { 141 func (em *EntityMap) ChangeStream(id string) (*mongo.ChangeStream, error) { func
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/go.mongodb.org/mongo-driver/mongo/integration/unified/ |
H A D | entity_test.go | 55 changeStreams map[string]*mongo.ChangeStream 69 changeStreams: make(map[string]*mongo.ChangeStream), 87 func (em *EntityMap) AddChangeStreamEntity(id string, stream *mongo.ChangeStream) error { 141 func (em *EntityMap) ChangeStream(id string) (*mongo.ChangeStream, error) { func
|
/dports/security/vault/vault-1.8.2/vendor/go.mongodb.org/mongo-driver/data/change-streams/ |
H A D | README.rst | 171 #. ``ChangeStream`` must continuously track the last seen ``resumeToken`` 172 #. ``ChangeStream`` will throw an exception if the server response is missing the resume token (if … 173 #. After receiving a ``resumeToken``, ``ChangeStream`` will automatically resume one time on a resu… 176 #. ``ChangeStream`` will perform server selection before attempting to resume, using initial ``read… 179 #. ``$changeStream`` stage for ``ChangeStream`` against a server ``>=4.0`` and ``<4.0.7`` that has … 181 #. For a ``ChangeStream`` under these conditions: 190 #. For a ``ChangeStream`` under these conditions: 201 #. For a ``ChangeStream`` under these conditions: 210 #. For a ``ChangeStream`` under these conditions: 226 #. ``$changeStream`` stage for ``ChangeStream`` started with ``startAfter`` against a server ``>=4.… [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/go.mongodb.org/mongo-driver/data/change-streams/ |
H A D | README.rst | 171 #. ``ChangeStream`` must continuously track the last seen ``resumeToken`` 172 #. ``ChangeStream`` will throw an exception if the server response is missing the resume token (if … 173 #. After receiving a ``resumeToken``, ``ChangeStream`` will automatically resume one time on a resu… 176 #. ``ChangeStream`` will perform server selection before attempting to resume, using initial ``read… 179 #. ``$changeStream`` stage for ``ChangeStream`` against a server ``>=4.0`` and ``<4.0.7`` that has … 181 #. For a ``ChangeStream`` under these conditions: 190 #. For a ``ChangeStream`` under these conditions: 201 #. For a ``ChangeStream`` under these conditions: 210 #. For a ``ChangeStream`` under these conditions: 226 #. ``$changeStream`` stage for ``ChangeStream`` started with ``startAfter`` against a server ``>=4.… [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/go.mongodb.org/mongo-driver/data/change-streams/ |
H A D | README.rst | 171 #. ``ChangeStream`` must continuously track the last seen ``resumeToken`` 172 #. ``ChangeStream`` will throw an exception if the server response is missing the resume token (if … 173 #. After receiving a ``resumeToken``, ``ChangeStream`` will automatically resume one time on a resu… 176 #. ``ChangeStream`` will perform server selection before attempting to resume, using initial ``read… 179 #. ``$changeStream`` stage for ``ChangeStream`` against a server ``>=4.0`` and ``<4.0.7`` that has … 181 #. For a ``ChangeStream`` under these conditions: 190 #. For a ``ChangeStream`` under these conditions: 201 #. For a ``ChangeStream`` under these conditions: 210 #. For a ``ChangeStream`` under these conditions: 226 #. ``$changeStream`` stage for ``ChangeStream`` started with ``startAfter`` against a server ``>=4.… [all …]
|
/dports/databases/p5-MongoDB/MongoDB-v2.2.2/t/data/change-streams/ |
H A D | README.rst | 151 1. ``ChangeStream`` must continuously track the last seen ``resumeToken`` 152 2. ``ChangeStream`` will throw an exception if the server response is missing the resume token (if … 153 3. ``ChangeStream`` will automatically resume one time on a resumable error (including `not master`… 154 4. ``ChangeStream`` will not attempt to resume on a server error 155 5. ``ChangeStream`` will perform server selection before attempting to resume, using initial ``read… 158 8. ``$changeStream`` stage for ``ChangeStream`` against a server ``>=4.0`` that has not received an… 159 9. ``ChangeStream`` will resume after a ``killCursors`` command is issued for its child cursor.
|
/dports/net-mgmt/semaphore/semaphore-2.6.8/vendor/go.mongodb.org/mongo-driver/mongo/integration/ |
H A D | change_stream_test.go | 305 var cs *mongo.ChangeStream 341 opts := options.ChangeStream().SetMaxAwaitTime(100 * time.Millisecond) 398 opts = options.ChangeStream().SetStartAfter(token) 402 opts = options.ChangeStream().SetResumeAfter(token) 405 opts = options.ChangeStream().SetStartAtOperationTime(&opTime) 454 {"resumeAfter", options.ChangeStream().SetResumeAfter(token), true, token, numEvents - 1}, 520 func closeStream(cs *mongo.ChangeStream) { argument 534 func killChangeStreamCursor(mt *mtest.T, cs *mongo.ChangeStream) { argument 558 func compareResumeTokens(mt *mtest.T, cs *mongo.ChangeStream, expected bson.Raw) { argument 563 func ensureResumeToken(mt *mtest.T, cs *mongo.ChangeStream) { argument
|
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/go.mongodb.org/mongo-driver/mongo/options/ |
H A D | changestreamoptions.go | 25 func ChangeStream() *ChangeStreamOptions { func 71 csOpts := ChangeStream()
|
/dports/security/vault/vault-1.8.2/vendor/go.mongodb.org/mongo-driver/mongo/integration/ |
H A D | change_stream_test.go | 301 var cs *mongo.ChangeStream 326 opts := options.ChangeStream().SetMaxAwaitTime(100 * time.Millisecond) 383 opts = options.ChangeStream().SetStartAfter(token) 387 opts = options.ChangeStream().SetResumeAfter(token) 390 opts = options.ChangeStream().SetStartAtOperationTime(&opTime) 439 {"resumeAfter", options.ChangeStream().SetResumeAfter(token), true, token, numEvents - 1}, 613 func closeStream(cs *mongo.ChangeStream) { argument 627 func killChangeStreamCursor(mt *mtest.T, cs *mongo.ChangeStream) { argument 651 func compareResumeTokens(mt *mtest.T, cs *mongo.ChangeStream, expected bson.Raw) { argument 656 func ensureResumeToken(mt *mtest.T, cs *mongo.ChangeStream) { argument
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/go.mongodb.org/mongo-driver/mongo/integration/ |
H A D | change_stream_test.go | 302 var cs *mongo.ChangeStream 327 opts := options.ChangeStream().SetMaxAwaitTime(100 * time.Millisecond) 384 opts = options.ChangeStream().SetStartAfter(token) 388 opts = options.ChangeStream().SetResumeAfter(token) 391 opts = options.ChangeStream().SetStartAtOperationTime(&opTime) 440 {"resumeAfter", options.ChangeStream().SetResumeAfter(token), true, token, numEvents - 1}, 614 func closeStream(cs *mongo.ChangeStream) { argument 628 func killChangeStreamCursor(mt *mtest.T, cs *mongo.ChangeStream) { argument 652 func compareResumeTokens(mt *mtest.T, cs *mongo.ChangeStream, expected bson.Raw) { argument 657 func ensureResumeToken(mt *mtest.T, cs *mongo.ChangeStream) { argument
|
/dports/security/vault/vault-1.8.2/vendor/go.mongodb.org/mongo-driver/mongo/options/ |
H A D | changestreamoptions.go | 52 func ChangeStream() *ChangeStreamOptions { func 103 csOpts := ChangeStream()
|
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/go.mongodb.org/mongo-driver/mongo/options/ |
H A D | changestreamoptions.go | 26 func ChangeStream() *ChangeStreamOptions { func 81 csOpts := ChangeStream()
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-database-mongodbatlas/vendor/go.mongodb.org/mongo-driver/mongo/options/ |
H A D | changestreamoptions.go | 52 func ChangeStream() *ChangeStreamOptions { func 103 csOpts := ChangeStream()
|
/dports/net-mgmt/semaphore/semaphore-2.6.8/vendor/go.mongodb.org/mongo-driver/mongo/options/ |
H A D | changestreamoptions.go | 26 func ChangeStream() *ChangeStreamOptions { func 81 csOpts := ChangeStream()
|