Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for EndpointDiscoverabilityPolicy (0.4 sec)

  1. pilot/pkg/serviceregistry/kube/controller/serviceexportcache.go

    // cluster and generates discoverability policies for the endpoints.
    type serviceExportCache interface {
    	// EndpointDiscoverabilityPolicy returns the policy for Service endpoints residing within the current cluster.
    	EndpointDiscoverabilityPolicy(svc *model.Service) model.EndpointDiscoverabilityPolicy
    
    	// ExportedServices returns the list of services that are exported in this cluster. Used for debugging.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/endpoint_builder.go

    	return out
    }
    
    func (b *EndpointBuilder) buildIstioEndpoint(
    	endpointAddress string,
    	endpointPort int32,
    	svcPortName string,
    	discoverabilityPolicy model.EndpointDiscoverabilityPolicy,
    	healthStatus model.HealthStatus,
    ) *model.IstioEndpoint {
    	if b == nil {
    		return nil
    	}
    
    	// in case pod is not found when init EndpointBuilder.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  3. pilot/pkg/model/service.go

    }
    
    // AlwaysDiscoverable is an EndpointDiscoverabilityPolicy that allows an endpoint to be discoverable throughout the mesh.
    var AlwaysDiscoverable EndpointDiscoverabilityPolicy = &endpointDiscoverabilityPolicyImpl{
    	name: "AlwaysDiscoverable",
    	f: func(*IstioEndpoint, *Proxy) bool {
    		return true
    	},
    }
    
    // DiscoverableFromSameCluster is an EndpointDiscoverabilityPolicy that only allows an endpoint to be discoverable
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    		// TODO(https://github.com/istio/istio/issues/34995) support FQDN endpointslice
    		return
    	}
    	svc := esc.c.GetService(hostName)
    	discoverabilityPolicy := esc.c.exports.EndpointDiscoverabilityPolicy(svc)
    
    	for _, e := range slice.Endpoints {
    		// Draining tracking is only enabled if persistent sessions is enabled.
    		// If we start using them for other features, this can be adjusted.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
Back to top