Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for workloadType (0.23 sec)

  1. pilot/pkg/xds/workload.go

    		aliases := addr.Aliases()
    		removed.DeleteAll(aliases...)
    		n := addr.ResourceName()
    		have.Insert(n)
    		haveAliases.InsertAll(aliases...)
    		switch w.TypeUrl {
    		case v3.WorkloadType:
    			if addr.GetWorkload() != nil {
    				resources = append(resources, &discovery.Resource{
    					Name:     n,
    					Aliases:  aliases,
    					Resource: protoconv.MessageToAny(addr.GetWorkload()), // TODO: pre-marshal
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 14:14:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  2. pkg/istio-agent/xds_proxy_delta.go

    	forward(resp)
    }
    
    func forwardDeltaToEnvoy(con *ProxyConnection, resp *discovery.DeltaDiscoveryResponse) {
    	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 Apr 04 20:29:08 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go

    					Network:           testNW,
    					Addresses:         [][]byte{parseIP("127.0.0.3")},
    					ServiceAccount:    "sa3",
    					Node:              "",
    					CanonicalName:     "other",
    					CanonicalRevision: "latest",
    					WorkloadType:      workloadapi.WorkloadType_POD,
    					WorkloadName:      "name3",
    					ClusterId:         testC,
    				},
    			},
    		},
    	}})
    	s.assertEvent(t, s.wleXdsName("name2"))
    	s.assertEvent(t, s.wleXdsName("name3"))
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  4. pilot/pkg/xds/ads.go

    // order after the types listed here
    var PushOrder = []string{
    	v3.ClusterType,
    	v3.EndpointType,
    	v3.ListenerType,
    	v3.RouteType,
    	v3.SecretType,
    	v3.AddressType,
    	v3.WorkloadType,
    	v3.WorkloadAuthorizationType,
    }
    
    // KnownOrderedTypeUrls has typeUrls for which we know the order of push.
    var KnownOrderedTypeUrls = sets.New(PushOrder...)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  5. pilot/pkg/xds/delta.go

    // This is used when resources are spontaneously pushed during Delta XDS
    func requiresResourceNamesModification(url string) bool {
    	return url == v3.AddressType || url == v3.WorkloadType
    }
    
    // neverRemoveDelta checks if a type should never remove resources
    func neverRemoveDelta(url string) bool {
    	// https://github.com/envoyproxy/envoy/issues/32823
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  6. pkg/istio-agent/xds_proxy.go

    	}
    }
    
    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)
  7. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go

    							ServiceAccount:    "sa1",
    							Uid:               s.podXdsName("pod3"),
    							Node:              "node1",
    							CanonicalName:     "other",
    							CanonicalRevision: "latest",
    							WorkloadType:      workloadapi.WorkloadType_POD,
    							WorkloadName:      "pod3",
    							ClusterId:         testC,
    							Status:            workloadapi.WorkloadStatus_HEALTHY,
    						},
    					},
    				},
    			},
    		})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 70.2K bytes
    - Viewed (0)
Back to top