Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 364 for chains (0.13 sec)

  1. pilot/pkg/networking/core/listener_inbound.go

    		}
    		// Build the actual chain
    		chains := lb.inboundChainForOpts(cc, mtls, opts)
    
    		if cc.bindToPort {
    			// If this config is for bindToPort, we want to actually create a real Listener.
    			listeners = append(listeners, lb.inboundCustomListener(cc, chains))
    		} else {
    			// Otherwise, just append the filter chain to the virtual inbound chains.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  2. pilot/pkg/simulation/traffic.go

    // not match. This means an empty match (`{}`) may not match if another chain
    // matches one criteria but not another.
    func (sim *Simulation) matchFilterChain(chains []*listener.FilterChain, defaultChain *listener.FilterChain,
    	input Call, hasTLSInspector bool,
    ) (*listener.FilterChain, error) {
    	chains = filter("DestinationPort", chains, func(fc *listener.FilterChainMatch) bool {
    		return fc.GetDestinationPort() == nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  3. src/crypto/x509/verify.go

    	}
    
    	return chains, nil
    }
    
    func appendToFreshChain(chain []*Certificate, cert *Certificate) []*Certificate {
    	n := make([]*Certificate, len(chain)+1)
    	copy(n, chain)
    	n[len(chain)] = cert
    	return n
    }
    
    // alreadyInChain checks whether a candidate certificate is present in a chain.
    // Rather than doing a direct byte for byte equivalency check, we check if the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:58:39 UTC 2024
    - 35.7K bytes
    - Viewed (0)
  4. pkg/util/iptables/testing/parse.go

    }
    
    func (dump *IPTablesDump) GetChain(table iptables.Table, chain iptables.Chain) (*Chain, error) {
    	t, err := dump.GetTable(table)
    	if err != nil {
    		return nil, err
    	}
    	for i := range t.Chains {
    		if t.Chains[i].Name == chain {
    			return &t.Chains[i], nil
    		}
    	}
    	return nil, fmt.Errorf("no such chain %q", chain)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 11.6K bytes
    - Viewed (0)
  5. pilot/pkg/xds/lds_test.go

    				chain = fc
    			}
    		}
    		if chain == nil {
    			t.Fatalf("Failed to find http_connection_manager")
    		}
    		if len(chain.Filters) != 1 {
    			t.Fatalf("Expected 1 filter in first filter chain, got %d", len(l.FilterChains))
    		}
    		filter := chain.Filters[0]
    		if filter.Name != wellknown.HTTPConnectionManager {
    			t.Fatalf("Expected HTTP connection, found %v", chain.Filters[0].Name)
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/listener_waypoint.go

    				// If we need to sniff, insert two chains and the protocol detector
    				chains = append(chains, tcpChain, httpChain)
    				portMapper.Map[portString] = match.ToMatcher(match.NewAppProtocol(match.ProtocolMatch{
    					TCP:  match.ToChain(tcpName),
    					HTTP: match.ToChain(httpName),
    				}))
    			} else if port.Protocol.IsHTTP() {
    				// Otherwise, just insert HTTP/TCP
    				chains = append(chains, httpChain)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  7. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/transform/ConsumerProvidedVariantFinder.java

             * @param transforms The remaining transforms which may be prepended to {@code chain} to produce a solution.
             */
            public ChainState(@Nullable ChainNode chain, ImmutableAttributes requested, ImmutableFilteredList<TransformRegistration> transforms) {
                this.chain = chain;
                this.requested = requested;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Oct 10 21:10:11 UTC 2023
    - 13.8K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/authentication/request/x509/x509.go

    var CommonNameUserConversion = UserConversionFunc(func(chain []*x509.Certificate) (*authenticator.Response, bool, error) {
    	if len(chain[0].Subject.CommonName) == 0 {
    		return nil, false, nil
    	}
    	return &authenticator.Response{
    		User: &user.DefaultInfo{
    			Name:   chain[0].Subject.CommonName,
    			Groups: chain[0].Subject.Organization,
    		},
    	}, true, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 18 01:31:22 UTC 2023
    - 10.3K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/listener_builder.go

    		Name:    model.VirtualOutboundCatchAllTCPFilterChainName,
    		Filters: filterStack,
    	})
    	return chains
    }
    
    func blackholeFilterChain(push *model.PushContext, node *model.Proxy) *listener.FilterChain {
    	return &listener.FilterChain{
    		Name: model.VirtualOutboundBlackholeFilterChainName,
    		FilterChainMatch: &listener.FilterChainMatch{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  10. pkg/controller/garbagecollector/dump_test.go

    				NewDOTVertex(charlieNode()),
    			},
    			expectEdges: []dotEdge{
    				{F: types.UID("alpha"), T: types.UID("bravo")},
    				{F: types.UID("alpha"), T: types.UID("charlie")},
    			},
    		},
    		{
    			name: "two-chains",
    			uidToNode: map[types.UID]*node{
    				types.UID("alpha"):   alphaNode(),
    				types.UID("bravo"):   bravoNode(),
    				types.UID("charlie"): charlieNode(),
    				types.UID("delta"):   deltaNode(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 00:05:53 UTC 2023
    - 11.2K bytes
    - Viewed (0)
Back to top