- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 70 for typeurl (0.26 sec)
-
pilot/pkg/xds/delta.go
return conn.deltaStream.Send(res) } err := sendResonse() if err == nil { if !strings.HasPrefix(res.TypeUrl, v3.DebugType) { conn.proxy.UpdateWatchedResource(res.TypeUrl, func(wr *model.WatchedResource) *model.WatchedResource { if wr == nil { wr = &model.WatchedResource{TypeUrl: res.TypeUrl} } // some resources dynamically update ResourceNames. Most don't though if newResourceNames != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/xds/xdsgen.go
cp, _ := controlPlane.Get() return cp } func (s *DiscoveryServer) findGenerator(typeURL string, con *Connection) model.XdsResourceGenerator { if g, f := s.Generators[con.proxy.Metadata.Generator+"/"+typeURL]; f { return g } if g, f := s.Generators[string(con.proxy.Type)+"/"+typeURL]; f { return g } if g, f := s.Generators[typeURL]; f { return g }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/xds/server.go
} // WatchedResource tracks an active DiscoveryRequest subscription. type WatchedResource struct { // TypeUrl is copied from the DiscoveryRequest.TypeUrl that initiated watching this resource. // nolint TypeUrl string // ResourceNames tracks the list of resources that are actively watched. // For LDS and CDS, all resources of the TypeUrl type are watched if it is empty.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pkg/xds/server_test.go
}, request: &discovery.DiscoveryRequest{ TypeUrl: model.ClusterType, }, response: true, }, { name: "ack", proxy: &TestProxy{ WatchedResources: map[string]*WatchedResource{ model.ClusterType: { NonceSent: "nonce", }, }, }, request: &discovery.DiscoveryRequest{ TypeUrl: model.ClusterType, VersionInfo: "v1",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 4.8K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
return } // if typeUrl is not empty, report all events that are not being watched unWatched := sets.NewWithLength[EventType](len(AllTrackingEventTypes)) watchedTypes := con.proxy.GetWatchedResourceTypes() for tyeUrl := range AllTrackingEventTypes { if _, exists := watchedTypes[tyeUrl]; !exists { unWatched.Insert(tyeUrl) } } for tyeUrl := range unWatched {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pilot/pkg/xds/deltatest.go
deleted model.DeletedResources, usedDelta bool, delta model.ResourceDelta, incremental bool, ) { current := con.proxy.GetWatchedResource(w.TypeUrl).LastResources if current == nil { log.Debugf("ADS:%s: resources initialized", v3.GetShortType(w.TypeUrl)) return } if deltaRes == nil && deleted == nil && len(sotwRes) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
istioctl/pkg/authz/analyzer_test.go
name string input *configdump.Wrapper wantErr error }{ { name: "Test1", input: &configdump.Wrapper{ ConfigDump: &envoy_admin.ConfigDump{ Configs: []*anypb.Any{ { TypeUrl: "type.googleapis.com/envoy.admin.v3.ListenersConfigDump", }, }, }, }, wantErr: nil, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 2.8K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
default: log.Infof("tap response %q arrived too late; discarding", resp.TypeUrl) } } func forwardToEnvoy(con *ProxyConnection, resp *discovery.DiscoveryResponse) { if !model.IsEnvoyType(resp.TypeUrl) && resp.TypeUrl != model.WorkloadType { proxyLog.Errorf("Skipping forwarding type url %s to Envoy as is not a valid Envoy type", resp.TypeUrl) return } if con.isClosed() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
pilot/pkg/model/context.go
ret := sets.NewWithLength[string](len(node.WatchedResources)) for typeURL := range node.WatchedResources { ret.Insert(typeURL) } return ret } func (node *Proxy) GetWatchedResource(typeURL string) *WatchedResource { node.RLock() defer node.RUnlock() return node.WatchedResources[typeURL] } func (node *Proxy) NonceSent(typeURL string) string { node.RLock() defer node.RUnlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (0) -
pkg/wasm/convert_test.go
if err != nil { t.Fatal(err) } return st } func messageToAnyWithTypeURL(t *testing.T, msg proto.Message, typeURL string) *anypb.Any { b, err := proto.MarshalOptions{Deterministic: true}.Marshal(msg) if err != nil { t.Fatal(err) } return &anypb.Any{ // nolint: staticcheck TypeUrl: typeURL, Value: b, } } func TestWasmConvertWithWrongMessages(t *testing.T) { cases := []struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 13.6K bytes - Viewed (0)