Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2025-05-25 12:27
📄 mode.go // 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 ( "fmt" "strings" ) // Mode indicates the user's preference on reads. type Mode uint8 // Mode constants const ( _ Mode = iota // PrimaryMode indicates that only a primary is // considered for reading. This is the default // mode. PrimaryMode // PrimaryPreferredMode indicates that if a primary // is available, use it; otherwise, eligible // secondaries will be considered. PrimaryPreferredMode // SecondaryMode indicates that only secondaries // should be considered. SecondaryMode // SecondaryPreferredMode indicates that only secondaries // should be considered when one is available. If none // are available, then a primary will be considered. SecondaryPreferredMode // NearestMode indicates that all primaries and secondaries // will be considered. NearestMode ) // ModeFromString returns a mode corresponding to // mode. func ModeFromString(mode string) (Mode, error) { switch strings.ToLower(mode) { case "primary": return PrimaryMode, nil case "primarypreferred": return PrimaryPreferredMode, nil case "secondary": return SecondaryMode, nil case "secondarypreferred": return SecondaryPreferredMode, nil case "nearest": return NearestMode, nil } return Mode(0), fmt.Errorf("unknown read preference %v", mode) } // String returns the string representation of mode. func (mode Mode) String() string { switch mode { case PrimaryMode: return "primary" case PrimaryPreferredMode: return "primaryPreferred" case SecondaryMode: return "secondary" case SecondaryPreferredMode: return "secondaryPreferred" case NearestMode: return "nearest" default: return "unknown" } } // IsValid checks whether the mode is valid. func (mode Mode) IsValid() bool { switch mode { case PrimaryMode, PrimaryPreferredMode, SecondaryMode, SecondaryPreferredMode, NearestMode: return true default: return false } }	2.12 KB	2025-05-25 12:27
📄 mode_test.go // Copyright (C) MongoDB, Inc. 2020-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 ( "testing" "go.mongodb.org/mongo-driver/internal/assert" ) func TestMode_String(t testing.T) { t.Parallel() testCases := []struct { name string mode Mode }{ {"primary", PrimaryMode}, {"primaryPreferred", PrimaryPreferredMode}, {"secondary", SecondaryMode}, {"secondaryPreferred", SecondaryPreferredMode}, {"nearest", NearestMode}, {"unknown", Mode(42)}, } for _, tc := range testCases { t.Run(tc.name, func(t testing.T) { assert.Equal(t, tc.name, tc.mode.String(), "expected %q, got %q", tc.name, tc.mode.String()) }) } }	853 B	2025-05-25 12:27
📄 options.go // 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 specifies a single tag set used to match replica set members. If no members match the // tag set, read operations will return an error. To avoid errors if no members match the tag set, use // [WithTagSets] and include an empty tag set as the last tag set in the list. // // The last call to [WithTags] or [WithTagSets] overrides all previous calls to either method. // // For more information about read preference tags, see // https://www.mongodb.com/docs/manual/core/read-preference-tags/ 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 specifies a list of tag sets used to match replica set members. If the list contains // multiple tag sets, members are matched against each tag set in succession until a match is found. // Once a match is found, the remaining tag sets are ignored. If no members match any of the tag // sets, the read operation returns with an error. To avoid an error if no members match any of the // tag sets, include an empty tag set as the last tag set in the list. // // The last call to [WithTags] or [WithTagSets] overrides all previous calls to either method. // // For more information about read preference tags, see // https://www.mongodb.com/docs/manual/core/read-preference-tags/ func WithTagSets(tagSets ...tag.Set) Option { return func(rp ReadPref) error { rp.tagSets = tagSets return nil } } // WithHedgeEnabled specifies whether or not hedged reads should be enabled in the server. This feature requires MongoDB // server version 4.4 or higher. For more information about hedged reads, see // https://www.mongodb.com/docs/manual/core/sharded-cluster-query-router/#mongos-hedged-reads. If not specified, the default // is to not send a value to the server, which will result in the server defaults being used. func WithHedgeEnabled(hedgeEnabled bool) Option { return func(rp *ReadPref) error { rp.hedgeEnabled = &hedgeEnabled return nil } }	2.96 KB	2025-05-25 12:27
📄 options_example_test.go // Copyright (C) MongoDB, Inc. 2023-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_test import ( "context" "go.mongodb.org/mongo-driver/mongo" "go.mongodb.org/mongo-driver/mongo/options" "go.mongodb.org/mongo-driver/mongo/readpref" "go.mongodb.org/mongo-driver/tag" ) // Configure a Client with a read preference that selects the nearest replica // set member that includes tags "region: South" and "datacenter: A". func ExampleWithTags() { rp := readpref.Nearest( readpref.WithTags( "region", "South", "datacenter", "A")) opts := options.Client(). ApplyURI("mongodb://localhost:27017"). SetReadPreference(rp) _, err := mongo.Connect(context.Background(), opts) if err != nil { panic(err) } } // Configure a Client with a read preference that selects the nearest replica // set member matching a set of tags. Try to match members in 3 stages: // // 1. Match replica set members that include tags "region: South" and // "datacenter: A". // 2. Match replica set members that includes tag "region: South". // 3. Match any replica set member. // // Stage 3 is used to avoid errors when no members match the previous 2 stages. func ExampleWithTagSets() { tagSetList := tag.NewTagSetsFromMaps([]map[string]string{ {"region": "South", "datacenter": "A"}, {"region": "South"}, {}, }) rp := readpref.Nearest(readpref.WithTagSets(tagSetList...)) opts := options.Client(). ApplyURI("mongodb://localhost"). SetReadPreference(rp) _, err := mongo.Connect(context.Background(), opts) if err != nil { panic(err) } }	1.72 KB	2025-05-25 12:27
📄 readpref.go // 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 defines read preferences for MongoDB queries. package readpref // import "go.mongodb.org/mongo-driver/mongo/readpref" import ( "bytes" "errors" "fmt" "time" "go.mongodb.org/mongo-driver/tag" ) var ( errInvalidReadPreference = errors.New("can not specify tags, max staleness, or hedge with mode primary") ) // Primary constructs a read preference with a PrimaryMode. func Primary() ReadPref { return &ReadPref{mode: PrimaryMode} } // PrimaryPreferred constructs a read preference with a PrimaryPreferredMode. func PrimaryPreferred(opts ...Option) ReadPref { // New only returns an error with a mode of Primary rp, _ := New(PrimaryPreferredMode, opts...) return rp } // SecondaryPreferred constructs a read preference with a SecondaryPreferredMode. func SecondaryPreferred(opts ...Option) ReadPref { // New only returns an error with a mode of Primary rp, _ := New(SecondaryPreferredMode, opts...) return rp } // Secondary constructs a read preference with a SecondaryMode. func Secondary(opts ...Option) ReadPref { // New only returns an error with a mode of Primary rp, _ := New(SecondaryMode, opts...) return rp } // Nearest constructs a read preference with a NearestMode. func Nearest(opts ...Option) ReadPref { // New only returns an error with a mode of Primary rp, _ := New(NearestMode, opts...) return rp } // New creates a new ReadPref. func New(mode Mode, opts ...Option) (ReadPref, error) { rp := &ReadPref{ mode: mode, } if mode == PrimaryMode && len(opts) != 0 { return nil, errInvalidReadPreference } for _, opt := range opts { if opt == nil { continue } err := opt(rp) if err != nil { return nil, err } } return rp, nil } // ReadPref determines which servers are considered suitable for read operations. type ReadPref struct { maxStaleness time.Duration maxStalenessSet bool mode Mode tagSets []tag.Set hedgeEnabled bool } // MaxStaleness is the maximum amount of time to allow // a server to be considered eligible for selection. The // second return value indicates if this value has been set. func (r ReadPref) MaxStaleness() (time.Duration, bool) { return r.maxStaleness, r.maxStalenessSet } // Mode indicates the mode of the read preference. func (r ReadPref) Mode() Mode { return r.mode } // TagSets are multiple tag sets indicating // which servers should be considered. func (r ReadPref) TagSets() []tag.Set { return r.tagSets } // HedgeEnabled returns whether or not hedged reads are enabled for this read preference. If this option was not // specified during read preference construction, nil is returned. func (r ReadPref) HedgeEnabled() bool { return r.hedgeEnabled } // String returns a human-readable description of the read preference. func (r ReadPref) String() string { var b bytes.Buffer b.WriteString(r.mode.String()) delim := "(" if r.maxStalenessSet { fmt.Fprintf(&b, "%smaxStaleness=%v", delim, r.maxStaleness) delim = " " } for _, tagSet := range r.tagSets { fmt.Fprintf(&b, "%stagSet=%s", delim, tagSet.String()) delim = " " } if r.hedgeEnabled != nil { fmt.Fprintf(&b, "%shedgeEnabled=%v", delim, r.hedgeEnabled) delim = " " } if delim != "(" { b.WriteString(")") } return b.String() }	3.47 KB	2025-05-25 12:27
📄 readpref_test.go // 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 ( "testing" "time" "go.mongodb.org/mongo-driver/internal/assert" "go.mongodb.org/mongo-driver/internal/require" "go.mongodb.org/mongo-driver/tag" ) func TestPrimary(t testing.T) { subject := Primary() require.Equal(t, PrimaryMode, subject.Mode()) _, set := subject.MaxStaleness() require.False(t, set) require.Len(t, subject.TagSets(), 0) } func TestPrimaryPreferred(t testing.T) { subject := PrimaryPreferred() require.Equal(t, PrimaryPreferredMode, subject.Mode()) _, set := subject.MaxStaleness() require.False(t, set) require.Len(t, subject.TagSets(), 0) } func TestPrimaryPreferred_with_options(t testing.T) { subject := PrimaryPreferred( WithMaxStaleness(time.Duration(10)), WithTags("a", "1", "b", "2"), ) require.Equal(t, PrimaryPreferredMode, subject.Mode()) ms, set := subject.MaxStaleness() require.True(t, set) require.Equal(t, time.Duration(10), ms) require.Equal(t, []tag.Set{{tag.Tag{Name: "a", Value: "1"}, tag.Tag{Name: "b", Value: "2"}}}, subject.TagSets()) } func TestSecondaryPreferred(t testing.T) { subject := SecondaryPreferred() require.Equal(t, SecondaryPreferredMode, subject.Mode()) _, set := subject.MaxStaleness() require.False(t, set) require.Len(t, subject.TagSets(), 0) } func TestSecondaryPreferred_with_options(t testing.T) { subject := SecondaryPreferred( WithMaxStaleness(time.Duration(10)), WithTags("a", "1", "b", "2"), ) require.Equal(t, SecondaryPreferredMode, subject.Mode()) ms, set := subject.MaxStaleness() require.True(t, set) require.Equal(t, time.Duration(10), ms) require.Equal(t, []tag.Set{{tag.Tag{Name: "a", Value: "1"}, tag.Tag{Name: "b", Value: "2"}}}, subject.TagSets()) } func TestSecondary(t testing.T) { subject := Secondary() require.Equal(t, SecondaryMode, subject.Mode()) _, set := subject.MaxStaleness() require.False(t, set) require.Len(t, subject.TagSets(), 0) } func TestSecondary_with_options(t testing.T) { subject := Secondary( WithMaxStaleness(time.Duration(10)), WithTags("a", "1", "b", "2"), ) require.Equal(t, SecondaryMode, subject.Mode()) ms, set := subject.MaxStaleness() require.True(t, set) require.Equal(t, time.Duration(10), ms) require.Equal(t, []tag.Set{{tag.Tag{Name: "a", Value: "1"}, tag.Tag{Name: "b", Value: "2"}}}, subject.TagSets()) } func TestNearest(t testing.T) { subject := Nearest() require.Equal(t, NearestMode, subject.Mode()) _, set := subject.MaxStaleness() require.False(t, set) require.Len(t, subject.TagSets(), 0) } func TestNearest_with_options(t testing.T) { subject := Nearest( WithMaxStaleness(time.Duration(10)), WithTags("a", "1", "b", "2"), ) require.Equal(t, NearestMode, subject.Mode()) ms, set := subject.MaxStaleness() require.True(t, set) require.Equal(t, time.Duration(10), ms) require.Equal(t, []tag.Set{{tag.Tag{Name: "a", Value: "1"}, tag.Tag{Name: "b", Value: "2"}}}, subject.TagSets()) } func TestHedge(t testing.T) { t.Run("hedge specified with primary mode errors", func(t testing.T) { _, err := New(PrimaryMode, WithHedgeEnabled(true)) assert.Equal(t, errInvalidReadPreference, err, "expected error %v, got %v", errInvalidReadPreference, err) }) t.Run("valid hedge document and mode succeeds", func(t testing.T) { rp, err := New(SecondaryMode, WithHedgeEnabled(true)) assert.Nil(t, err, "expected no error, got %v", err) enabled := rp.HedgeEnabled() assert.NotNil(t, enabled, "expected HedgeEnabled to return a non-nil value, got nil") assert.True(t, enabled, "expected HedgeEnabled to return true, got false") }) } func TestReadPref_String(t testing.T) { t.Run("ReadPref.String() with all options", func(t testing.T) { readPref := Nearest( WithMaxStaleness(120time.Second), WithTagSets(tag.Set{{"a", "1"}, {"b", "2"}}, tag.Set{{"q", "5"}, {"r", "6"}}), WithHedgeEnabled(true), ) expected := "nearest(maxStaleness=2m0s tagSet=a=1,b=2 tagSet=q=5,r=6 hedgeEnabled=true)" assert.Equal(t, expected, readPref.String(), "expected %q, got %q", expected, readPref.String()) }) t.Run("ReadPref.String() with one option", func(t testing.T) { readPref := Secondary(WithTags("a", "1", "b", "2")) expected := "secondary(tagSet=a=1,b=2)" assert.Equal(t, expected, readPref.String(), "expected %q, got %q", expected, readPref.String()) }) t.Run("ReadPref.String() with no options", func(t testing.T) { readPref := Primary() expected := "primary" assert.Equal(t, expected, readPref.String(), "expected %q, got %q", expected, readPref.String()) }) }	4.7 KB	2025-05-25 12:27

Terminal