- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for handlers (1.09 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
architecture/ambient/ztunnel.md
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) -
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) -
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)