Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 36 for Hiller (0.16 sec)

  1. istioctl/pkg/writer/envoy/clusters/clusters.go

    func (c *ConfigWriter) PrintEndpointsSummary(filter EndpointFilter) error {
    	if c.clusters == nil {
    		return fmt.Errorf("config writer has not been primed")
    	}
    
    	w := new(tabwriter.Writer).Init(c.Stdout, 0, 8, 5, ' ', 0)
    
    	clusterEndpoint := make([]EndpointCluster, 0)
    	for _, cluster := range c.clusters.ClusterStatuses {
    		for _, host := range cluster.HostStatuses {
    			if filter.Verify(host, cluster.Name) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 5.8K bytes
    - Viewed (0)
  2. manifests/charts/base/templates/validatingadmissionpolicy.yaml

                (has(object.spec.metrics) ? object.spec.metrics : {}).exists(m, has(m.reportingInterval)) ||
                (has(object.spec.accessLogging) ? object.spec.accessLogging : {}).exists(l, has(l.filter))
              )
            )
    ---
    apiVersion: admissionregistration.k8s.io/v1
    kind: ValidatingAdmissionPolicyBinding
    metadata:
      name: "stable-channel-default-policy-binding.istio.io"
    spec:
    Others
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 29 21:07:45 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  3. istioctl/cmd/options.go

    package cmd
    
    import (
    	"github.com/spf13/cobra"
    	"github.com/spf13/pflag"
    )
    
    var helpFlags = map[string]bool{
    	"log_as_json":          true,
    	"log_stacktrace_level": true,
    	"log_target":           true,
    	"log_caller":           true,
    	"log_output_level":     true,
    	// istioctl also inherits support for log_rotate, log_rotate_max_age, log_rotate_max_backups,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 1.8K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/envoy/configdump/testdata/routes/k8s-gateway-http-route-path-prefix/configdump.json

                 503
                ]
               },
               "cluster_not_found_response_code": "INTERNAL_SERVER_ERROR",
               "max_grpc_timeout": "0s"
              },
              "metadata": {
               "filter_metadata": {
                "istio": {
                 "config": "/apis/networking.istio.io/v1alpha3/namespaces/default/virtual-service/http-0-istio-autogenerated-k8s-gateway"
                }
               }
              },
    Json
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 3.1K bytes
    - Viewed (1)
  5. cni/pkg/repair/netns.go

    func getLinkWithDestinationOf(ip string) (netlink.Link, error) {
    	routes, err := netlink.RouteListFiltered(
    		netlink.FAMILY_V4,
    		&netlink.Route{Dst: &net.IPNet{IP: net.ParseIP(ip), Mask: net.CIDRMask(32, 32)}},
    		netlink.RT_FILTER_DST)
    	if err != nil {
    		return nil, err
    	}
    
    	if len(routes) == 0 {
    		return nil, fmt.Errorf("no routes found for %s", ip)
    	}
    
    	linkIndex := routes[0].LinkIndex
    	return netlink.LinkByIndex(linkIndex)
    }
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Dec 20 22:14:13 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/informers.go

    		controllers.WithGenericReconciler(s.reconcile),
    		controllers.WithMaxAttempts(5),
    	)
    	// We only need to handle pods on our node
    	s.pods = kclient.NewFiltered[*corev1.Pod](kubeClient, kclient.Filter{FieldSelector: "spec.nodeName=" + NodeName})
    	s.pods.AddEventHandler(controllers.FromEventHandler(func(o controllers.Event) {
    		s.queue.Add(o)
    	}))
    
    	// Namespaces could be anything though, so we watch all of those
    	//
    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)
  7. common-protos/k8s.io/api/storage/v1alpha1/generated.proto

    // They are consumed by the kube-scheduler when a CSI driver opts into
    // capacity-aware scheduling with CSIDriverSpec.StorageCapacity. The scheduler
    // compares the MaximumVolumeSize against the requested size of pending volumes
    // to filter out unsuitable nodes. If MaximumVolumeSize is unset, it falls back
    // to a comparison against the less precise Capacity. If that is also unset,
    // the scheduler assumes that capacity is insufficient and tries some other
    // node.
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/envoy/configdump/endpoint_test.go

    			outputFormat: "json",
    			filter:       EndpointFilter{},
    		},
    		{
    			name:         "emptyfilter",
    			outputFormat: "yaml",
    			filter:       EndpointFilter{},
    		},
    		{
    			name:         "portfilter",
    			outputFormat: "json",
    			filter: EndpointFilter{
    				Port: 8080,
    			},
    		},
    		{
    			name:         "portfilter",
    			outputFormat: "yaml",
    			filter: EndpointFilter{
    				Port: 8080,
    			},
    		},
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Jul 12 02:25:59 GMT 2022
    - 2.4K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/ztunnel/configdump/policies.go

    }
    
    // PrintServiceSummary prints a summary of the relevant services in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintPolicySummary(filter PolicyFilter) error {
    	w := c.tabwriter()
    	zDump := c.ztunnelDump
    
    	pols := slices.Filter(maps.Values(zDump.Policies), filter.Verify)
    	slices.SortFunc(pols, func(a, b *ZtunnelPolicy) int {
    		if r := cmp.Compare(a.Namespace, b.Namespace); r != 0 {
    			return r
    		}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  10. operator/cmd/mesh/manifest-generate.go

    	cmd.PersistentFlags().StringSliceVar(&args.Components, "component", nil, ComponentFlagHelpStr)
    	cmd.PersistentFlags().StringSliceVar(&args.Filter, "filter", nil, "")
    	_ = cmd.PersistentFlags().MarkHidden("filter")
    
    	cmd.PersistentFlags().BoolVar(&args.EnableClusterSpecific, "cluster-specific", false,
    		"If enabled, the current cluster will be checked for cluster-specific setting detection.")
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 8.5K bytes
    - Viewed (0)
Back to top