- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 250 for handleMsg (0.1 sec)
-
internal/handlers/proxy.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. // Originally from https://github.com/gorilla/handlers with following license // https://raw.githubusercontent.com/gorilla/handlers/master/LICENSE, forked // and heavily modified for MinIO's internal needs. package handlers import ( "net" "net/http" "regexp" "strings" ) var ( // De-facto standard header keys.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Dec 22 00:56:55 UTC 2023 - 5.1K bytes - Viewed (0) -
docs/en/docs/advanced/events.md
You can probably skip this part. /// There's an alternative way to define this logic to be executed during *startup* and during *shutdown*.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Oct 28 10:36:22 UTC 2024 - 7.6K bytes - Viewed (0) -
cmd/admin-handlers-users-race_test.go
Taran Pelkey <******@****.***> 1719565585 -0400
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 28 09:06:25 UTC 2024 - 4K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
util.GetPodIPsIfPresent(pod), valid.Netns, ).Return(nil) dpServer := getFakeDP(fs, client.Kube()) handlers := setupHandlers(ctx, client, dpServer, "istio-system") // We are not going to start the server, so the sockpath is irrelevant pluginServer := startCniPluginServer(ctx, "/tmp/test.sock", handlers, dpServer) // label the namespace labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`,
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 7.6K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib_test.cc
ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get()); const std::vector<std::unique_ptr<ParallelTensor>>& handles = *outputs; std::vector<ParallelTensor*> handle_inputs; handle_inputs.reserve(handles.size()); for (auto& handle : handles) { handle_inputs.push_back(handle.get()); } std::unique_ptr<TFE_Op, decltype(&TFE_DeleteOp)> read_op(
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Mon Oct 21 04:14:14 UTC 2024 - 15.6K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/util/CrawlerWebServer.java
resource_handler.setResourceBase(docRoot.getAbsolutePath()); Log.info("serving " + resource_handler.getBaseResource()); final HandlerList handlers = new HandlerList(); handlers.setHandlers(new Handler[] { resource_handler, new DefaultHandler() }); server.setHandler(handlers); } public void start() { try { server.start(); } catch (final Exception e) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 6.3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractorTest.java
server = new Server(port); final RequestHandlerImpl request_handler = new RequestHandlerImpl(); final HandlerList handlers = new HandlerList(); handlers.setHandlers(new Handler[] { request_handler, new DefaultHandler() }); server.setHandler(handlers); } public void start() { try { server.start(); } catch (final Exception e) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 5.4K bytes - Viewed (0) -
fess-crawler-opensearch/src/test/resources/logging.properties
handlers = java.util.logging.ConsoleHandler
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 59 bytes - Viewed (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/util/CrawlerWebServer.java
resource_handler.setResourceBase(docRoot.getAbsolutePath()); Log.info("serving " + resource_handler.getBaseResource()); final HandlerList handlers = new HandlerList(); handlers.setHandlers(new Handler[] { resource_handler, new DefaultHandler() }); server.setHandler(handlers); } public void start() { try { server.start(); } catch (final Exception e) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 5K bytes - Viewed (0) -
istioctl/pkg/cli/context.go
if err != nil { return "", "", err } return handlers.InferPodInfoFromTypedResource(name, i.NamespaceOrDefault(namespace), MakeKubeFactory(client)) } func (i *instance) InferPodsFromTypedResource(name, namespace string) ([]string, string, error) { client, err := i.CLIClient() if err != nil { return nil, "", err }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 23 19:31:32 UTC 2024 - 8.9K bytes - Viewed (0)