Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 66 for Filter (0.29 sec)

  1. istioctl/pkg/writer/envoy/configdump/listener_test.go

    				FilterChains: []*listener.FilterChain{{
    					Filters: []*listener.Filter{{
    						Name: wellknown.TCPProxy,
    					}},
    				}},
    			},
    			expect: true,
    		},
    		{
    			desc: "unknown-type",
    			inFilter: &ListenerFilter{
    				Type: "UNKNOWN",
    			},
    			inListener: &listener.Listener{
    				FilterChains: []*listener.FilterChain{{
    					Filters: []*listener.Filter{},
    				}},
    			},
    			expect: true,
    		},
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Sep 11 15:29:30 GMT 2023
    - 4.1K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/envoy/configdump/listener.go

    	}
    	return strings.Join(descrs, "; ")
    }
    
    func getFilterType(filters []*listener.Filter) string {
    	for _, filter := range filters {
    		if filter.Name == HTTPListener {
    			httpProxy := &hcm.HttpConnectionManager{}
    			// Allow Unmarshal to work even if Envoy and istioctl are different
    			filter.GetTypedConfig().TypeUrl = "type.googleapis.com/envoy.extensions.filters.network.http_connection_manager.v3.HttpConnectionManager"
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 18.1K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/ztunnel/configdump/services.go

    }
    
    // PrintServiceSummary prints a summary of the relevant services in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintServiceSummary(filter ServiceFilter) error {
    	w := c.tabwriter()
    	zDump := c.ztunnelDump
    
    	svcs := slices.Filter(maps.Values(zDump.Services), filter.Verify)
    	slices.SortFunc(svcs, func(a, b *ZtunnelService) 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.8K bytes
    - Viewed (0)
  4. istioctl/pkg/authz/testdata/configdump.yaml

             }
            }
           ],
           "listener_filters_timeout": "0s",
           "traffic_direction": "OUTBOUND",
           "continue_on_listener_filters_timeout": true,
           "default_filter_chain": {
            "filter_chain_match": {},
            "filters": [
             {
              "name": "istio.stats",
              "typed_config": {
    Others
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jun 21 14:20:23 GMT 2023
    - 206.7K bytes
    - Viewed (2)
  5. istioctl/pkg/writer/ztunnel/configdump/workload.go

    	"fmt"
    	"sort"
    	"strings"
    
    	"sigs.k8s.io/yaml"
    )
    
    // WorkloadFilter is used to pass filter information into workload based config writer print functions
    type WorkloadFilter struct {
    	Address   string
    	Node      string
    	Verbose   bool
    	Namespace string
    }
    
    // Verify returns true if the passed workload matches the filter fields
    func (wf *WorkloadFilter) Verify(workload *ZtunnelWorkload) bool {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 4K bytes
    - Viewed (0)
  6. istioctl/pkg/authz/listener.go

    	case *listener.Filter_TypedConfig:
    		if err := c.TypedConfig.UnmarshalTo(out); err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    func getHTTPConnectionManager(filter *listener.Filter) *hcm.HttpConnectionManager {
    	cm := &hcm.HttpConnectionManager{}
    	if err := getFilterConfig(filter, cm); err != nil {
    		log.Errorf("failed to get HTTP connection manager config: %s", err)
    		return nil
    	}
    	return cm
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Sep 11 15:29:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  7. istioctl/pkg/proxyconfig/testdata/config_dump.json

                    "port_value": 15021
                  }
                },
                "filter_chains": [
                  {
                    "filters": [
                      {
                        "name": "envoy.filters.network.http_connection_manager",
                        "typed_config": {
                          "@type": "type.googleapis.com/envoy.extensions.filters.network.http_connection_manager.v3.HttpConnectionManager",
    Json
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jan 03 23:08:06 GMT 2024
    - 54.8K bytes
    - Viewed (1)
  8. cni/pkg/repair/repaircontroller.go

    	fieldSelectors := []string{}
    	if cfg.FieldSelectors != "" {
    		fieldSelectors = append(fieldSelectors, cfg.FieldSelectors)
    	}
    	// filter out pod events from different nodes
    	fieldSelectors = append(fieldSelectors, fmt.Sprintf("spec.nodeName=%v", cfg.NodeName))
    	c.pods = kclient.NewFiltered[*corev1.Pod](client, kclient.Filter{
    		LabelSelector: cfg.LabelSelectors,
    		FieldSelector: strings.Join(fieldSelectors, ","),
    	})
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  9. 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)
  10. istioctl/pkg/writer/ztunnel/configdump/connections.go

    			return r
    		}
    		return cmp.Compare(a.Info.Namespace, b.Info.Namespace)
    	})
    	for _, wl := range workloads {
    		if filter.Namespace != "" && filter.Namespace != wl.Info.Namespace {
    			continue
    		}
    		name := fmt.Sprintf("%s.%s", wl.Info.Name, wl.Info.Namespace)
    		if filter.Direction != "outbound" {
    			for _, c := range wl.Connections.Inbound {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 15:39:28 GMT 2024
    - 3.3K bytes
    - Viewed (0)
Back to top