- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for errorHandler (0.2 sec)
-
pkg/util/filesystem/watcher.go
return w.watcher.Add(path) } func (w *fsnotifyWatcher) Init(eventHandler FSEventHandler, errorHandler FSErrorHandler) error { var err error w.watcher, err = fsnotify.NewWatcher() if err != nil { return err } w.eventHandler = eventHandler w.errorHandler = errorHandler return nil } func (w *fsnotifyWatcher) Run() { go func() { defer w.watcher.Close() for { select {
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/xds/debug_test.go
attempts := 5 for i := 0; i < attempts; i++ { gotStatus := getSyncStatus(t, s) var errorHandler func(string, ...any) if i == attempts-1 { errorHandler = t.Errorf } else { errorHandler = t.Logf } for _, ss := range gotStatus { if ss.ProxyID == nodeID { if ss.ProxyVersion == "" { errorHandler("ProxyVersion should always be set for %v", nodeID) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 7.8K bytes - Viewed (0) -
pkg/bootstrap/platform/aws_test.go
cases := []struct { name string handlers map[string]handlerFunc want *core.Locality }{ { "error", map[string]handlerFunc{"/placement/region": errorHandler, "/placement/availability-zone": errorHandler}, &core.Locality{}, }, { "locality", map[string]handlerFunc{"/placement/region": regionHandler, "/placement/availability-zone": zoneHandler},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 18 13:10:06 UTC 2022 - 3.2K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/syntax.go
Msg string } func (err Error) Error() string { return fmt.Sprintf("%s: %s", err.Pos, err.Msg) } var _ error = Error{} // verify that Error implements error // An ErrorHandler is called for each error encountered reading a .go file. type ErrorHandler func(err error) // A Pragma value augments a package, import, const, func, type, or var declaration. // Its meaning is entirely up to the PragmaHandler,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 01 18:18:07 UTC 2022 - 3.1K bytes - Viewed (0) -
internal/handlers/forwarder.go
f.modifyRequest(req, inReq.URL) }, BufferPool: newBufPool(128 << 10), Transport: f.RoundTripper, FlushInterval: defaultFlushInterval, ErrorHandler: f.customErrHandler, } if f.ErrorHandler != nil { revproxy.ErrorHandler = f.ErrorHandler } revproxy.ServeHTTP(w, outReq) } // customErrHandler is originally implemented to avoid having the following error //
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 07 05:42:10 UTC 2023 - 5.6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/VisitableURLClassLoader.java
private final TransformReplacer replacer; private final TransformErrorHandler errorHandler; public InstrumentingVisitableURLClassLoader(String name, ClassLoader parent, TransformedClassPath classPath) { super(name, parent, classPath); replacer = new TransformReplacer(classPath); errorHandler = new TransformErrorHandler(name); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 6.5K bytes - Viewed (0) -
platforms/jvm/jvm-services/src/main/java/org/gradle/jvm/toolchain/internal/MavenToolchainsInstallationSupplier.java
import org.gradle.api.provider.ProviderFactory; import org.gradle.internal.xml.XmlFactories; import org.gradle.util.internal.MavenUtil; import org.w3c.dom.Node; import org.w3c.dom.NodeList; import org.xml.sax.ErrorHandler; import org.xml.sax.SAXException; import org.xml.sax.SAXParseException; import javax.inject.Inject; import javax.xml.parsers.DocumentBuilder; import javax.xml.parsers.DocumentBuilderFactory;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 22:17:53 UTC 2024 - 6.5K bytes - Viewed (0) -
tests/test_ws_router.py
""" @websocket_middleware async def errorhandler(websocket: WebSocket, call_next): try: return await call_next() except Exception as e: await websocket.close(code=status.WS_1006_ABNORMAL_CLOSURE, reason=repr(e)) myapp = make_app(middleware=[Middleware(errorhandler)]) client = TestClient(myapp) with pytest.raises(WebSocketDisconnect) as e:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Jun 11 19:08:14 UTC 2023 - 7.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/utils/mlprogram_util.cc
"tf-lower-to-mlprogram-and-hlo", "Lower TF to ml_program + mhlo", [](mlir::OpPassManager& pm, llvm::StringRef options, llvm::function_ref<mlir::LogicalResult(const llvm::Twine&)> errorHandler) { tensorflow::PopulateLowerToMlProgramAndHloPipeline(pm); return mlir::success(); }, [](llvm::function_ref<void(const mlir::detail::PassOptions&)>) {}); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 22 22:13:50 UTC 2024 - 1.6K bytes - Viewed (0) -
pilot/pkg/util/informermetric/informerutil.go
"Total number of errorMetric syncing controllers.", ) mu sync.RWMutex handlers = map[cluster.ID]cache.WatchErrorHandler{} ) // ErrorHandlerForCluster fetches or creates an ErrorHandler that emits a metric // and logs when a watch error occurs. For use with SetWatchErrorHandler on SharedInformer. func ErrorHandlerForCluster(clusterID cluster.ID) cache.WatchErrorHandler { mu.RLock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 1.6K bytes - Viewed (0)