- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for Sood (0.14 sec)
-
src/cmd/api/testdata/src/pkg/p2/p2.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package p2 type Twoer interface { // Deprecated: No good. PackageTwoMeth() } // Deprecated: No good. func F() string {} func G() Twoer {}
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Dec 02 16:29:41 GMT 2022 - 337 bytes - Viewed (0) -
internal/cachevalue/cache.go
// even if updating the value errors out. // Returns the last good value AND the error. ReturnLastGood bool // If CacheError is set, errors will be cached as well // and not continuously try to update. // Should not be combined with ReturnLastGood. CacheError bool // If NoWait is set, Get() will return the last good value, // if TTL has expired but 2x TTL has not yet passed,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 4.2K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers.go
if err != nil { return "", "", err } if podName != "" { return podName, namespace, nil } // We need to pass in a sorter, and the one used by `kubectl logs` is good enough. sortBy := func(pods []*corev1.Pod) sort.Interface { return podutils.ByLogging(pods) } timeout := 2 * time.Second if getFirstPodFunc == nil { getFirstPodFunc = polymorphichelpers.GetFirstPod }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 06 15:01:41 GMT 2024 - 6.2K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
threeNanoSecs := time.Unix(3, 0).UTC() fourNanoSecs := time.Unix(4, 0).UTC() modTimesThreeNone := make([]time.Time, 16) modTimesThreeFour := make([]time.Time, 16) for i := 0; i < 16; i++ { // Have 13 good xl.meta, 12 for default parity count = 4 (EC:4) and one // to be tampered with. if i > 12 { modTimesThreeFour[i] = fourNanoSecs modTimesThreeNone[i] = timeSentinel continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 23K bytes - Viewed (1) -
internal/event/target/elasticsearch.go
ESSDeprecated ESSupportStatus = "ESSDeprecated" // ESSUnsupported -> we won't work with this ES server ESSUnsupported ESSupportStatus = "ESSUnsupported" // ESSSupported -> all good! ESSSupported ESSupportStatus = "ESSSupported" ) func getESVersionSupportStatus(version string) (res ESSupportStatus, err error) { parts := strings.Split(version, ".") if len(parts) < 1 {
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/test-utils_test.go
letterIdxMax = 63 / letterIdxBits // # of letter indices fitting in 63 bits ) // Random number state. // We generate random temporary file names so that there's a good // chance the file doesn't exist yet. var ( randN uint32 randmu sync.Mutex ) // Temp files created in default Tmp dir var globalTestTmpDir = os.TempDir()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/site-replication.go
return fmt.Errorf("bucket replication config validation error: %#v", apiErr) } err = newReplicationConfig.Validate(bucket, sameTarget) if err != nil { return err } // Config looks good, so we save it. replCfgData, err := xml.Marshal(newReplicationConfig) if err != nil { return err } _, err = globalBucketMetadataSys.Update(ctx, bucket, bucketReplicationConfig, replCfgData)
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) -
cmd/metacache-server-pool.go
} } if IsErr(err, []error{ nil, context.Canceled, context.DeadlineExceeded, // io.EOF is expected and should be returned but no need to log it. io.EOF, }...) { // Expected good errors we don't need to return error. return entries, err } entries.truncate(0) go func() { rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix)) if rpc != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
// something first, we expect to get an os.ErrDeadlineExceeded error // here if the connection is still alive. // note that unlike tcp connections, reading is a good enough test here. _, err := conn.readMessage(time.Second / 100) switch { case !errors.Is(err, os.ErrDeadlineExceeded): log.Debugf("ztunnel keepalive failed: %v", err) if errors.Is(err, io.EOF) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
// When a non-nil error is returned 'done' MUST be called // with the status of the response, if it corresponds to disk health. // If the pointer sent to done is non-nil AND the error // is either nil or io.EOF the disk is considered good. // So if unsure if the disk status is ok, return nil as a parameter to done. // Shadowing will work as long as return error is named: https://go.dev/play/p/sauq86SsTN2
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0)