Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 118 for errorCh (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/filter_test.go

    						Detail: "error1",
    					},
    				},
    				{
    					Error: &apiservercel.Error{
    						Detail: "error2",
    					},
    				},
    				{
    					Error: &apiservercel.Error{
    						Detail: "error3",
    					},
    				},
    			},
    			expected: []error{
    				errors.New("error1"),
    				errors.New("error2"),
    				errors.New("error3"),
    			},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 40.4K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top