Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 113 for EndpointPort (0.2 sec)

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

    		Labels:                b.labels,
    		ServiceAccount:        b.serviceAccount,
    		Locality:              b.locality,
    		TLSMode:               b.tlsMode,
    		Address:               endpointAddress,
    		EndpointPort:          uint32(endpointPort),
    		ServicePortName:       svcPortName,
    		Network:               networkID,
    		WorkloadName:          b.workloadName,
    		Namespace:             b.namespace,
    		HostName:              b.hostname,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  2. pilot/pkg/xds/eds_test.go

    				[]*model.IstioEndpoint{
    					{
    						Address:         "10.0.0.53",
    						EndpointPort:    53,
    						ServicePortName: "tcp-dns",
    						HealthStatus:    model.UnHealthy,
    					},
    					{
    						Address:         "10.0.0.54",
    						EndpointPort:    53,
    						ServicePortName: "tcp-dns",
    						HealthStatus:    model.UnHealthy,
    					},
    				})
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 20:58:47 UTC 2024
    - 39.6K bytes
    - Viewed (0)
  3. pkg/proxy/winkernel/proxier_test.go

    			eps.AddressType = discovery.AddressTypeIPv4
    			eps.Endpoints = []discovery.Endpoint{{
    				Addresses: []string{epIpAddressRemote},
    			}}
    			eps.Ports = []discovery.EndpointPort{{
    				Name:     ptr.To(svcPortName.Port),
    				Port:     ptr.To(int32(svcPort)),
    				Protocol: ptr.To(v1.ProtocolTCP),
    			}}
    		}),
    	)
    
    	proxier.setInitialized(true)
    	proxier.syncProxyRules()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  4. pkg/controlplane/reconcilers/none.go

    func (r *noneEndpointReconciler) ReconcileEndpoints(serviceName string, ip net.IP, endpointPorts []corev1.EndpointPort, reconcilePorts bool) error {
    	return nil
    }
    
    // RemoveEndpoints noop reconcile
    func (r *noneEndpointReconciler) RemoveEndpoints(serviceName string, ip net.IP, endpointPorts []corev1.EndpointPort) error {
    	return nil
    }
    
    func (r *noneEndpointReconciler) StopReconciling() {
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 05 11:45:48 UTC 2022
    - 1.5K bytes
    - Viewed (0)
  5. pkg/proxy/endpointschangetracker_test.go

    			},
    		}}
    		eps.Ports = []discovery.EndpointPort{{
    			Name:     ptr.To(""),
    			Port:     ptr.To[int32](11),
    			Protocol: ptr.To(v1.ProtocolUDP),
    		}}
    	}
    	unnamedPortLocal := func(eps *discovery.EndpointSlice) {
    		eps.Endpoints = []discovery.Endpoint{{
    			Addresses: []string{"1.1.1.1"},
    			NodeName:  ptr.To(testHostname),
    		}}
    		eps.Ports = []discovery.EndpointPort{{
    			Name:     ptr.To(""),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 79.9K bytes
    - Viewed (0)
  6. pkg/controller/endpointslicemirroring/metrics/cache_test.go

    	c := NewCache(int32(100))
    
    	p80 := int32(80)
    	p443 := int32(443)
    
    	pmKey80443 := endpointsliceutil.NewPortMapKey([]discovery.EndpointPort{{Port: &p80}, {Port: &p443}})
    	pmKey80 := endpointsliceutil.NewPortMapKey([]discovery.EndpointPort{{Port: &p80}})
    
    	spCacheEfficient := NewEndpointPortCache()
    	spCacheEfficient.Set(pmKey80, EfficiencyInfo{Endpoints: 45, Slices: 1})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/discovery/v1beta1/generated.pb.go

    var xxx_messageInfo_EndpointHints proto.InternalMessageInfo
    
    func (m *EndpointPort) Reset()      { *m = EndpointPort{} }
    func (*EndpointPort) ProtoMessage() {}
    func (*EndpointPort) Descriptor() ([]byte, []int) {
    	return fileDescriptor_6555bad15de200e0, []int{3}
    }
    func (m *EndpointPort) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *EndpointPort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    	b = b[:cap(b)]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 54.2K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/discovery/v1/generated.pb.go

    var xxx_messageInfo_EndpointHints proto.InternalMessageInfo
    
    func (m *EndpointPort) Reset()      { *m = EndpointPort{} }
    func (*EndpointPort) ProtoMessage() {}
    func (*EndpointPort) Descriptor() ([]byte, []int) {
    	return fileDescriptor_2237b452324cf77e, []int{3}
    }
    func (m *EndpointPort) XXX_Unmarshal(b []byte) error {
    	return m.Unmarshal(b)
    }
    func (m *EndpointPort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    	b = b[:cap(b)]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 55.6K bytes
    - Viewed (0)
  9. pkg/controlplane/reconcilers/reconcilers.go

    	//  * ReconcileEndpoints is called periodically from all apiservers.
    	ReconcileEndpoints(serviceName string, ip net.IP, endpointPorts []corev1.EndpointPort, reconcilePorts bool) error
    	// RemoveEndpoints removes this apiserver's lease.
    	RemoveEndpoints(serviceName string, ip net.IP, endpointPorts []corev1.EndpointPort) error
    	// StopReconciling turns any later ReconcileEndpoints call into a noop.
    	StopReconciling()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 26 13:49:31 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  10. pkg/controller/endpointslicemirroring/reconciler_helpers.go

    	return &desiredCalc{
    		portsByKey:          map[addrTypePortMapKey][]discovery.EndpointPort{},
    		endpointsByKey:      map[addrTypePortMapKey]endpointsliceutil.EndpointSet{},
    		numDesiredEndpoints: 0,
    	}
    }
    
    // desiredCalc helps calculate desired endpoints and ports.
    type desiredCalc struct {
    	portsByKey          map[addrTypePortMapKey][]discovery.EndpointPort
    	endpointsByKey      map[addrTypePortMapKey]endpointsliceutil.EndpointSet
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 4.7K bytes
    - Viewed (0)
Back to top