- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 293 for Kappen (0.16 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) -
internal/store/batch.go
if !ok { err = fmt.Errorf("item not found for the key: %v; should not happen;", key) return } orderedItems = append(orderedItems, item) delete(b.items, key) } b.keys = b.keys[:0] return } // GetByKey will get the batch item by the provided key func (b *Batch[K, T]) GetByKey(key K) (T, bool) { b.Lock() defer b.Unlock() item, ok := b.items[key] return item, ok }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 2.5K bytes - Viewed (0) -
.github/ISSUE_TEMPLATE/bug_report.md
<!--- Provide a general summary of the issue in the Title above --> ## Expected Behavior <!--- If you're describing a bug, tell us what should happen --> <!--- If you're suggesting a change/improvement, tell us how it should work --> ## Current Behavior <!--- If describing a bug, tell us what happens instead of the expected behavior --> <!--- If suggesting a change/improvement, explain the difference from current behavior --> ## Possible Solution
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 20 17:37:40 GMT 2022 - 1.7K 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/bucket-stats_gen.go
// map header, size 14 // string "ReplicatedSize" o = append(o, 0x8e, 0xae, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x65, 0x64, 0x53, 0x69, 0x7a, 0x65) o = msgp.AppendInt64(o, z.ReplicatedSize) // string "ReplicaSize" o = append(o, 0xab, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x53, 0x69, 0x7a, 0x65) o = msgp.AppendInt64(o, z.ReplicaSize) // string "FailStats" o = append(o, 0xa9, 0x46, 0x61, 0x69, 0x6c, 0x53, 0x74, 0x61, 0x74, 0x73)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 57.5K bytes - Viewed (0) -
internal/grid/msg.go
if m.MuxID != 0 { res = append(res, fmt.Sprintf("MuxID: %v", m.MuxID)) } if m.Seq != 0 { res = append(res, fmt.Sprintf("Seq: %v", m.Seq)) } if m.DeadlineMS != 0 { res = append(res, fmt.Sprintf("Deadline: %vms", m.DeadlineMS)) } if m.Handler != handlerInvalid { res = append(res, fmt.Sprintf("Handler: %v", m.Handler)) } if m.Op != 0 { res = append(res, fmt.Sprintf("Op: %v", m.Op)) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0) -
cmd/tier-journal_gen.go
o = append(o, 0x83, 0xa3, 0x6f, 0x62, 0x6a) o = msgp.AppendString(o, z.ObjName) // string "vid" o = append(o, 0xa3, 0x76, 0x69, 0x64) o = msgp.AppendString(o, z.VersionID) // string "tier" o = append(o, 0xa4, 0x74, 0x69, 0x65, 0x72) o = msgp.AppendString(o, z.TierName) return } // UnmarshalMsg implements msgp.Unmarshaler func (z *jentry) UnmarshalMsg(bts []byte) (o []byte, err error) { var field []byte
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jun 03 21:26:51 GMT 2021 - 6.1K bytes - Viewed (0) -
cmd/peer-s3-client.go
perPoolErrs := make([]error, 0, len(sys.peerClients)) for i, client := range sys.peerClients { if slices.Contains(client.GetPools(), poolIdx) { perPoolErrs = append(perPoolErrs, errs[i]) } } quorum := len(perPoolErrs) / 2 poolErrs = append(poolErrs, reduceWriteQuorumErrs(ctx, perPoolErrs, bucketOpIgnoredErrs, quorum)) } opts.Remove = isAllBucketsNotFound(poolErrs) opts.Recreate = !opts.Remove
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
cmd/signature-v2.go
lkey := strings.ToLower(key) if !strings.HasPrefix(lkey, "x-amz-") { continue } keys = append(keys, lkey) keyval[lkey] = strings.Join(headers[key], ",") } sort.Strings(keys) var canonicalHeaders []string for _, key := range keys { canonicalHeaders = append(canonicalHeaders, key+":"+keyval[key]) } return strings.Join(canonicalHeaders, "\n") }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 12.2K bytes - Viewed (0) -
cmd/common-main.go
continue } if !ellipses.HasEllipses(endpoint) { endpoints = append(endpoints, endpoint) continue } patterns, err := ellipses.FindEllipsesPatterns(endpoint) if err != nil { logger.Fatal(err, fmt.Sprintf("Invalid KES endpoint %q", endpoint)) } for _, lbls := range patterns.Expand() { endpoints = append(endpoints, strings.Join(lbls, "")) } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Apr 17 00:34:45 GMT 2024 - 35.5K bytes - Viewed (2)