- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 71 for Hevery (0.19 sec)
-
cmd/metacache-entries.go
} return other, false } // Tiebreak on version count. if len(eVers.versions) > len(oVers.versions) { return e, false } return other, false } // Check if each version matches... for i, eVer := range eVers.versions { oVer := oVers.versions[i] if eVer.header != oVer.header { if eVer.header.hasEC() != oVer.header.hasEC() {
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) -
cmd/batch-expire.go
go func() { saveTicker := time.NewTicker(10 * time.Second) defer saveTicker.Stop() for { select { case <-saveTicker.C: // persist in-memory state to disk after every 10secs. batchLogIf(ctx, ri.updateAfter(ctx, api, 10*time.Second, job)) case <-ctx.Done(): // persist in-memory state immediately before exiting due to context cancellation.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cni/pkg/plugin/sidecar_redirect.go
if valErr != nil { return nil, fmt.Errorf("annotation value error for value %s; annotationFound = %t: %v", "includeOutboundPorts", isFound, valErr) } // Add 15090 to sync with non-cni injection template // TODO: Revert below once https://github.com/istio/istio/pull/23037 or its follow up is merged. redir.excludeInboundPorts = strings.TrimSpace(redir.excludeInboundPorts)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.6K bytes - Viewed (0) -
cmd/batch-rotate.go
stopFn(result, nil) } ri.trackCurrentBucketObject(r.Bucket, result, success) ri.RetryAttempts = attempts globalBatchJobsMetrics.save(job.ID, ri) // persist in-memory state to disk after every 10secs. batchLogIf(ctx, ri.updateAfter(ctx, api, 10*time.Second, job)) if success { break } if delay > 0 { time.Sleep(delay + time.Duration(rnd.Float64()*float64(delay))) }
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/erasure-healing-common_test.go
} if diskIndex != 0 && disk == nil { t.Errorf("Drive erroneously filtered, driveIndex: %d", diskIndex) } } partsMetadata[0] = partsMetadataBackup // Revert before going to the next test // Test 3: Not synchronized DataDir partsMetadataBackup = partsMetadata[1] partsMetadata[1].DataDir = "foo-random" errs = make([]error, len(erasureDisks))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 23K bytes - Viewed (1) -
src/bufio/scan.go
// scanning lines, a [SplitFunc] can return (0, nil, nil) to signal the // [Scanner] to read more data into the slice and try again with a // longer slice starting at the same point in the input. // // The function is never called with an empty data slice unless atEOF // is true. If atEOF is true, however, data may be non-empty and, // as always, holds unprocessed text. type SplitFunc func(data []byte, atEOF bool) (advance int, token []byte, err error)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 23 09:06:30 GMT 2023 - 14.2K bytes - Viewed (0) -
src/archive/tar/format.go
// This field is special in that it is terminated by a NULL then space. var f formatter field := b.toV7().chksum() chksum, _ := b.computeChecksum() // Possible values are 256..128776 f.formatOctal(field[:7], chksum) // Never fails since 128776 < 262143 field[7] = ' ' } // computeChecksum computes the checksum for the header block. // POSIX specifies a sum of the unsigned byte values, but the Sun tar used // signed byte values.
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) -
operator/cmd/mesh/manifest_shared_test.go
allClusterGVKs = helmreconciler.ClusterResources ) func init() { if kubeBuilderInstalled() { // TestMode is required to not wait in the go client for resources that will never be created in the test server. helmreconciler.TestMode = true // Add install and controller to the list of commands to run tests against. testedManifestCmds = append(testedManifestCmds, cmdApply, cmdController) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
internal/event/target/elasticsearch.go
var keyHash string { key := eventData.S3.Bucket.Name + "/" + objectName if target.client.isAtleastV7() { hh, _ := highwayhash.New(magicHighwayHash256Key) // New will never return error since key is 256 bit hh.Write([]byte(key)) hashBytes := hh.Sum(nil) keyHash = base64.URLEncoding.EncodeToString(hashBytes) } else { keyHash = key } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
cmd/admin-heal-ops.go
return true default: return false } } // check if the heal sequence has ended func (h *healSequence) hasEnded() bool { h.mutex.RLock() defer h.mutex.RUnlock() // background heal never ends if h.clientToken == bgHealingUUID { return false } return !h.endTime.IsZero() } // stops the heal sequence - safe to call multiple times. func (h *healSequence) stop() { h.cancelCtx()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1)