- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for XdsType (0.19 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)