- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 585 for Jake (0.12 sec)
-
cmd/peer-rest-server.go
localDrives := cloneDrives(globalLocalDrives) globalLocalDrivesMu.RUnlock() errs := make([]error, len(localDrives)) infos := make([]DiskInfo, len(localDrives)) for i, drive := range localDrives { infos[i], errs[i] = drive.DiskInfo(GlobalContext, DiskInfoOptions{}) } infoMaps := make(map[string]madmin.DiskMetrics) for i := range infos {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/batch-expire.go
} if i > 0 { if wait := globalBatchConfig.ExpirationWait(); wait > 0 { time.Sleep(wait) } } i++ wk.Take() go func(toExpire []expireObjInfo) { defer wk.Give() toExpireAll := make([]ObjectInfo, 0, len(toExpire)) toDel := make([]ObjectToDelete, 0, len(toExpire)) oiCache := newObjInfoCache() for _, exp := range toExpire { if exp.ExpireAll {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/batch-rotate.go
} obj, err := api.GetObjectInfo(ctx, r.Bucket, objInfo.Name, opts) if err != nil { return err } oi := obj.Clone() var ( newKeyID string newKeyContext kms.Context ) encMetadata := make(map[string]string) for k, v := range oi.UserDefined { if stringsHasPrefixFold(k, ReservedMetadataPrefixLower) { encMetadata[k] = v } } if (sseKMS || sseS3) && r.Encryption.Type == ssekms {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/site-replication.go
bucketStats := make(map[string][]srBucketMetaInfo) policyStats := make(map[string][]srPolicy) userPolicyStats := make(map[string][]srPolicyMapping) groupPolicyStats := make(map[string][]srPolicyMapping) userInfoStats := make(map[string][]srUserInfo) groupDescStats := make(map[string][]srGroupDesc) ilmExpiryRuleStats := make(map[string][]srILMExpiryRule) numSites := len(sris)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cni/pkg/nodeagent/net.go
func (s *NetServer) AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error { log.Infof("in pod mode - adding pod %s/%s to ztunnel ", pod.Namespace, pod.Name) // make sure the cache is aware of the pod, even if we don't have the netns yet. s.currentPodSnapshot.Ensure(string(pod.UID)) openNetns, err := s.getOrOpenNetns(pod, netNs) if err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
internal/event/rulesmap_test.go
t.Fatalf("test %v: result: expected: not equal, got: equal", i+1) } } } func TestRulesMapAdd(t *testing.T) { rulesMapCase1 := make(RulesMap) rulesMapToAddCase1 := make(RulesMap) expectedResultCase1 := make(RulesMap) rulesMapCase2 := make(RulesMap) rulesMapToAddCase2 := NewRulesMap([]Name{ObjectCreatedAll}, "*", TargetID{"1", "webhook"})
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jan 05 18:43:06 GMT 2024 - 6.8K bytes - Viewed (0) -
internal/s3select/csv/reader.go
} // Create queue r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0)) r.input = make(chan *queueItem, runtime.GOMAXPROCS(0)) r.readerWg.Add(1) // Start splitter go func() { defer close(r.input) defer close(r.queue) defer r.readerWg.Done() for { q := queueItem{ input: next, dst: make(chan [][]string, 1), err: nextErr, } select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
clause/set.go
func (set Set) MergeClause(clause *Clause) { copiedAssignments := make([]Assignment, len(set)) copy(copiedAssignments, set) clause.Expression = Set(copiedAssignments) } func Assignments(values map[string]interface{}) Set { keys := make([]string, 0, len(values)) for key := range values { keys = append(keys, key) } sort.Strings(keys) assignments := make([]Assignment, len(keys)) for idx, key := range keys {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Nov 29 03:02:44 GMT 2021 - 1.4K bytes - Viewed (0) -
callbacks/query.go
clauseSelect.Columns = make([]clause.Column, len(db.Statement.Schema.DBNames)) for idx, dbName := range db.Statement.Schema.DBNames { clauseSelect.Columns[idx] = clause.Column{Table: db.Statement.Table, Name: dbName} } } specifiedRelationsName := make(map[string]interface{}) for _, join := range db.Statement.Joins {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Jan 29 03:34:57 GMT 2024 - 9.9K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
func (r *ReplicationStats) Get(bucket string) BucketReplicationStats { if r == nil { return BucketReplicationStats{Stats: make(map[string]*BucketReplicationStat)} } r.RLock() defer r.RUnlock() st, ok := r.Cache[bucket] if !ok { return BucketReplicationStats{Stats: make(map[string]*BucketReplicationStat)} } return st.Clone() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0)