- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 81 for clone (0.17 sec)
-
cmd/tier-last-day-stats.go
l.Bins[lastIdx] = tierStats{} } } func (l *lastDayTierStats) clone() lastDayTierStats { clone := lastDayTierStats{ UpdatedAt: l.UpdatedAt, } copy(clone.Bins[:], l.Bins[:]) return clone } func (l lastDayTierStats) merge(m lastDayTierStats) (merged lastDayTierStats) { cl := l.clone() cm := m.clone() if cl.UpdatedAt.After(cm.UpdatedAt) { cm.forwardTo(cl.UpdatedAt)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/event/rules.go
} } return targetIDs } // Clone - returns copy of this rules. func (rules Rules) Clone() Rules { rulesCopy := make(Rules) for pattern, targetIDSet := range rules { rulesCopy[pattern] = targetIDSet.Clone() } return rulesCopy } // Union - returns union with given rules as new rules. func (rules Rules) Union(rules2 Rules) Rules { nrules := rules.Clone() for pattern, targetIDSet := range rules2 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 2.7K bytes - Viewed (0) -
docs/hotfixes.md
``` commit 4f3317effea38c203c358af9cb5ce3c0e4173976 Author: Klaus Post <******@****.***> Date: Mon Nov 8 08:41:27 2021 -0800 Close stream on panic (#13605) Always close streamHTTPResponse on panic on main thread to avoid write/flush after response handler has returned. ``` ``` λ git cherry-pick 4f3317effea38c203c358af9cb5ce3c0e4173976 ```
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 14 21:36:02 GMT 2024 - 5K bytes - Viewed (0) -
internal/bucket/lifecycle/rule.go
return errXMLNotWellFormed } return nil } // CloneNonTransition - returns a clone of the object containing non transition rules func (r Rule) CloneNonTransition() Rule { return Rule{ XMLName: r.XMLName, ID: r.ID, Status: r.Status,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/http/server.go
} srv.listenerMutex.Unlock() if atomic.AddUint32(&srv.inShutdown, 1) > 1 { // shutdown in progress return http.ErrServerClosed } // Close underneath HTTP listener. srv.listenerMutex.Lock() err := srv.listener.Close() srv.listenerMutex.Unlock() if err != nil { return err } pollIntervalBase := time.Millisecond nextPollInterval := func() time.Duration {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
internal/event/targetidset.go
type TargetIDSet map[TargetID]struct{} // IsEmpty returns true if the set is empty. func (set TargetIDSet) IsEmpty() bool { return len(set) != 0 } // Clone - returns copy of this set. func (set TargetIDSet) Clone() TargetIDSet { setCopy := NewTargetIDSet() for k, v := range set { setCopy[k] = v } return setCopy } // add - adds TargetID to the set.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 1.9K bytes - Viewed (0) -
internal/config/identity/ldap/config.go
} // Enabled returns if LDAP is enabled. func (l *Config) Enabled() bool { return l.LDAP.Enabled } // Clone returns a cloned copy of LDAP config. func (l *Config) Clone() Config { if l == nil { return Config{} } cfg := Config{ LDAP: l.LDAP.Clone(), stsExpiryDuration: l.stsExpiryDuration, } return cfg } // LDAP keys and envs. const (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 7.9K bytes - Viewed (2) -
internal/config/subnet/config.go
// when transport is nil, it means we are just validating the // inputs not performing any network calls. return cfg, nil } // Make sure to clone the transport before editing the ProxyURL if proxyURL != nil { ctransport := transport.(*http.Transport).Clone() ctransport.Proxy = http.ProxyURL((*url.URL)(proxyURL)) cfg.transport = ctransport } else { cfg.transport = transport } return cfg, nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 24 17:59:35 GMT 2023 - 3.8K bytes - Viewed (0) -
internal/config/heal/heal.go
// // >0 interval duration between cycles func (opts Config) BitrotScanCycle() (d time.Duration) { configMutex.RLock() defer configMutex.RUnlock() return opts.cache.bitrotCycle } // Clone safely the heal configuration func (opts Config) Clone() (int, time.Duration, string) { configMutex.RLock() defer configMutex.RUnlock() return opts.IOCount, opts.Sleep, opts.Bitrot }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/http-tracer.go
return } tt := madmin.TraceInternal if strings.HasPrefix(tc.FuncName, "s3.") { tt = madmin.TraceS3 } // Calculate input body size with headers reqHeaders := r.Header.Clone() reqHeaders.Set("Host", r.Host) if len(r.TransferEncoding) == 0 { reqHeaders.Set("Content-Length", strconv.Itoa(int(r.ContentLength))) } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0)