Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 694 for handlers (0.29 sec)

  1. cni/pkg/nodeagent/cni-watcher_test.go

    	).Return(nil)
    
    	dpServer := &meshDataplane{
    		kubeClient: client.Kube(),
    		netServer:  fs,
    	}
    
    	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"}}}`,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 02 21:29:40 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  2. docs/en/docs/advanced/events.md

    {!../../../docs_src/events/tutorial001.py!}
    ```
    
    In this case, the `startup` event handler function will initialize the items "database" (just a `dict`) with some values.
    
    You can add more than one event handler function.
    
    And your application won't start receiving requests until all the `startup` event handlers have completed.
    
    ### `shutdown` event
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  3. 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
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 02 08:32:06 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/informers_test.go

    		ctx,
    		pod,
    		util.GetPodIPsIfPresent(pod),
    		"",
    	).Return(nil)
    
    	server := &meshDataplane{
    		kubeClient: client.Kube(),
    		netServer:  fs,
    	}
    
    	handlers := setupHandlers(ctx, client, server, "istio-system")
    	client.RunAndWait(ctx.Done())
    	go handlers.Start()
    
    	// label the namespace
    	labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`,
    		constants.DataplaneModeLabel, constants.DataplaneModeAmbient))
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/server.go

    		isReady:    ready,
    		dataplane: &meshDataplane{
    			kubeClient: client.Kube(),
    			netServer:  netServer,
    		},
    	}
    	s.NotReady()
    	s.handlers = setupHandlers(s.ctx, s.kubeClient, s.dataplane, args.SystemNamespace)
    
    	cniServer := startCniPluginServer(ctx, pluginSocket, s.handlers, s.dataplane)
    	err = cniServer.Start()
    	if err != nil {
    		return nil, fmt.Errorf("error starting cni server: %w", err)
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  6. maven-core/src/main/java/org/apache/maven/artifact/handler/manager/DefaultArtifactHandlerManager.java

        }
    
        @Override
        public void addHandlers(Map<String, ArtifactHandler> handlers) {
            throw new UnsupportedOperationException("Adding handlers programmatically is not supported anymore");
        }
    
        @Deprecated
        public Set<String> getHandlerTypes() {
            throw new UnsupportedOperationException("Querying handlers programmatically is not supported anymore");
        }
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Fri Mar 01 17:18:13 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  7. cmd/http-tracer.go

    	op = strings.Replace(op, "-fm", "", 1)
    	return op
    }
    
    // If trace is enabled, execute the request if it is traced by other handlers
    // otherwise, generate a trace event with request information but no response.
    func httpTracerMiddleware(h http.Handler) http.Handler {
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		// Setup a http request response recorder - this is needed for
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  8. docs/en/docs/tutorial/dependencies/dependencies-with-yield.md

    This was changed in version 0.110.0 to fix unhandled memory consumption from forwarded exceptions without a handler (internal server errors), and to make it consistent with the behavior of regular Python code.
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Sat Feb 24 23:06:37 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  9. docs/ru/docs/tutorial/dependencies/dependencies-with-yield.md

        opt raise
            dep -->> handler: Raise HTTPException
            handler -->> client: HTTP error response
            dep -->> dep: Raise other exception
        end
        dep ->> operation: Run dependency, e.g. DB session
        opt raise
            operation -->> dep: Raise HTTPException
            dep -->> handler: Auto forward exception
            handler -->> client: HTTP error response
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Tue Apr 02 04:21:06 GMT 2024
    - 19.6K bytes
    - Viewed (0)
  10. architecture/networking/controllers.md

    Construction should create informers (via `kclient.New`), setup a queue (via `controllers.NewQueue`), and register event handlers on the informers.
    Often, these handlers are adding something to the queue like `client.AddEventHandler(controllers.ObjectHandler(queue.AddObject))`.
    Construction should NOT actually start running all of these things, do I/O, or block in anyway.
    
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Feb 09 17:41:25 GMT 2024
    - 4.9K bytes
    - Viewed (0)
Back to top