- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 83 for kmap (0.12 sec)
-
istioctl/pkg/workload/workload_test.go
name string arg []string want map[string]string }{ {name: "empty", arg: []string{""}, want: map[string]string{"": ""}}, {name: "one-valid", arg: []string{"key=value"}, want: map[string]string{"key": "value"}}, {name: "one-valid-double-equals", arg: []string{"key==value"}, want: map[string]string{"key": "=value"}}, {name: "one-key-only", arg: []string{"key"}, want: map[string]string{"key": ""}}, }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
type PodNetnsCache interface { ReadCurrentPodSnapshot() map[string]WorkloadInfo } // Hold a cache of node local pods with their netns // if we don't know the netns, the pod will still be here with a nil netns. type podNetnsCache struct { openNetns func(nspath string) (NetnsCloser, error) currentPodCache map[string]WorkloadInfo mu sync.RWMutex } type WorkloadInfo struct {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
if err != nil { return nil, err } return map[string]*discovery.DiscoveryResponse{ CpInfo(response).ID: response, }, nil } } return nil, err } return mapShards(responses) } func mapShards(responses []*discovery.DiscoveryResponse) (map[string]*discovery.DiscoveryResponse, error) { retval := map[string]*discovery.DiscoveryResponse{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
return xdsResponses, nil } func HandlerForDebugErrors(kubeClient kube.CLIClient, centralOpts *clioptions.CentralControlPlaneOptions, writer io.Writer, istioNamespace string, xdsResponses map[string]*discovery.DiscoveryResponse, ) (map[string]*discovery.DiscoveryResponse, error) { for _, response := range xdsResponses { for _, resource := range response.Resources { eString := string(resource.Value) switch {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.9K bytes - Viewed (0) -
operator/cmd/mesh/profile-dump.go
if err != nil { return []string{}, err } var decoded any if uglyJSON[0] == '[' { decoded = make([]any, 0) } else { decoded = map[string]any{} } if err := json.Unmarshal(uglyJSON, &decoded); err != nil { return []string{}, err } if d, ok := decoded.(map[string]any); ok { if v, ok := d["spec"]; ok { // Fall back to showing the entire spec.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 7.1K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject.go
return nil }, RunE: func(cmd *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClient() if err != nil { return err } var podName, podNs string var podLabels, nsLabels map[string]string if len(args) == 1 { podName, podNs, err = ctx.InferPodInfoFromTypedResource(args[0], ctx.Namespace()) if err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
istioctl/pkg/util/formatting/formatter.go
// Formatting options for Messages const ( LogFormat = "log" JSONFormat = "json" YAMLFormat = "yaml" ) var ( MsgOutputFormatKeys = []string{LogFormat, JSONFormat, YAMLFormat} MsgOutputFormats = make(map[string]bool) termEnvVar = env.Register("TERM", "", "Specifies terminal type. Use 'dumb' to suppress color output") ) func init() { for _, key := range MsgOutputFormatKeys { MsgOutputFormats[key] = true }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 11 02:41:45 GMT 2023 - 3.1K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator.go
envoy, istiod *configdump.Wrapper w io.Writer context int location string } // NewComparator is a comparator constructor func NewComparator(w io.Writer, istiodResponses map[string][]byte, envoyResponse []byte) (*Comparator, error) { c := &Comparator{} for _, resp := range istiodResponses { istiodDump := &configdump.Wrapper{} err := json.Unmarshal(resp, istiodDump) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 3.7K bytes - Viewed (1) -
istioctl/pkg/writer/ztunnel/configdump/workload.go
return nil } func waypointName(wl *ZtunnelWorkload, services map[string]*ZtunnelService) string { if wl.Waypoint == nil { return "None" } if svc, ok := services[wl.Waypoint.Destination]; ok { return svc.Name } return "NA" // Shouldn't normally reach here } func serviceWaypointName(svc *ZtunnelService, services map[string]*ZtunnelService) string { if svc.Waypoint == nil { return "None"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 4K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_redirect.go
sidecarInterceptModeKey = annotation.SidecarInterceptionMode.Name sidecarPortListKey = annotation.SidecarStatusPort.Name kubevirtInterfacesKey = annotation.SidecarTrafficKubevirtInterfaces.Name annotationRegistry = map[string]*annotationParam{ "inject": {injectAnnotationKey, "", alwaysValidFunc}, "status": {sidecarStatusKey, "", alwaysValidFunc},
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.6K bytes - Viewed (0)