- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 118 for errorCh (0.11 sec)
-
pkg/util/filesystem/watcher.go
if pollInterval <= 0 { panic(fmt.Errorf("pollInterval must be > 0")) } if eventHandler == nil { panic(fmt.Errorf("eventHandler must be non-nil")) } if errorHandler == nil { errorHandler = func(err error) {} } // Initialize watcher, fall back to no-op var ( eventsCh chan fsnotify.Event errorCh chan error watcher watchAddRemover )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 23:09:15 UTC 2024 - 5.7K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
t.Run("gRPC-resolve", func(t *testing.T) { rb := xdsresolver stateCh := make(chan resolver.State, 1) errorCh := make(chan error, 1) _, err := rb.Build(resolver.Target{URL: url.URL{ Scheme: "xds", Path: "/" + net.JoinHostPort(testSvcHost, xdsPorts), }}, &testClientConn{stateCh: stateCh, errorCh: errorCh}, resolver.BuildOptions{ Authority: testSvcHost, }) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
if err = s.globalPushContext().InitContext(s.Env, nil, nil); err != nil { // Error accessing the data - log and close, maybe a different pilot replica // has more luck deltaLog.Warnf("Error reading config %v", err) return status.Error(codes.Unavailable, "error reading config") } con := newDeltaConnection(peerAddr, stream)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pkg/xds/server.go
Watcher() Watcher // Initialize checks the first request. Initialize(node *core.Node) error // Close discards the connection. Close() // Process responds to a discovery request. Process(req *discovery.DiscoveryRequest) error // Push responds to a push event queue Push(ev any) error } func Stream(ctx ConnectionContext) error { con := ctx.XdsConnection()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/filter_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 40.4K bytes - Viewed (0) -
pkg/filewatcher/filewatcher_test.go
errors1 = w.Errors(watchFile1) g.Expect(errors1).To(BeNil()) events2 = w.Events(watchFile2) g.Expect(events2).To(BeNil()) errors2 = w.Errors(watchFile2) g.Expect(errors2).To(BeNil()) } func TestErrors(t *testing.T) { w := NewWatcher() if ch := w.Errors("XYZ"); ch != nil { t.Error("Expected no channel") } if ch := w.Events("XYZ"); ch != nil { t.Error("Expected no channel")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 7.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/verification/report/HtmlDependencyVerificationReportRendererTest.groovy
renderer.reportFailure(onlyIgnoredKeys("Ivy")) } when: generateReport() def errors1 = errorsFor(":someConfiguration") def errors2 = errorsFor(":other:configuration") then: verifyAll(errors1[0]) { module == 'org:foo:1.0' artifact == 'foo-1.0.jar' artifactTooltip == "From repository 'Maven'"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 14.6K bytes - Viewed (0) -
src/errors/example_test.go
} } // Output: // Failed at path: non-existing } func ExampleUnwrap() { err1 := errors.New("error1") err2 := fmt.Errorf("error2: [%w]", err1) fmt.Println(err2) fmt.Println(errors.Unwrap(err2)) // Output: // error2: [error1] // error1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 16 02:08:40 UTC 2023 - 2.2K bytes - Viewed (0) -
src/errors/errors.go
// Unwrap method to return an []error containing a nil error value. // // An easy way to create wrapped errors is to call [fmt.Errorf] and apply // the %w verb to the error argument: // // wrapsErr := fmt.Errorf("... %w ...", ..., err, ...) // // Successive unwrapping of an error creates a tree. The [Is] and [As] // functions inspect an error's tree by examining first the error
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 02 19:45:41 UTC 2023 - 2.9K bytes - Viewed (0) -
internal/config/errors-utils.go
if errors.Is(err, syscall.EADDRINUSE) { return ErrPortAlreadyInUse(err).Msg("Specified port is already in use") } else if errors.Is(err, syscall.EACCES) || errors.Is(err, syscall.EPERM) { if netErr, ok := err.(*net.OpError); ok { return ErrPortAccess(netErr).Msg("Insufficient permissions to use specified port") } } // Failed to identify what type of error this, return a simple UI error
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 06 16:56:10 UTC 2023 - 3.7K bytes - Viewed (0)