diff options
Diffstat (limited to 'src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/mongo/readpref/options.go')
-rw-r--r-- | src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/mongo/readpref/options.go | 60 |
1 files changed, 0 insertions, 60 deletions
diff --git a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/mongo/readpref/options.go b/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/mongo/readpref/options.go deleted file mode 100644 index 74ce61b4986..00000000000 --- a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/mongo/readpref/options.go +++ /dev/null @@ -1,60 +0,0 @@ -// Copyright (C) MongoDB, Inc. 2017-present. -// -// Licensed under the Apache License, Version 2.0 (the "License"); you may -// not use this file except in compliance with the License. You may obtain -// a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 - -package readpref - -import ( - "errors" - "time" - - "go.mongodb.org/mongo-driver/tag" -) - -// ErrInvalidTagSet indicates that an invalid set of tags was specified. -var ErrInvalidTagSet = errors.New("an even number of tags must be specified") - -// Option configures a read preference -type Option func(*ReadPref) error - -// WithMaxStaleness sets the maximum staleness a -// server is allowed. -func WithMaxStaleness(ms time.Duration) Option { - return func(rp *ReadPref) error { - rp.maxStaleness = ms - rp.maxStalenessSet = true - return nil - } -} - -// WithTags sets a single tag set used to match -// a server. The last call to WithTags or WithTagSets -// overrides all previous calls to either method. -func WithTags(tags ...string) Option { - return func(rp *ReadPref) error { - length := len(tags) - if length < 2 || length%2 != 0 { - return ErrInvalidTagSet - } - - tagset := make(tag.Set, 0, length/2) - - for i := 1; i < length; i += 2 { - tagset = append(tagset, tag.Tag{Name: tags[i-1], Value: tags[i]}) - } - - return WithTagSets(tagset)(rp) - } -} - -// WithTagSets sets the tag sets used to match -// a server. The last call to WithTags or WithTagSets -// overrides all previous calls to either method. -func WithTagSets(tagSets ...tag.Set) Option { - return func(rp *ReadPref) error { - rp.tagSets = tagSets - return nil - } -} |