Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for XdsType (0.19 sec)

  1. pkg/bootstrap/option/instances.go

    }
    
    func NodeID(value string) Instance {
    	return newOption("nodeID", value)
    }
    
    func NodeType(value string) Instance {
    	ntype := strings.Split(value, "~")[0]
    	return newOption("nodeType", ntype)
    }
    
    func XdsType(value string) Instance {
    	return newOption("xds_type", value)
    }
    
    func Region(value string) Instance {
    	return newOptionOrSkipIfZero("region", value)
    }
    
    func Zone(value string) Instance {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:02:38 UTC 2024
    - 9K bytes
    - Viewed (0)
  2. pilot/pkg/model/xds_cache.go

    	// Cacheable indicates whether this entry is valid for cache. For example
    	// for EDS to be cacheable, the Endpoint should have corresponding service.
    	Cacheable() bool
    }
    
    const (
    	CDSType = "cds"
    	EDSType = "eds"
    	RDSType = "rds"
    	SDSType = "sds"
    )
    
    // NewXdsCache returns an instance of a cache.
    func NewXdsCache() XdsCache {
    	cache := XdsCacheImpl{
    		eds: newTypedXdsCache[uint64](),
    	}
    	if features.EnableCDSCaching {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 02 07:02:05 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  3. pilot/pkg/xds/xds_cache_test.go

    		}
    	})
    
    	t.Run("clear all", func(t *testing.T) {
    		c := model.NewXdsCache()
    		start := time.Now()
    		c.Add(ep1, &model.PushRequest{Start: start}, any1)
    		c.Add(ep2, &model.PushRequest{Start: start}, any2)
    
    		c.ClearAll()
    		if len(c.Keys(model.EDSType)) != 0 {
    			t.Fatalf("expected no keys, got: %v", c.Keys(model.EDSType))
    		}
    		if got := c.Get(ep1); got != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Aug 31 20:43:08 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/route/route_cache.go

    	DelegateVirtualServices []model.ConfigHash
    	DestinationRules        []*model.ConsolidatedDestRule
    	EnvoyFilterKeys         []string
    }
    
    func (r *Cache) Type() string {
    	return model.RDSType
    }
    
    func (r *Cache) Cacheable() bool {
    	if r == nil {
    		return false
    	}
    	if r.ListenerPort == 0 {
    		return false
    	}
    
    	for _, config := range r.VirtualServices {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/cluster_cache.go

    	serviceAccounts []string // contains all the service accounts associated with the service
    }
    
    func (t *clusterCache) Type() string {
    	return model.CDSType
    }
    
    func (t *clusterCache) Key() any {
    	// nolint: gosec
    	// Not security sensitive code
    	h := hash.New()
    	h.WriteString(t.clusterName)
    	h.Write(Separator)
    	h.WriteString(t.proxyVersion)
    	h.Write(Separator)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 18 19:09:43 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. pilot/pkg/xds/sds.go

    type SecretResource struct {
    	credentials.SecretResource
    	pkpConfHash string
    }
    
    var _ model.XdsCacheEntry = SecretResource{}
    
    func (sr SecretResource) Type() string {
    	return model.SDSType
    }
    
    func (sr SecretResource) Key() any {
    	return sr.SecretResource.Key() + "/" + sr.pkpConfHash
    }
    
    func (sr SecretResource) DependentConfigs() []model.ConfigHash {
    	configs := []model.ConfigHash{}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 15 23:04:36 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  7. pilot/pkg/xds/endpoints/endpoint_builder.go

    	if dr := b.destinationRule.GetRule(); dr != nil {
    		dr, _ := dr.Spec.(*v1alpha3.DestinationRule)
    		return dr
    	}
    	return nil
    }
    
    func (b *EndpointBuilder) Type() string {
    	return model.EDSType
    }
    
    func (b *EndpointBuilder) ServiceFound() bool {
    	return b.service != nil
    }
    
    func (b *EndpointBuilder) IsDNSCluster() bool {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 02:18:19 UTC 2024
    - 26.1K bytes
    - Viewed (0)
Back to top