Home
last modified time | relevance | path

Searched refs:ChangeStream (Results 1 – 25 of 117) sorted by relevance

12345

/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/vendor/gopkg.in/mgo.v2/
H A Dchangestreams.go11 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 Dchange_stream.go66 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 Dchange_stream.go66 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 Dchange_stream.go66 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 Dchange_stream.go66 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 Dchange_stream.go43 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 Dchange_stream.go43 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 Dchange_stream.go43 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 Dchange_stream.go43 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 DREADME.rst151 #. ``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 DREADME.rst151 #. ``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 Dentity_test.go55 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 Dentity_test.go55 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 DREADME.rst171 #. ``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 DREADME.rst171 #. ``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 DREADME.rst171 #. ``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 DREADME.rst151 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 Dchange_stream_test.go305 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 Dchangestreamoptions.go25 func ChangeStream() *ChangeStreamOptions { func
71 csOpts := ChangeStream()
/dports/security/vault/vault-1.8.2/vendor/go.mongodb.org/mongo-driver/mongo/integration/
H A Dchange_stream_test.go301 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 Dchange_stream_test.go302 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 Dchangestreamoptions.go52 func ChangeStream() *ChangeStreamOptions { func
103 csOpts := ChangeStream()
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/go.mongodb.org/mongo-driver/mongo/options/
H A Dchangestreamoptions.go26 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 Dchangestreamoptions.go52 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 Dchangestreamoptions.go26 func ChangeStream() *ChangeStreamOptions { func
81 csOpts := ChangeStream()

12345