- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for errorCh (0.94 sec)
-
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) -
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) -
staging/src/k8s.io/apimachinery/pkg/util/validation/field/errors.go
utilerrors "k8s.io/apimachinery/pkg/util/errors" "k8s.io/apimachinery/pkg/util/sets" ) // Error is an implementation of the 'error' interface, which represents a // field-level validation error. type Error struct { Type ErrorType Field string BadValue interface{} Detail string } var _ error = &Error{} // Error implements the error interface. func (v *Error) Error() string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 28 07:31:28 UTC 2023 - 11.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/errors/errors.go
// It supports wrapped errors and returns StatusReasonUnknown when // the error is nil or doesn't have a status. func ReasonForError(err error) metav1.StatusReason { if status, ok := err.(APIStatus); ok || errors.As(err, &status) { return status.Status().Reason } return metav1.StatusReasonUnknown } func reasonAndCodeForError(err error) (metav1.StatusReason, int32) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 21 03:41:32 UTC 2022 - 30.5K bytes - Viewed (0) -
fastapi/dependencies/utils.py
v_, errors_ = field.validate(value, values, loc=loc) if isinstance(errors_, list): errors.extend(errors_) elif errors_: errors.append(errors_) else: values[field.name] = v_ return values, errors
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Apr 02 02:52:56 UTC 2024 - 29.5K bytes - Viewed (0) -
src/runtime/error.go
package runtime import ( "internal/abi" "internal/bytealg" ) // The Error interface identifies a run time error. type Error interface { error // RuntimeError is a no-op function but // serves to distinguish types that are run time // errors from ordinary errors: a type is a // run time error if it has a RuntimeError method. RuntimeError() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 19:10:41 UTC 2024 - 9.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
return tracker.List(fakeGVR, fakeGVK, "") }, WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) { return tracker.Watch(fakeGVR, "") }, }, &unstructured.Unstructured{}, 30*time.Second, nil)} reconciler := func(namespace, name string, newObj *unstructured.Unstructured) error { var err error copied := newObj.DeepCopyObject()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0)