- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 237 for errchk (0.21 sec)
-
pkg/registry/core/pod/storage/storage_test.go
podUIDGetter func(pod *api.Pod) types.UID podResourceVersionGetter func(pod *api.Pod) string errOK func(error) bool expectedNodeName string }{ "originUID-originResourceVersion": { podUIDGetter: originUID, podResourceVersionGetter: originResourceVersion, errOK: noError, expectedNodeName: "machine", },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 07:18:44 UTC 2024 - 38.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/errors/errors.go
// Returns nil if all the functions complete successfully. func AggregateGoroutines(funcs ...func() error) Aggregate { errChan := make(chan error, len(funcs)) for _, f := range funcs { go func(f func() error) { errChan <- f() }(f) } errs := make([]error, 0) for i := 0; i < cap(errChan); i++ { if err := <-errChan; err != nil { errs = append(errs, err) } } return NewAggregate(errs) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 29 09:44:02 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/kubeapiserver/options/cloudprovider.go
fs.MarkDeprecated("cloud-provider", "will be removed in a future version") // nolint: errcheck fs.StringVar(&s.CloudConfigFile, "cloud-config", s.CloudConfigFile, "The path to the cloud provider configuration file. Empty string for no configuration file.") fs.MarkDeprecated("cloud-config", "will be removed in a future version") // nolint: errcheck
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 15:50:25 UTC 2023 - 3K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/syntax.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 01 18:18:07 UTC 2022 - 3.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime.go
var errs []error errChan := make(chan error, len(images)) klog.V(1).Info("pulling all images in parallel") for _, img := range images { image := img go func() { if ifNotPresent { exists := imageExistsFunc(image) if exists { klog.V(1).Infof("image exists: %s", image) errChan <- nil return } } err := pullImageFunc(image)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 06:33:22 UTC 2024 - 8.4K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
errCh := make(chan error, len(pods)) successfulDeletes := int32(len(pods)) wg := sync.WaitGroup{} wg.Add(len(pods)) for i := range pods { go func(pod *v1.Pod) { defer wg.Done() if err := jm.podControl.DeletePod(ctx, job.Namespace, pod.Name, job); err != nil && !apierrors.IsNotFound(err) { atomic.AddInt32(&successfulDeletes, -1) errCh <- err utilruntime.HandleError(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/conntest.go
t.Helper() c.SetDeadline(neverTimeout) errCh := make(chan error) go func() { _, err := c.Write([]byte{0xff}) errCh <- err }() buf := make([]byte, 1024) for { n, err := c.Read(buf) if n > 0 && bytes.IndexByte(buf[:n], 0xff) == n-1 { break } if err != nil { t.Errorf("unexpected Read error: %v", err) break } } if err := <-errCh; err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.2K bytes - Viewed (0) -
pkg/adsc/delta.go
mutex sync.RWMutex // lastReceived message, by type lastReceived map[string]*discovery.DeltaDiscoveryResponse deltaXDSUpdates chan *discovery.DeltaDiscoveryResponse // errChan is used to signal errors from the delta stream errChan chan error // closed is set to true when the client is closed closed bool }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 20.4K bytes - Viewed (0) -
src/net/sendfile_test.go
ln := newLocalListener(t, "tcp") defer ln.Close() errc := make(chan error, 1) go func(ln Listener) { // Wait for a connection. conn, err := ln.Accept() if err != nil { errc <- err close(errc) return } go func() { defer close(errc) defer conn.Close() f, err := os.Open(newton) if err != nil { errc <- err return } defer f.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 12.1K bytes - Viewed (0) -
cmd/kube-proxy/app/server_linux_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 21.9K bytes - Viewed (0)