- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 308 for Add (0.16 sec)
-
internal/event/rules_test.go
rules2Case4 := make(Rules) rules2Case4.Add(NewPattern("2010*", ""), TargetID{"1", "webhook"}) rules2Case4.Add(NewPattern("", "*.png"), TargetID{"2", "amqp"}) expectedResultCase4 := make(Rules) expectedResultCase4.Add(NewPattern("*", "*"), TargetID{"1", "webhook"}) rulesCase5 := make(Rules) rulesCase5.Add(NewPattern("*", ""), TargetID{"1", "webhook"})
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 8.8K bytes - Viewed (0) -
cni/pkg/nodeagent/fakes_test.go
r.AddInpodMarkIPRuleCnt.Add(1) return nil } func (r *fakeIptablesDeps) DelInpodMarkIPRule(cfg *iptables.Config) error { r.DelInpodMarkIPRuleCnt.Add(1) return nil } func (r *fakeIptablesDeps) AddLoopbackRoutes(cfg *iptables.Config) error { r.AddLoopbackRoutesCnt.Add(1) return r.AddRouteErr }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
if opts.UndoWrite { p.storage.setWriteAttribute(p.totalWrites.Add(^uint64(0))) return } if fi.Deleted { // Delete markers are a write operation not a permanent delete. p.storage.setWriteAttribute(p.totalWrites.Add(1)) return } p.storage.setDeleteAttribute(p.totalDeletes.Add(1)) } }() w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
internal/config/identity/openid/jwt.go
if err != nil { return err } for _, key := range jwk.Keys { pkey, err := key.DecodePublicKey() if err != nil { return err } pk.add(key.Kid, pkey) } return nil } func (pk *publicKeys) add(keyID string, key interface{}) { pk.Lock() defer pk.Unlock() pk.pkMap[keyID] = key } func (pk *publicKeys) get(kid string) interface{} { pk.RLock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 8.3K bytes - Viewed (5) -
istioctl/pkg/precheck/precheck.go
} } if verificationImpacted { res := ObjectToInstance(dr) messages.Add(msg.NewUpdateIncompatibility(res, "VERIFY_CERTIFICATE_AT_CLIENT", "1.20", "previously, TLS verification was skipped. Set `insecureSkipVerify` if this behavior is desired", "1.20")) } if sniImpacted { res := ObjectToInstance(dr) messages.Add(msg.NewUpdateIncompatibility(res, "ENABLE_AUTO_SNI", "1.20",
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
cmd/data-scanner_test.go
obj := ObjectInfo{ Name: "foo", ModTime: time.Now().Add(-31 * 24 * time.Hour), Size: 100 << 20, VersionID: uuid.New().String(), IsLatest: true, NumVersions: 4, } delMarker := ObjectInfo{ Name: "foo-deleted", ModTime: time.Now().Add(-61 * 24 * time.Hour), Size: 0, VersionID: uuid.New().String(), IsLatest: true,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
} value = sql.FormatSQLTimestamp(time.Unix(0, 0).Add(duration)) } } else if se.GetConvertedType() == parquettypes.ConvertedType_TIMESTAMP_MILLIS { duration := time.Duration(val) * time.Millisecond value = sql.FormatSQLTimestamp(time.Unix(0, 0).Add(duration)) } else if se.GetConvertedType() == parquettypes.ConvertedType_TIMESTAMP_MICROS {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 14 13:54:47 GMT 2022 - 4.5K bytes - Viewed (0) -
cmd/os-instrumented.go
return func() { duration := time.Since(startTime) atomic.AddUint64(&o.operations[s], 1) o.latency[s].add(duration) } } // incTime will increment time on metric s with a specific duration. func (o *osMetrics) incTime(s osMetric, d time.Duration) { atomic.AddUint64(&o.operations[s], 1) o.latency[s].add(d) } func osTrace(s osMetric, startTime time.Time, duration time.Duration, path string, err error) madmin.TraceInfo {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 6.3K bytes - Viewed (0) -
cmd/tier-last-day-stats.go
Bins [24]tierStats UpdatedAt time.Time } func (l *lastDayTierStats) addStats(ts tierStats) { now := time.Now() l.forwardTo(now) nowIdx := now.Hour() l.Bins[nowIdx] = l.Bins[nowIdx].add(ts) } // forwardTo moves time to t, clearing entries between last update and t. func (l *lastDayTierStats) forwardTo(t time.Time) { if t.IsZero() { t = time.Now() } since := t.Sub(l.UpdatedAt).Hours()
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
} pattern += suffix } pattern = strings.ReplaceAll(pattern, "**", "*") return pattern } // Rules - event rules type Rules map[string]TargetIDSet // Add - adds pattern and target ID. func (rules Rules) Add(pattern string, targetID TargetID) { rules[pattern] = NewTargetIDSet(targetID).Union(rules[pattern]) } // MatchSimple - returns true one of the matching object name in rules.
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)