- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 28 for handler (0.15 sec)
-
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) -
cni/pkg/monitoring/monitoring.go
return } exporter, err := monitoring.RegisterPrometheusExporter(nil, nil) if err != nil { log.Errorf("could not set up prometheus exporter: %v", err) return } mux.Handle(path, exporter) monitoringServer := &http.Server{ Handler: mux, } go func() { if err = monitoringServer.Serve(listener); network.IsUnexpectedListenerError(err) { log.Errorf("error running monitoring http server: %s", err) } }()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 07:54:01 GMT 2023 - 1.5K 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/ztunnelserver.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
iptablesBuilder.AppendRule(iptableslog.UndefinedCommand, ChainInpodPrerouting, iptablesconstants.MANGLE, "-m", "mark", "--mark", inpodMark, "-j", "CONNMARK", "--set-xmark", inpodTproxyMark) // Handle healthcheck probes from the host node. In the host netns, before the packet enters the pod, we SNAT // the healthcheck packet to a fixed IP if the packet is coming from a node-local process with a socket. //
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
istioctl/pkg/util/proto/messageslice.go
"istio.io/istio/pkg/util/protomarshal" ) // MessageSlice allows us to marshal slices of protobuf messages like clusters/listeners/routes/endpoints correctly type MessageSlice []proto.Message // MarshalJSON handles marshaling of slices of proto messages func (pSlice MessageSlice) MarshalJSON() ([]byte, error) { buffer := bytes.NewBufferString("[") sliceLength := len(pSlice) for index, msg := range pSlice {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 19 21:53:59 GMT 2021 - 1.3K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
change which control plane revision handles injection, it's possible to create a revision tag "prod" and label our namespace "istio.io/rev=prod". The "prod" revision tag could point to "1-7-6" initially and then be changed to point to "1-8-1" at some later point. This allows operators to change which Istio control plane revision should handle injection for a namespace or set of namespaces
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.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) -
istioctl/pkg/describe/describe.go
"istio.io/istio/istioctl/pkg/clioptions" "istio.io/istio/istioctl/pkg/completion" istioctlutil "istio.io/istio/istioctl/pkg/util" "istio.io/istio/istioctl/pkg/util/configdump" "istio.io/istio/istioctl/pkg/util/handlers" istio_envoy_configdump "istio.io/istio/istioctl/pkg/writer/envoy/configdump" "istio.io/istio/pilot/pkg/config/kube/crdclient" "istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/networking/util"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0) -
istioctl/pkg/util/clusters/wrapper.go
type Wrapper struct { *admin.Clusters } // MarshalJSON is a custom marshaller to handle protobuf pain func (w *Wrapper) MarshalJSON() ([]byte, error) { return protomarshal.Marshal(w) } // UnmarshalJSON is a custom unmarshaller to handle protobuf pain func (w *Wrapper) UnmarshalJSON(b []byte) error { cd := &admin.Clusters{} err := protomarshal.UnmarshalAllowUnknown(b, cd)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 1.2K bytes - Viewed (0)