- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 269 for Kappen (0.27 sec)
-
cmd/iam-store.go
if _, ok := cache.iamUsersMap[u]; !ok { // This case can happen when a temporary account is // deleted or expired - remove it from userPolicyMap. cache.iamUserPolicyMap.Delete(u) return true } } if pset.Contains(policy) { users = append(users, u) } return true })
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 74.4K bytes - Viewed (2) -
cmd/bucket-policy.go
data, err := json.Marshal(bucketPolicy) if err != nil { // This should not happen because bucketPolicy is valid to convert to JSON data. return nil, err } var policyInfo miniogopolicy.BucketAccessPolicy json := jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(data, &policyInfo); err != nil { // This should not happen because data is valid to JSON data. return nil, err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 8K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
} if missing > 0 { out += ".truncated" } else { out += ".complete" } fmt.Println(missing, "bytes missing. Truncating", len(filled)-lastValid-1, "from end.") mapped = mapped[:lastValid+1] err := os.WriteFile(out, mapped, os.ModePerm) if err != nil { return err } fmt.Println("Wrote output to", out) return nil
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 19.7K bytes - Viewed (1) -
cni/pkg/nodeagent/net.go
log.Warnf("failed to sync host IPset: %v", err) consErr = append(consErr, err) } podsByUID := slices.GroupUnique(ambientPods, (*corev1.Pod).GetUID) if err := s.buildZtunnelSnapshot(podsByUID); err != nil { log.Warnf("failed to construct initial ztunnel snapshot: %v", err) consErr = append(consErr, err) } return errors.Join(consErr...) }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.1K bytes - Viewed (1) -
cmd/global-heal.go
PoolIndex: disks[0].PoolIndex, } for _, disk := range disks { ss.Disks = append(ss.Disks, disk) if disk.Healing { ss.HealStatus = "Healing" ss.HealPriority = "high" status.HealDisks = append(status.HealDisks, disk.Endpoint) } } sortDisks(ss.Disks) status.Sets = append(status.Sets, ss) } sort.Slice(status.Sets, func(i, j int) bool {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 08 09:22:13 GMT 2024 - 14.2K bytes - Viewed (1) -
cmd/data-scanner.go
delete(abandonedChildren, h.Key()) // h.Key() already accounted for. if exists { existingFolders = append(existingFolders, this) f.updateCache.copyWithChildren(&f.oldCache, h, &thisHash) } else { newFolders = append(newFolders, this) } return nil } wait := noWait if f.weSleep() { // Dynamic time delay.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 09:40:19 GMT 2024 - 46.9K bytes - Viewed (0) -
internal/logger/logger.go
for _, goPathString := range goPathList { trimStrings = append(trimStrings, filepath.Join(goPathString, "src")+string(filepath.Separator)) } for _, goRootString := range goRootList { trimStrings = append(trimStrings, filepath.Join(goRootString, "src")+string(filepath.Separator)) } for _, defaultgoPathString := range defaultgoPathList {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.2K bytes - Viewed (0) -
cmd/iam-object-store.go
} bootstrapTraceMsg("purging expired STS credentials") iamListing, ok := iamOS.cachedIAMListing.Load().(map[string][]string) if !ok { // There has been no store yet. This should never happen! iamLogIf(GlobalContext, errors.New("WARNING: no cached IAM listing found")) return nil } // Scan STS users on disk and purge expired ones. We do not need to hold a // lock with store.lock() here.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
internal/event/targetlist.go
targets := []Target{} for _, tgt := range list.targets { targets = append(targets, tgt) } return targets } // List - returns available target IDs. func (list *TargetList) List() []TargetID { list.RLock() defer list.RUnlock() keys := []TargetID{} for k := range list.targets { keys = append(keys, k) } return keys }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
cmd/endpoint.go
} node.GridHost = ep.GridHost() } if !slices.Contains(node.Pools, ep.PoolIdx) { node.Pools = append(node.Pools, ep.PoolIdx) } nodesMap[ep.Host] = node } } nodes = make([]Node, 0, len(nodesMap)) for _, v := range nodesMap { nodes = append(nodes, v) } sort.Slice(nodes, func(i, j int) bool { return nodes[i].Host < nodes[j].Host }) return }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0)