- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 174 for typeurl (0.21 sec)
-
istioctl/pkg/writer/pilot/status_test.go
GenericXdsConfigs: []*status.ClientConfig_GenericXdsConfig{ { TypeUrl: v3.ClusterType, ConfigStatus: config.cdsSyncStatus, }, { TypeUrl: v3.ListenerType, ConfigStatus: config.ldsSyncStatus, }, { TypeUrl: v3.RouteType, ConfigStatus: config.rdsSyncStatus, }, { TypeUrl: v3.EndpointType, ConfigStatus: config.edsSyncStatus, }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/adsc/delta_test.go
{ desc: "put things together", serverResponses: []*discovery.DeltaDiscoveryResponse{ { TypeUrl: v3.ClusterType, Resources: []*discovery.Resource{ { Name: "test-eds", Resource: protoconv.MessageToAny(testCluster), }, }, }, { TypeUrl: v3.ListenerType, Resources: []*discovery.Resource{ { Name: "test-listener",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 13.9K 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/writer/pilot/status.go
// nolint: staticcheck for _, config := range clientConfig.GetXdsConfig() { var typeURL string switch config.PerXdsConfig.(type) { case *xdsstatus.PerXdsConfig_ListenerConfig: typeURL = xdsresource.ListenerType case *xdsstatus.PerXdsConfig_ClusterConfig: typeURL = xdsresource.ClusterType case *xdsstatus.PerXdsConfig_RouteConfig: typeURL = xdsresource.RouteType case *xdsstatus.PerXdsConfig_EndpointConfig:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 04:16:55 UTC 2024 - 6.1K 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) -
pilot/pkg/xds/deltaadstest.go
Node: req.Node, TypeUrl: req.TypeUrl, ResponseNonce: req.ResponseNonce, ErrorDetail: &status.Status{Message: "Test request NACK"}, }) return resp } func (a *DeltaAdsTest) WithID(id string) *DeltaAdsTest { a.ID = id return a } func (a *DeltaAdsTest) WithType(typeURL string) *DeltaAdsTest { a.Type = typeURL return a }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K 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/util/protoconv/protoconv.go
return nil } return out } func TypedStructWithFields(typeURL string, fields map[string]interface{}) *anypb.Any { value, err := structpb.NewStruct(fields) if err != nil { log.Error(fmt.Sprintf("error marshaling struct %s: %v", typeURL, err)) } return MessageToAny(&udpa.TypedStruct{ TypeUrl: typeURL, Value: value, }) } func SilentlyUnmarshalAny[T any](a *anypb.Any) *T {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 04:55:40 UTC 2024 - 2.7K bytes - Viewed (0) -
pilot/pkg/networking/apigen/apigen.go
// For example: type is for Any is 'type.googlepis.com/istio.networking.v1alpha3.EnvoyFilter // We use: networking.istio.io/v1alpha3/EnvoyFilter kind := strings.SplitN(w.TypeUrl, "/", 3) if len(kind) != 3 { log.Warnf("ADS: Unknown watched resources %s", w.TypeUrl) // Still return an empty response - to not break waiting code. It is fine to not know about some resource. return resp, model.DefaultXdsLogDetails, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 05 19:01:38 UTC 2023 - 5K bytes - Viewed (0)