- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 98 for bagian (0.14 sec)
-
cmd/leak-detect_test.go
leaked := initialSnapShot.CompareCurrentSnapshot() // current stack snapshot matches the initial one, no leaks, return. if len(leaked) == 0 { return } // wait a test again will deadline. if UTCNow().Before(deadline) { time.Sleep(leakDetectPauseTimeMs * time.Millisecond) continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
cmd/typed-errors.go
var errDataTooSmall = errors.New("Object size smaller than expected") // errServerNotInitialized - server not initialized. var errServerNotInitialized = errors.New("Server not initialized, please try again") // errRPCAPIVersionUnsupported - unsupported rpc API version. var errRPCAPIVersionUnsupported = errors.New("Unsupported rpc API version") // errServerTimeMismatch - server times are too far apart.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.3K bytes - Viewed (0) -
internal/grid/debugmsg_string.go
package grid import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[debugShutdown-0] _ = x[debugKillInbound-1] _ = x[debugKillOutbound-2] _ = x[debugWaitForExit-3] _ = x[debugSetConnPingDuration-4] _ = x[debugSetClientPingDuration-5]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 16:43:38 GMT 2024 - 993 bytes - Viewed (0) -
internal/bucket/lifecycle/action_string.go
package lifecycle import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[NoneAction-0] _ = x[DeleteAction-1] _ = x[DeleteVersionAction-2] _ = x[TransitionAction-3] _ = x[TransitionVersionAction-4] _ = x[DeleteRestoredAction-5]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 1.1K bytes - Viewed (0) -
cmd/dynamic-timeouts_test.go
timeout.LogSuccess(20 * time.Second) } adjustedAgain := timeout.Timeout() if initial <= adjusted || adjusted <= adjustedAgain { t.Errorf("Failure to decrease timeout multiple times, initial: %v, adjusted: %v, again: %v", initial, adjusted, adjustedAgain) } } func TestDynamicTimeoutManyDecreases(t *testing.T) { timeout := newDynamicTimeout(time.Minute, time.Second) initial := timeout.Timeout()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Oct 14 10:08:40 GMT 2022 - 5.4K bytes - Viewed (0) -
cmd/net.go
} // Parse address to extract host and scheme field u, err := url.Parse(hostAddr) if err != nil { return "", "", err } addr = u.Host scheme = u.Scheme // Use the given parameter again if url.Parse() // didn't return any useful result. if addr == "" { addr = hostAddr scheme = "http" } // At this point, addr can be one of the following form: // ":9000" // "localhost:9000"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/hash/reader.go
if t, ok := r.src.(etag.Tagger); ok { return t.ETag() } return nil } // MD5Current returns the MD5 checksum of the content // that has been read so far. // // Calling MD5Current again after reading more data may // result in a different checksum. func (r *Reader) MD5Current() []byte { if r.disableMD5 { return r.checksum } return r.ETag()[:] }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.8K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
// in that case, try finding the netns using procfs. if err := s.rescanPod(pod); err != nil { log.Errorf("error scanning proc: error was %s", err) return nil, err } // try again. we can still get here if the pod is in the process of being created. // in this case the CNI will be invoked soon and provide us with the netns. openNetns = s.currentPodSnapshot.Get(string(pod.UID)) if openNetns == nil {
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) -
istioctl/pkg/multixds/gather.go
responses, err = queryEachShard(all, dr, istioNamespace, kubeClient, centralOpts) } if err != nil { if _, ok := err.(ControlPlaneNotFoundError); ok { // Attempt to get the XDS address from the webhook and try again addr, err := getXdsAddressFromWebhooks(kubeClient) if err == nil { centralOpts.Xds = addr.host centralOpts.GCPProject = addr.gcpProject centralOpts.IstiodAddr = addr.istiod
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
src/bufio/scan.go
// yet hold a complete token, for instance if it has no newline while // 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,
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)