Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for handlers (1.09 sec)

  1. 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)
  2. 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)
  3. 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)
  4. manifests/charts/istio-control/istio-discovery/values.yaml

        # Only one environment should have this enabled.
        enableNamespacesByDefault: false
    
        # Mutations that occur after the sidecar injector are not handled by default, as the Istio sidecar injector is only run
        # once. For example, an OPA sidecar injected after the Istio sidecar will not have it's liveness/readiness probes rewritten.
    Others
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 22:00:40 GMT 2024
    - 20.3K bytes
    - Viewed (0)
  5. istioctl/pkg/waypoint/waypoint.go

    	waypointCmd.AddCommand(waypointListCmd)
    	waypointCmd.PersistentFlags().StringVarP(&waypointName, "name", "", constants.DefaultNamespaceWaypoint, "name of the waypoint")
    
    	return waypointCmd
    }
    
    // deleteWaypoints handles the deletion of waypoints based on the provided names, or all if names is nil
    func deleteWaypoints(cmd *cobra.Command, kubeClient kube.CLIClient, namespace string, names []string) error {
    	var multiErr *multierror.Error
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  6. cni/README.md

    ## Reference
    
    ### Design details
    
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/informers.go

    		// We have no good way to distinguish between these two cases from here. But we don't need to!
    		// Existing pods will be handled by the dataplane using `GetAmbientPods`,
    		// and the initial enqueueNamespace, and new pods will be handled by the CNI.
    
    	case controllers.EventUpdate:
    		// For update, we just need to handle opt outs
    		newPod := event.New.(*corev1.Pod)
    		oldPod := event.Old.(*corev1.Pod)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 9.6K bytes
    - Viewed (0)
  8. architecture/ambient/ztunnel.md

    How we handle this is [under discussion](https://docs.google.com/document/d/1uM1c3zzoehiijh1ZpZuJ1-SzuVVupenv8r5yuCaFshs/edit#heading=h.dwbqvwmg6ud3).
    
    ### Inbound
    
    Traffic entering a pod over HBONE will be handled by the "inbound" code path, on port 15008.
    
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 25 22:35:16 GMT 2024
    - 16.6K bytes
    - Viewed (0)
  9. Makefile.core.mk

    # As an optimization, these still build everything
    $(foreach bin,$(BINARIES),$(shell basename $(bin))): build
    ifneq ($(TARGET_OUT_LINUX),$(LOCAL_OUT))
    # if we are on linux already, then this rule is handled by build-linux above, which handles BUILD_ALL variable
    $(foreach bin,$(BINARIES),${LOCAL_OUT}/$(shell basename $(bin))): build
    endif
    
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 20:25:15 GMT 2024
    - 22.5K bytes
    - Viewed (0)
  10. istioctl/pkg/util/configdump/wrapper.go

    // Wrapper is a wrapper around the Envoy ConfigDump
    // It has extra helper functions for handling any/struct/marshal protobuf pain
    type Wrapper struct {
    	*admin.ConfigDump
    }
    
    // UnmarshalJSON is a custom unmarshaller to handle protobuf pain
    func (w *Wrapper) UnmarshalJSON(b []byte) error {
    	cd := &admin.ConfigDump{}
    	err := protomarshal.UnmarshalAllowUnknownWithAnyResolver(nonStrictResolver, b, cd)
    	*w = Wrapper{cd}
    	return err
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 1.8K bytes
    - Viewed (0)
Back to top