- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 55 for Sentry (0.14 sec)
-
cmd/metacache-entries.go
r.candidates = r.candidates[:0] objsAgree := 0 objsValid := 0 for i := range m { entry := &m[i] // Empty entry if entry.name == "" { continue } if entry.isDir() { dirExists++ selected = entry continue } // Get new entry metadata, // shallow decode. xl, err := entry.xlmeta() if err != nil { if !errors.Is(err, errFileNotFound) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
args: strings.Split("entry configure --name foo -o temp --clusterID cid", " "), expectedException: true, expectedOutput: "Error: expecting a WorkloadGroup artifact file or the name and namespace of an existing WorkloadGroup\n", }, { description: "Invalid command args - missing valid input spec", args: strings.Split("entry configure -n bar -o temp --clusterID cid", " "),
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
src/archive/zip/reader.go
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 27.7K bytes - Viewed (0) -
cmd/peer-rest-client.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
src/archive/tar/format.go
func (h *headerUSTAR) devMinor() []byte { return h[337:][:8] } func (h *headerUSTAR) prefix() []byte { return h[345:][:155] } type sparseArray []byte func (s sparseArray) entry(i int) sparseElem { return sparseElem(s[i*24:]) } func (s sparseArray) isExtended() []byte { return s[24*s.maxEntries():][:1] } func (s sparseArray) maxEntries() int { return len(s) / 24 } type sparseElem []byte
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 11.3K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
// 2. Get all pod ips (might be several, v6/v4) // 3. update ipsets accordingly func addPodToHostNSIpset(pod *corev1.Pod, podIPs []netip.Addr, hostsideProbeSet *ipset.IPSet) error { // Add the pod UID as an ipset entry comment, so we can (more) easily find and delete // all relevant entries for a pod later. podUID := string(pod.ObjectMeta.UID) ipProto := uint8(unix.IPPROTO_TCP) var ipsetAddrErrs []error
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) -
cmd/metacache-stream_test.go
if err != io.EOF { t.Fatal(err, entries.len()) } want := loadMetacacheSampleNames var noDirs []string for i, entry := range entries.entries() { if entry.name != want[i] { t.Errorf("entry %d, want %q, got %q", i, want[i], entry.name) } if !entry.isDir() { noDirs = append(noDirs, entry.name) } } if entries.len() != len(want) { t.Fatal("unexpected length:", entries.len(), "want:", len(want)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 15K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
// from an internal channel. for entry := range logCh { h.logEntry(entry) } } func (h *Target) logEntry(entry interface{}) { atomic.AddInt64(&h.totalMessages, 1) if err := h.send(entry); err != nil { atomic.AddInt64(&h.failedMessages, 1) h.kconfig.LogOnce(context.Background(), err, h.kconfig.Topic) } } func (h *Target) send(entry interface{}) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cmd/bucket-lifecycle.go
tasks += len(wrkr) } return tasks } // enqueueTierJournalEntry enqueues a tier journal entry referring to a remote // object corresponding to a 'replaced' object versions. This applies only to // non-versioned or version suspended buckets. func (es *expiryState) enqueueTierJournalEntry(je jentry) { wrkr := es.getWorkerCh(je.OpHash()) if wrkr == nil { es.stats.missedTierJournalTasks.Add(1) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
return true default: return false } } decommissionEntry := func(entry metaCacheEntry) { defer wk.Give() if entry.isDir() { return } fivs, err := entry.fileInfoVersions(bi.Name) if err != nil { return } // We need a reversed order for decommissioning,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1)