- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for XDSUpdates (0.14 sec)
-
pkg/adsc/adsc.go
// If nil, the defaults will be used. Metadata *pstruct.Struct // Updates includes the type of the last update received from the server. Updates chan string errChan chan error XDSUpdates chan *discovery.DiscoveryResponse VersionInfo map[string]string // Last received message, by type Received map[string]*discovery.DiscoveryResponse mutex sync.RWMutex Mesh *v1alpha1.MeshConfig
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0) -
pilot/pkg/xds/eds.go
kind.WasmPlugin, kind.ProxyConfig, kind.DNSName, kind.KubernetesGateway, kind.HTTPRoute, kind.TCPRoute, kind.TLSRoute, kind.GRPCRoute, ) func edsNeedsPush(updates model.XdsUpdates) bool { // If none set, we will always push if len(updates) == 0 { return true } for config := range updates { if !skippedEdsConfigs.Contains(config.Kind) { return true } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 15:58:06 UTC 2024 - 9.9K bytes - Viewed (0) -
pilot/pkg/xds/sds.go
configs = append(configs, config.HashCode()) } return configs } func (sr SecretResource) Cacheable() bool { return true } func sdsNeedsPush(updates model.XdsUpdates) bool { if len(updates) == 0 { return true } for update := range updates { switch update.Kind { case kind.Secret: return true case kind.ReferenceGrant: return true } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 15 23:04:36 UTC 2024 - 15.8K bytes - Viewed (0) -
pkg/adsc/adsc_test.go
TypeUrl: request.TypeUrl, } } tc := testCase{ desc: desc.desc, inAdsc: &ADSC{ Received: make(map[string]*discovery.DiscoveryResponse), Updates: make(chan string), XDSUpdates: make(chan *discovery.DiscoveryResponse), cfg: &ADSConfig{ Config: Config{}, InitialDiscoveryRequests: desc.initialRequests, }, VersionInfo: map[string]string{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 15.4K bytes - Viewed (0) -
pilot/pkg/model/context.go
a := make(Resources, 0, len(r)) for _, rr := range r { a = append(a, &discovery.Resource{Resource: rr}) } return a } // XdsUpdates include information about the subset of updated resources. // See for example EDS incremental updates. type XdsUpdates = sets.Set[ConfigKey] // XdsLogDetails contains additional metadata that is captured by Generators and used by xds processors
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (1)