- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 113 for EndpointPort (0.2 sec)
-
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) -
pilot/pkg/xds/eds_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)